Contents

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

module Mysql
  class TruncateTableQueryHandler < DdlQueryHandler
    PATTERN = /^TRUNCATE TABLE/i

    def initialize(context)
      super
    end

    def pattern
      PATTERN
    end

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

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
flydata-0.4.1	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.4.0	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.24	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.23	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.22	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.21	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.20	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.19	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.18	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.17	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.16	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.15	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.14	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.13	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.3.12	lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb