Sha256: 40868b21cbc8d622e9ce045e044a1b2d9703b0198a486cf0c4e72b09e320944a

Contents?: true

Size: 489 Bytes

Versions: 14

Compression:

Stored size: 489 Bytes

Contents

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

module Mysql
  class TruncateTableQueryHandler < DdlQueryHandler
    PATTERN = /^TRUNCATE/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

14 entries across 14 versions & 1 rubygems

Version Path
flydata-0.5.11 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.10 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.9 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.8 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.7 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.6 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.5 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.4 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.3 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.2 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.1 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.5.0 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.4.3 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb
flydata-0.4.2 lib/flydata/fluent-plugins/mysql/truncate_table_query_handler.rb