Class: LogStash::PluginMixins::JdbcStreaming::StatementHandler

Inherits:
Object
  • Object
show all
Includes:
LogStash::PluginMixins::Jdbc::ValueHandler
Defined in:
lib/logstash/plugin_mixins/jdbc_streaming/statement_handler.rb

Overview

so as to not clash with the class of the same name and function in the jdbc input this is in the module JdbcStreaming namespace this duplication can be removed in a universal plugin

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from LogStash::PluginMixins::Jdbc::ValueHandler

#decorate_value, #extract_values_from

Constructor Details

#initialize(plugin) ⇒ StatementHandler

Returns a new instance of StatementHandler.



20
21
22
23
24
25
 
# File 'lib/logstash/plugin_mixins/jdbc_streaming/statement_handler.rb', line 20

def initialize(plugin)
  @statement = plugin.statement
  klass = plugin.use_cache ? RowCache : NoCache
  @cache = klass.new(plugin.cache_size, plugin.cache_expiration)
  post_init(plugin)
end

Instance Attribute Details

#cache ⇒ Object (readonly)

Returns the value of attribute cache.



18
19
20
 
# File 'lib/logstash/plugin_mixins/jdbc_streaming/statement_handler.rb', line 18

def cache
  @cache
end

#parameters ⇒ Object (readonly)

Returns the value of attribute parameters.



18
19
20
 
# File 'lib/logstash/plugin_mixins/jdbc_streaming/statement_handler.rb', line 18

def parameters
  @parameters
end

#statement ⇒ Object (readonly)

Returns the value of attribute statement.



18
19
20
 
# File 'lib/logstash/plugin_mixins/jdbc_streaming/statement_handler.rb', line 18

def statement
  @statement
end

Class Method Details

.build_statement_handler(plugin) ⇒ Object 



13
14
15
16
 
# File 'lib/logstash/plugin_mixins/jdbc_streaming/statement_handler.rb', line 13

def self.build_statement_handler(plugin)
  klass = plugin.use_prepared_statements ? PreparedStatementHandler : NormalStatementHandler
  klass.new(plugin)
end

Instance Method Details

#cache_lookup(db, event) ⇒ Object

Get from cache or performs remote lookup and saves to cache

Parameters:

  • db (Sequel::Database)
  • event (LogStash::Event) 


31
32
33
 
# File 'lib/logstash/plugin_mixins/jdbc_streaming/statement_handler.rb', line 31

def cache_lookup(db, event)
  # override in subclass
end