Class: LogStash::PluginMixins::Jdbc::NormalStatementHandler
- Inherits:
-
StatementHandler
- Object
- StatementHandler
- LogStash::PluginMixins::Jdbc::NormalStatementHandler
- Defined in:
- lib/logstash/plugin_mixins/jdbc/statement_handler.rb
Instance Attribute Summary
Attributes inherited from StatementHandler
#parameters, #statement, #statement_logger
Instance Method Summary collapse
-
#perform_query(db, sql_last_value, jdbc_paging_enabled, jdbc_page_size) {|row| ... } ⇒ Object
Performs the query, respecting our pagination settings, yielding once per row of data.
Methods inherited from StatementHandler
build_statement_handler, #initialize
Constructor Details
This class inherits a constructor from LogStash::PluginMixins::Jdbc::StatementHandler
Instance Method Details
#perform_query(db, sql_last_value, jdbc_paging_enabled, jdbc_page_size) {|row| ... } ⇒ Object
Performs the query, respecting our pagination settings, yielding once per row of data
32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/logstash/plugin_mixins/jdbc/statement_handler.rb', line 32 def perform_query(db, sql_last_value, jdbc_paging_enabled, jdbc_page_size) query = build_query(db, sql_last_value) if jdbc_paging_enabled query.each_page(jdbc_page_size) do |paged_dataset| paged_dataset.each do |row| yield row end end else query.each do |row| yield row end end end |