Spring Boot elasticsearch7.6.2基础操作：创建索引、新增数据、查询数据

在本文中，我们将深入探讨如何使用Spring Boot与Elasticsearch 7.6.2进行基本操作，包括创建索引、添加数据以及查询数据。Elasticsearch是一个强大的分布式搜索引擎，而Spring Boot是Java开发中的轻量级框架，两者结合使得开发过程中对Elasticsearch的集成变得简单高效。 我们需要在Spring Boot项目中引入Elasticsearch的相关依赖。在`pom.xml`文件中，你需要添加如下依赖： ```xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency> ``` 接下来，我们需要配置Elasticsearch连接。在`application.properties`或`application.yml`中，添加以下配置： ``` spring.data.elasticsearch.cluster-name=your_cluster_name spring.data.elasticsearch.cluster-nodes=your_elasticsearch_node:9300 ``` 这里的`your_cluster_name`和`your_elasticsearch_node`应替换为实际的Elasticsearch集群名称和节点地址。 现在，我们创建一个实体类，比如`User`，用于映射Elasticsearch中的文档： ```java import org.springframework.data.annotation.Id; import org.springframework.data.elasticsearch.annotations.Document; @Document(indexName = "users") public class User { @Id private String id; private String name; private String email; // getters and setters } ``` 接着，创建一个ElasticsearchRepository接口来操作数据： ```java import org.springframework.data.elasticsearch.repository.ElasticsearchRepository; public interface UserRepository extends ElasticsearchRepository<User, String> { } ``` 有了这些基础，我们可以进行创建索引、新增数据和查询数据的操作。 **创建索引：** 当首次向Elasticsearch中添加`User`对象时，Spring Data Elasticsearch会自动创建名为`users`的索引。如果你需要手动创建，可以使用`ElasticsearchOperations`的`createIndex`方法。 **新增数据：** ```java @Autowired private UserRepository userRepository; public void saveUser(User user) { userRepository.save(user); } ``` **查询数据：** Spring Data Elasticsearch提供了多种查询方式。例如，按ID查询： ```java public User getUserById(String id) { return userRepository.findById(id).orElse(null); } ``` 范围查询： ```java public List<User> findUsersByAgeBetween(int minAge, int maxAge) { return userRepository.findAll(byAgeBetween(minAge, maxAge)); } private QueryBuilder byAgeBetween(int minAge, int maxAge) { return QueryBuilders.rangeQuery("age").gte(minAge).lte(maxAge); } ``` 全文搜索： ```java public List<User> searchUsers(String keyword) { NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder() .withQuery(QueryBuilders.matchQuery("name", keyword)) .withPageable(PageRequest.of(0, 10)); SearchResponse response = elasticsearchTemplate.query(queryBuilder.build(), new SearchResultMapper() { @Override public <T> T map(SearchHit<T> searchHit) { return searchHit.getContent(); } }); return response.getHits().getContent(); } ``` 以上就是使用Spring Boot和Elasticsearch 7.6.2进行基础操作的基本流程。通过这种方式，你可以轻松地在应用中集成Elasticsearch，实现高效的搜索功能。记住，Elasticsearch的强大还在于它的聚合分析、地理位置搜索等高级特性，这些都是进一步提升应用性能的关键。