elasticsearch-jdbc 使用

elasticsearch-jdbc是一個將關系型數據庫（RDBMS）數據導入到ElasticSearch庫中的一個工具包，支持mysql、oracle、postgrey、csv等存儲列式數據的容器。目前最新的版本是2.3.4.1，支持的ElasticSearch的版本為2.3.4。

下載elasticsearch-jdbc對應的版本。

切換到elasticsearch-jdbc-/bin目錄下，在此目錄下編寫你的運行腳本（不一定非要在bin目錄下）

例如：

’#!/bin/sh
bin=/Users/zhuzhiqiang/Desktop/javaxuxi/es/elasticsearch-jdbc-2.3.2.0/bin
lib=/Users/zhuzhiqiang/Desktop/javaxuxi/es/elasticsearch-jdbc-2.3.2.0/lib
echo '{
"type" : "jdbc",
"jdbc": {
"elasticsearch.autodiscover":true,
"elasticsearch.cluster":"es-cluster",
"url":"jdbc:mysql://127.0.0.1:3306/rocketmq-transaction-balance?characterEncoding=utf8&useSSL=false",
"user":"root",
"password":"root",
"sql":"select * from table",
"elasticsearch" : {
  "host" : "127.0.0.1:",
  "port" : 9300
},
"index" : "myindex",
"type" : "mytype" 
}
}'| java \
  -cp "${lib}/*" \
  -Dlog4j.configurationFile=${bin}/log4j2.xml \
  org.xbib.tools.Runner \
  org.xbib.tools.JDBCImporter

　　

執行shell腳本。