Springboot 整合ElasticSearch 常用的插入查询,模糊查询,范围查询
warning:
这篇文章距离上次修改已过192天,其中的内容可能已经有所变动。
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
可以进行更复杂的查询操作。
评论已关闭