springboot整合elasticsearch实现类似于mysql的like查询

本文介绍了如何在SpringBoot应用中整合Elasticsearch,利用from + size方法实现类似MySQL的LIKE模糊查询。讨论了ES分页的三种常见方式,并强调了from+size在大数据量时的性能问题及解决方案,包括调整index.max_result_window参数和使用search_after字段进行分页。

摘要生成于 C知道 ,由 DeepSeek-R1 满血版支持, 前往体验 >

目录

一、ES分页查询常用方式

二、引入es的依赖

三、es配置文件

四、es工具类

五、分页查询示例


一、ES分页查询常用方式

1.from + size

from表示从第几行开始,size表示查询多少条文档。from默认为0,size默认为10,最灵活的分页方式。

2.scroll

不适合用来做实时搜索,而更适用于后台批处理任务,如日志导出。暂存搜索结果,每次传入scroll_id。scroll_id会占用大量资源,用于非实时处理大量数据的情况。可以通过scroll 初始化查询后,指定scroll_id 结合from+size的方式来实现分页。

3. search_after

根据上一页的最后一条数据来确定下一页的位置。需要使用一个唯一值的字段作为排序字段。不能自由跳到一个随机页面。要想实现翻页,需要每次记录最后查询的sort。实现方式比较麻烦,需要去记录上一次查询的排序字段的值用于下一页分页查询。

此处采用第一种from + size方式来实现类似于mysql的like模糊查询。

二、引入es的依赖

  <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-elasticsearch -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        </dependency>

        <!-- elasticsearch-rest-high-level-client -->
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
        </dependency>

三、es配置文件

package com.crcm.elasticsearch.config;

import org.apache.http.HttpHost;
import org.apache.http.client.config.RequestConfig;
import org.elasticsearch.client.Node;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.Arrays;
import java.util.Objects;

/**
 *Elasticsearch配置类
 */
@Configuration
public class ElasticsearchConfig {
 
    private static final int ADDRESS_LENGTH = 2;
    @Value("${spring.elasticsearch.rest.uris}")
    private String ipAddress;
 
    @Bean
    public RestClientBuilder restClientBuilder() {

        HttpHost[] hosts = Arrays.stream(ipAddress.split(","))
                .map(this::makeHttpHost)
                .filter(Objects::nonNull)
                .toArray(HttpHost[]::new);
        RestClientBuilder restClientBuilder = R
评论
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值