Elasticsearch 类比 mysql 实现 in and like or(Spring-Data-Elasticsearch)

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
Elasticsearch Serverless通用抵扣包,测试体验金 200元
简介: Elasticsearch 类比 mysql 实现 in and like or(Spring-Data-Elasticsearch)

一、前提

1.springboot 版本为2.2.2.RELEASE

2.spring-boot-starter-data-elasticsearch 版本 跟随springboot版本

3.elasticsearch 版本为6.4.2


需要说明的一点 :拿mysql 类比elasticsearch 类比有点不妥,但是鉴于大部分人都是从传统关系型数据如 mysql ,慢慢才接触到elasticsearch 所以拿两者进行对比,比较好理解和快速上手!


本项目的完整源码地址:
https://github.com/Dr-Water/springdata-es-action


二 、数据准备

  1. 首先准备安装好 es 和 准备实验数据 ,可以参考如下链接
    springboot集成spring-data-elasticsearch 完成对es的操作
    ElasticSearch实战 之 es的安装和使用


实验数据如下:

二、实验

在kibana中修改几条es中的数据


PUT /myes/myuser/1001
{
    "id": 1001,
    "firstName": "张",
    "lastName": "三峰",
    "age": 1001,
    "about": "中华人民共和国"
  }
PUT /myes/myuser/1002
{
    "id": 1002,
    "firstName": "张",
    "lastName": "无极",
    "age": 1002,
    "about": "中华人民共和国公民"
  }
PUT /myes/myuser/1003
{
    "id": 1003,
    "firstName": "王",
    "lastName": "科",
    "age": 1003,
    "about": "中华人民共和国"
  }


修改完记得刷新一下es ,有时候es 不会立即生效


2.1 and

select * from user where about='中华人民共和国' and firstName=‘张’


@GetMapping("/and")
    public Page<User> query( Integer pageNum, Integer pageSize) {
        if(pageNum == null || pageNum <= 0){
            pageNum = 1;
        }
        if(pageSize == null || pageSize <= 0){
            pageSize = 5;
        }
        SearchQuery searchQuery = new NativeSearchQueryBuilder()
                    .withQuery(QueryBuilders.boolQuery()
                                        .must(QueryBuilders.termQuery("about","中华人民共和国"))
                                        .must(QueryBuilders.termQuery("firstName","张")))
                    .withPageable(PageRequest.of(pageNum - 1, pageSize))
                    .build();
        System.out.println(searchQuery.getQuery());
        Page<User> page = estemplate.queryForPage(searchQuery, User.class);
        return  page;
    }

2.2 or

select * from user where about='中华人民共和国' and firstName=‘王’


@GetMapping("/or")
    public Page<User> query2( Integer pageNum, Integer pageSize) {
        if(pageNum == null || pageNum <= 0){
            pageNum = 1;
        }
        if(pageSize == null || pageSize <= 0){
            pageSize = 5;
        }
        SearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withQuery(QueryBuilders.boolQuery()
                        .should(QueryBuilders.termQuery("about","中华人民共和国"))
                        .should(QueryBuilders.termQuery("firstName","王")))
                .withPageable(PageRequest.of(pageNum - 1, pageSize))
                .build();
        System.out.println(searchQuery.getQuery());
        Page<User> page = estemplate.queryForPage(searchQuery, User.class);
        return  page;
    }

2.3 and or 连用

select * from user where  firstName='张' and( firstName='王’ or about='中华人民共和国公民')


@GetMapping("/andOr")
    public Page<User> query3( Integer pageNum, Integer pageSize) {
        if(pageNum == null || pageNum <= 0){
            pageNum = 1;
        }
        if(pageSize == null || pageSize <= 0){
            pageSize = 5;
        }
        SearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withQuery(QueryBuilders.boolQuery()
                                .must(QueryBuilders.termQuery("firstName","张"))
                                .must(QueryBuilders.boolQuery()
                                        .should(QueryBuilders.termQuery("firstName","王"))
                                        .should(QueryBuilders.termQuery("about","中华人民共和国公民")))
                )
                .withPageable(PageRequest.of(pageNum - 1, pageSize))
                .build();
        System.out.println(searchQuery.getQuery());
        Page<User> page = estemplate.queryForPage(searchQuery, User.class);
        return  page;
    }

2.4 like

select * from user where about like '%中华%'


@GetMapping("/like")
    public Page<User> query4( Integer pageNum, Integer pageSize) {
        if(pageNum == null || pageNum <= 0){
            pageNum = 1;
        }
        if(pageSize == null || pageSize <= 0){
            pageSize = 5;
        }
        SearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withQuery(QueryBuilders.wildcardQuery("about","*中华*"))
                .withPageable(PageRequest.of(pageNum - 1, pageSize))
                .build();
        System.out.println(searchQuery.getQuery());
        Page<User> page = estemplate.queryForPage(searchQuery, User.class);
        return  page;
    }

2.5 in

select * from user where about in ('中华人民共和国','中华人民共和国公民')


@GetMapping("/in")
    public Page<User> query5( Integer pageNum, Integer pageSize) {
        if(pageNum == null || pageNum <= 0){
            pageNum = 1;
        }
        if(pageSize == null || pageSize <= 0){
            pageSize = 5;
        }
        SearchQuery searchQuery = new NativeSearchQueryBuilder()
                .withQuery(QueryBuilders.boolQuery()
                        .should(QueryBuilders.termQuery("about","中华人民共和国"))
                        .should(QueryBuilders.termQuery("about","中华人民共和国公民")))
                .withPageable(PageRequest.of(pageNum - 1, pageSize))
                .build();
        System.out.println(searchQuery.getQuery());
        Page<User> page = estemplate.queryForPage(searchQuery, User.class);
        return  page;
    }


相关实践学习
以电商场景为例搭建AI语义搜索应用
本实验旨在通过阿里云Elasticsearch结合阿里云搜索开发工作台AI模型服务,构建一个高效、精准的语义搜索系统,模拟电商场景,深入理解AI搜索技术原理并掌握其实现过程。
ElasticSearch 最新快速入门教程
本课程由千锋教育提供。全文搜索的需求非常大。而开源的解决办法Elasricsearch(Elastic)就是一个非常好的工具。目前是全文搜索引擎的首选。本系列教程由浅入深讲解了在CentOS7系统下如何搭建ElasticSearch,如何使用Kibana实现各种方式的搜索并详细分析了搜索的原理,最后讲解了在Java应用中如何集成ElasticSearch并实现搜索。 &nbsp;
目录
相关文章
|
5月前
|
监控 Java 关系型数据库
Spring Boot整合MySQL主从集群同步延迟解决方案
本文针对电商系统在Spring Boot+MyBatis架构下的典型问题(如大促时订单状态延迟、库存超卖误判及用户信息更新延迟)提出解决方案。核心内容包括动态数据源路由(强制读主库)、大事务拆分优化以及延迟感知补偿机制,配合MySQL参数调优和监控集成,有效将主从延迟控制在1秒内。实际测试表明,在10万QPS场景下,订单查询延迟显著降低,超卖误判率下降98%。
168 5
|
关系型数据库 MySQL 数据库
在 MySQL 中使用 LIKE
【8月更文挑战第12天】
1392 1
|
9月前
|
Java 关系型数据库 MySQL
如何将Spring Boot + MySQL应用程序部署到Pivotal Cloud Foundry (PCF)
如何将Spring Boot + MySQL应用程序部署到Pivotal Cloud Foundry (PCF)
150 5
|
10月前
|
搜索推荐 关系型数据库 MySQL
mysql like查询优化
通过合理的索引设计、使用全文索引、优化查询结构以及考虑分片和分区表,可以显著提高MySQL中 `LIKE`查询的性能。针对不同的应用场景选择合适的优化策略,能够有效地提升数据库查询效率,减少查询时间。希望这些方法和技巧能帮助您优化MySQL数据库中的模糊查询。
1063 4
|
12月前
|
NoSQL 关系型数据库 Redis
mall在linux环境下的部署(基于Docker容器),Docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongo
mall在linux环境下的部署(基于Docker容器),docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongodb、minio详细教程,拉取镜像、运行容器
mall在linux环境下的部署(基于Docker容器),Docker安装mysql、redis、nginx、rabbitmq、elasticsearch、logstash、kibana、mongo
|
11月前
|
关系型数据库 MySQL API
MySQL 历史数据迁移到 Elasticsearch
MySQL 历史数据迁移到 Elasticsearch
381 4
|
12月前
|
搜索推荐 关系型数据库 MySQL
MySQL 模糊查询新纪元:超越 LIKE+% 的高效探索
在数据库的日常操作中,模糊查询是一项不可或缺的功能,它允许我们根据不完全匹配的关键字来检索数据。传统上,MySQL 使用 LIKE 关键字配合 % 通配符来实现这一功能,虽然灵活但性能上往往不尽如人意,尤其是在处理大型数据集时。今天,我们将一起探索几种超越 LIKE+% 的模糊查询技术,以提升查询效率与用户体验。
644 2
|
11月前
|
消息中间件 监控 关系型数据库
MySQL数据实时同步到Elasticsearch:技术深度解析与实践分享
在当今的数据驱动时代,实时数据同步成为许多应用系统的核心需求之一。MySQL作为关系型数据库的代表,以其强大的事务处理能力和数据完整性保障,广泛应用于各种业务场景中。然而,随着数据量的增长和查询复杂度的提升,单一依赖MySQL进行高效的数据检索和分析变得日益困难。这时,Elasticsearch(简称ES)以其卓越的搜索性能、灵活的数据模式以及强大的可扩展性,成为处理复杂查询需求的理想选择。本文将深入探讨MySQL数据实时同步到Elasticsearch的技术实现与最佳实践。
525 0
|
Java 关系型数据库 数据库连接
|
存储 关系型数据库 MySQL
【Elasticsearch】在es中实现mysql中的FIND_IN_SET查询条件
【Elasticsearch】在es中实现mysql中的FIND_IN_SET查询条件
255 0

推荐镜像

更多