如何在R语言中使用MongoDB客户端执行原子事务？

支持情况说明 #

目前R生态下唯一仍在活跃维护、且支持原子事务的MongoDB客户端是mongolite包，2.0及以上版本可完美适配MongoDB 4.0+推出的多文档原子事务能力。其他已停止维护的客户端（如RMongo等）均不支持事务功能，不推荐使用。
注意：事务是MongoDB服务端的原生能力，仅当你的MongoDB部署为副本集或分片集群模式时才可使用，单机部署实例不支持事务，和R客户端无关。

具体操作步骤 #

1. 环境校验 #

• 确认MongoDB服务版本≥4.0，且部署为副本集/分片集群模式
• 确认R环境安装的mongolite包版本≥2.0，可执行packageVersion("mongolite")查看版本，版本过低可执行install.packages("mongolite")升级

2. 事务操作流程 #

核心逻辑为：获取会话对象→启动事务→执行所有关联操作→无异常则提交、出现异常则回滚。所有事务内的操作必须绑定对应的会话对象，否则会脱离事务上下文。

代码示例

library(mongolite)
# 初始化Mongo连接，替换为你的实际连接信息
mongo_conn <- mongo(
  collection = "test_col", 
  db = "test_db", 
  url = "mongodb://localhost:27017"
)
# 获取专属会话对象
session <- mongo_conn$session()
# 启动事务
session$start_transaction()
# 执行事务操作，异常捕获确保原子性
tryCatch({
  # 事务内插入操作，必须传入session参数
  mongo_conn$insert(
    list(user_id = 1001, balance = 500, create_time = Sys.time()),
    session = session
  )
  # 事务内更新操作
  mongo_conn$update(
    '{"user_id": 1002}',
    '{"$inc": {"balance": -200}}',
    session = session
  )
  # 所有操作无异常，提交事务
  session$commit_transaction()
  print("事务提交成功，所有操作均生效")
}, error = function(e) {
  # 任意操作报错，回滚全部事务操作
  session$abort_transaction()
  print(paste0("事务已回滚，错误原因：", e$message))
})

注意事项 #

• 事务内的所有读写操作必须传入生成的session参数，否则操作不具备原子性
• MongoDB默认单事务大小上限为16MB，超出限制的事务会直接执行失败
• 事务存在默认超时时间，长时间未提交的事务会被MongoDB服务端自动终止
• 跨集合、跨数据库的事务操作同样支持，只需确保所有操作都绑定同一个会话对象即可

内容的提问来源于stack exchange，提问作者AnjaM