欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

solr更新操作

程序员文章站 2022-05-28 11:35:07
...

最近项目中使用了solr技术,由于之前的数据有些小问题需要更新一下,到网上找了一下,没见更新的示例,自己通过添加索引,添加了部分数据,然后试着没有更改id,只是更改某些字段的值重复添加,发现值变了,但是总数没有发生改变,个人觉得solr中的更新和添加类似,如果有就更新没有就添加

public static final String solrURL = "http://localhost:8983/solr";
	
	
	@Test
	public void updateSolrField() {
		SolrServer solrServer = new HttpSolrServer(solrURL);
		SolrQuery solrQuery = new SolrQuery();
		
		solrQuery.setQuery("*:*");
		solrQuery.addFilterQuery("record_type:\"devicebasic\"");
		solrQuery.setStart(0);
		solrQuery.setRows(Integer.MAX_VALUE);
		QueryResponse response = new QueryResponse();
		
		try {
		     response = solrServer.query(solrQuery);
		     if(response != null && response.getResults() != null) {
			 SolrDocumentList results = response.getResults();
			 for (SolrDocument solrDocument : results) {
			     if(solrDocument.get("ORG_CODE") != null && solrDocument.get("ORG_CODE").toString().trim().length() > 0) {
				SolrInputDocument document = new SolrInputDocument();
				for (Map.Entry<String, Object> map : solrDocument.entrySet()) {															document.addField("ORG_CODE", orgCode);														}
												} else if(map.getKey().equals("_version_")) {
								continue;
							} else {
																document.addField(map.getKey(), map.getValue());
							}
						}
						solrServer.add(document);
						solrServer.commit();
					} else {
						continue;
					}
				}
				
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}

 

相关标签: solr 更新