Sha256: 822abaa1a18d7d323f4e66f3efe207e68b9549a1b19eef97df131a60d47e6fec
Contents?: true
Size: 742 Bytes
Versions: 24
Compression:
Stored size: 742 Bytes
Contents
require 'flydata/source_mysql/plugin_support/ddl_query_handler'
module Flydata
module SourceMysql
module PluginSupport
class CreateTableQueryHandler < TableDdlQueryHandler
PATTERN = /^CREATE TABLE/i
def initialize(context)
super
end
def pattern
PATTERN
end
def process(record)
if acceptable_db?(record)
emit_record(:create_table, record) do |opt|
table_name = table_info(record)[:table_name]
$log.info "type:create_table table_name:'#{table_name}' query:'#{record["query"]}' binlog_pos:'#{binlog_pos(record)}'"
opt[:increment_table_rev] = true
{ table_name: table_name, query: record["query"] }
end
end
end
end
end
end
end
Version data entries
24 entries across 24 versions & 1 rubygems