- MongoDB官方文档中文版
- MongoDB用户手册
- MongoDB简介
- 安装 MongoDB
- 安装MongoDB社区版
- 安装MongoDB企业版
- 将社区版MongoDB升级到企业版MongoDB
- 验证MongoDB软件包的完整性
- Mongo Shell
- 增删改查操作
- 聚合
- 数据模式
- 数据建模介绍
- 模式验证
- Data Modeling Concepts
- Data Model Examples and Patterns
- Model Relationships Between Documents
- Model One-to-One Relationships with Embedded Documents
- Model One-to-Many Relationships with Embedded Documents
- Model One-to-Many Relationships with Document References
- Model Tree Structures
- Model Tree Structures with Parent References
- Model Tree Structures with Child References
- Model Tree Structures with an Array of Ancestors
- Model Tree Structures with Materialized Paths
- Model Tree Structures with Nested Sets
- Model Specific Application Contexts
- Model Data for Atomic Operations
- Model Data to Support Keyword Search
- Model Data for Schema Versioning
- Model Monetary Data
- Model Time Data
- Model Computed Data
- Data Model Reference
- 事务
- 索引
- Single Field Indexes
- Compound Indexes
- Multikey Indexes
- Text Indexes
- Wildcard Indexes
- 2dsphere Indexes
- 2d Indexes
- geoHaystack Indexes
- Hashed Indexes
- 索引特性
- Index Builds on Populated Collections
- 索引交集
- Manage Indexes
- 衡量索引使用
- Indexing Strategies
- Indexing Reference
- 2d索引
- 2dsphere索引
- 复合索引
- geoHaystack索引
- Hashed 索引
- 在填充的集合上建立索引
- 索引参考
- 索引策略
- 管理索引
- 多键索引
- 单字段索引
- 文本索引
- 通配符索引
- 安全
- 安全检查列表
- Enable Access Control
- 身份验证
- Users
- Add Users
- Authentication Mechanisms
- SCRAM
- x.509
- Enterprise Authentication Mechanisms
- Kerberos Authentication
- LDAP Proxy Authentication
- LDAP Authorization
- Internal/Membership Authentication
- Deploy Replica Set With Keyfile Authentication
- Update Replica Set to Keyfile Authentication
- Update Replica Set to Keyfile Authentication (No Downtime)
- Rotate Keys for Replica Sets
- Deploy Sharded Cluster with Keyfile Authentication
- Update Sharded Cluster to Keyfile Authentication
- Update Sharded Cluster to Keyfile Authentication (No Downtime)
- Rotate Keys for Sharded Clusters
- Use x.509 Certificate for Membership Authentication
- Upgrade from Keyfile Authentication to x.509 Authentication
- Rolling Update of x.509 Cluster Certificates that Contain New DN
- Role-Based Access Control
- TLS/SSL (Transport Encryption)
- Encryption at Rest
- Client-Side Field Level Encryption
- 审计
- Network and Configuration Hardening
- Implement Field Level Redaction
- Security Reference
- Create a Vulnerability Report
- Appendix
- 附录
- 启用访问控制
- 网络和配置强化
- 安全参考
- 改变流
- 复制集
- 复制集成员
- 副本集日志
- Replica Set Data Synchronization
- 副本集部署架构
- Replica Set High Availability
- Replica Set Read and Write Semantics
- Replica Set Deployment Tutorials
- Member Configuration Tutorials
- Replica Set Maintenance Tutorials
- Change the Size of the Oplog
- Perform Maintenance on Replica Set Members
- Force a Member to Become Primary
- Resync a Member of a Replica Set
- Configure Replica Set Tag Sets
- Reconfigure a Replica Set with Unavailable Members
- Manage Chained Replication
- Change Hostnames in a Replica Set
- Configure a Secondary’s Sync Target
- Replication Reference
- 副本集数据同步
- 分片
- 分片集群组成]
- 片键
- 哈希分片
- 范围分片
- 部署分片集群
- 区域
- Data Partitioning with Chunks
- Balancer
- Administration
- Config Server Administration
- Replace a Config Server
- View Cluster Configuration
- Restart a Sharded Cluster
- Migrate a Sharded Cluster to Different Hardware
- Add Shards to a Cluster
- Remove Shards from an Existing Sharded Cluster
- Clear jumbo Flag
- Back Up Cluster Metadata
- Convert Sharded Cluster to Replica Set
- Convert a Replica Set to a Sharded Cluster
- Convert a Shard Standalone to a Shard Replica Set
- Sharding Reference
- 分片键
- Zone
- 管理权限
- 产品说明
- Operations Checklist
- Development Checklist
- Performance
- 配置和维护
- Data Center Awareness
- MongoDB Backup Methods
- Back Up and Restore with Filesystem Snapshots
- Back Up and Restore with MongoDB Tools
- Restore a Replica Set from MongoDB Backups
- Backup and Restore Sharded Clusters
- Back Up a Sharded Cluster with File System Snapshots
- Back Up a Sharded Cluster with Database Dumps
- Schedule Backup Window for Sharded Clusters
- Restore a Sharded Cluster
- Recover a Standalone after an Unexpected Shutdown
- Monitoring for MongoDB
- 开发检查表
- MogoDB 备份方法
- 操作检查表
- MongoDB性能
- 存储
- 常见问题
- 参考
- Operators
- Query and Projection Operators
- Comparison Query Operators
- Logical Query Operators
- Element Query Operators
- Evaluation Query Operators
- Geospatial Query Operators
- Array Query Operators
- Bitwise Query Operators
- $comment
- 查询与映射运算符
- 更新运算符
- Field Update Operators
- Array Update Operators
- Bitwise Update Operator
- Aggregation Pipeline Stages
- $addFields (aggregation)
- $bucket (aggregation)
- $bucketAuto (aggregation)
- $collStats (aggregation)
- $count (aggregation)
- $currentOp (aggregation)
- $facet (aggregation)
- $geoNear (aggregation)
- $graphLookup (aggregation)
- $group (aggregation)
- $indexStats (aggregation)
- $limit (aggregation)
- $listLocalSessions
- $listSessions
- $lookup (aggregation)
- $match (aggregation)
- $merge (aggregation)
- $out (aggregation)
- $planCacheStats
- $project (aggregation)
- $redact (aggregation)
- $replaceRoot (aggregation)
- $replaceWith (aggregation)
- $sample (aggregation)
- $set (aggregation)
- $skip (aggregation)
- $sort (aggregation)
- $sortByCount (aggregation)
- $unionWith (aggregation)
- $unset (aggregation)
- $unwind (aggregation)
- Aggregation Pipeline Operators
- $sin (aggregation)
- $abs (aggregation)
- $slice (aggregation)
- $accumulator (aggregation)
- $split (aggregation)
- $acos (aggregation)
- $sqrt (aggregation)
- $acosh (aggregation)
- $add (aggregation)
- $addToSet (aggregation)
- $allElementsTrue (aggregation)
- $and (aggregation)
- $anyElementTrue (aggregation)
- $arrayElemAt (aggregation)
- $arrayToObject (aggregation)
- $asin (aggregation)
- $asinh (aggregation)
- $sum (aggregation)
- $atan (aggregation)
- $atan2 (aggregation)
- $tan (aggregation)
- $atanh (aggregation)
- $avg (aggregation)
- $binarySize (aggregation)
- $bsonSize (aggregation)
- $ceil (aggregation)
- $toInt (aggregation)
- $cmp (aggregation)
- $concat (aggregation)
- $concatArrays (aggregation)
- $cond (aggregation)
- $convert (aggregation)
- $cos (aggregation)
- $dateFromParts (aggregation)
- $dateToParts (aggregation)
- $type (aggregation)
- $dateFromString (aggregation)
- $week (aggregation)
- $dateToString (aggregation)
- $year (aggregation)
- $dayOfMonth (aggregation)
- $zip (aggregation)
- $dayOfWeek (aggregation)
- $dayOfYear (aggregation)
- $degreesToRadians (aggregation)
- $divide (aggregation)
- $eq (aggregation)
- $exp (aggregation)
- $filter (aggregation)
- $first (aggregation accumulator)
- $first (aggregation)
- $floor (aggregation)
- $function (aggregation)
- $gt (aggregation)
- $gte (aggregation)
- $hour (aggregation)
- $ifNull (aggregation)
- $in (aggregation)
- $indexOfArray (aggregation)
- $indexOfBytes (aggregation)
- $indexOfCP (aggregation)
- $isArray (aggregation)
- $isNumber (aggregation)
- $isoDayOfWeek (aggregation)
- $isoWeek (aggregation)
- $isoWeekYear (aggregation)
- $last (aggregation accumulator)
- $last (aggregation)
- $let (aggregation)
- $literal (aggregation)
- $ln (aggregation)
- $log (aggregation)
- $log10 (aggregation)
- $lt (aggregation)
- $lte (aggregation)
- $trim (aggregation)
- $map (aggregation)
- $max (aggregation)
- $mergeObjects (aggregation)
- $meta
- $min (aggregation)
- $millisecond (aggregation)
- $minute (aggregation)
- $mod (aggregation)
- $month (aggregation)
- $multiply (aggregation)
- $ne (aggregation)
- $not (aggregation)
- $objectToArray (aggregation)
- $or (aggregation)
- $pow (aggregation)
- $push (aggregation)
- $radiansToDegrees (aggregation)
- $range (aggregation)
- $reduce (aggregation)
- $regexFind (aggregation)
- $regexFindAll (aggregation)
- $regexMatch (aggregation)
- $replaceOne (aggregation)
- $replaceAll (aggregation)
- $reverseArray (aggregation)
- $round (aggregation)
- $rtrim (aggregation)
- $second (aggregation)
- $setDifference (aggregation)
- $setEquals (aggregation)
- $setIntersection (aggregation)
- $setIsSubset (aggregation)
- $setUnion (aggregation)
- $size (aggregation)
- $slice (aggregation)
- $split (aggregation)
- $sqrt (aggregation)
- $stdDevPop (aggregation)
- $stdDevSamp (aggregation)
- $strcasecmp (aggregation)
- $strLenBytes (aggregation)
- $strLenCP (aggregation)
- $substr (aggregation)
- $substrBytes (aggregation)
- $substrCP (aggregation)
- $subtract (aggregation)
- $sum (aggregation)
- $switch (aggregation)
- $tan (aggregation)
- $toBool (aggregation)
- $toDate (aggregation)
- $toDecimal (aggregation)
- $toDouble(aggregation)
- $toInt (aggregation)
- $toLong (aggregation)
- $toObjectId (aggregation)
- $toString (aggregation)
- $toLower (aggregation)
- $toUpper (aggregation)
- $trim (aggregation)
- $trunc (aggregation)
- $type (aggregation)
- $week (aggregation)
- $year (aggregation)
- $zip (aggregation)
- 查询修饰符
- $comment
- $explain
- $hint
- $max
- $maxTimeMS
- $min
- $orderby
- $query
- $returnKey
- $showDiskLoc
- $natural
- 聚合管道操作符
- $abs (aggregation)
- $acos (aggregation)
- $acosh (aggregation)
- $add (aggregation)
- $addToSet (aggregation)
- $and (aggregation)
- $anyElementTrue (aggregation)
- $arrayElemAt (aggregation)
- $arrayToObject (aggregation)
- $asin (aggregation)
- $asinh (aggregation)
- $atan (aggregation)
- $atan2 (aggregation)
- $atanh (aggregation)
- $avg (aggregation)
- $ceil (aggregation)
- $cmp (aggregation)
- $concat (aggregation)
- $concatArrays (aggregation)
- $cond (aggregation)
- $convert (aggregation)
- $cos (aggregation)
- $dateFromParts (aggregation)
- $dateFromString (aggregation)
- $dateToParts (aggregation)
- $dateToString (aggregation)
- $literal (aggregation)
- 聚合管道阶段
- 数据库命令
- Aggregation Commands
- aggregate
- count
- distinct
- mapReduce
- Geospatial Commands
- geoSearch
- Query and Write Operation Commands
- delete
- find
- findAndModify
- getLastError
- getMore
- insert
- resetError
- update
- 查询计划缓存命令
- planCacheClear
- planCacheClearFilters
- planCacheListFilters
- planCacheSetFilter
- 认证命令
- authenticate
- getnonce
- logout
- User Management Commands
- createUser
- dropAllUsersFromDatabase
- dropUser
- grantRolesToUser
- revokeRolesFromUser
- updateUser
- usersInfo
- Role Management Commands
- createRole
- dropRole
- dropAllRolesFromDatabase
- grantPrivilegesToRole
- grantRolesToRole
- invalidateUserCache
- revokePrivilegesFromRole
- revokeRolesFromRole
- rolesInfo
- updateRole
- Replication Commands
- applyOps
- isMaster
- replSetAbortPrimaryCatchUp
- replSetFreeze
- replSetGetConfig
- replSetGetStatus
- replSetInitiate
- replSetMaintenance
- replSetReconfig
- replSetResizeOplog
- replSetStepDown
- replSetSyncFrom
- Sharding Commands
- addShard
- addShardToZone
- balancerCollectionStatus
- balancerStart
- balancerStatus
- balancerStop
- checkShardingIndex
- clearJumboFlag
- cleanupOrphaned
- enableSharding
- flushRouterConfig
- getShardMap
- getShardVersion
- isdbgrid
- listShards
- medianKey
- moveChunk
- movePrimary
- mergeChunks
- refineCollectionShardKey
- removeShard
- removeShardFromZone
- setShardVersion
- shardCollection
- shardingState
- split
- splitChunk
- splitVector
- unsetSharding
- updateZoneKeyRange
- Sessions Commands
- abortTransaction
- commitTransaction
- endSessions
- killAllSessions
- killAllSessionsByPattern
- killSessions
- refreshSessions
- startSession
- Administration Commands
- cloneCollectionAsCapped
- collMod
- compact
- connPoolSync
- convertToCapped
- create
- createIndexes
- currentOp
- drop
- dropDatabase
- dropConnections
- dropIndexes
- filemd5
- fsync
- fsyncUnlock
- getDefaultRWConcern
- getParameter
- killCursors
- killOp
- listCollections
- listDatabases
- listIndexes
- logRotate
- reIndex
- renameCollection
- setFeatureCompatibilityVersion
- setIndexCommitQuorum
- setParameter
- setDefaultRWConcern
- shutdown
- Diagnostic Commands
- availableQueryOptions
- buildInfo
- collStats
- connPoolStats
- connectionStatus
- cursorInfo
- dataSize
- dbHash
- dbStats
- diagLogging
- driverOIDTest
- explain
- features
- getCmdLineOpts
- getLog
- hostInfo
- isSelf
- listCommands
- lockInfo
- netstat
- ping
- profile
- serverStatus
- shardConnPoolStats
- top
- validate
- whatsmyuri
- 免费监控命令
- getFreeMonitoringStatus
- setFreeMonitoring
- 数据库命令
- logApplicationMessage
- 管理命令
- 聚合命令
- 诊断命令
- 地理空间命令
- 查询和写操作命令
- 复制命令
- 角色管理命令
- 会话命令
- 分片命令
- 用户管理命令
- mongo Shell 方法
- Collection Methods
- db.collection.aggregate()
- db.collection.bulkWrite()
- db.collection.copyTo()
- db.collection.count()
- db.collection.countDocuments()
- db.collection.estimatedDocumentCount()
- db.collection.createIndex()
- db.collection.createIndexes()
- db.collection.dataSize()
- db.collection.deleteOne()
- db.collection.deleteMany()
- db.collection.distinct()
- db.collection.drop()
- db.collection.dropIndex()
- db.collection.dropIndexes()
- db.collection.ensureIndex()
- db.collection.explain()
- db.collection.find()
- db.collection.findAndModify()
- db.collection.findOne()
- db.collection.findOneAndDelete()
- db.collection.findOneAndReplace()
- db.collection.findOneAndUpdate()
- db.collection.getIndexes()
- db.collection.getShardDistribution()
- db.collection.getShardVersion()
- db.collection.hideIndex()
- db.collection.insert()
- db.collection.insertOne()
- db.collection.insertMany()
- db.collection.isCapped()
- db.collection.latencyStats()
- db.collection.mapReduce()
- db.collection.reIndex()
- db.collection.remove()
- db.collection.renameCollection()
- db.collection.replaceOne()
- db.collection.save()
- db.collection.stats()
- db.collection.storageSize()
- db.collection.totalIndexSize()
- db.collection.totalSize()
- db.collection.unhideIndex()
- db.collection.update()
- db.collection.updateOne()
- db.collection.updateMany()
- db.collection.watch()
- db.collection.validate()
- Cursor Methods
- cursor.addOption()
- cursor.allowDiskUse()
- cursor.allowPartialResults()
- cursor.batchSize()
- cursor.close()
- cursor.isClosed()
- cursor.collation()
- cursor.comment()
- cursor.count()
- cursor.explain()
- cursor.forEach()
- cursor.hasNext()
- cursor.hint()
- cursor.isExhausted()
- cursor.itcount()
- cursor.limit()
- cursor.map()
- cursor.max()
- cursor.maxTimeMS()
- cursor.min()
- cursor.next()
- cursor.noCursorTimeout()
- cursor.objsLeftInBatch()
- cursor.pretty()
- cursor.readConcern()
- cursor.readPref()
- cursor.returnKey()
- cursor.showRecordId()
- cursor.size()
- cursor.skip()
- cursor.sort()
- cursor.tailable()
- cursor.toArray()
- Database Methods
- db.adminCommand()
- db.aggregate()
- db.cloneDatabase()
- db.commandHelp()
- db.copyDatabase()
- db.createCollection()
- db.createView()
- db.currentOp()
- db.dropDatabase()
- db.eval()
- db.fsyncLock()
- db.fsyncUnlock()
- db.getCollection()
- db.getCollectionInfos()
- db.getCollectionNames()
- db.getLastError()
- db.getLastErrorObj()
- db.getLogComponents()
- db.getMongo()
- db.getName()
- db.getProfilingLevel()
- db.getProfilingStatus()
- db.getReplicationInfo()
- db.getSiblingDB()
- db.help()
- db.hostInfo()
- db.isMaster()
- db.killOp()
- db.listCommands()
- db.logout()
- db.printCollectionStats()
- db.printReplicationInfo()
- db.printShardingStatus()
- db.printSlaveReplicationInfo()
- db.resetError()
- db.runCommand()
- db.serverBuildInfo()
- db.serverCmdLineOpts()
- db.serverStatus()
- db.setLogLevel()
- db.setProfilingLevel()
- db.shutdownServer()
- db.stats()
- db.version()
- db.watch()
- Query Plan Cache Methods
- db.collection.getPlanCache()
- PlanCache.clear()
- PlanCache.clearPlansByQuery()
- PlanCache.help()
- PlanCache.list()
- Bulk Operation Methods
- db.collection.initializeOrderedBulkOp()
- db.collection.initializeUnorderedBulkOp()
- Bulk()
- Bulk.execute()
- Bulk.find()
- Bulk.find.arrayFilters()
- Bulk.find.collation()
- Bulk.find.hint()
- Bulk.find.remove()
- Bulk.find.removeOne()
- Bulk.find.replaceOne()
- Bulk.find.updateOne()
- Bulk.find.update()
- Bulk.find.upsert()
- Bulk.getOperations()
- Bulk.insert()
- Bulk.tojson()
- Bulk.toString()
- User Management Methods
- db.auth()
- db.changeUserPassword()
- db.createUser()
- db.dropUser()
- db.dropAllUsers()
- db.getUser()
- db.getUsers()
- db.grantRolesToUser()
- db.removeUser()
- db.revokeRolesFromUser()
- db.updateUser()
- passwordPrompt()
- Role Management Methods
- db.createRole()
- db.dropRole()
- db.dropAllRoles()
- db.getRole()
- db.getRoles()
- db.grantPrivilegesToRole()
- db.revokePrivilegesFromRole()
- db.grantRolesToRole()
- db.revokeRolesFromRole()
- db.updateRole()
- Replication Methods
- rs.add()
- rs.addArb()
- rs.conf()
- rs.freeze()
- rs.help()
- rs.initiate()
- rs.printReplicationInfo()
- rs.printSlaveReplicationInfo()
- rs.reconfig()
- rs.remove()
- rs.status()
- rs.stepDown()
- rs.syncFrom()
- Sharding Methods
- sh.addShard()
- sh.addShardTag()
- sh.addShardToZone()
- sh.addTagRange()
- sh.balancerCollectionStatus()
- sh.disableBalancing()
- sh.enableBalancing()
- sh.disableAutoSplit
- sh.enableAutoSplit
- sh.enableSharding()
- sh.getBalancerHost()
- sh.getBalancerState()
- sh.removeTagRange()
- sh.removeRangeFromZone()
- sh.help()
- sh.isBalancerRunning()
- sh.moveChunk()
- sh.removeShardTag()
- sh.removeShardFromZone()
- sh.setBalancerState()
- sh.shardCollection()
- sh.splitAt()
- sh.splitFind()
- sh.startBalancer()
- sh.status()
- sh.stopBalancer()
- sh.waitForBalancer()
- sh.waitForBalancerOff()
- sh.waitForPingChange()
- sh.updateZoneKeyRange()
- convertShardKeyToHashed
- Free Monitoring Methods
- db.disableFreeMonitoring()
- db.enableFreeMonitoring()
- db.getFreeMonitoringStatus
- Object Constructors and Methods
- BulkWriteResult()
- Date()
- ObjectId
- ObjectId.getTimestamp()
- ObjectId.toString()
- ObjectId.valueOf()
- UUID()
- WriteResult()
- WriteResult.hasWriteError()
- WriteResult.hasWriteConcernError()
- Connection Methods
- connect()
- Mongo()
- Mongo.getDB()
- Mongo.getReadPrefMode()
- Mongo.getReadPrefTagSet()
- Mongo.isCausalConsistency()
- Mongo.setCausalConsistency()
- Mongo.setReadPref()
- Mongo.startSession()
- Mongo.watch()
- Session
- SessionOptions
- Native Methods
- cat()
- cd()
- copyDbpath()
- getHostName()
- getMemInfo()
- hostname()
- isInteractive()
- listFiles()
- load()
- ls()
- md5sumFile()
- mkdir()
- pwd()
- quit()
- removeFile()
- resetDbpath()
- sleep()
- setVerboseShell()
- version()
- _isWindows()
- _rand()
- Client-Side Field Level Encryption Methods
- getKeyVault()
- KeyVault.createKey()
- KeyVault.deleteKey()
- KeyVault.getKey()
- KeyVault.getKeys()
- KeyVault.addKeyAlternateName()
- KeyVault.removeKeyAlternateName()
- KeyVault.getKeyByAltName()
- getClientEncryption()
- ClientEncryption.encrypt()
- ClientEncryption.decrypt()
- mongo Shell 方法
- MongoDB Package Components
- Configuration File Options
- MongoDB Server Parameters
- MongoDB Limits and Thresholds
- Explain Results
- System Collections
- 连接字符串URI格式
- 排序
- MongoDB的Wire协议
- 日志消息
- Exit Codes and Statuses
- 词汇表
- 默认的MongoDB端口
- Default MongoDB Read Concerns/Write Concerns
- 服务器会话
- Configuration File Options
- 默认的MongoDB读/写关注
- 退出代码和状态
- MongoDB Limits and Thresholds
- Operators
- 更新说明
- Release Notes for MongoDB 4.4
- Release Notes for MongoDB 4.2
- Release Notes for MongoDB 4.0
- Release Notes for MongoDB 3.6
- Release Notes for MongoDB 3.4
- Release Notes for MongoDB 3.2
- Release Notes for MongoDB 3.0
- Release Notes for MongoDB 2.6
- Release Notes for MongoDB 2.4
- Release Notes for MongoDB 2.2
- Release Notes for MongoDB 2.0
- Release Notes for MongoDB 1.8
- Release Notes for MongoDB 1.6
- Release Notes for MongoDB 1.4
- Release Notes for MongoDB 1.2.x
- MongoDB Versioning
- 技术支持
- 开始使用MongoDB开发
- 联系我们
- 更多资料
- 本书使用 GitBook 发布
事务
事务
在本页
在MongoDB中,对单个文档的操作是原子的。因为您可以使用嵌入式文档和数组来捕获单个文档结构中的数据之间的关系,而不是在多个文档和集合之间进行规范化,所以这种单文档原子性消除了许多实际用例中对多文档事务的需求。
对于需要原子性地读写多个文档(在单个或多个集合中)的情况,MongoDB支持多文档事务。使用分布式事务,可以跨多个操作,集合,数据库,文档和分片使用事务。
事务API
以下示例重点介绍了事务API的关键组成:
译者注,原文可看不同类型的代码
PYTHON
JAVA (SYNC)
NODE.JS
- PHP
- MOTOR
- C
- C++11
- C
该示例使用新的回调API来处理事务,该API启动事务,执行指定的操作并提交(可能因为错误而中止)。新的回调API还针对 TransientTransactionError
或UnknownTransactionCommitResult
提交错误合并了重试逻辑。
重点
对于MongoDB 4.2(副本集和分片群集)上的事务,客户端必须使用将MongoDB驱动程序更新为MongoDB 4.2。
使用驱动程序时,事务中的每个操作必须与会话相关联(即,将每个操作传递在会话中传递)。
参考
比如,在mongo shell中参考 mongo Shell Example.
事务和原子性
分布式事务和多文档事务
从MongoDB 4.2开始,这两个术语是同义词。 分布式事务是指分片群集和副本集上的多文档事务。 从MongoDB 4.2开始,多文档事务(无论是在分片群集或副本集上)也称为分布式事务。
对于需要原子性地读写多个文档(在单个或多个集合中)的情况,MongoDB支持多文档事务:
在4.0版中,MongoDB支持副本集上的多文档事务。
在版本4.2中,MongoDB引入了分布式事务,它增加了对分片群集上多文档事务的支持,并合并了对副本集上多文档事务的现有支持。
要在MongoDB 4.2部署(副本集和分片群集)上使用事务,客户端必须使用为MongoDB 4.2更新的MongoDB驱动程序。
多文档交易是原子性的(即提供“全有或全无”主张):
- 提交事务时,将保存在事务中进行的所有数据更改,并在事务外部可见。 也就是说,一个事务在回滚其他事务时将不会提交其某些更改。在提交事务之前,在事务外部看不到在事务中进行的数据更改。
但是,当事务写入多个分片时,并非所有外部读取操作都需要等待已提交事务的结果在所有分片上可见。 例如,如果提交了一个事务,并且在分片A上可以看到写1,但是在分片B上却看不到写2,则外部读取时设置读关注 "local"
结果为可以读取写入1的结果而看不到写入2。
- 当事务中止时,在事务中进行的所有数据更改都将被丢弃,而不会变得可见。 例如,如果事务中的任何操作失败,则事务中止,并且在事务中进行的所有数据更改都将被丢弃,而不会变得可见。
重点
在大多数情况下,与单文档写入相比,多文档事务产生的性能成本更高,并且多文档事务的可用性不应替代有效的架构设计。 在许多情况下, 非规范化数据模型(嵌入的文档和数组) 仍将是最佳选择您的数据和用例。 也就是说,在许多情况下,适当地对数据建模将最大程度地减少对多文档交易的需求。
有关其他事务使用方面的注意事项(例如运行时限制和oplog大小限制),另请参阅生产注意事项.
也可参考提交期间的外部读取
事务和操作
分布式事务可用于多个操作,集合,数据库,文档,以及从MongoDB 4.2分片开始的。
对于事务:
您可以在现有集合上指定读/写(CRUD)操作。集合可以在不同的数据库中。有关CRUD操作的列表,请参考 CRUD 操作。
您无法写入 capped 集合。 (从MongoDB 4.2开始)
您无法在
config
,admin
或local
数据库中读取/写入集合。您无法写入
system。*
集合。您无法返回支持的操作的查询计划(如
explain
)。对于在事务外部创建的游标,不能在事务内部调用
getMore
。对于在事务中创建的游标,不能在事务外调用
getMore
。从MongoDB 4.2开始,您不能将
killCursors
指定为事务的第一个操作。
事务中不允许执行影响数据库目录的操作,例如创建或删除集合或索引。例如,事务不能包含将导致创建新集合的插入操作。请参阅受限操作。
提示
创建或删除集合后立即开始事务,如果在事务内访问了该集合,请在创建或者删除时设置write concern为 "majority"
,以确保该事务可以获取所需的锁。
可参考:事务和操作参考
count 操作
要在事务中执行计数操作,请使用 $count
聚合阶段或者 $group
(带有 $sum
表达式)聚合阶段。
与4.0功能兼容的MongoDB驱动程序提供了一个集合级API countDocuments(filter, options)
作为使用带有$sum
的 $group
表达式进行计数。4.0驱动程序已弃用 count()
API。
从MongoDB 4.0.3开始, mongo
shell提供使用$sum
的 $group
表达式进行计数的 db.collection.countDocuments()
方法。
distinct 操作
在事务中执行不同的操作:
对于未分片的集合,可以使用
db.collection.distinct()
方法或者distinct
命令以及具有$group
阶段的聚合管道。对于分片集合,不可以使用
db.collection.distinct()
方法或者distinct
命令。
要查找分片集合的不同值,请使用带有 $group
阶段的聚合管道,例如:
- 代替
db.coll.distinct("x")
,使用
db.coll.aggregate([
{ $group: { _id: null, distinctValues: { $addToSet: "$x" } } },
{ $project: { _id: 0 } }
])
- 代替
db.coll.distinct("x", { status: "A" })
,使用:
db.coll.aggregate([
{ $match: { status: "A" } },
{ $group: { _id: null, distinctValues: { $addToSet: "$x" } } },
{ $project: { _id: 0 } }
])
管道将游标返回到文档:
{ "distinctValues" : [ 2, 3, 1 ] }
迭代光标以访问结果文档。
信息类操作
信息命令在事务中是允许的,如 isMaster
, buildInfo
, connectionStatus
(以及辅助方法);但是他们不能是事务中的第一个操作。
限制的操作
事务中不允许以下的操作:
- 影响数据库目录的操作,例如创建或删除集合或索引。 例如,事务不能包含将导致创建新集合的插入操作。
listCollections
和 listIndexes
命令及其辅助方法也被排除在外。
- 非CRUD和非信息性操作,例如
createUser
,getParameter
,count
等等及其辅助命令。
可参考
事务和会话
事务与会话关联; 即您开始一个会话的事务。
在任何给定时间,一个会话最多只能有一个未完成的事务。
使用驱动程序时,事务中的每个操作必须与会话关联。 有关详细信息,请参阅驱动程序专用文档。
如果会话结束并且具有打开的事务,则事务中止。
读关注/写关注/读偏好
事务和读偏好
事务中的操作使用事务级别的读偏好。
使用驱动程序,可以在事务开始时设置事务级别的 读偏好 :
如果未设置事务级别的读取首选项,则事务将使用会话级别的读取首选项。
如果未设置事务级别和会话级别的读选项,则事务将使用客户端级别的读偏好。 默认情况下,客户端级别的读选项为
primary
。
包含读取操作的多文档事务必须使用读偏好primary
。 给定事务中的所有操作都必须路由到同一成员。
事务和读关注
事务中的操作使用事务级别的读关注。 也就是说,在事务内部忽略在集合和数据库级别设置的任何读取关注。
您可以在事务开始时设置事务级别的读关注。
如果未设置事务级读关注,则事务级读关注默认为会话级读关注。
如果未设置事务级别和会话级别的读关注,则事务级别的读取关注点默认为客户端级别的读关注。 默认情况下,对于主服务器的读取,客户端级别的读关注为
“ local”
。 另请参见事务和读选项。
事务支持一下读关注级别:
"local"
读关注点
“ local”
返回该节点可用的最新数据,但可以回滚。对于分片群集上的事务,
“ local”
读关注不能保证数据是从整个分片的同一快照视图获取。 如果需要快照隔离,请使用“snapshot”读关注。
"majority"
如果以写关注“majority”提交事务,读关注
"majority"
返回大多数副本成员已确认的数据(即无法回滚数据)。如果事务未使用 写关注“majority” 进行提交,则
“majority”
读关注不保证读操作可以读取多数提交的数据。对于分片群集上的事务,
“majority”
读取关注不能保证数据是从整个分片的同一快照视图中获取。 如果需要快照隔离,请使用“snapshot”读关注。
"snapshot"
如果事务提交时带有写关注“majority”,读关注
"snapshot"
从大多数已提交数据的快照中返回数据。如果事务未使用写关注“majority”进行提交,则
"snapshot"
读关注不保证读操作使用了大部分提交的数据的快照。对于分片群集上的事务,数据的
"snapshot"
视图 跨分片同步。
事务和写关注
事务使用事务级别的写关注进行写操作。 必须在没有显式写关注规范的情况下发出事务内部的写操作,并使用默认写关注。 在提交时,然后使用事务级写关注来提交写操作。
提示:
不要为事务中的各个写操作明确设置写关注。 为事务中的各个写操作设置写关注点将导致错误。
您可以在事务开始时设置事务级别的写关注:
如果未设置事务级写关注,则事务级写关注默认为提交的会话级写关注。
如果未设置事务级写关注和会话级写关注,则事务级写关注默认为客户端级写关注。 默认情况下,客户端级别的写入问题为
w:1
。
事务支持所有写关注w值,包括:
w: 1
- 在主节点提交写关注w:1后返回确认。
重要
当您使用w:1
提交时,您的事务如果存在故障则可以回滚。
当您提交
w:1
时,会写成事物级别的“majority”
读关注,不保证事务中的读取操作会读取多数提交的数据 。当您提交
w:1
时,会写成事务级别的"snapshot"
,读取关注不保证事务中的读取操作使用多数快照提交的数据。
w: "majority"
在提交已应用于多数( M)有投票权的成员后,写关注
w:“majority”
返回确认; 即提交已应用于主要和(M-1)个投票辅助。当您提交
w:“ majority”
时,事务级别的“ majority “
读关注保证了操作已读取多数提交的数据。 对于分片群集上的事务,大多数分批提交的数据的视图不会在分片之间同步。当您使用
w:“majority”
提交时,事务级别“快照 “读关注保证操作来自大多数提交的数据的同步快照。
注意
不管事务指定的写关注,分片集群事务的提交操作都包含使用{w:“多数”,j:是}
写关注。
一般信息
注意事项
有关使用事务的各种注意事项,请参阅注意事项。 另外,分片群集,另请参见注意事项(分片群集)。
仲裁者
如果任何事务操作读取或写入包含仲裁程序的分片,则其写操作跨越多个分片的事务将出错并中止。
另请参见禁用读关注Majority,以了解已禁用读关注majority的分片的事务限制。
禁用读关注Majority
一个含有3成员PSA(主-次-仲裁器)副本集,或具有3成员PSA分片的分片群集可能已禁用读关注Majority(--enableMajorityReadConcern false
或replication.enableMajorityReadConcern:false
)
- 对于分片集群:
如果事务涉及的分片具有禁用读关注Majority,则事务中不能使用的读关注“快照”
。 您只能在事务中使用读关注的“ local”
或“majority”
。 如果使用读关注“ snapshot”
,则事务错误并中止。
当enableMajorityReadConcern = false时,分片群集中不支持读关注级别 'snapshot' 。
如果任何事务的读或写操作涉及禁用了读关注"majority"
的分片,则其写操作跨越多个分片的事务将出错并中止。
- 在已禁用读关注“majority”副本集中,您可以指定读关注
“ local”
或“majority”
或“snapshot”
。但是,如果您打算过渡到具有禁用读关注majority分片的分片群集,则避免使用读关注的"snapshot"
。
提示:
检查是否已禁用读关注“majority”,可以在 mongod
上运行db.serverStatus()
并检查storageEngine.supportsCommittedReads
字段。 如果为“ false”,则禁用读关注“majority” 。
有关更多信息,请参阅3-成员主-从-仲裁者体系结构和三成员主-从-仲裁者 分片。
分片配置限制
您不能在writeConcernMajorityJournalDefault
设置为“ false”的分片群集上运行事务( 如 使用内存存储引擎的具有投票成员的分片)。
注意
不管为事务指定的写关注,分片集群事务的提交操作都包含使用{w:“majority”,j:true}
写关注。
诊断
MongoDB提供了各种指标:
方法 | |
---|---|
db.serverStatus() 方法serverStatus 命令 | 返回 事务 指标。 |
$currentOp 聚合管道 | 如果操作是事务的一部分,则返回$currentOp.transaction 。 无效会话 的信息作为事务的一部分持有锁。$currentOp.twoPhaseCommitCoordinator 这些指标涉及向多个分片写入的分片事务。 |
db.currentOp() 方法currentOp 命令 | 如果操作是事务的一部分,则返回currentOp.transaction 。currentOp.twoPhaseCommitCoordinator 这些指标涉及写入多个分片的分片事务。 |
mongod 和 mongos 日志信息 | 包括TXN 日志组件下慢事务信息(即超过operationProfiling.slowOpThresholdMs 阈值的事务信息)。 |
功能兼容版本 (FCV)
要使用事务,部署的所有成员的featureCompatibilityVersion必须至少为:
部署 | Minimum featureCompatibilityVersion //最小FCV |
---|---|
副本 | 4.0 |
分片 | 4.2 |
要检查成员的FCV,请连接到该成员并运行以下命令:
db.adminCommand( { getParameter: 1, featureCompatibilityVersion: 1 } )
有关更多信息,请参见设置FCV
参考页。
存储引擎
从MongoDB 4.2开始,副本集和分片群集支持多文档事务:
主节点使用WiredTiger存储引擎,并且
从成员使用WiredTiger存储引擎或内存存储引擎
在MongoDB 4.0中,仅使用WiredTiger存储引擎的副本集支持事务。
注意:
您无法在具有writeConcernMajorityJournalDefault
设置为“ false”的分片的分片集群上运行事务,例如使用内存存储引擎具有投票成员的分片。
其他事务话题
译者:王金铷
原文链接:https://docs.mongodb.com/manual/core/transactions/
参见
原文 - Transactions
Copyright © 上海锦木信息技术有限公司 all right reserved,powered by Gitbook文件修订时间: 2020-12-18 11:34:57