一、通過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

總結

以上是生活随笔為你收集整理的java solr_通过Java访问Solr服务实例及相关配置的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。