node.js的MongoDB驱动程序，事务API，错误“client.startsession（）不是函数”

Question

我试图使用MongoDB驱动程序for Node.js创建事务。这是我的代码。

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://someone:[e-mail]/myFirstDatabase?retryWrites=true&w=majority";

function dbConnect () {
    callback = callbackTrans;
    MongoClient.connect (uri, callback);
};

function callbackTrans (err, db) {
    if (err) throw err;
    var session = MongoClient.startSession();
    console.log ('so far so good');
};

dbConnect ();

当然，这是不完整的代码。但我得到以下错误，当我运行这个程序...

D:\NodeJS\node_modules\mongodb\lib\topologies\replset.js:339
          throw err;
          ^

TypeError: MongoClient.startSession is not a function
    at callbackTrans (D:\NodeJS\transaction.js:11:31)
    at D:\NodeJS\node_modules\mongodb\lib\utils.js:693:5
    at D:\NodeJS\node_modules\mongodb\lib\mongo_client.js:227:7
    at connectCallback (D:\NodeJS\node_modules\mongodb\lib\operations\connect.js:366:5)      
    at D:\NodeJS\node_modules\mongodb\lib\operations\connect.js:602:5
    at ReplSet.connectHandler (D:\NodeJS\node_modules\mongodb\lib\topologies\replset.js:336:9)
    at Object.onceWrapper (events.js:422:26)
    at ReplSet.emit (events.js:315:20)
    at D:\NodeJS\node_modules\mongodb\lib\core\topologies\replset.js:796:18
    at processTicksAndRejections (internal/process/task_queues.js:75:11)

我错过了什么/做错了什么？多谢了。

Answer 1

基本上，MongoClient.startSession()；无效，因为startSession()不是MongoClient上的静态方法，而是应在客户端实例本身调用的实例方法。MongoClient.Connect()将在回调中传递客户端实例，您应该使用它对其调用StartSession()。

试试看：

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://someone:[e-mail]/myFirstDatabase?retryWrites=true&w=majority";

function dbConnect () {
    callback = callbackTrans;
    MongoClient.connect (uri, callback);
};

function callbackTrans (err, client) {
    if (err) throw err;
    var session = client.startSession();
    console.log ('so far so good');
};

dbConnect();

参考资料：

1. ConnectCallback
2. StartSession方法

Answer 2

您必须调用回调的“db”参数的startSession方法，如果连接成功，这就是包含startSession方法的内容。

const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://someone:[e-mail]/myFirstDatabase?retryWrites=true&w=majority";

function dbConnect () {
    callback = callbackTrans;
    MongoClient.connect (uri, callback);
};

function callbackTrans (err, db) {
    if (err) throw err;
    var session = db.startSession();
    console.log ('so far so good');
};

dbConnect ();