Spring Boot整合Elasticsearch进行插入、查询（精确查询、模糊查询、范围查询）可以使用Spring Data Elasticsearch。
- 添加依赖到
pom.xml：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<!-- 其他依赖 -->
</dependencies>
- 配置
application.properties或application.yml：
spring.data.elasticsearch.cluster-name=elasticsearch
spring.data.elasticsearch.cluster-nodes=localhost:9300
- 创建实体类：
@Document(indexName = "your_index_name", type = "your_type")
public class YourEntity {
@Id
private String id;
// 其他属性
}
- 创建Repository接口：
public interface YourEntityRepository extends ElasticsearchRepository<YourEntity, String> {
// 可以使用Spring Data Elasticsearch提供的方法，也可以自定义查询
}
- 插入数据：
@Autowired
YourEntityRepository repository;
public void index(YourEntity entity) {
repository.save(entity);
}
- 精确查询：
public YourEntity findById(String id) {
return repository.findById(id).orElse(null);
}
- 模糊查询：
public List<YourEntity> searchByName(String name) {
// 使用QueryBuilders构建查询条件
QueryBuilder queryBuilder = QueryBuilders.matchQuery("name", name);
Iterable<YourEntity> searchResult = elasticsearchTemplate.search(
new Query(queryBuilder), YourEntity.class
);
// 转换为List
return StreamSupport.stream(searchResult.spliterator(), false)
.collect(Collectors.toList());
}
- 范围查询：
public List<YourEntity> findByRange(int lowerBound, int upperBound) {
Criteria criteria = new Criteria("age").gte(lowerBound).lte(upperBound);
Query query = new Query(new Criteria(criteria));
return elasticsearchTemplate.find(query, YourEntity.class);
}
注意：
- 确保Elasticsearch服务器正在运行并可访问。
- 实际使用时，根据实体类属性和查询需求调整查询方法。
- 范围查询可以使用Elasticsearch的
gte（大于等于）和lte（小于等于）方法。 - 模糊查询可以使用
matchQuery进行精确匹配查询或者matchPhraseQuery进行短语匹配查询。 - 使用
elasticsearchTemplate可以进行更复杂的查询操作。