Class: Flydata::SourceMysql::PluginSupport::DmlRecordHandler
- Inherits:
-
BinlogRecordHandler
- Object
- BinlogRecordHandler
- Flydata::SourceMysql::PluginSupport::DmlRecordHandler
- Defined in:
- lib/flydata/source_mysql/plugin_support/dml_record_handler.rb
Constant Summary collapse
- ROW =
:row
- OLD =
:old
- INTEGER_TYPES =
{'TINY' => 1, 'SHORT' => 2, 'INT24' => 3, 'LONG' => 4, 'LONGLONG' => 8 }
- SIGNLESS_INTEGER_PREFIX =
'0SL'
Constants included from PluginSupport::SyncRecordEmittable
PluginSupport::SyncRecordEmittable::RESPECT_ORDER, PluginSupport::SyncRecordEmittable::SEQ, PluginSupport::SyncRecordEmittable::SRC_POS, PluginSupport::SyncRecordEmittable::TABLE_NAME, PluginSupport::SyncRecordEmittable::TABLE_REV, PluginSupport::SyncRecordEmittable::TYPE, PluginSupport::SyncRecordEmittable::V
Instance Attribute Summary
Attributes included from PluginSupport::SyncRecordEmittable
Instance Method Summary collapse
Methods inherited from BinlogRecordHandler
Methods included from PluginSupport::SyncRecordEmittable
Constructor Details
This class inherits a constructor from Flydata::SourceMysql::PluginSupport::BinlogRecordHandler
Instance Method Details
#process(record, type) ⇒ Object
18 19 20 21 22 23 24 25 26 27 28 29 |
# File 'lib/flydata/source_mysql/plugin_support/dml_record_handler.rb', line 18 def process(record, type) case type when :write_rows emit_insert(record) when :delete_rows emit_delete(record) when :update_rows emit_update(record) else raise "Invalid type:#{type}" end end |