我有一个 solr 索引,我正在使用 mysql DB 进行 DIH。
当我运行该delta-import
命令时,正在收集自上次完全导入以来在 DB 中插入的 4 行,但索引没有更新!
841705 [qtp108251962-14] INFO org.apache.solr.handler.dataimport.DataImporter – Loading DIH Configuration: db-data-config.xml
841708 [qtp108251962-14] INFO org.apache.solr.handler.dataimport.DataImporter – Data Configuration loaded successfully
841709 [Thread-31] INFO org.apache.solr.handler.dataimport.DataImporter – Starting Delta Import
841709 [qtp108251962-14] INFO org.apache.solr.core.SolrCore – [db] webapp=/solr path=/dataimport params={command=delta-import} status=0 QTime=4
841716 [Thread-31] INFO org.apache.solr.handler.dataimport.SimplePropertiesWriter – Read dataimport.properties
841719 [Thread-31] INFO org.apache.solr.handler.dataimport.DocBuilder – Starting delta collection.
841719 [Thread-31] INFO org.apache.solr.handler.dataimport.DocBuilder – Running ModifiedRowKey() for Entity: employees
841720 [Thread-31] INFO org.apache.solr.handler.dataimport.JdbcDataSource – Creating a connection for entity employees with URL: jdbc:mysql://localhost/sampledb
841735 [Thread-31] INFO org.apache.solr.handler.dataimport.JdbcDataSource – Time taken for getConnection(): 15
841736 [Thread-31] INFO org.apache.solr.handler.dataimport.DocBuilder – Completed ModifiedRowKey for Entity: employees rows obtained : 4
841736 [Thread-31] INFO org.apache.solr.handler.dataimport.DocBuilder – Completed DeletedRowKey for Entity: employees rows obtained : 0
841736 [Thread-31] INFO org.apache.solr.handler.dataimport.DocBuilder – Completed parentDeltaQuery for Entity: employees
841743 [Thread-31] INFO org.apache.solr.handler.dataimport.DocBuilder – Delta Import completed successfully
841743 [Thread-31] INFO org.apache.solr.handler.dataimport.DocBuilder – Time taken = 0:0:0.26
841744 [Thread-31] INFO org.apache.solr.update.processor.LogUpdateProcessor – [db] webapp=/solr path=/dataimport params={command=delta-import} status=0 QTime=4 {} 0 4
这是 db-data-config.xml:
<dataConfig>
<dataSource driver="com.mysql.jdbc.Driver" url="jdbc:mysql://localhost/sampledb" user="root" password="system" />
<document>
<entity name="employees" pk="ID"
query="SELECT * FROM employees"
deltaImportQuery="SELECT * FROM employees WHERE ID='${dataimporter.delta.id}'"
deltaQuery="SELECT ID from employees WHERE TRANSTIME > '${dataimporter.last_index_time}'">
<field column="ID" name="id" />
<field column="NAME" name="name" />
<field column="CITY" name="city" />
<field column="SERVICE_ID" name="service_id" />
</entity>
</document>
</dataConfig>
但是索引仍然没有更新......我该如何解决这个问题?
这是核心的 conf 文件:
https ://github.com/MuhammadHewedy/db_cores/tree/master/db/conf
https://github.com/MuhammadHewedy/db_cores/blob/master/db/conf/db-data -config.xml
https://github.com/MuhammadHewedy/db_cores/blob/master/db/conf/schema.xml
https://github.com/MuhammadHewedy/db_cores/blob/master/db/conf/solrconfig.xml
谢谢。