ElasticSearch同步MySql
2016-07-01 09:07
477 查看
ElasticSearch同步Mysql的插件选择了elasticsearch-jdbc,理由是活跃度高,持续更新,最新版本兼容elasticsearch-2.3.3.
下载后解压,里面有bin、lib2个目录.
新建一张user表
插入几条数据.
查看所有数据:
这样mysql中的数据就准备好了.
其中bin和lib用了绝对路径.
添加可执行权限:
执行脚本:
报了一个SSL连接的警告,没有错误.如果出现
查看导入结果:
head插件中查看:
elasticsearch-jdbc实现MySQL同步到ElasticSearch深入详解
一、下载
下载地址:https://github.com/jprante/elasticsearch-jdbc下载后解压,里面有bin、lib2个目录.
二、mysql配置
确保mysql能用,在mysql中新建一个test数据库mysql>create database test;
新建一张user表
mysql> create table user(id int(10) Not null,name char(10));
插入几条数据.
mysql> insert into test values("1","zhangsan"); mysql> insert into user values("2","LiSi"); mysql> insert into user values("3","WangWu"); mysql> insert into user values("4","MaLiu");
查看所有数据:
mysql> select * from user; +----+----------+ | id | name | +----+----------+ | 1 | zhangsan | | 2 | LiSi | | 3 | WangWu | | 4 | MaLiu | +----+----------+ 4 rows in set (0.00 sec)
这样mysql中的数据就准备好了.
三、导入数据
新建一个odbc_es文件夹,新建mysql_import_es.sh脚本,脚本内容:
bin=/Users/yaopan/Documents/bropen/elasticsearch-jdbc-2.3.2.0/bin lib=/Users/yaopan/Documents/bropen/elasticsearch-jdbc-2.3.2.0/lib echo '{ "type" : "jdbc", "jdbc" : { "elasticsearch.autodiscover":true, "elasticsearch.cluster":"bropen", "url" : "jdbc:mysql://localhost:3306/test", "user" : "root", "useSSL":"true", "password" : "123456", "sql" : "select *, id as _id from user", "elasticsearch" : { "host" : "127.0.0.1", "port" : 9300 }, "index" : "test", "type" : "user" } }' | java \ -cp "${lib}/*" \ -Dlog4j.configurationFile=${bin}/log4j2.xml \ org.xbib.tools.Runner \ org.xbib.tools.JDBCImporter
其中bin和lib用了绝对路径.
添加可执行权限:
chmod a+x mysql_import_es.sh
执行脚本:
./mysql_import_es.sh
报了一个SSL连接的警告,没有错误.如果出现
Error: Could not find or load main class org.xbib.tools.Runner之类的错误,很有可能是bin和lib路径出现问题.
查看导入结果:
http://localhost:9200/test/user/_search?pretty
head插件中查看:
参考文章
ElasticSearch同步Mysqlelasticsearch-jdbc实现MySQL同步到ElasticSearch深入详解
相关文章推荐
- Mysql连接数设置
- Servlet上传到mysql数据库中文乱码问题
- MySQL事务控制语句
- MySql + EF6 + .Net Core
- MySql数据库基本操作练习
- MySQL5.7.13源码编译安装与配置
- mysql 数据库中 常用数据类型,约束
- MySQL 5.7 学习心得之安全相关特性
- MySQL 密码增强插件
- MySql5.6使用validate password 插件加强密码强度的安装及使用方法
- Mysql row number()排序函数的用法和注意
- MYSQL数据库及字段命名规范
- mysql 1064错误
- MySQL数据库PDO教程
- mysql用一个表的一列,更新另一表的一列
- SparkSQL JDBC连接 mysql
- 12步安装MySQL-Server5.5.32
- mysql从数据表中随机取数据!!!
- mysql中kill掉所有锁表的进程
- mysql5.7 社区zip版安装配置