一、通过Java访问Solr服务(手动创建索引库)
1、创建项目，配置环境(导包及相关文件)
1、SolrJ核心包 /solr-4.10.3/dist/solr-solrj-4.10.3.jar
2、SolrJ依赖包 /solr-4.10.3/dist/solrj-lib下的所有包
3、日志依赖包 /solr-4.10.3/example/lib/ext目录下的所有jar包
4、JDBC驱动包 mysql-connector-java-5.1.10-bin.jar
5、拷贝log4j.properties到src目录下。(或者创建一个Source Folder)
项目结构如下所示
2、编写代码
【1】采集数据
1】创建pojo，创建Product类
package cn.jinshan.pojo;
public class Product {
private Integer pid;
private String name;
private String catalogName;
private double price;
private String description;
private String picture;
// 补全get、set方法}
【2】创建连接数据的 ProductDao类
package cn.jinshan.dao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import cn.jinshan.pojo.Product;
public class ProductDao {
public List getAllProducts() {
List products = new ArrayList<>();
//连接数据库 Connection connection = null;
PreparedStatement prepareStatement=null;
ResultSet resultSet = null;
try {
//加载驱动 Class.forName("com.mysql.jdbc.Driver");
//获取连接 connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/solr", "root", "gzsxt");
//获取预处理编译对象 prepareStatement = connection.prepareStatement("select pid,name,price,description,catalog_name,picture from products");
//执行 resultSet = prepareStatement.executeQuery();
Product product = null;
while (resultSet.next()) {
product = new Product();
product.setPid(resultSet.getInt("pid"));
product.setName(resultSet.getString("name"));
product.setPrice(resultSet.getDouble("price"));
product.setDescription(resultSet.getString("description"));
product.setCatalogName(resultSet.getString("catalog_name"));
product.setPicture(resultSet.getString("picture"));
products.add(product);
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}finally {
if (resultSet !=null) {
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (prepareStatement != null) {
try {
prepareStatement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection !=null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
return products;
}
}
【3】创建一个测试类，测试能否取出数据
package cn.jinshan.test;
import org.junit.Test;
import cn.jinshan.dao.ProductDao;
public class ProductDaoTest {
@Test
public void getAll() {
ProductDao dao = new ProductDao();
System.out.println(dao.getAllProducts());
}
}
注：运行测试类，控制台可以打印出数据，则证明数据采集正常
【2】将数据转换成Solr文档SolrInputDocument
1】将文档的域配置在Solr实例的schema.xml配置文件中，如下图所示：
2】通过代码将数据转为SolrInputDocument文档
//将采集的数据转为SolrInputDocument文档 public List getSolrDocument(List products) {
List solrInputDocuments = new ArrayList<>();
SolrInputDocument solrInputDocument = null;
for (Product product : products) {
solrInputDocument = new SolrInputDocument();
//此处addField的域,必须跟实例的schema.xml配置文件中配置的域相同 solrInputDocument.addField("id", product.getPid());
solrInputDocument.addField("product_name", product.getName());
solrInputDocument.addField("product_catalog_name", product.getCatalogName());
solrInputDocument.addField("product_price", product.getPrice());
solrInputDocument.addField("product_description", product.getDescription());
solrInputDocument.addField("product_picture", product.getPicture());
solrInputDocuments.add(solrInputDocument);
}
return solrInputDocuments;
}
3】手动创建索引库(执行方法后，课查看实例中是否生成数据(位置：D:\java\solr\solrHome\collection1\data\index))
//手动创建索引库 @Test
public void createIndex() {
ProductDao productDao = new ProductDao();
//将数据加入到Solr的索引库 //第一步:连接Solr HttpSolrServer solrServer = new HttpSolrServer("http://localhost:8888/solr/solr1");
try {
solrServer.add(productDao.getSolrDocument(productDao.getAllProducts()));
solrServer.commit();
} catch (SolrServerException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
三、Solr服务插件及其他配置(通过配置文件系统自动创建索引)
可以在管理界面直接从数据库导入数据到索引库，不需要通过手动创建索引的全部操作
1、安装DataImport插件
【1】配置依赖包
将/solr-4.10.3/dist/solr-dataimporthandler-4.10.3.jar拷贝到/depJar/contrib/dataimporthandler/lib目录下
将jdbc驱动包拷贝到 /depJar/contrib/db/lib 目录下
【2】 加载依赖包的相关配置
在相关实例的solrconfig.xml文件中，加载这两个jar依赖，如下所示：
2、配置 数据库表和solr域的映射关系
【1】创建配置文件
在solr实例的conf目录下，配置数据库映射文件data-config.xml(建议不要修改配置文件名字)，文件内容如下：
为数据库连接的相关配置
...数据库表和solr域的关联相关配置(column为表的字段，name为solr域的名称)
driver="com.mysql.jdbc.Driver"
url="jdbc:mysql://localhost:3306/solr"
user="root"
password="gzsxt"/>
配置完成，重启solr服务；
访问solr服务控制台如下，则插件安装完成
2、配置中文分析器 ( IKAnalyzer)
【1】 把IKAnalyzer2012FF_u1.jar添加到solr/WEB-INF/lib目录下
【2】 拷贝IkAnalyzer的配置文件IKAnalyzer.cfg.xml到solr/WEB-INF/classes目录下
IK Analyzer 扩展配置
stopword.dic;
【3】 在schema.xml中自定义一个FieldType，指定中文分词器IKAnalyzer
注：指定中文分词器后，solr域中的个别域的类型就不能写text_general就需要改成text_ik
)
)
)
