我jdbc在logstash輸入的插件中有這樣的MySQL語句。

statement => "SELECT * from TEST where id > :sql_last_value"

我的表沒有任何date或datetime字段。因此，我嘗試通過使用來檢查scheduler每一分鐘，以更新索引，是否在表中添加了任何新行。

我應(yīng)該只能更新新記錄，而不能更新現(xiàn)有記錄中的現(xiàn)有值更改。為此，我需要進(jìn)行以下logstash輸入：

input {

jdbc {

jdbc_connection_string => "jdbc:mysql://myhostmachine:3306/mydb"

jdbc_user => "root"

jdbc_password => "root"

jdbc_validate_connection => true

jdbc_driver_library => "/mypath/mysql-connector-java-5.1.39-bin.jar"

jdbc_driver_class => "com.mysql.jdbc.Driver"

jdbc_paging_enabled => "true"

jdbc_page_size => "50000"

schedule => "* * * * *"

statement => "SELECT * from mytable where id > :sql_last_value"

use_column_value => true

tracking_column => id

last_run_metadata_path => "/path/.logstash_jdbc_last_run"

clean_run => true

}

}

因此，每當(dāng)我創(chuàng)建索引并運(yùn)行該logstash文件以上傳文檔時(shí)，它就根本不會(huì)上傳。文檔數(shù)顯示為零。我確保.logstash_jdbc_last_run在運(yùn)行l(wèi)ogstashconf文件之前刪除了。

logstash控制臺(tái)輸出的一部分：

[2016-11-02T16：33：00,294] [INFO] [logstash.inputs.jdbc](0.002000s)SELECT

count(*)AS countFROM(SELECT * from TEST，其中id>‘2016-11-02 11:02： 00’)AS

t1LIMIT 1

并且通過逐分鐘檢查是正確的來繼續(xù)進(jìn)行，但是隨后沒有得到記錄。它是如何工作的？

我想念什么嗎？任何幫助，不勝感激。

總結(jié)

以上是生活随笔為你收集整理的Java中lastValue_在Logstash中为sql_last_value使用表的ID？的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。