springboot 连接solr操作(三)

2020-12-02 17:59:24 阅读：427 来源： 互联网

标签：springboot demo springframework where org import solr 连接

该文章记录的是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);
    }
}

标签：springboot,demo,springframework,where,org,import,solr,连接
来源： https://blog.csdn.net/qq_25771201/article/details/110492384

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

springboot 连接solr操作(三)