该文章记录的是solr删除数据
传送门:
springboot 连接solr操作(一)
springboot 连接solr操作(二)
如果没有看前两篇文章 请先看前两篇文章 因为该文章有些内容是依托于前两篇文章的。
一、solr的操作类
package com.demo.demo.service;
import com.demo.demo.bean.solr.GoodsSolrEntity;
import org.apache.solr.client.solrj.response.UpdateResponse;
import org.apache.solr.common.SolrInputDocument;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.solr.core.SolrTemplate;
import org.springframework.data.solr.core.query.Criteria;
import org.springframework.data.solr.core.query.SimpleQuery;
import org.springframework.data.solr.core.query.SolrDataQuery;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
/**
* @program: com.zhangxian.pay.service
* @author: zwx
* @create: 2020-12-01 17:14
**/
@Service
public class GoodsSolrOperations {
@Autowired
private SolrTemplate solrTemplate;
/**
* 通过主键ID删除solr数据 批量删除
* @param ids
*/
public void deleteSolrById(List<String> ids)
{
solrTemplate.deleteByIds("haircut_goods", ids);
solrTemplate.commit("haircut_goods");
}
/**
* 通过条件删除文档
* @param where
*/
// ? 是类型通配符 使用类型通配符的原因是 循环添加删除条件无法确定类型
public void deleteSolrByQuery(Map< String, ? > where)
{
SolrDataQuery solrDataQuery = new SimpleQuery();
for (Map.Entry<String, ?> entry: where.entrySet()) {
solrDataQuery.addCriteria(Criteria.where(entry.getKey()).is(entry.getValue()));
}
solrTemplate.delete("haircut_goods", solrDataQuery);
solrTemplate.commit("haircut_goods");
}
}
二、控制器调用
package com.demo.demo.controller;
import com.demo.demo.bean.solr.GoodsSolrEntity;
import com.demo.demo.service.GoodsSolrOperations;
import com.demo.demo.service.impl.HaircutUsers;
import org.apache.poi.ss.formula.functions.T;
import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.SolrServerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.solr.core.SolrTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.io.IOException;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
@RestController
@RequestMapping("index")
public class IndexController {
@Autowired
private HaircutUsers haircutUsers;
@Autowired
private SolrClient solrClient;
@Autowired
private SolrTemplate solrTemplate;
@Autowired
private GoodsSolrOperations goodsSolrOperations;
@GetMapping("index/{nickname}")
public void Index(@PathVariable(value = "nickname") String nickname) throws IOException, SolrServerException {
// 根据主键ID批量删除
goodsSolrOperations.deleteSolrById(Arrays.asList("6", "7"));
Map where = new HashMap();
where.put("id", "6");
where.put("store_id", 3);
where.put("desc", "描述");
goodsSolrOperations.deleteSolrByQuery(where);
}
}