spring boot整合elasticsearch实现查询功能

第一步、添加依赖（注意版本对应关系）根据spring boot版本选择合适的版本

        <dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.6.2</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-elasticsearch</artifactId><version>2.3.12.RELEASE</version></dependency>

第二步、添加配置

spring:elasticsearch:rest:uris: localhost:9200connection-timeout: 1000request-timeout: 1000read-timeout: 1000username: elasticpassword: elastic

 第三步、编码

/*** 商城商品* @Author: 陈礼林* @CreateTime: 2023-04-20  09:28*/
@Document(indexName = "mall_commodity")
@Data
public class MallCommodityDtoRsp {/*** 主键*/@Id@Field(store = true, index = false, type = org.springframework.data.elasticsearch.annotations.FieldType.Text)private String id;/*** 商品名称*/private String name;/*** 分类名称*/private String classifyName;/*** 分类名称*/private String attributeName;/*** 商品缩略图*/private String picture;/*** 商品规格类型 1单规格 2多规格 3套餐*/private Integer specType;/*** 商品编号*/private String commodityNo;/*** 生产批号*/private String batchNo;/*** 商品类型(1普通，2赠送)*/private Integer commodityType;/*** 销售价格(单位分)*/private Integer minPrice;/*** 销售价格(单位分)*/private Integer maxPrice;/*** 单位*/private String unit;/*** 排序*/private Integer sort;/*** 商品数量*/private Integer commodityCount;/*** 商品状态 1上架 2下架*/private Integer status;@Field(store = true, index = false, type = FieldType.Object)private List<MallCommodityDetailed> detailedList;}

 同步mysql数据到elasticsearch服务器

/*** @Description: 同步mysql数据到es定时任务* @Author: 陈礼林* @CreateTime: 2024-03-16  10:56*/
@Slf4j
@Component
public class CommoditySyncEsTask {@Resourceprivate MallCommodityService service;@Resourceprivate ElasticsearchRestTemplate elasticsearchRestTemplate;@XxlJob("commoditySyncEsHandler")public void commoditySyncEs(){log.info("开始执行：商品同步定时任务");MallCommodityDtoPageReq req = new MallCommodityDtoPageReq();List<MallCommodityDtoRsp> records = service.page(req).getRecords();if (ListUtil.isNotNull(records)) {elasticsearchRestTemplate.save(records);}log.info("执行结束：商品同步定时任务");}
}
/*** 商城-商品表控制器** @author 陈礼林* @date 2022-04-12 14:39:41*/
@RestController
@RequestMapping("/mmServer/mall/commodity")
public class MallCommodityController {@Resourceprivate ElasticsearchRestTemplate elasticsearchRestTemplate;/*** 分页** @param req 分页参数* @return 查询结果*/@PostMapping("/page")public R page(@RequestBody MallCommodityDtoPageReq req){//查询条件
//        查询全部数据
//        QueryBuilder queryBuilder = QueryBuilders.matchAllQuery();//        精确查询 =
//        QueryBuilder queryBuilder = QueryBuilders.termQuery("name", "lisi");//        精确查询 多个 in
//        QueryBuilder queryBuilder = QueryBuilders.termsQuery("name", "张三", "lisi");//        match匹配，会把查询条件进行分词，然后进行查询，多个词条之间是 or 的关系,可以指定分词
//        QueryBuilder queryBuilder = QueryBuilders.matchQuery("name", "张三");
//        QueryBuilder queryBuilder = QueryBuilders.matchQuery("name", "张三").analyzer("ik_max_word");//        match匹配 查询多个字段
//        QueryBuilder queryBuilder = QueryBuilders.multiMatchQuery("男", "name", "sex");//        fuzzy 模糊查询，返回包含与搜索字词相似的字词的文档。
//        QueryBuilder  queryBuilder = QueryBuilders.fuzzyQuery("name","lisx");//        prefix 前缀检索
//        QueryBuilder  queryBuilder = QueryBuilders.prefixQuery("name","张");//        wildcard 通配符检索
//        QueryBuilder  queryBuilder = QueryBuilders.wildcardQuery("name","张*");//        regexp 正则查询
//        QueryBuilder queryBuilder = QueryBuilders.regexpQuery("name", "(张三)|(lisi)");//        boost 评分权重,令满足某个条件的文档的得分更高，从而使得其排名更靠前。
//        queryBuilder.boost(2);
//        多条件构建BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
//        并且 and
//        queryBuilder.must(QueryBuilders.termQuery("name", "张三"));if (req.getSpecType() != null) {queryBuilder.must(QueryBuilders.termQuery("specType", req.getSpecType()));}if (req.getName() != null) {queryBuilder.should(QueryBuilders.fuzzyQuery("name", req.getName()));}//        或者 or
//        queryBuilder.should(QueryBuilders.fuzzyQuery("name", "测试"));
//        queryBuilder.should(QueryBuilders.termQuery("name", "lisi"));//        不等于,去除
//        queryBuilder.mustNot(QueryBuilders.termQuery("name", "lisi"));//        过滤数据
//        queryBuilder.filter(QueryBuilders.matchQuery("name", "张三"));//        范围查询/*gt 大于 >gte 大于等于 >=lt 小于 <lte 小于等于 <=*/
//        queryBuilder.filter(new RangeQueryBuilder("age").gt(10).lte(50));//        构建分页，page 从0开始Pageable pageable = PageRequest.of(req.getPageNumber(), req.getPageSize());Query query = new NativeSearchQueryBuilder().withQuery(queryBuilder).withPageable(pageable)//排序
//                .withSort(SortBuilders.fieldSort("_score").order(SortOrder.DESC))//投影
//                .withFields("name").build();SearchHits<MallCommodityDtoRsp> search = elasticsearchRestTemplate.search(query, MallCommodityDtoRsp.class);return R.ok(search.getSearchHits());
//        return R.ok(service.page(req));}/*** 通过id集合查询列表** @param id id* @return 查询结果*/@PostMapping("/get")public R<MallCommodityDtoRsp> get(@Param("id") Long id){MallCommodityDtoRsp search = elasticsearchRestTemplate.get(id.toString(),MallCommodityDtoRsp.class);return R.ok(search);}}

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/759377.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

华为综合案例-普通WLAN全覆盖配置（2）

华为综合案例-普通WLAN全覆盖配置（2）

组网图 结果验证 在AC_1和AC_2上执行display ap all命令&#xff0c;检查当前AP的状态&#xff0c;显示以下信息表示AP上线成功。[AC_1] display ap all Total AP information: nor : normal [1] ExtraInfo : Extra information P : insufficient power supply ---…
阅读更多...
wireshark抓tcp包使用指南

wireshark抓tcp包使用指南

本博文源于笔者不断探索加上去网络总结获得的经验&#xff0c;撰写wireshark如何抓tcp包 文章目录 1、打开wireshark2、选择网络源3、搜索ip地址与tcp条件4、看灰色的条纹 1、打开wireshark 2、选择网络源 选择自己当前的ip地址适用于的网络源&#xff0c;比如这里选择“以太…
阅读更多...
ideaSSM 高校公寓交流员管理系统bootstrap开发mysql数据库web结构java编程计算机网页源码maven项目

ideaSSM 高校公寓交流员管理系统bootstrap开发mysql数据库web结构java编程计算机网页源码maven项目

一、源码特点 idea 开发 SSM 高校公寓交流管理系统是一套完善的信息管理系统&#xff0c;结合SSM框架和bootstrap完成本系统&#xff0c;对理解JSP java编程开发语言有帮助系统采用SSM框架&#xff08;MVC模式开发&#xff09;&#xff0c;系统具有完整的源代码和数据库&…
阅读更多...
get_local_ip.bat：快速获取IPv4地址

get_local_ip.bat：快速获取IPv4地址

批处理脚本&#xff0c;用于在Windows命令提示符下获取本地计算机的IPv4地址。 echo off ipconfig | findstr IPv4 pause - echo off&#xff1a;这会关闭命令提示符窗口中的命令回显&#xff0c;使得在运行脚本时不会显示每条命令的执行结果。 - ipconfig&#xff1a;这是一…
阅读更多...
ELK快速搭建图文详细步骤

ELK快速搭建图文详细步骤

目录 一、下载地址二、安装docker-compose(已安装则跳过)三、初始化ELK1. 赋予/setup/entrypoint.sh执行权限2. 初始化 docker-elk 所需的 Elasticsearch 用户和组3. 重置默认用户的密码4. 替换配置文件中的用户名和密码5. 重启 Logstash 和 Kibana&#xff0c;使用新密码重新连…
阅读更多...
蓝桥杯算法基础（26）子数组最大累加和，子矩阵最大累加和

蓝桥杯算法基础（26）子数组最大累加和，子矩阵最大累加和

子数组最大累加和 给定一个数组arr,返回子数组的最大累加和 例:arr[1,-2,3,5,-2,6,-1];所有的子数组中[3,5,-2,6]可以累加出最大的和12&#xff0c;所以返回12static void findByForce(int[] arr){int manSumarr[0];for(int i0;i<arr.length;i){int sumarr[j];//某个元素为子…
阅读更多...
鲁棒的基于表面势的GaN HEMT集成电路紧凑模型

鲁棒的基于表面势的GaN HEMT集成电路紧凑模型

来源&#xff1a;Robust Surface-Potential-Based Compact Model forGaN HEMT IC Design&#xff08;TED 13年&#xff09; 摘要 我们提出了一种精确且稳健的基于表面势的紧凑模型&#xff0c;用于模拟采用氮化镓高电子迁移率晶体管&#xff08;GaN HEMT&#xff09;设计的电…
阅读更多...
关于vuex 的模块开发和使用

关于vuex 的模块开发和使用

1、文件结构 2、modules 文件内容 例子&#xff1a; ccc.js 文件内容如下&#xff1a; // 基础配置项 const state {aa: [] }const mutations {setaa (state, data) {state.aa data} }const actions {} export default {namespaced: true, state,mutations,actions } **注…
阅读更多...
高效编写产品规格书的秘诀与注意事项

高效编写产品规格书的秘诀与注意事项

高效编写产品规格书的秘诀&#xff1a;学会利用简单的工具&#xff0c;写出效果最佳的产品规格书。比如&#xff0c;你可以使用HelpLook、Markdown编辑器、LaTeX、notion等。 在快节奏的商业环境中&#xff0c;产品规格书是企业向市场展示产品特性和优势的重要工具。一份清晰、…
阅读更多...
quartz整合前端vue加后端springboot

quartz整合前端vue加后端springboot

因工作需求&#xff0c;需要能修改定时的任务&#xff0c;前端vue3&#xff0c;后端是springboot 看看页面效果&#xff1a; 首先maven加上引入 <dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><versi…
阅读更多...
电源配小了，是不是容易烧？是的！

电源配小了，是不是容易烧？是的！

电源小的话会不会容易烧毁&#xff1f; 是的。 功率电压*电流。 随着功率增大&#xff0c;电压不变&#xff0c;电流增大&#xff0c;发热量增大&#xff0c;可能会烧毁。 今天给大家推荐一款650w的电脑电源&#xff0c;不过在推荐之前&#xff0c;首先要确认自己的电脑功耗…
阅读更多...
串行通信接口之RS232、RS485与RS422

串行通信接口之RS232、RS485与RS422

前言 RS232&#xff0c;RS485&#xff0c;RS422都是串口通信协议家族的一员&#xff0c;那么他们有什么区别呢&#xff1f;首先让我们来了解俩个简单的知识点&#xff0c;TTL电平以及CMOS电平&#xff0c;单端传输以及差分传输。 TTL电平 TTL电平接口电路由晶体管构成&#x…
阅读更多...
Oracle19C静默安装教程

Oracle19C静默安装教程

文章目录 一、安装前的准备1、安装Linux操作系统2、配置网络源或者本地源3、hosts文件配置 二、准备安装环境1、安装依赖包2、创建oracle用户组3、配置系统内核参数4、关闭selinux5、配置oracle用户环境6、修改用户的Shell限制 三、静默安装Oracle数据库1、创建oracle安装目录2…
阅读更多...
c++销售公司员工管理系统

c++销售公司员工管理系统

定制魏：QTWZPW，获取更多源码等 目录 题目 目的 要求 回顾或复习的内容 类声明 构造函数 核心算法实现 测试与结论 添加员工 显示所有员工 保存数据到文件 完整代码 总结 题目 设计一个虚基类Staff(员工),包含编号、姓名和年龄保护数据成员以及相关的成员函数;由S…
阅读更多...
spring MVC是如何找到html文件并返回的？

spring MVC是如何找到html文件并返回的？

Spring MVC 搜索路径 启动一个SpringBoot项目时&#xff0c;访问http://localhost:8080&#xff0c;对于SpringMVC&#xff0c;它会默认把这段url看成http://localhost:8080/index.html&#xff0c;所以这两个url是等价的。 .html, .css, .js, .img …都是静态资源文件&#x…
阅读更多...
前端小白的学习之路(ES6 一)

前端小白的学习之路(ES6 一)

提示&#xff1a;关键字声明&#xff1a;let与const,长度单位&#xff1a;em与rem,vw与wh&#xff0c;解构赋值&#xff0c;箭头函数(简介) 目录 一、ES6介绍 二、let&const 1.let 1) 用 let 关键字声明的变量不能提前引用 2) 不允许重复声明变量 3) 可以产生块级作用…
阅读更多...
基于Spring Boot+Vue的社区医院管理系统

基于Spring Boot+Vue的社区医院管理系统

末尾获取源码作者介绍&#xff1a;大家好&#xff0c;我是墨韵&#xff0c;本人4年开发经验&#xff0c;专注定制项目开发 更多项目&#xff1a;CSDN主页YAML墨韵 学如逆水行舟&#xff0c;不进则退。学习如赶路&#xff0c;不能慢一步。 目录 一、项目简介 一、研究背景 二…
阅读更多...
Python文件

Python文件

Python文件 1 文件与文件路径1.1 什么是文件和文件路径1.2 绝对路径1.3 相对路径 2 文件的基本操作2.1 路径检查方法2.2 目录操作方法2.3 信息获取方法 3 文件读写3.1 打开文件3.2 读取文件3.3 文件写入3.4 关闭文件3.5 示例3.6 with as 上下文语法 4 文件复制4.1 复制文件4.2 …
阅读更多...
ubuntu20.04搭建rtmp视频服务

ubuntu20.04搭建rtmp视频服务

1.安装软件 sudo apt-get install ffmpeg sudo apt-get install nginx sudo apt-get install libnginx-mod-rtmp 2.nginx配置 修改/etc/nginx/nginx.conf文件&#xff0c;在末尾添加&#xff1a; rtmp {server {listen 1935;application live {live on;}} } 3.视频测试 本…
阅读更多...
idea创建maven-archetype-quickstart框架无法显示src/目录

idea创建maven-archetype-quickstart框架无法显示src/目录

一、配置好idea中Maven目录 1、不使用idea自带Maven&#xff0c; 2、配置好Maven环境变量M2_HOME 3、修改maven中 setting.xml文件 <?xml version"1.0" encoding"UTF-8"?><settings xmlns"http://maven.apache.org/SETTINGS/1.2.0"…
阅读更多...
最新文章

Copyright @ 2022~2023