springboot集成ElasticSearch的具体操作(系统全文检索)

本文涉及的产品
Elasticsearch Serverless通用抵扣包,测试体验金 200元
简介: springboot集成ElasticSearch的具体操作(系统全文检索)

es搜索引擎的个人理解:将数据库中 ,在需要做全文检索的业务数据同步一份到es搜索引擎里面,建立在同一个索引下的数据集。

1.项目引入maven依赖

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>

2.建立es与数据库数据的实体类
package com.test.model;

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;

import java.util.Date;

/**

  • Es 索引库实体
    *
  • @author wangwei
  • @date 2023-07-31
    */
    @Document(indexName = "rabbit1")
    @Data
    public class EsModel {

    /** 索引id/
    @Field(type = FieldType.Long)
    private Long id;

    /** es中对应的数据库业务单据id*/
    @Field(analyzer = "ik_max_word")
    private Long ctId;

    /** es中业务数据 对应的业务数据库表名称*/
    @Field(analyzer = "ik_max_word")
    private String ctTableName;

    /** es中业务数据 对应的 业务简称*/
    @Field(analyzer = "ik_max_word")
    private String ctName;

/**** es中业务数据 对应的 业务内容详细信息*/
@Field(analyzer = "ik_max_word")
private String ctContent;


/** 备注 */
@Field(analyzer = "ik_max_word")
private String remark;

/** 备用1 */
@Field(analyzer = "ik_max_word")
private String by1;

/** 备用2 */
@Field(analyzer = "ik_max_word")
private String by2;

/** 备用3 */
@Field(analyzer = "ik_max_word")
private String by3;

/** 备用4 */
@Field(analyzer = "ik_max_word")
private String by4;

/** 备用5 */
@Field(analyzer = "ik_max_word")
private String by5;

}
3.建立es操作接口
package com.test.repository;

import com.test.model.EsModel;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;

/**

  • @author wangwei
  • @date 2023-07-31 14:12:36
    */
    @Repository
    public interface EsRepository extends ElasticsearchRepository {
/****
 * 删除es操作
 */
public void deleteById(Long id);

}
4.具体业务使用

package com.test.business.service.impl;
import java.io.IOException;
import java.util.List;
import com.alibaba.fastjson.JSON;
import com.test.business.domain.;
import com.test.business.domain.dto.TbAjkDto;
import com.test.business.domain.dto.TbAjkExportDto;
import com.test.business.mapper.
;
import com.test.common.exception.CustomException;
import com.test.constant.EsConstants;
import com.test.model.EsModel;
import com.test.model.TbAjkEs;
import com.test.model.TbAjkEsRepository;
import com.test.repository.EsRepository;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.stereotype.Service;
import com.test.business.service.ITbAjkService;
import org.springframework.transaction.annotation.Transactional;

/**

  • 库详情Service业务层处理
    *
  • @author wangwei
  • @date 2023-07-18
    */
    @Service
    public class TbAjkServiceImpl implements ITbAjkService {
    @Autowired
    private TbAjkMapper tbAjkMapper;
    @Autowired
    private TbAjgjcMapper tbAjgjcMapper;
    @Autowired
    private TbAjxyrMapper tbAjxyrMapper;
    @Autowired
    private TbAjxxlMapper tbAjxxlMapper;
    @Autowired
    private TbAjwllMapper tbAjwllMapper;
    @Autowired
    private TbAjzjlMapper tbAjzjlMapper;
    @Autowired
    private TbAjtxlMapper tbAjtxlMapper;
    @Autowired
    private PublicSqlMapper publicSqlMapper;
    @Autowired
    private TbAjkEsRepository tbAjkEsRepository;
    @Autowired
    private EsRepository esRepository;
    @Autowired
    private RestHighLevelClient client;
/**
 * 查询库详情
 *
 * @param id 详情主键
 * @return 库详情
 */
@Override
public TbAjk selectTbAjkById(Long id) {
    return tbAjkMapper.selectTbAjkByCtId(id);
}

/**
 * 查询详情列表
 *
 * @param 库详情
 * @return 库详情
 */
@Override
public List<TbAjk> selectTbAjkList(TbAjk tbAjk) {
    return tbAjkMapper.selectTbAjkList(tbAjk);
}

/**
 * 新增库详情
 * 新增es中的信息
 *
 * @param tbAjk 详情
 * @return 结果
 */
@Transactional(rollbackFor = Exception.class)
@Override
public int insertTbAjk(TbAjk tbAjk) {
    int i = tbAjkMapper.insertTbAjk(tbAjk);
    if (i == 1) {
        EsModel esModel = new EsModel();
        Integer integer = publicSqlMapper.selectInsertId();
        esModel.setId(Long.valueOf(integer));
        esModel.setCtId(Long.valueOf(integer));
        esModel.setCtTableName("tb_ajk");
        esModel.setCtName(tbAjk.getAjmc());
        esModel.setCtContent(tbAjk.getCjsy());//处事由
        esModel.setBy1(tbAjk.getLaay());//案由
        esModel.setBy2(tbAjk.getAjlb());//类别
        esModel.setBy3(tbAjk.getCjnr());//内容
        esModel.setBy4(tbAjk.getContent());//出内容
        esModel.setBy5(tbAjk.getCbpcs());//承办
        esModel.setRemark(tbAjk.getJyaq());//简要情
        try {
            esRepository.save(esModel);
        } catch (Exception e) {
            throw new CustomException("ES数据同步失败,请联系管理员处理!");
        }
    } else {
        throw new CustomException("数据库操作失败,请联系管理员处理!");
    }
    return 1;
}

/**
 * 修改库详情
 * 修改es中的信息
 * es: 1. 查询es中的数据
 * es: 2. 修改es中的数据
 *
 * @param 库详情
 * @return 结果
 */
@Transactional(rollbackFor = Exception.class)
@Override
public int updateTbAjk(TbAjk tbAjk) {
    int i = tbAjkMapper.updateTbAjk(tbAjk);
    if (i == 1) {
        // public UpdateRequest(String index, String type, String id) {
        //  es-update  https://www.jb51.net/article/246798.htm
        UpdateRequest updateRequest = new UpdateRequest(EsConstants.ES_INDEX, EsConstants.ES_INDEX_TYPE, String.valueOf(tbAjk.getCtId()));
        EsModel esModel = new EsModel();
        esModel.setId(Long.valueOf(tbAjk.getCtId()));
        esModel.setCtId(Long.valueOf(tbAjk.getCtId()));
        esModel.setCtName(tbAjk.getAjmc());
        esModel.setCtContent(tbAjk.getCjsy());//事由
        esModel.setBy1(tbAjk.getLaay());//案由
        esModel.setBy2(tbAjk.getAjlb());//类别
        esModel.setBy3(tbAjk.getCjnr());//内容
        esModel.setBy4(tbAjk.getContent());//出内容
        esModel.setBy5(tbAjk.getCbpcs());//承办
        esModel.setRemark(tbAjk.getJyaq());//简要情
        //更新    将对象转换为json
        updateRequest.doc(JSON.toJSONString(esModel), XContentType.JSON);
        //客户端发送请求,进行更新
        UpdateResponse update = null;
        try {
            update = client.update(updateRequest, RequestOptions.DEFAULT);
        } catch (IOException e) {
            throw new CustomException("ES数据同步失败可能原因是es中的业务ctId在数据库中不存在,请查看es客户端查询验证,请联系管理员处理!");
        }

        if (!"OK".equals(update.status().toString())) {
            throw new CustomException("ES数据同步失败,请联系管理员处理!");
        }
    } else {
        throw new CustomException("数据库操作失败,请联系管理员处理!");
    }
    return 1;
}

/**
 * 批量删除库详情
 *
 * @param ids 需要删除的详情主键
 * @return 结果
 */
@Transactional(rollbackFor = Exception.class)
@Override
public int deleteTbAjkByIds(Long[] ids) {
    int i = tbAjkMapper.deleteTbAjkByCtIds(ids);
    if (i != 1) {
        throw new CustomException("数据库操作失败,请联系管理员处理!");
    }
    for (int ii = 0; ii < ids.length; ii++) {
        try {
            esRepository.deleteById(ids[ii]);
        } catch (Exception e) {
            throw new CustomException("ES同步数据失败,请联系管理员处理!");
        }
    }
    return 1;
}

/**
 * 删除详情信息
 *
 * @param id 详情主键
 * @return 结果
 */
@Transactional(rollbackFor = Exception.class)
@Override
public int deleteTbAjkById(Long id) {
    int i = tbAjkMapper.deleteTbAjkByCtId(id);
    if (i != 1) {
        throw new CustomException("数据库操作失败,请联系管理员处理!");
    }
    try {
        esRepository.deleteById(id);
    } catch (Exception e) {
        throw new CustomException("ES同步数据失败,请联系管理员处理!");
    }
    return 1;
}

}

5.es查询说明

5.1 es案字段key查询
@Override
public AjaxResult searchES(String key) {
Pageable pageable = null;
Page byAjmc = tbAjkEsRepository.findByAjmc(key, pageable);
return AjaxResult.success(byAjmc);
}

5.2 全文检索(高阶用法)

说明:按业务需要在withQuery(matchQuery("", key))中天剑需要检索的字段键值,进行全文检索
/*

 * //全文检索
 * @param key
 * @return
 */
@Override
public AjaxResult searchWhole(String key) {
    Pageable pageable = null;

    if (StringUtils.isEmpty(key)) {
        System.out.println("key is null");
    }
    //全文检索
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

    SearchQuery searchQuery = new NativeSearchQueryBuilder()
            .withQuery(matchQuery("ctName", key))
            .withQuery(matchQuery("ctContent", key))
            .withQuery(matchQuery("remark", key))
           // .withPageable(pageable)
            .build();

    Page<EsModel> esModels = elasticsearchRestTemplate.queryForPage(searchQuery, EsModel.class);
    return AjaxResult.success(esModels);
}

6.es客户端查看数据的操作
image.png

image.png
image.png
image.png

相关实践学习
以电商场景为例搭建AI语义搜索应用
本实验旨在通过阿里云Elasticsearch结合阿里云搜索开发工作台AI模型服务,构建一个高效、精准的语义搜索系统,模拟电商场景,深入理解AI搜索技术原理并掌握其实现过程。
ElasticSearch 最新快速入门教程
本课程由千锋教育提供。全文搜索的需求非常大。而开源的解决办法Elasricsearch(Elastic)就是一个非常好的工具。目前是全文搜索引擎的首选。本系列教程由浅入深讲解了在CentOS7系统下如何搭建ElasticSearch,如何使用Kibana实现各种方式的搜索并详细分析了搜索的原理,最后讲解了在Java应用中如何集成ElasticSearch并实现搜索。 &nbsp;
相关文章
|
6天前
|
JavaScript Java 关系型数据库
基于springboot的小区车位租售管理系统
针对城市化进程中小区停车难问题,本文设计基于SpringBoot的车位租售管理系统,结合Vue前端与MySQL数据库,实现车位信息数字化、租售流程自动化。系统支持在线查询、申请、支付及数据统计,提升管理效率与用户体验,促进资源优化配置。
|
6天前
|
JavaScript Java 关系型数据库
基于springboot的校内跑腿管理系统
针对校园跑腿服务效率低、信任难等问题,本研究设计基于Spring Boot与Vue的校内跑腿管理系统,融合MySQL数据库与智能化调度技术,实现任务发布、智能匹配、实时追踪与评价反馈一体化,提升服务效率与质量,助力智慧校园建设。
|
7天前
|
JavaScript Java 关系型数据库
基于springboot的快递分拣管理系统
本系统基于SpringBoot框架,结合Java、MySQL与Vue技术,构建智能化快递分拣管理平台。通过自动化识别、精准分拣与实时跟踪,提升分拣效率与准确性,降低人力成本,推动快递行业向智能化、高效化转型,助力电商物流高质量发展。
|
9天前
|
搜索推荐 算法 JavaScript
基于springboot的健康饮食营养管理系统
本系统基于Spring Boot、Vue与MySQL技术,融合大数据与AI算法,构建个性化健康饮食管理平台。结合用户身体状况、目标需求,智能推荐营养方案,助力科学饮食与健康管理。
|
9天前
|
JavaScript 安全 Java
基于springboot的摄影器材租赁回收系统
本系统基于Java、Spring Boot与Vue技术,构建摄影器材租赁回收平台,解决市场不规范、资源浪费等问题。支持在线预约、信用免押、智能评估等功能,提升器材利用率,降低用户成本,推动行业绿色可持续发展。
|
10天前
|
JavaScript 前端开发 Java
基于springboot的4s店汽车试驾销售服务系统
针对传统4S店运营效率低、服务体验差等问题,研究基于SpringBoot的汽车销售服务系统,融合Java、Vue、MySQL等技术,实现业务自动化、客户个性化服务与数据智能分析,提升管理效率与客户满意度,推动4S店数字化转型与竞争力升级。
|
10天前
|
JavaScript Java 关系型数据库
基于springboot的旅游门票预定系统
在数字化时代,旅游门票预定系统应运而生,结合Spring Boot、Vue、Java与MySQL技术,实现在线预订、电子验票、数据分析等功能,提升游客体验与景区管理效率,推动旅游业智能化转型。
|
11天前
|
JavaScript 安全 Java
基于springboot的大学生心理咨询管理系统
本研究针对大学生心理健康问题,构建基于Spring Boot、Vue等技术的心理咨询管理系统,实现心理数据电子化、智能化管理。系统支持在线预约、匿名咨询、心理测评与数据分析,兼具隐私保护与危机预警功能,提升服务可及性与干预精准度,助力高校心理健康工作科学化发展。
|
11天前
|
供应链 JavaScript Java
基于springboot的半成品配菜管理系统
本研究基于SpringBoot框架构建半成品配菜管理系统,旨在解决行业库存、订单与供应链管理难题。系统实现库存预警、订单自动化与供应链协同,提升企业效率与客户满意度,推动行业信息化、智能化发展,具有重要现实意义与应用价值。(238字)
|
12天前
|
监控 JavaScript Java
基于springboot的游乐园管理系统
本系统基于SpringBoot与Vue技术,构建高效、智能的游乐园管理系统,实现票务电子化、设备监控智能化、员工管理自动化,提升运营效率与游客体验,推动游乐园数字化转型与智慧升级。