Contents

require 'flydata/fluent-plugins/mysql/ddl_query_handler'

module Mysql
  class TruncateTableQueryHandler < TableDdlQueryHandler
    PATTERN = /^TRUNCATE/i

    def initialize(context)
      super
    end

    def pattern
      PATTERN
    end

    def process(record)
      emit_record(:truncate_table, record) do |opt|
        {
          table_name: record['table_name'],
          query: record["query"]
        }
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
flydata-0.6.11	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.6.10	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.6.9	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.6.8	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.6.7	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.6.6	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.6.5	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.6.4	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb