input {
jdbc {
jdbc_connection_string => "jdbc:oracle:thin:@host:port/service"
jdbc_user => "user"
jdbc_password => "pass"
jdbc_validate_connection => "true"
jdbc_driver_library => "C:\logstash\lib\ojdbc7.jar"
jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
statement => "select * from bugDB where product_id=01 and status <=30 where upd_date > :sql_last_value"
schedule => "*/5 * * * *"
}
}
I have the configuration as above. The issue i am facing is after the first run, as I have scheduled the job to run in every 5 mins, the updated records in DB are not being fetched. the data type of upd_date field is "DATE". How to get the recently updated records and keep DB and ES sync