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

news2024/11/25 16:34:43

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

文章目录

      • 引言
      • 一、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://www.coloradmin.cn/o/1952493.html

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

相关文章

青少年绘画大赛兰州站:童梦起航 致敬科学 续写降压0号之父强国梦

2024年7月21日,“鹤舞童梦致敬科学精神”青少年绘画大赛在兰州隆重启幕。 活动邀请了多位重量级嘉宾担任评委,包括中国美术家协会会员、甘肃省油画协会常务理事马爱兵,兰州交通大学天佑美术馆馆长王欣,以及国家一级美术师蔡晓斌。…

【Java基础系列】RBAC:介绍与原理

💝💝💝欢迎来到我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…

【C++】模板详解

📢博客主页:https://blog.csdn.net/2301_779549673 📢欢迎点赞 👍 收藏 ⭐留言 📝 如有错误敬请指正! 📢本文由 JohnKi 原创,首发于 CSDN🙉 📢未来很长&#…

Activiti 本地画流程 http://localhost:8080/activiti-app/#/

http://localhost:8080/activiti-app/#/ 1、本地安装了Tomcat 2、本地安装了Activiti 3、拷贝Activiti中这两个文件到Tomcat中的webapps目录下 4、启动startu.bat 5、http://localhost:8080/activiti-app/#/ 账号:admin 密码:test

Redis-jenkins

1. 什么是jenkins Jenkins是一个开源软件项目,是基于Java开发的一种持续集成工具,用于监控持续重复的工作,旨在提供一个开放易用的软件平台,使软件项目可以进行持续集成。 2. 为什么使用jenkins 使用 Jenkins之前使用 Jenkins之…

【图形图像-1】SDF

在图形图像处理中,SDF(Signed Distance Field,带符号的距离场)是一种表示图形轮廓和空间距离的数学结构。它通常用于计算机图形学、文本渲染、碰撞检测和物理模拟等领域。 SDF(Signed Distance Field,带符号…

白鲸开源CEO郭炜荣获「2024中国数智化转型升级先锋人物」称号

2024年7月24日,由数据猿主办,IDC协办,新华社中国经济信息社、上海大数据联盟、上海市数商协会、上海超级计算中心作为支持单位,举办“数智新质力拓未来 2024企业数智化转型升级发展论坛——暨AI大模型趋势论坛”数据猿“年中特别策…

.h264 .h265 压缩率的直观感受

1.资源文件 https://download.csdn.net/download/twicave/89579327 上面是.264 .265和原始的YUV420文件,各自的大小。 2.转换工具: 2.1 .h264 .h265互转 可以使用ffmpeg工具:Builds - CODEX FFMPEG gyan.dev 命令行参数: …

二叉树详解-第四篇 二叉树链式结构的实现

目录 1.二叉树的遍历 1.1前序遍历: 1.2 中序遍历: 1.3 后序遍历: 2.二叉树链式结构的实现 2.1 Tree.h 2.2 Tree.cpp 2.2.1 前序遍历 void PreOrder(TNode* Root) 2.2.2 中序遍历 void InOrder(TNode* Root) 2.2.3 后序遍历 void Bac…

Linux中断框架

不管是裸机实验还是 Linux 下的驱动实验,中断都是频繁使用的功能,在裸机中使用中断我们需要做一大堆的工作,比如配置寄存器,使能 IRQ 等等。Linux 内核提供了完善的中断框架,我们只需要申请中断,然后注册中…

【rockyLinux】rockyLinux 9.4 安装 java jdk

一、安装 java 1.选择版本 yum list | grep jdk各个版本之间的区别: 2.选择了:java-17-openjdk-devel.x86_64(开发者版本),开始安装 建议安装在 /usr/local 这个目录下,可以创建一个 app 目录来收录它…

重生奇迹MU 三个阶段三种体验

重生奇迹MU的玩家们通常按等级分为三个阶段。在这三个不同的阶段里,游戏中的玩家好像深入了三个不同的世界,经历了三种不同的游戏体验,收获了三种不同的精彩! 从刚开始游戏一直到达到400级,是游戏中的第一个阶段&…

0719_驱动3 printk使用方法

一、printk使用方法 1.应用层打印使用printf,内核层使用printk 2.如何查看内核层中printk如何使用 3.在内核空间执行grep "printk" * -nR 4.在内核空间执行vi -t KERN_INFO 5.printk有8中打印级别(0-7),打印级别用来过滤…

暴雨宅家?AI拯救你的无聊暑假!高中生必藏神器大公开

嘿,各位高中生朋友们,最近是不是被这没完没了的暴雨困在家里,感觉暑假生活都快发霉了?别急,今天我要揭秘一个宝藏网站—— ai123.cn,它简直就是咱们暑期宅家必备的救星!接下来,我就来…

Selenium相对定位

测试网站:Web form 相对定位的方法: above():定位基准元素上方的元素below():定位基准元素下方的元素to_left_of():定位基准元素左侧的元素to_right_of():定位基准元素右侧的元素near() :定位基…

Windows横向渗透

准备靶机windows:192.168.10.131 准备攻击机:192.168.10.130 1.用cs连接到了windows靶机 2.使用cs探测内网信息: 查看当前目标系统网络情况,确认目标系统所在内网网段为10段 3.使用cs的portscan功能对内网进行扫描 portscan 1…

aarch64环境安装minio

1.去官网查看最新版本 MinIO | 用于AI的S3 & Kubernetes原生对象存储 2.使用命令安装,采取wget和dnf安装 wget https://dl.min.io/server/minio/release/linux-arm64/archive/minio-20240113075303.0.0-1.aarch64.rpm -O minio.rpm sudo dnf install minio.rpm 注意点…

MATLAB学习日志DAY16

16.数组类型(1) 16.1多维数组 MATLAB 环境中的多维数组是具有多个下标的数组。创建多维数组的一种方法是调用具有多个参数的 zeros、ones、rand 或 randn。 R randn(3,4,5); 创建一个 345 数组,共包含 3*4*5 60 个正态分布的随机元素。…

springboot在加了mapper之后报错

springboot在加了mapper之后报错 最后发现是spring boot版本不兼容,spring-boot-starter-parent换成3.0.5之后可以了

大模型金九银十秋招:AI时代的就业新趋势,收藏我这篇就够了非常详细

随着人工智能技术的飞速发展,大模型(Large Models)在各个领域的应用日益广泛,从自然语言处理到图像识别,从自动驾驶到智能推荐系统,大模型正逐渐成为AI领域的新宠。在这个背景下,大模型的秋招&a…