MySQL同步到Elasticsearch (ES) 的方法有多种，以下是几种常见的解决方案：
- 使用Logstash: Logstash 是一个强大的数据管道平台，可以同步MySQL和Elasticsearch。
input {
jdbc {
jdbc_driver_library => "/path/to/mysql-connector-java-x.x.x-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://localhost:3306/yourdatabase"
jdbc_user => "yourusername"
jdbc_password => "yourpassword"
schedule => "* * * * *"
statement => "SELECT * FROM your_table"
}
}
output {
elasticsearch {
hosts => ["localhost:9200"]
index => "yourindex"
document_id => "%{unique_id}"
}
}- 使用Elasticsearch JDBC river: 这是一个已经被废弃的插件，可以用来同步MySQL数据到ES。
- 使用Elasticsearch官方同步工具: 这是一个新的同步工具，可以直接同步MySQL数据到ES。
- 使用自定义同步程序: 可以编写一个定时任务，使用JDBC连接MySQL，并使用Elasticsearch的API索引数据到ES。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
// ...
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/yourdatabase", "yourusername", "yourpassword");
Statement statement = conn.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM your_table");
// 使用Elasticsearch客户端将数据索引到ES
// ...- 使用第三方库: 例如
Pentaho Data Integration(Kettle) 可以同步MySQL和Elasticsearch。
选择合适的方法取决于你的具体需求和环境。对于简单的同步任务，Logstash 或自定义同步程序可能是最快的方法。对于更复杂的需求，可能需要使用专业的数据集成工具或编写更复杂的同步逻辑。