Springboot和Es整合

阐明：本文章重要是简单整合和简单增删改查。

1.pom.xml

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <modelVersion>4.0.0</modelVersion>
7.     <parent>
8.         <groupId>org.springframework.boot</groupId>
9.         <artifactId>spring-boot-starter-parent</artifactId>
10.         <version>2.2.2.RELEASE</version>
11.         <relativePath/> <!-- lookup parent from repository -->
12.     </parent>
14.     <groupId>org.example</groupId>
15.     <artifactId>EsDemo</artifactId>
16.     <version>1.0-SNAPSHOT</version>
18.     <properties>
19.         <maven.compiler.source>8</maven.compiler.source>
20.         <maven.compiler.target>8</maven.compiler.target>
21.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
22.     </properties>
24.     <dependencies>
26.         <dependency>
27.             <groupId>org.springframework.boot</groupId>
28.             <artifactId>spring-boot-starter-web</artifactId>
29.         </dependency>
31.         <dependency>
32.             <groupId>org.springframework.boot</groupId>
33.             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
34.         </dependency>
36.         <dependency>
37.             <groupId>org.projectlombok</groupId>
38.             <artifactId>lombok</artifactId>
39.             <version>1.18.10</version>
40.         </dependency>
42.         <!-- swagger -->
43.         <dependency>
44.             <groupId>com.github.xiaoymin</groupId>
45.             <artifactId>knife4j-spring-boot-starter</artifactId>
46.             <version>2.0.9</version>
47.         </dependency>
49.         <dependency>
50.             <groupId>commons-lang</groupId>
51.             <artifactId>commons-lang</artifactId>
52.             <version>2.6</version>
53.         </dependency>
55.     </dependencies>
57. </project>

复制代码

2.application.yml

1. spring:
2.   elasticsearch:
3.     rest:
4.       uris: http://192.168.18.154:9200

复制代码

3.App.java

1. package org.example;
4. import org.springframework.boot.SpringApplication;
5. import org.springframework.boot.autoconfigure.SpringBootApplication;
7. @SpringBootApplication
8. public class App {
9.     public static void main(String[] args) {
10.         SpringApplication.run(App.class, args);
11.     }
12. }

复制代码

4.SwaggerConfig.java

1. package org.example.config;
3. import com.github.xiaoymin.knife4j.spring.annotations.EnableKnife4j;
4. import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
5. import org.springframework.context.annotation.Bean;
6. import org.springframework.context.annotation.Configuration;
7. import springfox.documentation.builders.ApiInfoBuilder;
8. import springfox.documentation.builders.ParameterBuilder;
9. import springfox.documentation.builders.RequestHandlerSelectors;
10. import springfox.documentation.schema.ModelRef;
11. import springfox.documentation.service.ApiInfo;
12. import springfox.documentation.service.Parameter;
13. import springfox.documentation.spi.DocumentationType;
14. import springfox.documentation.spring.web.plugins.Docket;
15. import springfox.documentation.swagger2.annotations.EnableSwagger2WebMvc;
17. import java.util.ArrayList;
18. import java.util.List;
21. /**
22. * @author 李庆伟
23. */
24. @ConditionalOnWebApplication
25. @Configuration
26. @EnableSwagger2WebMvc
27. @EnableKnife4j
28. public class SwaggerConfig {
30.     /**
31.      * Swagger2的配置文件，这里可以配置Swagger2的一些基本的内容，比如扫描的包等等
32.      * []
33.      * @return {@link Docket}
34.      * @throws
35.      * @author 李庆伟
36.      */
37.     @Bean
38.     public Docket createRestApi() {
39.         //设置请求在父类方法中,如果在本类方法中设置请求头，则覆盖父类方法
40.         List<Parameter> pars = makeHeader();
41.         return new Docket(DocumentationType.SWAGGER_2)
42.                 .select()
43.                 //多包扫描
44.                 .apis(RequestHandlerSelectors.basePackage(makeScanOne()))
45.                         //.or(RequestHandlerSelectors.basePackage(makeScanTwo()))
46.                         //.or(RequestHandlerSelectors.basePackage(makeScanThree())))
47.                 //.apis(RequestHandlerSelectors.basePackage(App8300.class.getPackage().getName()))
48.                 .build()
49.                 .globalOperationParameters(pars)
50.                 .apiInfo(apiInfo());
51.     }
53.     /**
54.      * swagger封装请求头
55.      * [pars]
56.      * @return {@link List< Parameter>}
57.      * @throws
58.      * @author 李庆伟
59.      */
60.     public List<Parameter> makeHeader(){
61.         List<Parameter> pars = new ArrayList<>();
62.         ParameterBuilder token = new ParameterBuilder();
63.         token.name("Authorization").description("Authorization")
64.                 .modelRef(new ModelRef("string"))
65.                 .parameterType("header")
66.                 .required(false).build();
67.         pars.add(token.build());
69.         ParameterBuilder languageCode = new ParameterBuilder();
70.         languageCode.name("languageCode").description("languageCode")
71.                 .modelRef(new ModelRef("string"))
72.                 .parameterType("header")
73.                 .required(false).build();
74.         pars.add(languageCode.build());
76.         return pars;
77.     }
79.     public String makeScanOne(){
80.         return "org.example.controller";
81.     }
85.     /**
86.      * 构建API文档的详细信息函数
87.      * @return
88.      */
89.     public ApiInfo apiInfo() {
90.         return new ApiInfoBuilder()
91.                 .title(makeApiName())
92.                 .version("1.0")
93.                 .build();
94.     }
96.     public String makeApiName(){
97.         return "文档服务接口-API";
98.     }
101. }

复制代码

5.EsBook.java

1. package org.example.entity;
5. import lombok.Data;
6. import org.springframework.data.annotation.Id;
7. import org.springframework.data.elasticsearch.annotations.Document;
8. import org.springframework.data.elasticsearch.annotations.Field;
9. import org.springframework.data.elasticsearch.annotations.FieldType;
12. import java.util.Date;
14. @Data
15. @Document(indexName = "es_book_index",type = "xiyouji")
16. //indexName相当于数据库   type相当于表  实体属性相当于表的字段
17. public class EsBook {
20.     @Id
21.     private String id;//章节
23.     @Field(store = true, type = FieldType.Keyword)
24.     private String title;//章节名称
26.     @Field(store = true, type = FieldType.Keyword)
27.     private String code;//章节编码
29. }

复制代码

6.IndexController.java

1. package org.example.controller;
4. import io.swagger.annotations.Api;
5. import io.swagger.annotations.ApiOperation;
6. import io.swagger.annotations.ApiParam;
7. import org.example.entity.EsBook;
8. import org.example.service.IndexService;
9. import org.springframework.beans.factory.annotation.Autowired;
10. import org.springframework.data.domain.Page;
11. import org.springframework.web.bind.annotation.PostMapping;
12. import org.springframework.web.bind.annotation.RequestMapping;
13. import org.springframework.web.bind.annotation.RequestParam;
14. import org.springframework.web.bind.annotation.RestController;
16. import java.util.List;
18. @RestController
19. @RequestMapping("/index")
20. @Api(value = "索引_相当于数据库", tags = "索引_相当于数据库")
21. public class IndexController {
24.     @Autowired
25.     private IndexService indexService;
27.     /**
28.      * 添加
29.      * @return {@link }
30.      * @throws
31.      * @author
32.      * @date
33.      */
34.     @PostMapping(value = "/add")
35.     @ApiOperation(value = "添加", notes = "添加", produces = "application/json")
36.     public String add(EsBook esBook) {
37.         indexService.add(esBook);
38.         return "ok";
39.     }
41.     /**
42.      * 修改
43.      * @return {@link }
44.      * @throws
45.      * @author
46.      * @date
47.      */
48.     @PostMapping(value = "/update")
49.     @ApiOperation(value = "修改", notes = "修改", produces = "application/json")
50.     public String update(EsBook esBook) {
51.         indexService.update(esBook);
52.         return "ok";
53.     }
55.     /**
56.      * 查询
57.      * @return {@link }
58.      * @throws
59.      * @author
60.      * @date
61.      */
62.     @PostMapping(value = "/query")
63.     @ApiOperation(value = "查询", notes = "查询", produces = "application/json")
64.     public List<EsBook> findQuery(EsBook esBook) {
65.         List<EsBook> list = indexService.findListByQuery(esBook);
66.         return list;
67.     }
69.     /**
70.      * 分页
71.      * @return {@link }
72.      * @throws
73.      * @author
74.      * @date
75.      */
76.     @PostMapping(value = "/findByPage")
77.     @ApiOperation(value = "分页查询", notes = "分页查询", produces = "application/json")
78.     public Page<EsBook> findByPage(@ApiParam(required = true, value = "pageNo") @RequestParam(value = "pageNo", required = true) Integer pageNo,
79.                                    @ApiParam(required = true, value = "pageSize") @RequestParam(value = "pageSize", required = true) Integer pageSize,
80.                                    @ApiParam(required = false, value = "title") @RequestParam(value = "title", required = false) String title) {
81.         Page<EsBook> list = indexService.findByPage(pageNo, pageSize, title);
82.         return list;
83.     }
85.     /**
86.      * 详情
87.      * @return {@link }
88.      * @throws
89.      * @author
90.      * @date
91.      */
92.     @PostMapping(value = "/show")
93.     @ApiOperation(value = "详情", notes = "详情", produces = "application/json")
94.     public EsBook show(@ApiParam(required = true, value = "章节名称") @RequestParam(value = "id", required = true) String id) {
95.         EsBook es = indexService.get(id);
96.         return es;
97.     }
99.     /**
100.      * 删除
101.      * @return {@link }
102.      * @throws
103.      * @author
104.      * @date
105.      */
106.     @PostMapping(value = "/delete")
107.     @ApiOperation(value = "删除", notes = "删除", produces = "application/json")
108.     public String delete(@ApiParam(required = true, value = "章节名称") @RequestParam(value = "id", required = true) String id) {
109.         indexService.delete(id);
110.         return "ok";
111.     }
113. }

复制代码

7.IndexService.java

1. package org.example.service;
3. import org.example.entity.EsBook;
4. import org.springframework.data.domain.Page;
6. import java.util.List;
8. public interface IndexService {
11.     void add(EsBook esBook);
13.     void delete(String id);
15.     void update(EsBook esBook);
17.     List<EsBook> findListByQuery(EsBook esBook);
19.     EsBook get(String id);
21.     Page<EsBook> findByPage(Integer pageNo, Integer pageSize, String title);
22. }

复制代码

8.IndexServiceImpl.java

1. package org.example.service.impl;
3. import org.elasticsearch.index.query.BoolQueryBuilder;
4. import org.elasticsearch.index.query.QueryBuilders;
5. import org.example.entity.EsBook;
6. import org.example.mapper.EsBookMapper;
7. import org.example.service.IndexService;
8. import org.springframework.beans.factory.annotation.Autowired;
9. import org.springframework.data.domain.Page;
10. import org.springframework.data.domain.PageRequest;
11. import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;
12. import org.springframework.data.elasticsearch.core.query.SearchQuery;
13. import org.springframework.stereotype.Service;
15. import java.util.ArrayList;
16. import java.util.Date;
17. import java.util.List;
18. import java.util.UUID;
21. @Service
22. public class IndexServiceImpl implements IndexService {
25.     @Autowired
26.     private EsBookMapper esBookMapper;
28.     @Override
29.     public void add(EsBook esBook) {
30.         esBook.setId(UUID.randomUUID().toString().replace("-", ""));
31.         esBookMapper.save(esBook);
32.     }
34.     @Override
35.     public void update(EsBook esBook) {
36.         esBookMapper.save(esBook);
37.     }
39.     @Override
40.     public List<EsBook> findListByQuery(EsBook esBook) {
41.         List<EsBook> list = new ArrayList<>();
43.         BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
44.         queryBuilder.must(QueryBuilders.termQuery("title", esBook.getTitle()));
46.         Iterable<EsBook> it = esBookMapper.search(queryBuilder);
47.         it.forEach(e->list.add(e));
48.         return list;
49.     }
51.     @Override
52.     public EsBook get(String id) {
53.         try {
54.             return esBookMapper.findById(id).get();
55.         } catch (Exception e) {
56.             e.printStackTrace();
57.         }
58.         return null;
59.     }
61.     @Override
62.     public Page<EsBook> findByPage(Integer pageNo, Integer pageSize, String title) {
63.         SearchQuery searchQuery = new NativeSearchQueryBuilder()
64.                // .withQuery(QueryBuilders.matchPhraseQuery("name", kw))
65.                 .withPageable(PageRequest.of(pageNo, pageSize))
66.                 .build();
67.         return esBookMapper.search(searchQuery);
68.     }
70.     @Override
71.     public void delete(String id) {
72.         EsBook esBook = new EsBook();
73.         esBook.setId(id);
74.         esBookMapper.delete(esBook);
75.     }
78. }

复制代码

9.EsBookMapper.java

1. package org.example.mapper;
3. import org.example.entity.EsBook;
4. import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
6. public interface EsBookMapper extends ElasticsearchRepository<EsBook,String> {
10. }

复制代码

总结一下，纪录一点点。。。。。。。。。。。。。。







免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。