MongoDB事务实现

Question

我得到了这段代码，使用 express 和 mongodb(mongoose) 将喜欢的动画存储在 db 中，用户可以点赞/不喜欢动画，所以我需要实现事务：

const express = require('express');
const router = express.Router();
const mongoose = require('mongoose');
const User = require('./login').User;

mongoose.connect('mongodb://localhost:27017/animationsdb');

router.get('/', async(req, res) => {
    // implement transaction
    try {
        const result = await User.findOne({ username: req.query.username });
        if (result) {
            console.log("Liked animations:", result.likedAnimations);
            res.send({ animationList: result.likedAnimations });
        } else {
            console.log("no database result found");
            res.sendStatus(404);
        }
    } catch (e) {
        console.log(e);
        res.sendStatus(500);
    }
});

我需要帮助来实现交易，我尝试过这种方式：

const express = require('express');
const router = express.Router();
const mongoose = require('mongoose');
const User = require('./login').User;

mongoose.connect('mongodb://localhost:27017/animationsdb');

router.get('/', async(req, res) => {
    // implement transactions
    try {
        const session = await mongoose.startSession();
        session.startTransaction();
        const result = await User.findOne({ username: req.query.username }).session(session);
        if (result) {
            console.log("Liked animations:", result.likedAnimations);
            res.send({ animationList: result.likedAnimations });
        } else {
            console.log("no database result found");
            res.sendStatus(404);
        }
        await session.commitTransaction();
        session.endSession();
    } catch (e) {
        console.log(e);
        res.sendStatus(500);
    }
});

但它不起作用。 我还尝试在连接字符串中添加?replicaSet=rs 和?retryWrites=false 并安装

npm install run-rs -g

但都没有效果

Answer 1

尝试在会话之外发送响应。在await session.commitTransaction();之后 也试试这个问题的解决方案Mongodb v4.0 Transaction, MongoError: Transaction numbers are only allowed on a replica set member or mongos

如果您使用 Windows，请勿在连接字符串中使用 localhost 或 127.0.0.1 作为主机名，而是使用 计算机名 并在末尾添加 ?replicaSet=rs。 rs 是副本集的名称。

别忘了将&retryWrites=false 添加到您的连接字符串中。

使用run-rs -v 4.0.0 启动副本集。