java 对ElasticSearch数据库操作封装工具类（对你是否适用嘞）

news2024/12/25 19:00:23

在 Java 中封装 ElasticSearch（ES）数据库操作（ES版本之间变动挺大的，别轻易换版本），可以使得与 ES 的交互更加简洁和易于维护。通过封装常见的操作，如插入文档、查询、更新和删除等，我们可以创建一个高效的工具类来简化开发流程。以下是一个简单的 ES 操作工具类的封装示例。

1. 添加 Elasticsearch 依赖

首先，确保在项目中添加了 Elasticsearch 的 Java 客户端依赖。以下是 Maven 依赖配置：

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.10.0</version> <!-- 请根据版本需求修改 -->
</dependency>

2. Elasticsearch 操作封装工具类

import org.apache.http.HttpHost;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.query.QuerySearchResult;
import org.elasticsearch.search.query.QuerySearchResponse;
import org.elasticsearch.search.query.SearchRequest;
import org.elasticsearch.search.query.SearchResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.search.SearchHit;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

public class ElasticSearchUtil {

    private static final String ES_HOST = "localhost";  // ES 集群地址
    private static final int ES_PORT = 9200;           // 默认端口号
    private static RestHighLevelClient client;

    // 静态初始化：创建 Elasticsearch 客户端
    static {
        client = new RestHighLevelClient(
                RestClient.builder(new HttpHost(ES_HOST, ES_PORT, "http")));
    }

    // 获取 Elasticsearch 客户端
    public static RestHighLevelClient getClient() {
        return client;
    }

    // 关闭 Elasticsearch 客户端连接
    public static void close() throws IOException {
        if (client != null) {
            client.close();
        }
    }

    // 插入文档
    public static void indexDocument(String index, String id, String jsonData) {
        IndexRequest request = new IndexRequest(index).id(id).source(jsonData);
        try {
            client.index(request, RequestOptions.DEFAULT);
            System.out.println("Document indexed successfully.");
        } catch (IOException e) {
            System.err.println("Failed to index document: " + e.getMessage());
        }
    }

    // 更新文档
    public static void updateDocument(String index, String id, String jsonData) {
        UpdateRequest request = new UpdateRequest(index, id).doc(jsonData);
        try {
            client.update(request, RequestOptions.DEFAULT);
            System.out.println("Document updated successfully.");
        } catch (IOException e) {
            System.err.println("Failed to update document: " + e.getMessage());
        }
    }

    // 查询文档
    public static List<String> searchDocuments(String index, String field, String value) {
        SearchRequest searchRequest = new SearchRequest(index);
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(QueryBuilders.matchQuery(field, value));
        searchRequest.source(sourceBuilder);

        List<String> results = new ArrayList<>();
        try {
            SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
            SearchHit[] hits = searchResponse.getHits().getHits();
            for (SearchHit hit : hits) {
                results.add(hit.getSourceAsString());
            }
        } catch (IOException e) {
            System.err.println("Failed to search documents: " + e.getMessage());
        }
        return results;
    }

    // 删除文档
    public static void deleteDocument(String index, String id) {
        try {
            client.delete(new DeleteRequest(index, id), RequestOptions.DEFAULT);
            System.out.println("Document deleted successfully.");
        } catch (IOException e) {
            System.err.println("Failed to delete document: " + e.getMessage());
        }
    }

    public static void main(String[] args) throws IOException {
        // 插入文档示例
        String jsonData = "{\"name\":\"John\",\"age\":30}";
        indexDocument("users", "1", jsonData);

        // 查询文档示例
        List<String> documents = searchDocuments("users", "name", "John");
        for (String doc : documents) {
            System.out.println(doc);
        }

        // 更新文档示例
        String updatedData = "{\"name\":\"John\",\"age\":31}";
        updateDocument("users", "1", updatedData);

        // 删除文档示例
        deleteDocument("users", "1");

        // 关闭 Elasticsearch 客户端
        close();
    }
}

3. 功能说明

1. 客户端初始化与关闭
  • RestHighLevelClient 用于与 Elasticsearch 进行交互。
  • client = new RestHighLevelClient(...)：初始化客户端连接。
  • client.close()：关闭客户端连接，释放资源。
2. 插入文档：
public static void indexDocument(String index, String id, String jsonData) {
    IndexRequest request = new IndexRequest(index).id(id).source(jsonData);
    try {
        client.index(request, RequestOptions.DEFAULT);
        System.out.println("Document indexed successfully.");
    } catch (IOException e) {
        System.err.println("Failed to index document: " + e.getMessage());
    }
}
  • IndexRequest 用于向指定索引中插入文档。
  • source(jsonData)：文档内容以 JSON 格式传入。
3. 更新文档：
public static void updateDocument(String index, String id, String jsonData) {
    UpdateRequest request = new UpdateRequest(index, id).doc(jsonData);
    try {
        client.update(request, RequestOptions.DEFAULT);
        System.out.println("Document updated successfully.");
    } catch (IOException e) {
        System.err.println("Failed to update document: " + e.getMessage());
    }
}
  • UpdateRequest 用于更新指定 ID 的文档。
4. 查询文档：
public static List<String> searchDocuments(String index, String field, String value) {
    SearchRequest searchRequest = new SearchRequest(index);
    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
    sourceBuilder.query(QueryBuilders.matchQuery(field, value));
    searchRequest.source(sourceBuilder);

    List<String> results = new ArrayList<>();
    try {
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        SearchHit[] hits = searchResponse.getHits().getHits();
        for (SearchHit hit : hits) {
            results.add(hit.getSourceAsString());
        }
    } catch (IOException e) {
        System.err.println("Failed to search documents: " + e.getMessage());
    }
    return results;
}
  • SearchRequest 和 SearchSourceBuilder 用于构建查询请求。
  • QueryBuilders.matchQuery() 用于构建匹配查询。
5. 删除文档：
public static void deleteDocument(String index, String id) {
    try {
        client.delete(new DeleteRequest(index, id), RequestOptions.DEFAULT);
        System.out.println("Document deleted successfully.");
    } catch (IOException e) {
        System.err.println("Failed to delete document: " + e.getMessage());
    }
}
  • DeleteRequest 用于删除指定 ID 的文档。

4. 如何使用该工具类

  • 插入文档：使用 indexDocument() 方法，将 JSON 数据插入指定的 Elasticsearch 索引中。
  • 更新文档：使用 updateDocument() 方法更新指定 ID 的文档。
  • 查询文档：使用 searchDocuments() 方法，根据字段值进行查询。
  • 删除文档：使用 deleteDocument() 方法删除指定 ID 的文档。

5. 改进与扩展

  • 分页查询：可以扩展查询功能，支持分页，避免返回过多数据。
  • 错误处理：根据实际需要加强错误处理逻辑，捕获并处理可能的异常。
  • 连接池支持：为了提高性能，建议使用连接池来管理 Elasticsearch 客户端。

通过这样的封装工具类，你可以轻松地执行 Elasticsearch 的常见操作，而不需要每次都编写繁琐的客户端代码。

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

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

相关文章

【python】银行客户流失预测预处理部分，独热编码·标签编码·数据离散化处理·数据筛选·数据分割

【python】银行客户流失预测预处理部分，独热编码·标签编码·数据离散化处理·数据筛选·数据分割

数据预处理 通过网盘分享的文件&#xff1a;银行流失预测数据和代码 链接: https://pan.baidu.com/s/1loiB8rMvZArfjJccu4KW6w?pwdpfcs 提取码: pfcs 非数值特征处理 目的&#xff1a;将非数值特征转换为数值型&#xff0c;以便模型能够处理。方法&#xff1a; 地理位置&am…
阅读更多...
从零开始使用MaxKB打造本地大语言模型智能问答系统与远程交互

从零开始使用MaxKB打造本地大语言模型智能问答系统与远程交互

文章目录 前言1. 下载运行Ollama2. 安装大语言模型3. 安装Cpolar工具4. 配置公网地址5. 固定公网地址6. MaxKB 添加Olama7.创建问答应用 前言 目前大语言模型&#xff08;LLM&#xff09;已经成为了人工智能领域的一颗璀璨明星&#xff0c;从自然语言处理到智能问答系统&#…
阅读更多...
neo4j无法导入csv文件

neo4j无法导入csv文件

文章目录 问题解决方案1. 检查Neo4j的neo4j.conf配置文件2. 确保文件路径正确3. 将CSV文件放置到import目录4. 重启Neo4j服务器 问题 neo4j browser中导入csv文件报错无法导入 具体&#xff1a;输入下列语句LOAD CSV WITH HEADERS FROM “file:///D:/KG/relation.csv” AS lin…
阅读更多...
WebLogic T3反序列化漏洞(CVE-2018-2628)--vulhub

WebLogic T3反序列化漏洞(CVE-2018-2628)--vulhub

WebLogic T3反序列化漏洞(CVE-2018-2628) WebLogic在通信过程中使用T3协议传输数据&#xff0c;涉及到了序列化和反序列化操作。 T3协议概述 T3协议是Oracle的私有协议&#xff0c;所以公开的相关资料比较少&#xff0c;这里结合其他师傅的博客简单对T3协议进行一个简要分析…
阅读更多...
在瑞芯微RK3588平台上使用RKNN部署YOLOv8Pose模型的C++实战指南

在瑞芯微RK3588平台上使用RKNN部署YOLOv8Pose模型的C++实战指南

在人工智能和计算机视觉领域，人体姿态估计是一项极具挑战性的任务，它对于理解人类行为、增强人机交互等方面具有重要意义。YOLOv8Pose作为YOLO系列中的新成员，以其高效和准确性在人体姿态估计任务中脱颖而出。本文将详细介绍如何在瑞芯微RK3588平台上，使用RKNN（Rockchip N…
阅读更多...
scala借阅图书保存记录（三）

scala借阅图书保存记录（三）

BookDAO package org.app package daoimport models.BookModelimport scala.collection.mutable.ListBuffer//图书&#xff0c;数据操作 class BookDAO {//加载图书&#xff0c;从文件中读入def loadBooks(): ListBuffer[BookModel] {val books new ListBuffer[BookModel]()…
阅读更多...
无标记动作捕捉系统如何赋能体育运动分析，推动体育科学发展？

无标记动作捕捉系统如何赋能体育运动分析，推动体育科学发展？

随着技术的不断发展与社会的需要&#xff0c;健康、科学运动成为了大众关注的一个热词。在韩国首尔的中央大学&#xff0c;其生物运动临床康复实验室和运动训练中心就致力于通过生物力学分析来研究与运动相关的伤害&#xff0c;并通过定制科学的训练计划来帮助运动员改进他们的…
阅读更多...
Unittest02|TestSuite、TestRunner、HTMLTestRunner、处理excel表数据、邮件接收测试结果

Unittest02|TestSuite、TestRunner、HTMLTestRunner、处理excel表数据、邮件接收测试结果

目录 八、测试套件TestSuite和测试运行器TestRunner 1、基本概念 2、创建和使用测试套件 3、 自动发现测试用例、创建测试套件、运行测试 4、生成html的测试报告&#xff1a;HTMLTestRunner 1️⃣导入HTMLTestRunner模块 2️⃣运行测试用例并生成html文件 九、unittest…
阅读更多...
[搜广推]王树森推荐系统笔记——曝光过滤 Bloom Filter

[搜广推]王树森推荐系统笔记——曝光过滤 Bloom Filter

曝光过滤 & Bloom Filter 曝光过滤主要在召回阶段做&#xff0c;主要方法是Bloom Filter 曝光过滤问题 -如果用户看过某个物品&#xff0c;则不再把该物品曝光给该用户。 - 原因是重复曝光同一个物品会损害用户体验 - 但长视频通常没有曝光过滤&#xff08;youtube&…
阅读更多...
JS CSS HTML 的代码如何快速封装

JS CSS HTML 的代码如何快速封装

我们为什么要封装代码&#xff0c;是因为封装后的代码&#xff0c;会显得非常美观&#xff0c;减少代码的复用&#xff0c;方便我们更好的去维护代码&#xff0c;不用一个一个页面的去找去改&#xff0c;直接封装好的代码里面去改就可以了 目录 1.html代码封装 2.CSS代码封装 …
阅读更多...
acme ssl证书自动续签 nginx

acme ssl证书自动续签 nginx

参考 github 官方操作 &#xff0c;acme操作说明 说下我的操作 安装 acme.sh curl https://get.acme.sh | sh source ~/.bashrc 2.注册 acme.sh --register-account -m 123qq.com 如果你在配置 acme.sh 时选择了其他 CA&#xff08;如 Let’s Encrypt&#xff09;&#xff…
阅读更多...
【专题】2024抖音电商母婴行业分析报告汇总PDF洞察（附原数据表）

【专题】2024抖音电商母婴行业分析报告汇总PDF洞察（附原数据表）

原文链接&#xff1a;https://tecdat.cn/?p38651 在数字化浪潮的席卷下&#xff0c;抖音电商母婴行业正经历着深刻变革。当下&#xff0c;年轻一代父母崛起&#xff0c;特别是 24 至 30 岁以及 18 至 23 岁的群体成为抖音母婴行业兴趣人群的主力军。他们带来全新育儿理念&…
阅读更多...
设计模式之 abstract factory

设计模式之 abstract factory

适用场景 一个系统要独立于它的产品的创建、组合和表示时。一个系统要由多个产品系列中的一个来配置时。当你要强调一系列相关的产品对象的设计以便进行联合使用时。当你提供一个产品类库&#xff0c;而只想显示它们的接口而不是实现时 架构演示 首先client这个东西可以接触到…
阅读更多...
UE5仿漫威争锋灵蝶冲刺技能

UE5仿漫威争锋灵蝶冲刺技能

这两天玩了一下漫威争锋Marvel Rivals&#xff0c;发现是UE5做的&#xff0c;对里面一些角色技能挺感兴趣的&#xff0c;想简单复刻一下技能功能&#xff0c;顺便复习一下学过的知识 首先把摄像机设置调整一下 CameraBoom里搜索lag 把摄像机延迟关掉 &#xff0c;这样摄像机就…
阅读更多...
尼伽OLED赋能中国移动，打造移动AI数字人透明显示屏

尼伽OLED赋能中国移动，打造移动AI数字人透明显示屏

随着人工智能和显示技术的不断进步&#xff0c;中国移动紧跟科技潮流&#xff0c;将移动AI数字人技术与透明屏完美结合&#xff0c;为用户带来了前所未有的智能交互体验。基于中国移动九天大模型生成的数字人小天&#xff0c;便是这一创新技术的典型代表。它不仅能够实现定点播…
阅读更多...
goview——vue3+vite——数据大屏配置系统

goview——vue3+vite——数据大屏配置系统

低代码数据大屏配置系统&#xff1a; 数据来源是可以动态api配置的&#xff1a; 配置上面的api接口后&#xff0c;在数据过滤中进行数据格式的转化。 以上内容&#xff0c;来源于https://gitee.com/dromara/go-view/tree/master-fetch/ 后端代码如下&#xff0c;需要更改…
阅读更多...
GitLab安装|备份数据|迁移数据及使用教程

GitLab安装|备份数据|迁移数据及使用教程

作者&#xff1a; 宋发元 最后更新时间&#xff1a;2024-12-24 GitLab安装及使用教程 官方教程 https://docs.gitlab.com/ee/install/docker.html Docker安装GitLab 宿主机创建容器持久化目录卷 mkdir -p /docker/gitlab/{config,data,logs}拉取GitLab镜像 docker pull gi…
阅读更多...
JavaWeb Servlet的反射优化、Dispatcher优化、视图(重定向)优化、方法参数值获取优化

JavaWeb Servlet的反射优化、Dispatcher优化、视图(重定向)优化、方法参数值获取优化

目录 1. 背景2. 实现2.1 pom.xml2.2 FruitController.java2.3 DispatcherServlet.java2.4 applicationContext.xml 3. 测试 1. 背景 前面我们做了Servlet的一个案例。但是存在很多问题&#xff0c;现在我们要做优化&#xff0c;优化的步骤如下&#xff1a; 每个Fruit请求都需…
阅读更多...
selenium执行js

selenium执行js

JS知识 获取元素 document.getElement 移除属性&#xff1a;removeAttribute("xx") 窗口移动&#xff1a;window.scrollTo(0, document.body.scrollHeight)方法 drivier.execute_script(js)场景&#xff1a; 日期选择框&#xff0c;不能输入&#xff0c;只能设置…
阅读更多...
《信管通低代码信息管理系统开发平台》Linux环境安装说明

《信管通低代码信息管理系统开发平台》Linux环境安装说明

1 简介 信管通低代码信息管理系统应用平台提供多环境软件产品开发服务&#xff0c;包括单机、局域网和互联网。我们专注于适用国产硬件和操作系统应用软件开发应用。为事业单位和企业提供行业软件定制开发&#xff0c;满足其独特需求。无论是简单的应用还是复杂的系统&#xff…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023