我想在 mongo 中运行批量操作,但同时在多文档事务中运行它。我正在使用 Meteor 运行 MongoDb 的 NodeJs 驱动程序。
根据 MongoDB 文档 ( https://docs.mongodb.com/manual/reference/method/Bulk/ ),应该可以将批量
和多文档事务
结合起来。但是,我一直无法解决这个问题。
我的问题是如何将 session
对象传递给批量操作。对于非批量操作,我们只需将其作为选项对象 const options = {session: session}
传递。我尝试了多种方法,但似乎都不起作用。
如何在批量
操作中使用session
对象?
下面是我想要实现的目标的一个简单示例。
const getMongoClient = function() {
const { client } = MongoInternals.defaultRemoteCollectionDriver().mongo;
return client;
}
const session = client.startSession();
try {
session.startTransaction();
const bulk = someCollectionToBulkWrite.rawCollection().initializeOrderedBulkOp(); // Pass the session here?
const dataInsert = someCollection.insert(someObject, {session}).await().value;
const dataInsertOtherDocument = someOtherCollection.insert(someOtherObject, {session}).await().value;
bulk.find( { _id: someId } ).update( { $set: { testField: 3}}); //Or pass the session here?
bulk.find( { _id: someOtherId } ).update( { $set: { testField: 3}});
bulk.execute().await(); // Or pass the session here?
session.commitTransaction().await();
} finally {
session.endSession();
}
最佳答案
我检查了 NodeJS 的 MongoDB 驱动程序的代码,更具体地说是 Bulk
API ( https://github.com/mongodb/node-mongodb-native/blob/master/lib/bulk/common.js )
execute
方法的定义如下:
execute(_writeConcern, 选项, 回调);
因此, session 应作为第二个参数传递给execute
。在问题中提供的示例中,如下所示:
bulk.execute(null, {session}).await();
关于node.js - 如何在 Node Js 中使用 Mongodb Bulk 和多文档事务?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59908071/