博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Solr之Solrj封装
阅读量:4110 次
发布时间:2019-05-25

本文共 2751 字,大约阅读时间需要 9 分钟。

基本信息:

版本:7.0.0

单机版,cloud版本有所区分

步骤:

1.依赖:

org.apache.solr
solr-solrj
7.0.0

2.业务封装代码:

public class SearchClient {	private SolrClient client;	public SearchClient(String baseSolrUrl, String core) {		client = new HttpSolrClient.Builder(baseSolrUrl + core).build();	}	 	public List
search(String kw, int rows) throws Exception { SolrQuery query = new SolrQuery(); query.setQuery("title:" + kw); query.setQuery("type:" + kw); query.setQuery("content:" + kw); query.setRows(rows); QueryResponse queryResponse = client.query(query); SolrDocumentList results = queryResponse.getResults(); List
items =new ArrayList
(); for (SolrDocument solrDocument : results) { Article item=new Article(); item.setId(solrDocument.get("id")+""); item.setTitle(solrDocument.get("title")+""); item.setType(solrDocument.get("type")+""); items.add(item); } return items; } public void delete(String id) throws Exception { client.deleteById(id); client.commit(); } public void add(List
items) throws Exception { for (Article item : items) { SolrInputDocument solrInputDocument = new SolrInputDocument(); solrInputDocument.addField("id", item.getId()); solrInputDocument.addField("content", item.getContent()); solrInputDocument.addField("title", item.getTitle()); solrInputDocument.addField("type", item.getType()); client.add(solrInputDocument); } client.commit(); } public void closeQuietly() { try { client.close(); } catch (IOException e) { e.printStackTrace(); } }}

测试:

public static void add() throws Exception {	String baseSolrUrl="http://localhost:8983/solr/";	String core="someabcd";	SearchClient client=new SearchClient(baseSolrUrl,core);	List
items=new ArrayList
(); List
lines=FileUtils.readLines(new File("E:/data/test.data00")); for (String line : lines) { Article item=JSON.parseObject(line, Article.class); item.setId(CommonUtils.getUUID32()); items.add(item); } client.add(items); client.closeQuietly();}public static void search() throws Exception { String baseSolrUrl="http://localhost:8983/solr/"; String core="someabcd"; SearchClient client=new SearchClient(baseSolrUrl,core); List
items=client.search("Apache版本", 10); System.out.println(items); client.closeQuietly();}public static void del(String id) throws Exception { String baseSolrUrl="http://localhost:8983/solr/"; String core="someabcd"; SearchClient client=new SearchClient(baseSolrUrl,core); client.delete(id); client.closeQuietly();}

 

ps:

如果想直接反序列为Bean那么需要用其自定义注解

@Field("id")

private String id;

@Field

private String title;

转载地址:http://wrqsi.baihongyu.com/

你可能感兴趣的文章
DirectX11 光照演示示例Demo
查看>>
VUe+webpack构建单页router应用(一)
查看>>
Node.js-模块和包
查看>>
(python版)《剑指Offer》JZ01:二维数组中的查找
查看>>
管理用户状态——Cookie与Session
查看>>
Spring MVC中使用Thymeleaf模板引擎
查看>>
PHP 7 的五大新特性
查看>>
深入了解php底层机制
查看>>
PHP中的stdClass 【转】
查看>>
XHProf-php轻量级的性能分析工具
查看>>
OpenCV gpu模块样例注释:video_reader.cpp
查看>>
【增强学习在无人驾驶中的应用】
查看>>
OpenCV meanshift目标跟踪总结
查看>>
就在昨天,全球 42 亿 IPv4 地址宣告耗尽!
查看>>
听说玩这些游戏能提升编程能力?
查看>>
如果你还不了解 RTC,那我强烈建议你看看这个!
查看>>
沙雕程序员在无聊的时候,都搞出了哪些好玩的小玩意...
查看>>
Mysql复制表以及复制数据库
查看>>
Kafka
查看>>
9.1 为我们的角色划分权限
查看>>