class LogStash::PluginMixins::Jdbc::StatementHandler

Attributes

parameters[R]
statement[R]
statement_logger[R]

Public Class Methods

build_statement_handler(plugin, logger) click to toggle source
# File lib/logstash/plugin_mixins/jdbc/statement_handler.rb, line 5
def self.build_statement_handler(plugin, logger)
  klass = plugin.use_prepared_statements ? PreparedStatementHandler : NormalStatementHandler
  klass.new(plugin, logger)
end
new(plugin, statement_logger) click to toggle source
# File lib/logstash/plugin_mixins/jdbc/statement_handler.rb, line 12
def initialize(plugin, statement_logger)
  @statement = plugin.statement
  @statement_logger = statement_logger
  post_init(plugin)
end

Public Instance Methods

build_query(db, sql_last_value) click to toggle source
# File lib/logstash/plugin_mixins/jdbc/statement_handler.rb, line 18
def build_query(db, sql_last_value)
  # override in subclass
end
post_init(plugin) click to toggle source
# File lib/logstash/plugin_mixins/jdbc/statement_handler.rb, line 22
def post_init(plugin)
  # override in subclass, if needed
end