SolrCloud数据导入

2019-11-08 20:54:55

字体：大中小

来源：转载

供稿：网友

拷贝/app/solrhome/configsets/basic_configs文件到/app/solrhome，重命名为address修改solrconfig.xml文件在文件最后节点加上<requestHandler name="/dataimport" class="org.apache.solr.handler.dataimport.DataImportHandler"> <lst name="defaults"> <str name="config">data-config.xml</str> </lst></requestHandler>在managed-schema里加上字段<field name="ADDRESSID" type="string" indexed="true" stored="true" required="true" multiValued="false" /><field name="MEMBERID" type="string" indexed="true" stored="true" required="false" multiValued="false"/><field name="MEMBERTYPE" type="string" indexed="true" stored="true" required="false" multiValued="false"/><field name="COUNTRY" type="string" indexed="true" stored="true" required="false" multiValued="false"/>新增data-config.xml文件<dataConfig> <dataSource name="address_01" type="JdbcDataSource" driver="com.MySQL.jdbc.Driver" url="jdbc:mysql://10.202.38.15:3306/member1?useUnicode=true&serverTimezone=GMT&characterEncoding=UTF-8&userssL=false" user="member" passWord="sf123456" batchSize="-1"/> <document> <entity name="address_01" dataSource="address_01" pk="ADDRESSID" query="select * ,CONCAT(LONGITUDE,' ',LATITUDE) as job_coordinate from cx_customer_address" deltaQuery="select ADDRESSID from cx_customer_address where MODIFYTIME > '${dih.last_index_time}'" deltaImportQuery="select * ,CONCAT(LONGITUDE,' ',LATITUDE) as job_coordinate from cx_customer_address where ADDRESSID='${dih.delta.ADDRESSID}'"> <field column="ADDRESSID" name="ADDRESSID"/> <field column="MEMBERID" name="MEMBERID"/> <field column="MEMBERTYPE" name="MEMBERTYPE"/> <field column="COUNTRY" name="COUNTRY"/> </entity> </document></dataConfig>

上一篇：mongo - 副本集增加新成员

下一篇：MongoDB 文档字段增删改

学习交流

索泰发布一款GTX 1070 Mini迷你版本:小机

索泰发布一款GTX 1070 Mini迷你版本:小机箱大爱...

热门图片

猜你喜欢的新闻

猜你喜欢的关注