当前位置：首页 > news >正文

java 对mongodb操作封装工具类

news 来源：原创 2025/5/18 21:35:33

在 Java 中，封装 MongoDB 操作的工具类是非常常见的做法。使用 MongoDB 官方的 Java 驱动程序，结合常用的工具类封装，可以使得与 MongoDB 的交互更加方便和清晰。下面是一个简单的 MongoDB 操作封装工具类的示例代码。

前提

首先，确保你已经在项目中引入了 MongoDB Java 驱动的依赖。你可以使用 Maven 或 Gradle 来添加依赖。

Maven 依赖：

<dependency><groupId>org.mongodb</groupId><artifactId>mongodb-driver</artifactId><version>4.9.0</version> <!-- 请检查最新版本 -->
</dependency>

MongoDB 工具类封装

1. MongoDB 工具类

这个类包含了与 MongoDB 交互的常见操作，如获取数据库、获取集合、插入、查询、更新、删除等。

import com.mongodb.client.*;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Updates;
import org.bson.Document;
import org.bson.conversions.Bson;import java.util.ArrayList;
import java.util.List;public class MongoDBUtil {private static final String URI = "mongodb://localhost:27017";  // MongoDB 连接字符串private static final String DATABASE_NAME = "testdb";           // 默认数据库名private static MongoClient mongoClient;private static MongoDatabase database;// 静态初始化，建立数据库连接static {mongoClient = MongoClients.create(URI);database = mongoClient.getDatabase(DATABASE_NAME);}// 获取数据库实例public static MongoDatabase getDatabase() {return database;}// 获取集合实例public static MongoCollection<Document> getCollection(String collectionName) {return database.getCollection(collectionName);}// 插入一条记录public static void insertOne(String collectionName, Document document) {MongoCollection<Document> collection = getCollection(collectionName);collection.insertOne(document);}// 插入多条记录public static void insertMany(String collectionName, List<Document> documents) {MongoCollection<Document> collection = getCollection(collectionName);collection.insertMany(documents);}// 查找单条记录public static Document findOne(String collectionName, Bson filter) {MongoCollection<Document> collection = getCollection(collectionName);return collection.find(filter).first();}// 查找所有记录public static List<Document> findAll(String collectionName) {MongoCollection<Document> collection = getCollection(collectionName);List<Document> result = new ArrayList<>();collection.find().forEach(result::add);return result;}// 查找满足条件的记录public static List<Document> find(String collectionName, Bson filter) {MongoCollection<Document> collection = getCollection(collectionName);List<Document> result = new ArrayList<>();collection.find(filter).forEach(result::add);return result;}// 更新一条记录public static void updateOne(String collectionName, Bson filter, Bson update) {MongoCollection<Document> collection = getCollection(collectionName);collection.updateOne(filter, update);}// 更新多条记录public static void updateMany(String collectionName, Bson filter, Bson update) {MongoCollection<Document> collection = getCollection(collectionName);collection.updateMany(filter, update);}// 删除一条记录public static void deleteOne(String collectionName, Bson filter) {MongoCollection<Document> collection = getCollection(collectionName);collection.deleteOne(filter);}// 删除多条记录public static void deleteMany(String collectionName, Bson filter) {MongoCollection<Document> collection = getCollection(collectionName);collection.deleteMany(filter);}// 关闭 MongoDB 连接public static void close() {if (mongoClient != null) {mongoClient.close();}}public static void main(String[] args) {// 测试 MongoDB 操作MongoDBUtil.insertOne("users", new Document("name", "John").append("age", 30));MongoDBUtil.insertMany("users", List.of(new Document("name", "Jane").append("age", 25),new Document("name", "Mike").append("age", 35)));Document user = MongoDBUtil.findOne("users", Filters.eq("name", "John"));System.out.println(user.toJson());List<Document> allUsers = MongoDBUtil.findAll("users");allUsers.forEach(u -> System.out.println(u.toJson()));MongoDBUtil.updateOne("users", Filters.eq("name", "John"), Updates.set("age", 31));MongoDBUtil.deleteOne("users", Filters.eq("name", "Mike"));MongoDBUtil.close(); // 关闭连接}
}

2. 功能解释

连接 MongoDB

MongoClients.create(URI)：创建 MongoDB 客户端连接。
mongoClient.getDatabase(DATABASE_NAME)：获取指定名称的数据库实例。

数据库操作

insertOne()：插入单条数据。
insertMany()：插入多条数据。
findOne()：查询单条记录，返回符合条件的第一条文档。
findAll()：查询集合中的所有文档。
find()：根据查询条件查找所有符合条件的记录。
updateOne()：更新符合条件的第一条记录。
updateMany()：更新所有符合条件的记录。
deleteOne()：删除符合条件的第一条记录。
deleteMany()：删除所有符合条件的记录。

连接关闭

mongoClient.close()：关闭 MongoDB 客户端连接。

3. 使用该工具类

您可以像上面代码中的 main 方法那样，使用该工具类进行各种 MongoDB 操作。

4. 异常处理和连接池

在生产环境中，通常建议：

异常处理：对数据库连接或操作进行异常捕获，避免应用崩溃。
连接池：对于高并发的应用，可以考虑使用 MongoDB 提供的连接池机制，以提高性能。

5. 改进和扩展

您可以根据需要扩展这个工具类：

增加更多查询功能：比如分页查询、排序、聚合查询等。
更复杂的更新：例如使用 upsert（如果文档不存在则插入）等操作。

通过这个封装类，您可以简化 MongoDB 操作的复杂性，并且使得代码更具可维护性。

java 对mongodb操作封装工具类

在 Java 中，封装 MongoDB 操作的工具类是非常常见的做法。使用 MongoDB 官方的 Java 驱动程序，结合常用的工具类封装，可以使得与 MongoDB 的交互更加方便和清晰。下面是一个简单的 MongoDB 操作封装工具类的示例代码。前提首先&#xff0…...

编程日记 2025/5/18 21:35:33

Spark-Streaming集成Kafka

Spark Streaming集成Kafka是生产上最多的方式，其中集成Kafka 0.10是较为简单的，即：Kafka分区和Spark分区之间是1:1的对应关系，以及对偏移量和元数据的访问。与高版本的Kafka Consumer API 集成时做了一些调整，下面我们…...

编程日记 2025/5/18 7:10:19

最大似然检测在通信解调中的应用

最大似然检测（Maximum Likelihood Detection，MLD），也称为最大似然序列估计（Maximum Likelihood Sequence Estimation，MLSE），是一种在通信系统中广泛应用的解调方法。其核心思想是在给…...

编程日记 2025/5/16 14:19:25

Bert各种变体——RoBERTA/ALBERT/DistillBert

RoBERTa 会重复一个语句10次，然后每次都mask不同的15%token。丢弃了NSP任务，论文指出NSP任务有时甚至会损害性能。使用了BPE ALBERT 1. 跨层参数共享可以共享多头注意力层的参数，或者前馈网络层的参数，或者全部共享。实验结果…...

编程日记 2025/5/15 4:57:59

力扣周赛T2-执行操作后不同元素的最大数量

给你一个整数数组 nums 和一个整数 k。你可以对数组中的每个元素最多执行一次以下操作： 将一个在范围 [-k, k] 内的整数加到该元素上。返回执行这些操作后，nums 中可能拥有的不同元素的最大数量。示例 1： 输入： nums [1…...

编程日记 2025/5/13 4:53:13

uniapp 3分钟集成轮播广告图

先上效果图顶部广告栏为移动app常见需求，今天主要演示如何快速实现.这里还是基于《星云erp-移动版》演示版 （自行下载导入 Hbuilder, 后端接口可以直接使用我演示接口，不需要修改） 第一步: 组件选择我们直接使用uni-swipe…...

编程日记 2025/5/16 2:32:50

图像修复和编辑大一统 | 腾讯北大等联合提出BrushEdit：BrushNet进阶版来了

文章链接：https://arxiv.org/pdf/2412.10316 项目链接：https://liyaowei-stu.github.io/project/BrushEdit 亮点直击提出了BrushEdit，这是先前BrushNet模型的高级迭代版本。BrushEdit通过开创基于修复（inpainting）的图…...

编程日记 2025/5/18 19:49:19

极狐GitLab 17.7正式发布，可从 GitLab 丝滑迁移至极狐GitLab【二】

GitLab 是一个全球知名的一体化 DevOps 平台，很多人都通过私有化部署 GitLab 来进行源代码托管。极狐GitLab 是 GitLab 在中国的发行版，专门为中国程序员服务。可以一键式部署极狐GitLab。学习极狐GitLab 的相关资料： 极狐GitLab 官网极狐…...

编程日记 2025/5/16 12:03:55

Python基础知识回顾

数据类型 Python可以区分整数（integers、下文简写为int）、浮点数（float）、字符串（string）和布尔值（Boolean）等数据类型。 1）int是可正可负的整数 2）float包…...

编程日记 2025/5/17 21:04:37

SpringCloud2023集成Nacos2.4.3

基本都是最新版，踩了两天的坑终于集成上了，实现了多环境配置。使用版本关键应用版本备注Java21Oracle OpenJDK 21.0.5Spring Boot3.2.4Spring Cloud2023.0.1Spring Cloud Alibaba2023.0.1.3Nacos2.4.3单机模式 nacos安装我学习过程使用的是windows…...

编程日记 2025/5/16 12:55:22

数势科技指标平台，让数据产生最大价值

近来，指标体系和指标平台的重要性正被越来越多的业界同仁所认可。作为行业领先的数据智能产品提供商，数势科技最早推出了统一指标开发管理平台这一突破性产品（2021年获得软著），并首家完成了中国信通院数据指标管理平台…...

编程日记 2025/5/13 23:51:13

【玩转MacBook】Maven安装

下载Maven 官网： https://maven.apache.org/download.cgi 下载 Zip 类型的压缩包： 配置环境变量以管理员身份编辑配置文件。注意，由于 MacBook 上使用了 zsh 命令行，所以需要编辑~/.zshrc文件而不是~/.bash_profile文件&am…...

编程日记 2025/5/12 11:15:42

OpenGL笔记（1）

GLFW的函数说明 GLFW: Window guide 窗口创建提示在创建窗口和上下文之前，可以设置多个提示。有些提示影响窗口本身，另一些则影响帧缓冲区或上下文。这些提示每次通过 glfwInit 初始化库时都会被重置为默认值。整数值的提示可以通过 glfwWindowHint …...

编程日记 2025/5/16 17:20:01

前端Python应用指南（二）深入Flask：理解Flask的应用结构与模块化设计

《写给前端的python应用指南》系列： （一）快速构建 Web 服务器 - Flask vs Node.js 对比书接上文，这一篇将会深入了解下Flask，这个轻量级的Web框架，非常适合用来构建小型应用和快速原型开发。但是&#x…...

编程日记 2025/5/18 14:29:30

前端Python应用指南（三）Django vs Flask：哪种框架适合构建你的下一个Web应用？

《写给前端的python应用指南》系列： （一）快速构建 Web 服务器 - Flask vs Node.js 对比（二）深入Flask：理解Flask的应用结构与模块化设计在上一篇博文中，我们深入探讨了Flask框架，…...

编程日记 2025/5/12 9:34:49

Unity3D Huatuo技术原理剖析详解

前言在游戏开发领域，Unity3D凭借其强大的跨平台能力和丰富的功能，成为了众多开发者的首选工具。而在Unity3D的生态系统中，Huatuo作为一款重要的插件，为游戏开发带来了极大的便利。本文将深入剖析Huatuo的技术原理，并…...

编程日记 2025/5/15 19:46:04

复习打卡大数据篇——Hadoop HDFS 03

目录 1. HDFS元数据存储 2. HDFS HA 高可用 1. HDFS元数据存储 HDFS中的元数据按类型可以分为： 文件系统的元数据：包括文件名、目录名、修改信息、block的信息、副本信息等。datanodes的状态信息：比如节点状态、使用率等。 HDFS中的元数…...

编程日记 2025/5/14 9:53:41

宠物行业的出路：在爱与陪伴中寻找增长新机遇

在当下的消费市场中，如果说有什么领域能够逆势而上，宠物行业无疑是一个亮点。当人们越来越注重生活品质和精神寄托时，宠物成为了许多人的重要伴侣。它们不仅仅是家庭的一员，更是情感的寄托和生活的调剂。然而，随着行业…...

编程日记 2025/5/17 5:11:13

使用Turtle库实现，鼠标左键绘制路径，用鼠标右键结束绘制，小海龟并沿路径移动

使用Turtle库实现，鼠标左键绘制路径，用鼠标右键结束绘制，小海龟并沿路径移动 Turtle库是Python标准库的一部分，它提供了一种基于命令的图形绘制方式。Turtle模块通过一个“海龟”（Turtle）对象在屏幕上移动…...

编程日记 2025/5/18 11:29:00

海格通信嵌入式面试题及参考答案

计算电路的最高工作频率如何计算？计算电路的最高工作频率主要考虑电路中的关键路径延迟。关键路径是指在整个电路中，信号传播延迟最长的路径。电路的最高工作频率的倒数就是时钟周期，而时钟周期必须大于关键路径的延迟时间。首先要确定电路中各个模块的延迟。比如对于组合…...

编程日记 2025/5/18 11:55:53

3D几何建模引擎Parasolid功能解析

一、什么是Parasolid？ Parasolid是由Siemens PLM Software开发的高精度精密几何建模引擎。它全面评估CAD（计算机辅助设计）、CAM（计算机辅助制造）、CAE（计算机辅助工程）、PLM（产品生…...

编程日记 2025/5/18 1:29:20

AI的进阶之路：从机器学习到深度学习的演变（四）

AI的进阶之路：从机器学习到深度学习的演变（三） 五、深度学习的应用领域深度学习的应用领域广泛，涵盖了计算机视觉、自然语言处理、语音识别和推荐系统等多个方面。以下将详细探讨这些关键应用领域，展示深度学习在不同…...

编程日记 2025/5/12 12:24:24

【ES6复习笔记】rest参数（7）

什么是 rest 参数？ rest 参数是 ES6 引入的一个特性，它允许我们将一个不定数量的参数表示为一个数组。使用 rest 参数可以更方便地处理函数的参数，尤其是在参数数量不确定的情况下。如何使用 rest 参数？ 在函数定义中&#xf…...

编程日记 2025/5/16 3:20:49

安装MongoDB，环境配置

官网下载地址：MongoDB Shell Download | MongoDB 选择版本安装下载完成双击打开点击mongodb-windows-x86_64-8.0.0-signed 选择安装地址检查安装地址安装成功二.配置MongoDB数据库环境 1.找到安装好MongoDB的bin路径复制bin路径打开此电脑 -> 打开高级…...

编程日记 2025/5/12 15:58:40

1 查看ip地址 rootu22-tools-20:~# ip addr 1: lo: <LOOPBACK,UP,LOWER_UP> mtu 65536 qdisc noqueue state UNKNOWN group default qlen 1000 link/loopback 00:00:00:00:00:00 brd 00:00:00:00:00:00 inet 127.0.0.1/8 scope host lo valid_lft forever…...

编程日记 2025/5/15 22:02:58

flask后端开发（1）：第一个Flask项目

目录一、Helloworddebug、host、port的配置 gitcode地址： https://gitcode.com/qq_43920838/flask_project.git 一、Helloword 一般是会创建两个文件夹和app.py app.py from flask import FlaskappFlask(__name__)app.route(/) def hello_world():return Hello…...

编程日记 2025/5/15 21:52:57

详解下c语言中struct和union的对齐规则

接触过c语言的同学应该都知道字节对齐。有些时候我们很容易弄错字节对齐的方式，特别是涉及到struct（结构体）和union（联合体）时。今天我们通过详细例子来说明下struct和union的对齐规则，以便了解各种struct和…...

编程日记 2025/5/17 4:50:36

虚拟机桥接模式网络连接不上解决方法

可能是桥接模式自动配置网络地址的时候没配好，自己手动配置一下。先看看windows里的wifi的ip 把虚拟机的网络设置打开ipv4把地址、子网掩码、网关输进去，然后再连接...

编程日记 2025/5/7 2:52:34

MySQL用表组织数据

用表组织数据文章目录用表组织数据一.四种完整性约束二.数值类型2-1三.数值类型2-2四.字符串.日期类型五.设置1.设置主键2.设置标识列3.设置非空4.设置默认值六.主外键建立后注意事项一.四种完整性约束 1.域完整性列域完整性约束方法:限制数据类型,检查约束,外键约束,默…...

编程日记 2025/5/15 17:54:44

基于python 微信小程序的医院就诊小程序

标题:基于 Python 微信小程序的医院就诊小程序内容:1.摘要基于 Python 微信小程序的医院就诊小程序旨在解决传统医院就诊流程繁琐、排队时间长等问题。通过小程序，患者可以在线预约挂号、查询医生信息、在线支付等，提高就诊效率。本小程序采用 Python…...

编程日记 2025/5/14 3:13:13

VUE3+django接口自动化部署平台部署说明文档（使用说明，需要私信）

网址连接：http://118.25.110.213:5200/#/login 账号/密码：renxiaoyong 1、VUE3部署本地。 1.1本地安装部署node.js 1.2安装vue脚手架 npm install -g vue/cli # 或者 yarn global add vue/cli1.3创建本地项目 vue create my-vue-project1.4安装依赖和插…...

编程日记 2025/5/12 11:24:30

【MySQL】十三，关于MySQL的全文索引

MySQL的全文索引用于搜索文本中的关键字，类似于like查询。演示建表 CREATE TABLE demo (id INT(11) NOT NULL,name CHAR(30) NOT NULL,age INT(11) NOT NULL,info VARCHAR(255),primary key(id),fulltext index futxt_idx_info(info) );此表的默认存储引擎为In…...

编程日记 2025/5/18 5:53:09

人工智能学习框架入门教程（一）

人工智能（AI）学习框架是指为开发、训练和部署人工智能模型提供的结构化工具和环境。它们帮助开发者实现AI项目的高效性、可扩展性、可维护性，并提供了优化算法、模型训练、评估、调优等功能。根据任务的不同，人工智能框架可以分为…...

编程日记 2025/5/9 15:38:21

NNDL 作业11 LSTM

习题6-4 推导LSTM网络中参数的梯度， 并分析其避免梯度消失的效果先来推个实例： 看式子中间，上半部分并未有连乘项，而下半部分有到的连乘项，从这可以看出，LSTM能缓解梯度消失，梯度爆炸只是不易…...

编程日记 2025/5/17 2:29:22

Git 操作全解：从基础命令到高级操作的实用指南

文章目录 1.基本命令1.初始化仓库2.克隆远程仓库3.查看当前仓库状态4.查看提交日志5.添加文件到暂存区6.提交更改7.查看仓库的配置信息 2.分支操作1.查看所有分支2.创建新分支3.切换名称4.创建并切换到新分支5.删除分支6.查看当前分支 3.合并分支1.合并分支2.解决合并冲突 4.远…...

编程日记 2025/5/17 2:46:44

CSS（四）display和float

display display 属性用于控制元素的显示类型，用的 display 值包括： block：块级元素使元素成为块级元素，占据一整行，前后有换行宽度默认为父容器的 100%，可以设置宽高，支持 margin、padding、…...

编程日记 2025/5/16 8:06:14

python中使用selenium执行组合快捷键ctrl+v不生效问题

在执行ctrlv进行粘贴时，绑定一个页面上的元素对象（无论元素对象是否是引用过期或者是粘贴的目标文本区，但前提需要粘贴的目标文本区获取焦点）执行ctrlv后可以生效。执行粘贴组合快捷键（ctrlv）的示例代码 se…...

编程日记 2025/5/10 8:35:11

数据结构 C/C++(实验五:图)

（大家好，今天分享的是数据结构的相关知识，大家可以在评论区进行互动答疑哦~加油！💕） 目录提要：实验题目一、实验目的二、实验内容及要求三、源程序及注释实验1代码 （折半查…...

编程日记 2025/5/16 4:52:53

非零掩码矩阵邻接矩阵

文章目录 1. 举例：2. python 代码3. 邻接矩阵 1. 举例： 在深度学习过程中，我们经常会用到掩码矩阵，比如我们有一个矩阵A表示如下,希望得到矩阵B，在矩阵A的非零位置表示为1，零位置表示为0， A …...

编程日记 2025/5/17 6:56:36

Docker安装

目录 1. 联网安装 Docker 2. 离线安装 Docker 3. 安装 Docker Compose 4. 卸载 Docker 和 Docker Compose 1. 联网安装 Docker 在 CentOS 上通过 yum 安装 Docker： # 安装 Docker yum -y install docker # 启动 Docker systemctl start docker # 查看 D…...

编程日记 2025/5/12 23:27:28

嵌入式驱动开发详解21（网络驱动开发）

文章目录前言以太网框架ENET 接口简介MAC接口MII \ RMII 接口MDIO 接口RJ45 接口 PHY芯片以太网驱动驱动挂载wifi模块挂载后续前言 linux驱动主要是字符设备驱动、块设备驱动还有网络设备驱动、字符设备驱动在本专栏前面已经详细将解了，网络设备驱动本文会做简要…...

编程日记 2025/5/14 3:45:32

2024年12月25日Github流行趋势

项目名称：system-design-primer 项目维护者：donnemartin, cclauss, satob, fluency03, linhe0x0项目介绍：学习如何设计大规模系统。为系统设计面试做准备。包括 Anki 卡片。项目star数：282,387项目fork数：47,226 项目…...

编程日记 2025/5/18 14:18:27

6、mysql的MHA故障切换

MHA的含义 MHA：master high availability，建立在主从复制基础上的故障切换的软件系统。主从复制的单点问题： 当主从复制当中，主服务器发生故障，会自动切换到一台从服务器，然后把从服务器升格成主&…...

编程日记 2025/5/13 11:43:19

#error: WinSock.h has already been included解决方案

原因： 在工程中使用了 Boot 库之后，使用了socket、tcp 相关的头文件，在其他地方还是包括了头文件<windows.h>，该头文件内包含了<winsock.h>。导致遇到报错问题：WinSock.h has already been included 解决…...

编程日记 2025/5/16 8:01:10

npm淘宝镜像

通过命令行配置npm的淘宝镜像源和官方镜像源，以及如何安装和使用cnpm来解决安装包卡顿或无法安装的问题。通过设置registry和disturl，配合清理缓存，可以优化npm的下载速度。 1、官方默认镜像 npm config set registry https://registry.n…...

编程日记 2025/5/15 20:29:42