MongoDB教程(二十三):关于MongoDB自增机制

💝💝💝首先,欢迎各位来到我的博客,很高兴能够在这里和您见面!希望您在这里不仅可以有所收获,同时也能感受到一份轻松欢乐的氛围,祝你生活愉快!

文章目录

      • 引言
      • 一、MongoDB 默认的ObjectId
      • 二、实现自动增长ID
        • 1. 创建自增ID文档
        • 2. 获取并更新自增ID
      • 三、案例代码:实现自增ID
        • 1. 创建自增ID文档
        • 2. 获取并更新自增ID
        • 3. 插入订单
      • 四、并发场景下的自增ID
        • 1. 使用锁机制
        • 2. 使用事务
      • 五、结论

引言

在MongoDB中,自动生成或自动增长的ID是许多应用场景中的常见需求,特别是在需要连续编号的情况下。尽管MongoDB默认使用ObjectId作为文档的主键,但在某些情况下,开发者可能需要实现自定义的自增ID机制。本文将深入探讨如何在MongoDB中实现自动增长的ID,并通过具体的案例代码展示这一过程的每一个细节。

一、MongoDB 默认的ObjectId

MongoDB 默认使用ObjectId作为文档的_id字段。ObjectId是一个12字节的BSON类型,由以下四个部分组成:

  1. 时间戳(4字节):记录ObjectId创建时的时间,单位为秒。
  2. 机器标识符(3字节):表示生成ObjectId的机器,前两字节是网络字节序的机器ID,后一字节是进程ID。
  3. 计数器(2字节):每次在同一台机器同一进程中生成新的ObjectId时,计数器会递增。
  4. 随机数(3字节):增加随机性,降低冲突概率。

二、实现自动增长ID

在某些场景下,如订单编号、流水号等,需要使用连续的数字作为ID。MongoDB 不直接支持自增ID,但可以通过创建一个文档来模拟实现。

1. 创建自增ID文档

首先,需要在数据库中创建一个用于存储自增ID的文档。

db.auto_incr_ids.insert({ _id: "orders", sequence_value: 0 });

这里,orders 是自增ID的名称,sequence_value 是当前的ID值。

2. 获取并更新自增ID

每当需要一个新的自增ID时,可以通过原子操作获取并更新该文档。

db.auto_incr_ids.update({ _id: "orders" },{ $inc: { sequence_value: 1 } },{ upsert: true, new: true }
);

这里,$inc 操作符用于增加 sequence_value 的值,upsert 选项表示如果文档不存在,则创建新文档。

三、案例代码:实现自增ID

假设我们正在开发一个电子商务平台,需要为每个订单生成唯一的自增ID。

1. 创建自增ID文档
db.auto_incr_ids.insert({ _id: "order_numbers", sequence_value: 0 });
2. 获取并更新自增ID
function getNextSequence(name) {let result = db.auto_incr_ids.findOneAndUpdate({ _id: name },{ $inc: { sequence_value: 1 } },{ upsert: true, new: true });return result.sequence_value;
}let orderId = getNextSequence("order_numbers");
console.log(orderId);

这里,getNextSequence 函数用于获取下一个自增ID。

3. 插入订单
db.orders.insertOne({order_number: getNextSequence("order_numbers"),customer_name: "John Doe",items: [{ product: "T-shirt", quantity: 2 },{ product: "Jeans", quantity: 1 }],total_amount: 99.99
});

四、并发场景下的自增ID

在高并发场景下,直接使用 findOneAndUpdate 可能会遇到竞态条件。为了确保线程安全,可以使用锁机制或事务来处理。

1. 使用锁机制
const session = db.getMongo().startSession();
session.startTransaction();try {let result = db.auto_incr_ids.findOneAndUpdate({ _id: "order_numbers" },{ $inc: { sequence_value: 1 } },{ upsert: true, new: true, session });session.commitTransaction();
} catch (e) {session.abortTransaction();
} finally {session.endSession();
}
2. 使用事务

在MongoDB 4.0及以上版本,可以使用事务来确保操作的原子性。

const session = db.getMongo().startSession();
session.startTransaction();try {let result = db.auto_incr_ids.findOneAndUpdate({ _id: "order_numbers" },{ $inc: { sequence_value: 1 } },{ upsert: true, new: true, session });session.commitTransaction();
} catch (e) {session.abortTransaction();
} finally {session.endSession();
}

五、结论

自增ID机制非常适合需要连续编号的场景,如订单号、发票号等。需要注意的是,在高并发环境下,要确保并发安全性,可以使用锁机制或事务来处理。


喜欢博主的同学,请给博主一丢丢打赏吧↓↓↓您的支持是我不断创作的最大动力哟!感谢您的支持哦😘😘😘
打赏下吧

💝💝💝如有需要请大家订阅我的专栏【MongoDB系列】哟!我会定期更新相关系列的文章
💝💝💝关注!关注!!请关注!!!请大家关注下博主,您的支持是我不断创作的最大动力!!!

MongoDB相关文章索引文章链接
MongoDB教程(一):Linux系统安装mongoDB详细教程MongoDB教程(一):Linux系统安装mongoDB详细教程
MongoDB教程(二):mongoDB引用shellMongoDB教程(二):mongoDB引用shell
MongoDB教程(三):mongoDB用户管理MongoDB教程(三):mongoDB用户管理
MongoDB教程(四):mongoDB索引MongoDB教程(四):mongoDB索引
MongoDB教程(五):mongoDB聚合框架MongoDB教程(五):mongoDB聚合框架
MongoDB教程(六):mongoDB复制副本集MongoDB教程(六):mongoDB复制副本集
MongoDB教程(七):mongoDB分片MongoDB教程(七):mongoDB分片
MongoDB教程(八):mongoDB数据备份与恢复MongoDB教程(八):mongoDB数据备份与恢复
MongoDB教程(九):java集成mongoDBMongoDB教程(九):java集成mongoDB
MongoDB教程(十):Python集成mongoDBMongoDB教程(十):Python集成mongoDB
MongoDB教程(十一):MongoDB关系管理与文档关联MongoDB教程(十一):MongoDB关系管理与文档关联
MongoDB教程(十二):MongoDB数据库索引MongoDB教程(十二):MongoDB数据库索引
MongoDB教程(十四):MongoDB查询分析MongoDB教程(十四):MongoDB查询分析
MongoDB教程(十五):MongoDB原子操作MongoDB教程(十五):MongoDB原子操作
MongoDB教程(十六):MongoDB高级索引MongoDB教程(十六):MongoDB高级索引
MongoDB教程(十七):MongoDB主键类型ObjectIdMongoDB教程(十七):MongoDB主键类型ObjectId
MongoDB教程(十八):MongoDB MapReduceMongoDB教程(十八):MongoDB MapReduce
MongoDB教程(十九):MongoDB全文检索MongoDB教程(十九):MongoDB全文检索
MongoDB教程(二十):MongoDB正则表达式MongoDB教程(二十):MongoDB正则表达式
MongoDB教程(二十一):MongoDB大文件存储GridFSMongoDB教程(二十一):MongoDB大文件存储GridFS
MongoDB教程(二十二):MongoDB固定集合MongoDB教程(二十二):MongoDB固定集合

❤️❤️❤️觉得有用的话点个赞 👍🏻 呗。
❤️❤️❤️本人水平有限,如有纰漏,欢迎各位大佬评论批评指正!😄😄😄
💘💘💘如果觉得这篇文对你有帮助的话,也请给个点赞、收藏下吧,非常感谢!👍 👍 👍
🔥🔥🔥Stay Hungry Stay Foolish 道阻且长,行则将至,让我们一起加油吧!🌙🌙🌙

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

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

raise JSONDecodeError(“Expecting value”, s, err.value) from None

raise JSONDecodeError(“Expecting value”, s, err.value) from None 目录 raise JSONDecodeError(“Expecting value”, s, err.value) from None 【常见模块错误】 【解决方案】 欢迎来到英杰社区https://bbs.csdn.net/topics/617804998 欢迎来到我的主页,我是…

ISO 50001能源管理体系:企业可持续发展的新引擎

在全球范围内,能源管理正成为企业战略规划的重要组成部分。ISO 50001能源管理体系(EnMS)作为一项国际标准,为企业提供了一套系统的方法,帮助其提高能源绩效,降低能源消耗,减少碳排放。通过有效实…

Feign-微服务通信(Feign远程调⽤ Feign简介 基本使⽤ ⾃定义配置 Feign使⽤优化)

目录 一、Feign远程调⽤ 二、Feign简介 三、基本使⽤ 1. 加⼊Fegin的依赖 2. 在主类上添加Fegin的注解 3. 创建⼀个service, 并使⽤Fegin实现微服务调⽤ 4. 修改controller代码,并启动验证 5. 重启order微服务,查看效果 四、⾃定义配置…

oncoPredict:根据细胞系筛选数据预测体内或癌症患者药物反应和生物标志物

在14年的时候,oncoPredict函数的开发团队在Genome Biology上发了一篇文章。 这篇文章的核心目的是阐释了使用治疗前基线肿瘤基因表达数据去预测患者化疗反应。开发团队发现使用细胞系去预测临床样本的药物反应是可行的。 鉴于之前的理论,该研究团队首先…

C语言开关迷宫

目录 注意事项开头程序程序的流程图程序的效果结尾 注意事项 程序里有关字符’\033’的输出都关于Sunshine-Linux的其中一篇博客——《printf函数高级用法设置打印字体颜色和背景色等》 开头 大家好,我叫这是我58。今天,我们来看一下我用C语言编译的开…

昇思25天学习打卡营第23天|munger85

FCN图像语义分割 FCN-8s表示从8倍下采样的特征图通过上采样恢复到原图尺寸的网络结构。现在下载数据集,这种8倍的比较好。 from download import download url “https://mindspore-website.obs.cn-north-4.myhuaweicloud.com/notebook/datasets/dataset_fcn8s.t…

2024年用户口碑超佳的硬U盘数据恢复工具榜

U盘一个体积小小却能携带大量文件、视频的日常存储好物,你肯定也有吧。不知道你有没有遇到过U盘里数据丢失的情况,这时候U盘数据恢复工具就能帮我们走出这种困境。 1.U盘F0XIT数据恢复大师 一键直达>>https://www.pdf365.cn/foxit-restore/ 这…

自动驾驶-机器人-slam-定位面经和面试知识系列05之常考公式推导(02)

这个博客系列会分为C STL-面经、常考公式推导和SLAM面经面试题等三个系列进行更新,基本涵盖了自己秋招历程被问过的面试内容(除了实习和学校项目相关的具体细节)。在知乎和牛客(牛客上某些文章上会附上内推码)也会同步…

文章解读与仿真程序复现思路——电网技术EI\CSCD\北大核心《面向东北地区调频指标两段式火储联合调频策略》

本专栏栏目提供文章与程序复现思路,具体已有的论文与论文源程序可翻阅本博主免费的专栏栏目《论文与完整程序》 论文与完整源程序_电网论文源程序的博客-CSDN博客https://blog.csdn.net/liang674027206/category_12531414.html 电网论文源程序-CSDN博客电网论文源…

浅谈断言之XML断言

浅谈断言之XML断言 XML断言是JMeter的一个组件,用于验证请求的响应数据是否符合XML结构。这对于测试返回XML格式数据的Web服务特别有用。 如何添加XML断言? 要在JMeter测试计划中添加XML断言,遵循以下步骤: 打开测试计划&…

C#知识|账号管理系统:将修改账号信息提交到数据库

哈喽,你好啊,我是雷工! 昨天练习了账号管理系统-修改账号按钮功能的实现: 《修改账号按钮功能的实现》; 接下来继续学习,如何将修改完的信息提交到数据库, 以下为学习笔记。 01 实现功能 ①:当修改完信息,点击【提交修改】按钮时,将修改完的信息保存到SQLServer数…

Qt调用谷歌拼音输入插件

要在Qt中调用谷歌拼音输入插件 编译谷歌拼音输入法源码: 可以通过编译谷歌拼音输入法的源码来实现在Qt中的应用。以下是一些步骤: 下载QtInputMethod_GooglePinyin源码,例如从Gitee获取。 使用MinGW64或MSVC2019_64构建套件编译源码。 编译完…

Cyberchef基础概念之-循环语句操作-Jump/Label

在本专栏的前面的文章介绍了fork,merge,subsection,register等多种概念来解决实际场景的问题。本文将介绍的Jump/Label的操作类似于编程语言中的for和while的功能,相信在学会使用jump操作后,将有助于解决更为复杂的数据处理问题。 本文将详细的介绍该操…

小程序的运营方法:从入门到精通

随着科技的快速发展,小程序已成为我们日常生活和工作中不可或缺的一部分。小程序无需下载安装,即用即走的特点深受用户喜爱。那么,如何运营好一个小程序呢?下面就为大家分享一些小程序的运营方法。 一、明确目标用户 在运营小程序…

【计算机网络】单臂路由实现VLAN间路由实验

一:实验目的 1:掌握如何在路由器端口上划分子接口,封装dot1q协议,实现VLAN间的路由。 二:实验仪器设备及软件 硬件:RCMS-C服务器、网线、Windows 2019/2003操作系统的计算机等。具体为:路由器…

集成千兆网口(Gigabit Ethernet Port)的作用主要是提供高速的有线网络连接,其工作原理涉及以下几个关键点:

传输速率: 千兆网口支持的最高传输速率达到1 Gbps(即每秒10亿位),是传统百兆网口(100 Mbps)的十倍速度。这使得它能够处理更大量、更高质量的数据传输。 数据传输效率: 千兆网口能显著提高局域…

express连接mysql

一、 安装express npm install express --save二、express配置 //引入 const express require("express"); //创建实例 const app express(); //启动服务 app.listen(8081, () > {console.log("http://localhost:8081"); });三、安装mysql npm i m…

pip install albumentations安装下载超级细水管

albumentations 是一个用于图像增强的 Python 库,它提供了丰富的图像变换功能,可以用于数据增强,从而提高深度学习模型的泛化能力。 直接安装命令: pip install albumentations但是如果半夜遇到这种19kB/s的下载速度 为头发着想&…

《Milvus Cloud向量数据库指南》——Zilliz引领非结构化数据革命:北京Meetup圆满落幕,共绘AI新篇章

7月20日北京Unstructured Data Meetup圆满落幕:Zilliz引领非结构化数据革命,共绘AI新蓝图 随着数字时代的到来,数据已成为驱动社会进步与产业升级的关键要素。其中,非结构化数据以其形式多样、内容丰富、增长迅速的特点,在医疗、金融、教育、娱乐等多个领域展现出巨大的应…

Ruby、Python、Java 开发者必备:Codigger之软件项目体检

在编程的广阔天地里,Ruby、Python 和 Java 开发者们各自凭借着独特的语言特性,构建着精彩纷呈的应用世界。然而,无论使用哪种语言,确保项目的高质量始终是至关重要的目标。而 Codigger 项目体检则成为了实现这一目标的得力助手&am…