SpringBoot集成elasticsearch使用（增删改查）

以上面的Goods对象举例，创建接口EsGoodsRepository，继承Spring封装的ElasticsearchRepository，ElasticsearchRepository提供了一些简单的操作es方法

创建EsGoodsRepository接口：

package com.buba.service;


import com.buba.pojo.Goods;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

public interface EsGoodsRepository extends ElasticsearchRepository {
}

保存或者更新时，先存db后操作es(增删改查+批量删除)。.

@RequestMapping("/goods")
@RestController
public class GoodsControoler{
    @Autowired
    private GoodService goodService;
    @Autowired
    private EsGoodsRepository esGoodsRepository;

    @Autowired
    private EsGoodsService esGoodsService;

    @PostMapping("/add")
    @ApiOperation(value = "添加商品")
    public Result save(@RequestBody Goods goods)  {
        goods.setProductCreateTime(new Date());

        int i = goodService.insert(goods);
        if (i==1){
            // 调用EsGoodsRepository save 方法
            Goods save=esGoodsRepository.save(goods);
            return new Result(true, StatusCode.OK,"添加成功");
        }else {
            return new Result(true, StatusCode.ERROR,"添加失败");
        }

    }

//     引用pagehelper写分页查询
    @GetMapping("/list")
    @ApiOperation(value = "查询商品列表")
    public Result list(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum, @RequestParam(value = "pageSize", defaultValue = "10") int pageSize) {

        PageInfo page = goodService.findAllUserByPageS(pageNum,pageSize);
        return new Result(true, StatusCode.OK, "查询成功", page);
    }

    @GetMapping("/searchGoods")
    @ApiOperation(value = "查询检索功能")
    public Result searchProduct(@RequestParam("productName") String productName,@RequestParam(value = "pageNum", defaultValue = "0") int pageNum, @RequestParam(value = "pageSize", defaultValue = "1") int pageSize){
        QueryBuilder  queryBuilder  = QueryBuilders.matchQuery("productName", productName);
        PageRequest pageRequest  = PageRequest.of(pageNum, pageSize);

        Page search = esGoodsRepository.search(queryBuilder, pageRequest);

        if (search != null){
            return new Result(true,StatusCode.OK,"商品展示成功",search);
        }
        return new Result(false,StatusCode.ERROR,"查询失败");
    }



    //根据id 删除商品
    @DeleteMapping("/delete")
    @ApiOperation(value = "删除商品")
    public Result delete(@RequestParam( "list") List ids) {
        int i = goodService.deleteByPrimaryKey(ids);
        if (i >= 1) {
            esGoodsService.deleteByIds(ids);
            return new Result(true, StatusCode.OK, "删除成功");
        } else {
            return new Result(true, StatusCode.ERROR, "删除失败");
        }

    }

    //根据id修改商品
    @PutMapping("/update")
    @ApiOperation(value = "修改商品")
    public Result update(@RequestBody Goods goods) {
        int i = goodService.updateByPrimaryKeySelective(goods);
        if (i == 1) {
            esGoodsRepository.save(goods);
            return new Result(true, StatusCode.OK, "修改成功");
        }
        return new Result(true, StatusCode.ERROR, "修改失败");
    }

5.swagger +postman 测试

这里只测试了添加 其余自己测

总结

提示：这里对文章遇到报错总结：

1. NodeAvailableException[None of the configured nodes are availabl

原因是我们application.yaml配置文件出现了问题：

配置文件正确写法：

spring:
  data:
    elasticsearch:
      cluster-name: my-application
      cluster-nodes: 127.0.0.1:9300

可以看到这其中有两个配置:

cluster-name: my-application
cluster-nodes: 127.0.0.1:9300

① cluster-name

SpringDataElasticsearch底层使用的不是Elasticsearch提供的RestHighLevelClient，而是TransportClient，并不采用Http协议通信，而是访问elasticsearch对外开放的tcp端口

cluster-name的名字，在elasticsearch安装的config目录下的elasticsearch.yml文件中可以查看到，如果注释，则需要放开注释

②cluster-nodes

SpringDataElasticsearch底层使用的不是Elasticsearch提供的RestHighLevelClient，而是TransportClient，并不采用Http协议通信，而是访问elasticsearch对外开放的tcp端口

默认配置的9300才是对外开放的tcp端口，当然我们也可以通过配置去改变这个端口号。

2.批量删除自定义方法

Error creating bean with name ‘esGoodsRepository’: Invocation of init

method failed; nested exception is

org.springframework.data.mapping.PropertyReferenceException: No

property ids found for type Goods! Did you mean ‘id’?

创建一个service 类

package com.buba.service;

import org.springframework.stereotype.Service;

import java.util.List;

@Service
public interface EsGoodsService {
    void deleteByIds(List ids);
}
在这里插入代码片

创建一个实现类（实现批量删除方法）

package com.buba.service;

import com.buba.pojo.Goods;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.ArrayList;
import java.util.List;

@Service
public class EsGoodsRepositoryImpl implements EsGoodsService {

    @Autowired
    private EsGoodsRepository esGoodsRepository;

    @Override
    public void deleteByIds(List ids) {
        if (!CollectionUtils.isEmpty(ids)) {
            List esProductList = new ArrayList();
            for (Integer id : ids) {
                Goods goods = new Goods();
                goods.setId(id);
                esProductList.add(goods);
            }
            esGoodsRepository.deleteAll(esProductList);
        }
    }
}

controller 调用 service 方法来实现批量删除