solr 连接mysql数据库dataimport

时间:2021-02-02 18:08:28

1.在对应的core/conf下新建文件data-config-comment.xml,配置数据源及导入的

<dataConfig>
<dataSource type="JdbcDataSource"
driver="com.mysql.jdbc.Driver"
url="jdbc:mysql://localhost:3308/taxparty"
user="root"
password="123456"/>
<document>
<entity name="tbl_ask_bank"
query="SELECT bank_id,ask_title from tbl_ask_bank"
deltaImportQuery="SELECT bank_id,ask_title from tbl_ask_bank'"
deltaQuery="SELECT bank_id FROM tbl_ask_bank WHERE DATE(submit_time) >= '${dih.last_index_time}'">
<field column="bank_id" name="bank_id"/>
<field column="ask_title" name="ask_title"/>
<field column="submit_time" name="submit_time"/>
</entity>
</document>
</dataConfig>

  • entity对应MySQL数据库表中的一行

  • query对应全库导入的SQL查询

  • queryImportQuery 对应增量导入的SQL查询

  • deltaQuery对应增量导入获取最新修改的行ID,这些ID用于queryImportQuery,SQL的含义中

2. 配置Solr的 solrconfig.xml
  <requestHandler name="/dataimportcomment" class="org.apache.solr.handler.dataimport.DataImportHandler"> 
<lst name="defaults">
<str name="config">data-config-comment.xml</str>
</lst>
</requestHandler>

3.拷贝jar包到solr/WEB-INF/lib下solr-dataimporthandler-5.5.0.jar和solr-dataimporthandler-extras-5.5.0.jar