如何把mysql中的數(shù)據(jù)同步到elasticsearch中？這幾年我接觸了更多有同步需求的項(xiàng)目，文件同步，主流和非主流數(shù)據(jù)庫(kù)之間的同步。要將MySQL中的數(shù)據(jù)同步到Elasticsearch，可以通過(guò)

如何把mysql中的數(shù)據(jù)同步到elasticsearch中？

這幾年我接觸了更多有同步需求的項(xiàng)目，文件同步，主流和非主流數(shù)據(jù)庫(kù)之間的同步。要將MySQL中的數(shù)據(jù)同步到Elasticsearch，可以通過(guò)以下實(shí)現(xiàn)。

自我實(shí)現(xiàn)

數(shù)據(jù)同步的關(guān)鍵是提取變化的數(shù)據(jù)。在MySQL中捕獲數(shù)據(jù)變化的方法有:

觸發(fā)器:簡(jiǎn)單直接，使用觸發(fā)器將變更記錄的主鍵插入到中間表中，程序定時(shí)掃描提取數(shù)據(jù)。

Binlog:基于數(shù)據(jù)庫(kù)的二進(jìn)制日志，在日志中記錄數(shù)據(jù)的添加、刪除、修改操作。通常，該程序用于模擬從站接收和解析日志以獲取數(shù)據(jù)。

冗余字段:可以在同步表中添加更新時(shí)間字段，以定期掃描和提取大于某個(gè)時(shí)間點(diǎn)的數(shù)據(jù)。

自我實(shí)現(xiàn)的成本很高，當(dāng)然也有很多開源工具可用。

使用其他工具

Logstash-input-jdbc:這是Logstash提供的官方插件，支持完全同步和增量同步。原理比較簡(jiǎn)單，就是定期執(zhí)行SQL，可以使用上面的* *冗余字段的方法。地址:Go-mysql-elasticsearch:基于Go開發(fā)并與Binlog同步的第三方開源工具。地址:elasticsearch-jdbc:基于SQL的完全和增量同步的第三方工具。地址:

推薦Logstash-input-jdbc，簡(jiǎn)單易用，穩(wěn)定。

java怎樣查詢MYSQL數(shù)據(jù)庫(kù)中的數(shù)據(jù)；根據(jù)id字段查詢，獲取id對(duì)應(yīng)的一行數(shù)據(jù)，并顯示，在標(biāo)簽上？

首先需要獲取數(shù)據(jù)庫(kù)連接，獲取sql執(zhí)行器執(zhí)行sql語(yǔ)句，select * from table name，where id，獲取帶有你傳遞的id的結(jié)果集，從結(jié)果集中獲取數(shù)據(jù)。