Spring操作Elasticsearch查询详解与示例

144 浏览量更新于2024-09-02 收藏 53KB PDF 举报

身份认证购VIP最低享 7 折!

30元优惠券

在本文中，我们将深入探讨如何在Spring框架中有效地操作Elasticsearch进行查询。Spring操作Elasticsearch是一个强大的组合，它允许开发人员利用Spring的便利性来集成高性能的全文搜索引擎。首先，我们来了解一下基本的概念和依赖。 1. Spring集成Elasticsearch: Spring提供了Spring Data Elasticsearch模块，这使得与Elasticsearch的交互变得更加简单。通过Spring Boot，我们可以快速地在项目中配置Elasticsearch客户端，并利用其数据访问和事务管理能力。 2. 设置环境: 在开始之前，确保在项目中正确引入Elasticsearch客户端依赖，如`org.springframework.data.elasticsearch`库。同时，你需要一个运行中的Elasticsearch集群，可以通过Spring Data Elasticsearch的`@Configuration`类配置连接信息。 3. 基础查询操作: 通过`Client`对象执行查询，例如使用`SearchResponse`类来获取搜索结果。`BoolQueryBuilder`是构建复杂查询的基础，允许我们组合多个条件。例如： ```java BoolQueryBuilder boolQuery = QueryBuilders.boolQuery() .must(QueryBuilders.matchQuery("field", "value")) .filter(QueryBuilders.termQuery("anotherField", "anotherValue")); ``` 4. 搜索请求和响应处理: 使用`ActionFuture<SearchResponse>`发起搜索请求，当请求完成时，可以获取到`SearchResponse`对象，从中解析搜索结果和相关元数据。 5. 高亮和排序: `HighlightBuilder`用于提取文档中的高亮部分，帮助我们展示搜索结果的关键信息。例如： ```java HighlightBuilder highlightBuilder = new HighlightBuilder() .field(new Field("fieldToHighlight")); SearchResponse searchResponse = client.prepareSearch("index") .setQuery(boolQuery) .setHighlight(highlightBuilder) .execute().actionGet(); ``` 6. 健康检查: 在进行大规模操作前，可以使用`ClusterHealthRequest`检查集群的健康状况，例如检查`ClusterHealthStatus`： ```java ClusterHealthRequest clusterHealthRequest = new ClusterHealthRequest(); ClusterHealthResponse clusterHealthResponse = client.admin().cluster().health(clusterHealthRequest).actionGet(); ``` 7. 异常处理和最佳实践: 优雅地处理可能出现的异常，如网络错误、索引不存在等，并遵循Elasticsearch的最佳实践，比如定期刷新索引以提高检索性能。这篇文章详细展示了如何在Spring环境中利用Elasticsearch的强大功能进行查询，包括构建复杂的搜索查询、处理搜索结果以及对Elasticsearch集群的监控。通过这些操作，开发者能够轻松地将Elasticsearch融入到Spring应用中，提升应用程序的数据处理能力。

资源详情

资源推荐

spring 操作操作elasticsearch查询使用方法查询使用方法

本篇文章主要介绍了spring 操作elasticsearch使用方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一

起跟随小编过来看看吧

最近学习了一下elasticsearch使用，网上的资料又很少，真是一个头两个大。好歹最后终于了解了。留个笔记做日后查询。

package com.gooddeep.dev.elasticsearch.commons.dao;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import org.elasticsearch.action.ActionFuture;

import org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest;

import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;

import org.elasticsearch.action.search.SearchResponse;

import org.elasticsearch.client.Client;

import org.elasticsearch.cluster.health.ClusterHealthStatus;

import org.elasticsearch.common.text.Text;

import org.elasticsearch.index.query.BoolQueryBuilder;

import org.elasticsearch.index.query.QueryBuilders;

import org.elasticsearch.search.SearchHit;

import org.elasticsearch.search.highlight.HighlightBuilder;

import org.elasticsearch.search.highlight.HighlightBuilder.Field;

import org.elasticsearch.search.sort.FieldSortBuilder;

import org.elasticsearch.search.sort.SortOrder;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.domain.Page;

import org.springframework.data.domain.PageImpl;

import org.springframework.data.domain.PageRequest;

import org.springframework.data.domain.Pageable;

import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;

import org.springframework.data.elasticsearch.core.SearchResultMapper;

import org.springframework.data.elasticsearch.core.query.Criteria;

import org.springframework.data.elasticsearch.core.query.CriteriaQuery;

import org.springframework.data.elasticsearch.core.query.DeleteQuery;

import org.springframework.data.elasticsearch.core.query.IndexQuery;

import org.springframework.data.elasticsearch.core.query.IndexQueryBuilder;

import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder;

import org.springframework.data.elasticsearch.core.query.SearchQuery;

import org.springframework.data.elasticsearch.core.query.StringQuery;

import org.springframework.stereotype.Component;

import com.gooddeep.dev.core.helper.PropertyHelper;

import com.gooddeep.dev.core.helper.UuidHelper;

import com.gooddeep.dev.core.model.BasePage;

import com.gooddeep.dev.elasticsearch.commons.model.EsBaseBean;

import com.gooddeep.dev.elasticsearch.commons.service.EsBaseService;

@Component("esBaseDao")

public abstract class EsBaseDaoImpl<T> implements EsBaseDao<T> {

private Logger logger = LoggerFactory.getLogger(EsBaseService.class);

@Autowired

private ElasticsearchTemplate elasticsearchTemplate;

@Autowired

private Client esClient;

/**

* 插入或等新，需要有id，id需要自己生成

* @param tList

* @return

public boolean insertOrUpdate(List<T> tList) {

List<IndexQuery> queries = new ArrayList<IndexQuery>();

for (T t : tList) {

String id = ((EsBaseBean) t).getId();

if (id == null) {

id = UuidHelper.getRandomUUID();

((EsBaseBean) t).setId(id);

}

IndexQuery indexQuery = new IndexQueryBuilder().withId(id).withObject(t).build();

queries.add(indexQuery);

}

elasticsearchTemplate.bulkIndex(queries);

return true;

}

下载后可阅读完整内容，剩余4页未读，立即下载

weixin_38631960

粉丝: 5
资源: 920

Spring操作Elasticsearch查询详解与示例

elasticsearch+SpringMVC工具.7z

springboot集合elasticsearch demo(内含增删改查)

Spring+springMvc+redis+elasticsearch之附件

elasticsearch查询方法

Spring Boot Elasticsearch

你的项目中没有使用Spring Data Elasticsearch来操作Elasticsearch，而是直接使用了Elasticsearch的原生API进行操作

Spring Data Elasticsearch 使用教程

Spring Data Elasticsearch

spring data elasticsearch

springdata elasticsearch 的详细使用方式

Spring Data Elasticsearch 模糊查询

Spring Data Elasticsearch4.1.0使用教程

springcloud集成elasticsearch

spring data elasticsearch date

spring data elasticsearch 与elasticsearch的对应关系

Spring Data Elasticsearch4.1.0 复杂文档使用教程

springboot操作elasticsearch

spring boot整合Elasticsearch

不用Spring Data Elasticsearch 呢

spring.elasticsearch支持集群吗

最新资源