Mongoose 事务 session.withTransaction 不是函数答案

【问题标题】：Mongoose transaction session.withTransaction is not a functionMongoose 事务 session.withTransaction 不是函数
【发布时间】：2021-06-15 07:14:06
【问题描述】：

我正在阅读这些试图实现猫鼬事务的链接： Mongoose pass data out of withTransaction helper https://github.com/mongodb-developer/nodejs-quickstart/blob/master/transaction.js

我想通过更新客户端来编写一个工作示例，然后在失败时实现回滚。但是我遇到了这两个错误： The transaction was aborted due to an unexpected error: TypeError: session.withTransaction is not a function (node:60708) UnhandledPromiseRejectionWarning: TypeError: session.endSession is not a function

副本集已设置：运行-rs -v 4.0.0 --shell

Purging database...
Running '/usr/local/lib/node_modules/run-rs/4.0.0/mongod' [ 27017, 27018, 27019 ]
Starting replica set...
(node:61139) Warning: Accessing non-existent property 'count' of module exports inside circular dependency
(Use `node --trace-warnings ...` to show where the warning was created)
(node:61139) Warning: Accessing non-existent property 'findOne' of module exports inside circular dependency
(node:61139) Warning: Accessing non-existent property 'remove' of module exports inside circular dependency
(node:61139) Warning: Accessing non-existent property 'updateOne' of module exports inside circular dependency
Started replica set on "mongodb://localhost:27017,localhost:27018,localhost:27019?replicaSet=rs"
Running mongo shell: /usr/local/lib/node_modules/run-rs/4.0.0/mongo

代码：

ADMIN_MONGO_URL: "mongodb://localhost:27017/admin?retryWrites=true&w=majority",
       
transactionCreateProject: async function (newProjectJson) {
            const mongoConnectConfig = {useNewUrlParser: true, useUnifiedTopology: true, useCreateIndex: true};
            const connection = await mongoose.connect(CONSTANTS.ADMIN_MONGO_URL, mongoConnectConfig)
            const db = mongoose.connection;
            db.on('error', console.error.bind(console, 'MongoDB connection error：'))
            let projectModel = mongoose.model('project', mongooseProjectSchema)
    
            // either of next two line does not work.
            const session = connection.startSession();
            // const session = mongoose.startSession();
    
            const transactionOptions = {
                readPreference: 'primary',
                readConcern: { level: 'local' },
                writeConcern: { w: 'majority' }
            };
            try {
                const transactionResults = await session.withTransaction(async () => {
                    let resultObj = await projectModel.updateOne({'uuid': newProjectJson['clientID']}, {$push: {'accumulatedProj': {'uuid': newProjectJson.uuid}}});
                    console.log(resultObj)
                }, transactionOptions);
                console.log(transactionResults)
                if (transactionResults) {
                    console.log("The reservation was successfully created.");
                } else {
                    console.log("The transaction was intentionally aborted.");
                }
            }
            catch (e) {
                console.log("The transaction was aborted due to an unexpected error: " + e);
            }
            finally {
                await session.endSession();
            }

我做错了什么？

【问题讨论】：

猫鼬和节点驱动程序都有我建议先阅读的文档而不是 SO 帖子。

标签： mongodb mongoose transactions

【解决方案1】：

你需要在像这样声明会话时放置一个等待：

const session = await connection.startSession()

如果你在没有等待的情况下记录会话，你可以看到这是一个承诺，所以基本上你只需要等待就可以了

【讨论】：