接上期，MongoDB 的事务操作已经操作了，但细节和参数并没有弄清楚，通过mongodb 的事务操作主要分为以下几个部分
1 Session.startTransaction
2 Session.commitTransaction
3 Session.abortTransaction
简单的回顾一下，MONGODB 的事务，当一个事务中所有对数据的更改commit 后，外部是可以读取 commit 后的数据，在commit前这些数据在事务之外都不可见。事务中多个操作，其中之一失败，则事务整体失败，则在失败事务之前的操作全部丢弃。这里暂且认为MONGODB 的事务是 READ COMMITED 的方式对我们呈现的。
在昨天的示例里， mongodb 开始一个事务
session.startTransaction( { readConcern: { level: "snapshot" }, writeConcern: { w: "majority" } } );
需要注意的参数 readConcern 和 writeConcern
readConcern 可以选择 snapshot local majority
这三者的不同点 snapshot 主要针对多文档的事务提交，在readConcern选择了snapshot后，保证了多文档提交后，读取数据是从大多数节点，保证数据的准确性，事务提交时 startTransaction 的readConcern 必须要选择 snapshot, writeConcern 则也必须选择 marjority 保证写入的事务不会在回滚，确定在大多数节点已经落实。
对于事务的操作总，数据库中config, admin, local collections 是无效的，system.开头的 collection 也是无效的，对于事务的操作仅仅限于客户自定义的collections。游标如果是在事务内发生的，则只能在事务内部调用，同理事务内部不能调用外部的游标。
在事务内也禁止使用 DDL 操作，如创建一个索引，一个collection ,一个database ，创建账号 修改密码 等操作，事务内支持 CRUD 的操作。
事务的操作中，如果事务中的一个单独的操作失败了，是不会在进行重试，在事务commit 的阶段提交如果失败了，MONGODB 是会进行重试的。
那么一个完整的事务的提交并且包含重试和报错的程序怎么来操作
下面是一些操作步骤，
1 登陆mongoshell 通过mongosh 登陆 （不知道什么是mongosh 可以去官网看一下）
2 两个
function runTransactionWithRetry(txnFunc, session) {
while (true) {
try {
txnFunc(session); // performs transaction
break;
} catch (error) {
if ( error.hasOwnProperty("errorLabels") && error.errorLabels.includes("TransientTransactionError") ) {
print("TransientTransactionError, retrying transaction ...");
continue;
} else {
throw error;
}
}
}
}
function commitWithRetry(session) {
while (true) {
try {
session.commitTransaction();
print("Transaction committed.");
break;
} catch (error) {
if (error.hasOwnProperty("errorLabels") && error.errorLabels.includes("UnknownTransactionCommitResult") ) {
print("UnknownTransactionCommitResult, retrying commit operation ...");
continue;
} else {
print("Error during commit ...");
throw error;
}
}
}
}
事务函数
function updateEmployeeInfo(session) {
employeesCollection = session.getDatabase("test").test;
eventsCollection = session.getDatabase("test").test1;
session.startTransaction( { readConcern: { level: "snapshot" }, writeConcern: { w: "majority" } } );
try{
employeesCollection.insertOne( { employee: 3 }, { $set: { status: "Inactive" } } );
eventsCollection.insertOne( { employee: 3, status: { new: "Inactive", old: "Active" } } );
} catch (error) {
print("Caught exception during transaction, aborting.");
session.abortTransaction();
throw error;
}
commitWithRetry(session);
——————————————————————————————
执行MONGODB 事务
session = db.getMongo().startSession( { readPreference: { mode: "primary" } } );
try{
runTransactionWithRetry(updateEmployeeInfo, session);
} catch (error) {
} finally {
session.endSession();
}
执行后的结果。
具体MONGODB 在事务中可以操作的列表命令 在下方网址可以查询详细信息
Transactions and Operations — MongoDB Manual
后面还会关注MONGODB 的事务，以及一些案例。
