我试图使用MongoDB驱动程序for Node.js创建事务。这是我的代码。
const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://someone:someone@somecluster.xxxyy.mongodb.net/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)
我错过了什么/做错了什么？多谢了。
您必须调用回调的“db”参数的startSession方法，如果连接成功，这就是包含startSession方法的内容。
const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://someone:someone@somecluster.xxxyy.mongodb.net/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 ();
基本上，MongoClient.startSession()；无效，因为startSession()不是MongoClient上的静态方法，而是应在客户端实例本身调用的实例方法。MongoClient.Connect()将在回调中传递客户端实例，您应该使用它对其调用StartSession()。
试试看：
const MongoClient = require('mongodb').MongoClient;
const uri = "mongodb+srv://someone:someone@somecluster.xxxyy.mongodb.net/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();
参考资料：
