Fix jdbc_paging_enabled config flag not being passed through

Author: bmax

lib/logstash/plugin_mixins/jdbc/jdbc.rb

@@ -244,7 +244,7 @@ def execute_statement
       begin
         sql_last_value = @use_column_value ? @value_tracker.value : Time.now.utc
         @tracking_column_warning_sent = false
-        @statement_handler.perform_query(@database, @value_tracker.value) do |row|
+        @statement_handler.perform_query(@database, @value_tracker.value, @jdbc_paging_enabled, @jdbc_page_size) do |row|
           sql_last_value = get_column_value(row) if @use_column_value
           yield extract_values_from(row)
         end

lib/logstash/plugin_mixins/jdbc/statement_handler.rb

@@ -29,10 +29,10 @@ class NormalStatementHandler < StatementHandler
     # @param db [Sequel::Database]
     # @param sql_last_value [Integet|DateTime|Time]
     # @yieldparam row [Hash{Symbol=>Object}]
-    def perform_query(db, sql_last_value)
+    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|
+      if jdbc_paging_enabled
+        query.each_page(jdbc_page_size) do |paged_dataset|
           paged_dataset.each do |row|
             yield row
           end
@@ -74,7 +74,7 @@ class PreparedStatementHandler < StatementHandler
     # @param db [Sequel::Database]
     # @param sql_last_value [Integet|DateTime|Time]
     # @yieldparam row [Hash{Symbol=>Object}]
-    def perform_query(db, sql_last_value)
+    def perform_query(db, sql_last_value, jdbc_paging_enabled, jdbc_page_size)
       query = build_query(db, sql_last_value)
       query.each do |row|
         yield row