mongoose、mongodb 中无法引用方法`db.start Session()`

Question

当我尝试引用 db.startSession () 时，出现错误 db.startSession () is not a function。在console.log 我把db 和我把记录的变量放在下面。为什么我不能参考startSession()？

连接

module.exports.db = mongoose
    .createConnection(process.env.DATABASE, { 
        useNewUrlParser: true, 
        useFindAndModify: false,
        useUnifiedTopology: true, 
        useCreateIndex: true
    }
);

控制器

const db = require('./connection');

const session = db.startSession();
session.startTransaction();

记录的变量数据库

{
  db: NativeConnection {
    base: Mongoose {
      connections: [Array],
      models: [Object],
      modelSchemas: [Object],
      options: [Object],
      _pluralize: [Function: pluralize],
      plugins: [Array]
    },
    collections: {},
    models: {},
    config: { autoIndex: true },
    replica: false,
    options: null,
    otherDbs: [],
    relatedDbs: {},
    states: [Object: null prototype] {
      '0': 'disconnected',
      '1': 'connected',
      '2': 'connecting',
      '3': 'disconnecting',
      '99': 'uninitialized',
      disconnected: 0,
      connected: 1,
      connecting: 2,
      disconnecting: 3,
      uninitialized: 99
    },
    _readyState: 1,
    _closeCalled: false,
    _hasOpened: true,
    _listening: false,
    _connectionOptions: {
      useNewUrlParser: true,
      useFindAndModify: false,
      useUnifiedTopology: true,
      useCreateIndex: true,
      promiseLibrary: [Function: Promise]
    },
    client: MongoClient {
      _events: [Object: null prototype] {},
      _eventsCount: 0,
      _maxListeners: undefined,
      s: [Object],
      topology: [ReplSet],
      [Symbol(kCapture)]: false
    },
    name: null,
    '$initialConnection': Promise { [Circular] },
    db: Db {
      _events: [Object: null prototype],
      _eventsCount: 3,
      _maxListeners: undefined,
      s: [Object],
      serverConfig: [Getter],
      bufferMaxEntries: [Getter],
      databaseName: [Getter],
      [Symbol(kCapture)]: false
    }
  }
}

Answer 1

你可以这样做在猫鼬中使用事务：

注意：使用事务需要复制mongodb，所以需要将Standalone转换为Replica Set，并且需要在mongoose.createConnection()中添加retryWrites: false作为参数

连接到猫鼬：

      await mongoose.connect(`mongodb://localhost/namedb`, {
        useNewUrlParser: true,
        useUnifiedTopology: true,
        useCreateIndex: true,
        retryWrites: false
      });

const mongoose = require("mongoose");

const sess = await mongoose.startSession();
sess.startTransaction(); 
await teacher.save({ session: sess }); // a query
student.messeges.push(); // do somthing
await student.save({ session: sess }); //// a query
await sess.commitTransaction();

要在 localhost 中使用副本集，您应该停止 mongod 服务并运行此代码

mongod --port 27017 --dbpath C:\data\rs1 --replSet m101 --bind_ip localhost

C:\data\rs1数据存储路径

 rs.initiate()