Solr DIH delta-import 带有复合主键？

Question

我的 Solr 数据源是一个 SQL 数据库，其中主键是复合的（即它有两个字段）。

这对于我的主要 DIH 查询 来说很好，我只需连接字段即可成为我的 Solr 主键。然而，从文档中并不清楚我如何编写增量导入查询来支持这一点。

该文档建议我需要两个查询 - 一个查询用于查找已更改行的主键，另一个查询用于实际检索与每个键对应的单个文档。不过，没有示例显示复合键的这一点。

理想情况我根本不想要这两个单独的查询，如果将这两个查询简单地组合起来，那么数据库上的负载就会减少，这样查询和deltaQuery 是基于 last_changed 进行过滤的 WHERE 子句。

因此，如果我的主要查询是：

SELECT key1 || key2 as pk FROM table

相关的deltaQuery（和/或deltaImportQuery）会是什么样子？

我尝试仅添加 WHERE 子句，但在查询运行后，我收到了有关缺少 deltaImportQuery 的警告，然后收到了空指针异常。

Answer 1

query="SELECT key1 || key2 as id, ...other fields FROM table"

deltaImportQuery="SELECT key1 || key2 as id, ... other fields
                  FROM table
                  where key1 = '${dataimporter.delta.key1}'
                  and key2 = '${dataimporter.delta.key2}'"

deltaQuery="SELECT key1 || key2 as id, key1, key2
            FROM table
            WHERE lastUpdated > '${dataimporter.last_index_time}'"

假设 key1 和 key2 是文本。例如，如果 key2 是数字，则不需要 ${dataimporter.delta.key2} 周围的单引号。

Answer 2

将 deltaQuery 设置为“select 1”，这将触发 deltaImportQuery
然后只需在 where 子句中使用 '${dataimporter.last_index_time}' 编写 deltaImportQuery

即可 deltaQuery="select 1"
deltaImportQuery =“从a_table中选择*，其中lastUpdated＆gt;'$ {dataimporter.last_index_time}'”

Answer 3

有两个 deltaImport 查询。第一个（deltaQuery）用于确定要索引的内容。例如，我们可以在其中定义我们需要索引什么ID。另一个用于根据该 id 确定数据。看看我的例子，希望它能帮助你：

<entity name="address" pk="address_id" query="SELECT * FROM address a" deltaImportQuery="SELECT * FROM address a where a.address_id > ${dataimporter.delta.id}"
            deltaQuery="select address_id as id from address where address_id=101010">

deltaImportQuery 的重要部分是 ${dataimporter.delta.id}。这就是我们将 id 从 deltaQuery 设置为 deltaImportQuery 的方法。