jdbc.rb in logstash-input-jdbc-4.1.2

- old
+ new

@@ -149,10 +149,13 @@
   config :use_column_value, :validate => :boolean, :default => false
 
   # If tracking column value rather than timestamp, the column whose value is to be tracked
   config :tracking_column, :validate => :string
 
+  # Type of tracking column. Currently only "numeric" and "timestamp"
+  config :tracking_column_type, :validate => ['numeric', 'timestamp'], :default => 'numeric'
+
   # Whether the previous run state should be preserved
   config :clean_run, :validate => :boolean, :default => false
 
   # Whether to save state or not in last_run_metadata_path
   config :record_last_run, :validate => :boolean, :default => true
@@ -181,9 +184,10 @@
   config :columns_charset, :validate => :hash, :default => {}
 
   public
 
   def register
+    @logger = self.logger
     require "rufus/scheduler"
     prepare_jdbc_connection
 
     # Raise an error if @use_column_value is true, but no @tracking_column is set
     if @use_column_value