发布：2024/2/22 22:00:06作者：管理员 来源：本站 浏览次数：925
具体实现
添加（修改）方法如下：
/**
* 添加、修改文档
* @throws Exception
*/
@Test
public void addDocment() throws Exception {
//建立solr连接
HttpSolrClient httpSolrClient = new HttpSolrClient.Builder("http://localhost:8983/solr/new_core").build();
//创建一个文档对象
SolrInputDocument document = new SolrInputDocument();
//如果需要修改，即id一致即可
//item_title、item_price、item_desc这些字段都是之前添加的业务字段
document.addField("id","10000000");
document.addField("city_name","河南");
document.addField("city_shortname","郑州");
//把文档写入索引库
UpdateResponse add = httpSolrClient.add(document);
//提交操作
httpSolrClient.commit();
}
删除方法如下：
/**
* 删除文档
* @throws Exception
*/
@Test
public void deleteDocment() throws Exception {
//建立solr连接
HttpSolrClient httpSolrClient = new HttpSolrClient.Builder("http://localhost:8983/solr/new_core").build();
//根据id删除文档
/* httpSolrClient.deleteById("110106");*/
//批量删除文档
httpSolrClient.deleteById(new ArrayList<String>(){{add("110108");add("110109");}});
//提交操作
httpSolrClient.commit();
}
查询方法：
/*
*
* 查询方法：如下
* */
@Test
public void testquery() throws IOException, SolrServerException {
/*
* 1.连接到solr
*
*
* */
//1.固定语句：连接到solr
HttpSolrClient httpSolrClient = new HttpSolrClient.Builder("http://localhost:8983/solr/new_core").build();
//2.获取solrsolrdoucument对象
SolrDocument solrDocument=httpSolrClient.getById("1212322");
//3.httpSolrClient以及SolrDocument 获取我们具体的实体
Product bean = httpSolrClient.getBinder().getBean(Product.class, solrDocument);
//获取数值
System.out.println("bean="+bean);
}
总结
每个solr版本所对应的语句变化较大！本版本：7.7.2
<dependency>
<groupId>org.apache.solr</groupId>
<artifactId>solr-solrj</artifactId>
<version>7.7.2</version>
</dependency>
© Copyright 2014 - 2025 柏港建站平台 ejk5.com. 渝ICP备16000791号-4