elasticsearch-jdbc的安装和使用

elasticsearch-jdbc是一个开源的将mysql和es的数据同步的工具，可以很好的实现数据的同步增加和更新（无法实现物理删除）。 1.下载 下载可以直接从网页上下载，链接是

http://xbib.org/repository/org/xbib/elasticsearch/importer/elasticsearch-jdbc/2.3.4.0/elasticsearch-jdbc-2.3.4.0-dist.zip

（下载相应版本即可），或是终端里面下载 wget http://xbib.org/repository/org/xbib/elasticsearch/importer/elasticsearch-jdbc/2.3.4.0/elasticsearch-jdbc-2.3.4.0-dist.zip 下载完成之后直接解压就可以。 2.配置和运行。 es-jdbc通过shell脚本的方式运行. 假设需要同步的mysql是这样的 mysql> select * from stu; +—-+——-+——+——+ | id | name | age | xb | +—-+——-+——+——+ | 1 | messi | 29 | f | | 2 | jack | 18 | m | | 3 | rose | 16 | f | | 4 | curry | 24 | m | | 5 | tom | 15 | m | | 7 | paul | 20 | m | | 8 | kasa | 30 | m | +—-+——-+——+——+ 7 rows in set (0.00 sec)

新建es-mysql-jdbc.sh文件

bin=$JDBC_IMPORTER_HOME/bin lib=$JDBC_IMPORTER_HOME/lib echo '{ "type" : "jdbc", "jdbc": { "url":"jdbc:mysql://localhost:3306/test", "user":"root", "password":"123456", "sql":"select id as \"_id\", name , age, xb from stu", "index" : "myindex", //索引名相当于库 "type" : "mytype" //类行名相当于表 } }' | java \ -cp "${lib}/*" \ -Dlog4j.configurationFile=${bin}/log4j2.xml \ org.xbib.tools.Runner \ org.xbib.tools.JDBCImporter

3.测试 修改或者增加mysql中的数据后，执行刚才的脚本文件（es和mysql要处于开启状态），浏览器中输入localhost：9200/_plugin/head或者直接在终端输入 curl -XGET ‘http://localhost:9200/myindex/mytype/_search?pretty‘就可以查看结果。 注：配合上一篇文章中的计时任务就可以实习mysql和es的 实时同步。

一个学习网站http://how2j.cn?p=40188