在java中使用solrj对solr进行CRUD

如果想要知道如何安装solr,集成IKAnalyzer中文分词器，批量导入数据库数据，java使用参照以下本博主博文：

安装solr

https://blog.csdn.net/u013294097/article/details/89735654

集成IKAnalyzer中文分词器

https://blog.csdn.net/u013294097/article/details/89735890

solr使用浏览器批量导入数据库中数据

https://blog.csdn.net/u013294097/article/details/89739768

solr在java中的案例

https://blog.csdn.net/u013294097/article/details/89739859

github代码：

https://github.com/mx342/luceneDemo

1.必要的pom,本文使用的是springboot做案例

包含核心包solrj，http链接的包等，springboot自带日志

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.apache.solr</groupId><artifactId>solr-solrj</artifactId><version>4.10.3</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpmime</artifactId><version>4.3.1</version></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version><type>pom</type></dependency><dependency><groupId>org.codehaus.woodstox</groupId><artifactId>wstx-asl</artifactId><version>3.2.7</version></dependency><dependency><groupId>org.noggit</groupId><artifactId>noggit</artifactId><version>0.5</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpcore</artifactId><version>4.3</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.3.1</version></dependency><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.6</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>

2.测试代码

import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.SolrServer;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;import java.util.List;
import java.util.Map;@RunWith(SpringRunner.class)
@SpringBootTest
public class SolrApplicationTests {@Value("${spring.data.solr.host}")private String solrHost = "";/*** 作者 ZYL* 功能描述 : 生成索引* 日期 2019/5/1 17:30* 参数* 返回值 void*/@Testpublic void testIndexCreate() throws Exception {//连接solr服务端SolrServer solrServer = new HttpSolrServer(solrHost);SolrInputDocument doc = new SolrInputDocument();//域要先定义后使用，必须要要注意要有id主键域//solr中没有专用的修改方法，会根据id进行查找，如果找到了，删除原来的，根据新的进行查找doc.addField("id","a001");doc.addField("product_name","台灯111");doc.addField("product_price","12.5");solrServer.add(doc);solrServer.commit();}/*** 作者 ZYL* 功能描述 : 删除操作* 日期 2019/5/1 17:44* 参数* 返回值 void*/@Testpublic void testIndexDel() throws Exception{SolrServer solrServer = new HttpSolrServer(solrHost);//根据主键id进行删除solrServer.deleteById("a001");
//        solrServer.deleteByQuery("*:*");solrServer.commit();}/*** 作者 ZYL* 功能描述 : 简单查询* 日期 2019/5/1 17:31* 参数 null* 返回值*/@Testpublic void tesIndexSearch1() throws Exception{SolrServer solrServer = new HttpSolrServer(solrHost);//创建solr的查询条件对象SolrQuery solrQuery = new SolrQuery();solrQuery.setQuery("product_name:台灯");//查询并获取查询响应对象QueryResponse queryResponse = solrServer.query(solrQuery);//从查询响应中获取查询结果集对象SolrDocumentList results = queryResponse.getResults();//遍历查询结果集//打印查询的一共的多少条System.err.println("总查询条数:" + results.getNumFound());for (SolrDocument doc : results) {System.err.println("==============" + doc.get("id"));System.err.println("==============" + doc.get("product_name"));System.err.println("==============" + doc.get("product_price"));System.err.println("---------------------------------------------------");}solrServer.commit();}/*** 作者 ZYL* 功能描述 : 复杂查询* 日期 2019/5/1 19:34* 参数* 返回值 void*/@Testpublic void tesIndexSearch2() throws Exception {SolrServer solrServer = new HttpSolrServer(solrHost);//创建solr的查询条件对象SolrQuery solrQuery = new SolrQuery();solrQuery.setQuery("台灯");//设置默认搜索与solrQuery.set("df","product_keywords");//设置过滤条件solrQuery.addFilterQuery("product_price:[1 TO 100]");//设置排序，降序solrQuery.setSort("product_price", SolrQuery.ORDER.desc);//设置分页solrQuery.setStart(0);//设置查询多少条solrQuery.setRows(10);//设置高亮hlsolrQuery.setHighlight(true);//设置高亮显示的域String highlightingField = "product_name";solrQuery.addHighlightField(highlightingField);//设置高亮前缀solrQuery.setHighlightSimplePre("<span style=\"color:red\" >");//设置高亮后缀solrQuery.setHighlightSimplePost("</span>");//=========================查询并获取查询响应对象=======================QueryResponse queryResponse = solrServer.query(solrQuery);//从查询响应中获取查询结果集对象SolrDocumentList results = queryResponse.getResults();//遍历查询结果集//打印查询的一共的多少条System.err.println("总查询条数:" + results.getNumFound());Map<String, Map<String, List<String>>> highlighting = queryResponse.getHighlighting();for (SolrDocument doc : results) {System.err.println("==============" + doc.get("id"));Map<String, List<String>> highlightingById = highlighting.get(doc.get("id"));if(highlightingById.containsKey(highlightingField)){List<String> msgList = highlightingById.get(highlightingField);for (String s : msgList) {System.err.println("==============highlighting:" + s);}}System.err.println("==============" + doc.get("product_name"));System.err.println("==============" + doc.get("product_price"));System.err.println("---------------------------------------------------");}}
}

如果觉得本文对您有所帮助，欢迎您扫码下图所示的支付宝和微信支付二维码对本文进行随意打赏。您的支持将鼓励我继续创作

在java中使用solrj对solr进行CRUD相关推荐

java中使用pgsql的json类型CRUD
java po类: private Object labReportBO; 数据库类型: lab_report_bo JSON; mapper.xml <resultMap id="B ...
solr使用三(在实际业务中使用SolrJ)
Solr官方提供了对于不同客户端的例子,详见SolrJ官方文档一.引入pom文件 <dependency><groupId>org.apache.solr</group ...
java全文搜索服务器 solr_Apache Solr采用Java开发、基于Lucene的全文搜索服务器
http://docs.spring.io/spring-data/solr/ 首先介绍一下solr: Apache Solr (读音: SOLer) 是一个开源.高性能.采用Java开发.基于Luc ...
java创建的窗口无法关闭_在Java中添加canvas后无法关闭窗口(Can't close window after adding canvas in Java)...
在Java中添加canvas后无法关闭窗口(Can't close window after adding canvas in Java) public class Screen extends Ca ...
java中实现具有传递性吗_Java中volatile关键字详解,jvm内存模型，原子性、可见性、有序性...
一.Java内存模型想要理解volatile为什么能确保可见性,就要先理解Java中的内存模型是什么样的. Java内存模型规定了所有的变量都存储在主内存中.每条线程中还有自己的工作内存,线程的工作 ...
java中调用python
在Java中调用Python </h1><div class="clear"></div><div class="postBod ...
java中hashcode_浅谈Java中的Hash值
1.Hash值有什么用? HashMap.HashTable.HashSet,所以涉及到使用Hash值进行优化存储的地方,都会用到HashCode.HashCode是Key,这种计算为提高计算的性能. ...
JAVA中获取当前系统时间
JAVA中获取当前系统时间转自:http://www.cnblogs.com/Matrix54/archive/2012/05/01/2478158.html 一. 获取当前系统时间和日期并格式化输 ...
Java中的对象和包
什么是对象对象就是实际生活中的事物,可以说一切事物都是对象. 对象的三个特点 1 对象的行为:这个对象能做什么, 例如包子是用来吃的 2 对象的状态:对象保持的一种状态,例如这个包子是热的还是凉 ...