客户端会话无法序列化为BSON。

Question

你好，我一直在尝试使用mongoose为我的mongodb atlas实现事务处理的crud操作，我已经查找了一些教程和资料，但实际上没有太多可用的资源。当我尝试访问用户创建路由后，我遇到了“ClientSession cannot be serialized to BSON”的问题，以下是我的代码：

router.post(
'/',
[
check('name', 'Por favor, ingresar el nombre')
  .not()
  .isEmpty(),
check('email', 'Por favor, ingresar un correo válido').isEmail(),
check(
  'password',
  'Por favor, ingresar una contraseña con 6 o más carácteres'
).isLength({ min: 6 })
],
async (req, res) => {
const errors = validationResult(req);
if (!errors.isEmpty()) {
  return res.status(400).json({ errors: errors.array() });
}

    const { name, email, password, imagen } = req.body;

    const session = await User.startSession() // Las transacciones usan sesiones
    // const session = await mongoose.startSession() // Las transacciones usan sesiones
    session.startTransaction()  // Empezar una transacción

try {

    const opts = {session} // Opciones de consulta del modelo

  const user = await User.findOne({ email }, opts ); // Enviar opts para usar transac

  if (user) {
    return res
      .status(400)
      .json({ errors: [{ msg: 'Ya existe una cuenta creada con este correo' }] });
        }

  user = new User({
    name,
    email,
            password,
            imagen
  });

  const salt = await bcrypt.genSalt(10);

  user.password = await bcrypt.hash(password, salt);

  await user.save(opts);

  const payload = {
    user: {
      id: user.id
    }
  };

  jwt.sign(
    payload,
    config.get('jwtSecret'),
    { expiresIn: 360000 },  // Cambiar a 3600 en producción 3600s = 1 hora
    (err, token) => {
      if (err) throw err;
      res.json({ token });
    }
        );

        await session.commitTransaction(); // Commit de la transacción
  session.endSession(); // Terminar la sesión
  return true
} catch (err) {

        await session.abortTransaction(); // Abortar o rollback de la transacción
        session.endSession(); // Terminar la sesión
  console.error(err.message);
  res.status(500).send('Error del servidor');
}});

所以，我不太确定这是什么意思，我想了解mongoose事务的基本步骤，以便掌握主要概念，谢谢。

- Ariel Bailón

Answer 1

我遇到了相同的问题。所以尝试替换

。

const user = await User.findOne({ email }, opts );

就这样：

const user = await User.findOne({ email }, null, opts );

它解决了我的问题 :)

- Alon Malivanchuk

---

请参见以下网址的说明：https://github.com/Automattic/mongoose/issues/6663 - J.E.C.

User.findOne({ email }, opts).session(session) 也可以工作。 - J.E.C.

Answer 2

我知道这是一个老问题，但我不得不面对相同的情况，以下是我如何克服这个挑战的方法。这些信息可能会有所帮助。

问题在于Model.findOne()的第二个参数始终是一个投影。如果您像这样操作，它将起作用：

await A.findOne({}, null, { session });

这是一个代码片段的例子

const mongoose = require('mongoose');
mongoose.connect('mongodb://localhost:27017,localhost:27018,localhost:27019/gh-6663?replicaSet=rs');
const conn = mongoose.connection;
const Schema = mongoose.Schema;

const schemaA = new Schema({
  name: String
});

const schemaB = new Schema({
  name: String
});

const A = mongoose.model('A', schemaA);
const B = mongoose.model('B', schemaB);

const a = new A({ name: 'Andrew' });
const b = new B({ name: 'Billy' });

async function run() {
  await conn.dropDatabase();
  await a.save();
  await b.save();

  const session = await A.startSession();
  await session.startTransaction();
  const foundA = await A.findOne({}, {}, { session });
  await B.findOneAndUpdate({}, { name: foundA.name }, { session });

  await session.commitTransaction();
  session.endSession();

  let newB = await B.findOne({});
  console.log(`hello from ${newB.name}`);
  return conn.close();
}

run().catch(console.error)

来源：mongoose GitHub问题

- Asela Priyadarshana