Elasticsearch系列(二)SpringBoot集成Spring-Data-Elasticsearch

落日映苍穹つ 2022-04-14 04:29 230阅读 0赞

**一、添加依赖**

SpringBoot版本需2.0x以上：

<parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.5.RELEASE</version>
            <relativePath/> 
        </parent>
    		
    	<dependency>
    	    <groupId>org.springframework.boot</groupId>
    	    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    	</dependency>

二、Document对象

@Data
    @Document(indexName = "rate_routing",type = "rate_routing")
    public class RateRoutingDoc {
    
        private Long rateId;
    
        private Long itemId;
    
        private Long accountId;
    
        private String text;
    
        private Long createTime;
    }

三、操作

@Autowired
        private ElasticsearchTemplate elasticsearchTemplate;
    
        @Test
        public void add(){
    
            RateRoutingDoc rateRoutingDoc = new RateRoutingDoc();
            rateRoutingDoc.setRateId(100L);
            rateRoutingDoc.setAccountId(101L);
            rateRoutingDoc.setItemId(10002L);
            rateRoutingDoc.setCreateTime(System.currentTimeMillis());
            rateRoutingDoc.setText("评论");
    
            HashMap<String, Object> map = new HashMap<>();
            map.put("rateId",rateRoutingDoc.getRateId());
            map.put("accountId",rateRoutingDoc.getAccountId());
            map.put("itemId",rateRoutingDoc.getItemId());
            map.put("createTime",rateRoutingDoc.getCreateTime());
            map.put("text",rateRoutingDoc.getText());
    
            IndexRequest indexRequest = new IndexRequest()
                    .index("rate_routing")
                    .type("rate_routing")
                    .routing(String.valueOf(rateRoutingDoc.getItemId()))
                    .source(map);
    
            elasticsearchTemplate.getClient().index(indexRequest);
        }
    
        @Test
        public void getByRoute(){
    
            NativeSearchQuery searchQuery = new NativeSearchQueryBuilder().withRoute("10002").build();
    
            List<RateRoutingDoc> routingDocs = elasticsearchTemplate.queryForList(searchQuery, RateRoutingDoc.class);
    
            routingDocs.forEach(routingDoc ->
                    System.out.println(routingDoc.toString())
            );
    
        }

更多查看官方文档：

[Spring Data Elasticsearch][]

[spring-projects/spring-data-elasticsearch][spring-projects_spring-data-elasticsearch]

参考：[ElasticSearch基础操作及ElasticsearchTemplate API][ElasticSearch_ElasticsearchTemplate API]

[Spring Data Elasticsearch]: https://docs.spring.io/spring-data/elasticsearch/docs/current/reference/html/
[spring-projects_spring-data-elasticsearch]: https://github.com/spring-projects/spring-data-elasticsearch
[ElasticSearch_ElasticsearchTemplate API]: https://blog.csdn.net/mj86534210/article/details/79910909