elasticsearch - 删除 Elasticsearch 河插件中未更新的记录

Question

在 flex 搜索河中，如果我删除了mysql中的一条记录，它仍显示在索引中。我也启用了自动提交。如何使mysql和 flex 搜索同步，以及如何使delta导入在 flex ？

   {
"type" : "jdbc",
"jdbc" : {
    "driver" : "com.mysql.jdbc.Driver",
    "url" : "jdbc:mysql://localhost:3306/testrivet",
    "user" : "root",
    "password" : "Gemini*123",
    "sql" : [
                        { 
                             "statement" : "select *,empid as _id from empdata"

                        }
       ],
    "strategy" : "simple",
 "schedule" : "0 0-59 0-23 ? * *",
 "autocommit" : true,
 "metrics": {enabled:true}
    },
    "index" : {
   "autocommit":true
    }
}

Answer 1

实际上，如果从数据库中删除了一条记录，那么您的JDBC河将无法再检索它以删除ES中的相应记录。

另一种方法是通过设置标志(即新的 bool(boolean) 列)从数据库中“软删除”记录。当记录处于 Activity 状态时，该标志为true；当删除记录时，该标志为false。这样，当您的导入过程运行时，您将获得所有记录，并根据该标志知道必须从Elasticsearch中删除文档。

还有其他方法，但是它们涉及将其他成分添加到混合中，因此，如果这样做可以做，我建议这样做。