Solr数据库导入

Solr数据库导入：

以mysql为例，将数据导入solr。

1.先在mysql的storm数据库中建一个表receivelog

2.向receivelog表中插入测试数据

3.打开solrcore 中conf目录下的solrconfig.xml配置文件，添加如下内容。

<!—name名称可以随意取-->

<requestHandler name="/mysqlimport" class="org.apache.solr.handler.dataimport.DataImportHandler">

        <lst name="defaults">

<!—data-config.xml 配置文件名称跟后面新建文件名一致-->

            <str name="config">data-config.xml</str>

        </lst>

</requestHandler>

4.在相同目录下新建一个data-config.xml文件，添加如下内容。

driver：mysql去掉

url：mysql数据库url地址

user:用户名

password：密码

query：从数据库中查询需要的字段导入solr中

<?xml version="1.0" encoding="UTF-8" ?>

<dataConfig>

    <dataSource type="JdbcDataSource"

              driver="com.mysql.jdbc.Driver"

              url="jdbc:mysql://192.168.8.200/storm"

              user="root"

              password="111111" />

    <document>

        <entity name="receivelog" 

            query="select id, loc, sex, pt from receivelog >

        </entity>

    </document>

</dataConfig>

5.找到Solr下的dist目录，将solr-dataimporthandler-4.10.0.jar和solr-dataimporthandler-extras-4.10.0.jar两个jar包拷贝到tomcat中的solr项目中。

6.下载mysql的jdbc jar包并拷贝到tomcat中的solr项目中。

7.进入solrcore的conf目录下，打开schema.xml核心配置文件，增加数据库字段配置。

<field name="id"  type="int" indexed="true" stored="true"  multiValued="false" required="true"/>

<field name="loc"  type="int" indexed="true" stored="true"/>

<field name="sex"  type="string" indexed="true" stored="true"/>

<field name="pt"  type="int" indexed="true" stored="true"/>

8. 打开solr web管理界面操作mysql数据导入。

测试导入数据。