Spring boot 整合 Elasticsearch

雨点打透心脏的1/2处 2021-11-05 00:38 312阅读 0赞

第一、安装Elasticsearch [请移步][Link 1]

本文Elasticsearch版本：6.4.2

第二、项目操作

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
            </dependency>

实体类   indexName 可以当做数据库名 加上了@Document注解之后，默认情况下这个实体中所有的属性都会被建立索引、并且分词

@Data
    @Document(indexName = "commodity")
    public class Commodity implements Serializable {
    
        @Id
        private String skuId;
    
        private String name;
    
        private String category;
    
        private Integer price;
    
        private String brand;
    
        private Integer stock;
    
    }

dao层

@Repository
    public interface CommodityRepository extends ElasticsearchRepository<Commodity, String> {
    }

service层

public interface CommodityService {
        long count();
    
        Commodity save(Commodity commodity);
    
        void delete(Commodity commodity);
    
        Iterable<Commodity> getAll();
    
        List<Commodity> getByName(String name);
    
        Page<Commodity> pageQuery(Integer pageNo, Integer pageSize, String kw);
    }

实现类

@Service
    public class CommodityServiceImpl implements CommodityService {
        @Autowired
        private CommodityRepository commodityRepository;
    
    
        @Override
        public long count() {
            return commodityRepository.count();
        }
    
        @Override
        public Commodity save(Commodity commodity) {
            return commodityRepository.save(commodity);
        }
    
        @Override
        public void delete(Commodity commodity) {
            commodityRepository.delete(commodity);
    //        commodityRepository.deleteById(commodity.getSkuId());
        }
    
        @Override
        public Iterable<Commodity> getAll() {
            return commodityRepository.findAll();
        }
    
        @Override
        public List<Commodity> getByName(String name) {
            List<Commodity> list = new ArrayList<>();
            MatchQueryBuilder matchQueryBuilder = new MatchQueryBuilder("name", name);
            Iterable<Commodity> iterable = commodityRepository.search(matchQueryBuilder);
            iterable.forEach(e->list.add(e));
            return list;
        }
    
        @Override
        public Page<Commodity> pageQuery(Integer pageNo, Integer pageSize, String kw) {
            SearchQuery searchQuery = new NativeSearchQueryBuilder()
                    .withQuery(QueryBuilders.matchPhraseQuery("name", kw))
                    .withPageable(PageRequest.of(pageNo, pageSize))
                    .build();
            return commodityRepository.search(searchQuery);
        }
    }

controller类

@RestController
    @RequestMapping(value = "/es")
    public class ESController {
    
        @Autowired
        private CommodityService commodityService;
    
        @RequestMapping("/testInsert")
        public void testInsert() {
            Commodity commodity = new Commodity();
            commodity.setSkuId("1501009001");
            commodity.setName("原味切片面包（10片装）");
            commodity.setCategory("101");
            commodity.setPrice(880);
            commodity.setBrand("良品铺子");
            commodityService.save(commodity);
    
            commodity = new Commodity();
            commodity.setSkuId("1501009002");
            commodity.setName("原味切片面包（6片装）");
            commodity.setCategory("101");
            commodity.setPrice(680);
            commodity.setBrand("良品铺子");
            commodityService.save(commodity);
    
            commodity = new Commodity();
            commodity.setSkuId("1501009004");
            commodity.setName("元气吐司850g");
            commodity.setCategory("101");
            commodity.setPrice(120);
            commodity.setBrand("百草味");
            commodityService.save(commodity);
    
        }
    
        @RequestMapping(value = "/testGetByName")
        public Result testGetByName(String name) {
            List<Commodity> list = commodityService.getByName(name);
            return new Result(Result.STATE_SUCCESS,list);
        }
    
        @RequestMapping(value = "/testPage")
        public Result testPage() {
            Page<Commodity> page = commodityService.pageQuery(0, 10, "切片");
            System.out.println(page.getTotalPages());
            System.out.println(page.getNumber());
            System.out.println(page.getContent());
            return new Result(Result.STATE_SUCCESS,page);
        }

application.yml配置信息  cluster-name 必须和elasticsearch.yml的cluster.name 一样

spring:
      application:
        name: qxgf-elasticsearch
      data:
        elasticsearch:
          cluster-nodes: 127.0.0.1:9300
          cluster-name: qxgf-es
          repositories:
            enabled: true

测试

![1334408-20190509150523590-447276103.png][]

![1334408-20190509150609796-171682730.png][]

转载于:https://www.cnblogs.com/tangyin/p/10838463.html

[Link 1]: https://www.cnblogs.com/tangyin/p/10830142.html
[1334408-20190509150523590-447276103.png]: /images/20211104/4be18c59891547c0a56578e663bb3826.png
[1334408-20190509150609796-171682730.png]: /images/20211104/c1e41d53da6444338e619fdb48cee5df.png