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 文檔字段增刪改