Class: Mysql::AlterTableQueryHandler

Inherits:
BinlogQueryHandler show all
Defined in:
lib/flydata/fluent-plugins/mysql/alter_table_query_handler.rb

Constant Summary collapse

PATTERN = 
/^alter table/

Constants inherited from BinlogRecordHandler

BinlogRecordHandler::RESPECT_ORDER, BinlogRecordHandler::SEQ, BinlogRecordHandler::SRC_POS, BinlogRecordHandler::TABLE_NAME, BinlogRecordHandler::TABLE_REV, BinlogRecordHandler::TYPE

Instance Method Summary collapse

Constructor Details

#initialize(context) ⇒ AlterTableQueryHandler

Returns a new instance of AlterTableQueryHandler.



8
9
10
 
# File 'lib/flydata/fluent-plugins/mysql/alter_table_query_handler.rb', line 8

def initialize(context)
  super
end

Instance Method Details

#pattern ⇒ Object 



12
13
14
 
# File 'lib/flydata/fluent-plugins/mysql/alter_table_query_handler.rb', line 12

def pattern
  PATTERN
end

#process(record, normalized_query) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
 
# File 'lib/flydata/fluent-plugins/mysql/alter_table_query_handler.rb', line 16

def process(record, normalized_query)
  case normalized_query
  when /^alter table [^\s]+ add column/i
    on_add_column(record, normalized_query)
  when /^alter table [^\s]+ drop/i
    on_drop_column(record, normalized_query)
  else
    $log.debug("not supported alter table query:'#{normalized_query}'")
  end
end