Debes incluir la session dentro de las opciones para todas las operaciones de lectura/escritura que están activas durante una transacción. Solo entonces se aplican realmente al alcance de la transacción donde puede revertirlos.
Como listado un poco más completo, y simplemente usando el más clásico Order/OrderItems modelado que debería ser bastante familiar para la mayoría de las personas con alguna experiencia en transacciones relacionales:
const { Schema } = mongoose = require('mongoose');
// URI including the name of the replicaSet connecting to
const uri = 'mongodb://localhost:27017/trandemo?replicaSet=fresh';
const opts = { useNewUrlParser: true };
// sensible defaults
mongoose.Promise = global.Promise;
mongoose.set('debug', true);
mongoose.set('useFindAndModify', false);
mongoose.set('useCreateIndex', true);
// schema defs
const orderSchema = new Schema({
name: String
});
const orderItemsSchema = new Schema({
order: { type: Schema.Types.ObjectId, ref: 'Order' },
itemName: String,
price: Number
});
const Order = mongoose.model('Order', orderSchema);
const OrderItems = mongoose.model('OrderItems', orderItemsSchema);
// log helper
const log = data => console.log(JSON.stringify(data, undefined, 2));
// main
(async function() {
try {
const conn = await mongoose.connect(uri, opts);
// clean models
await Promise.all(
Object.entries(conn.models).map(([k,m]) => m.deleteMany())
)
let session = await conn.startSession();
session.startTransaction();
// Collections must exist in transactions
await Promise.all(
Object.entries(conn.models).map(([k,m]) => m.createCollection())
);
let [order, other] = await Order.insertMany([
{ name: 'Bill' },
{ name: 'Ted' }
], { session });
let fred = new Order({ name: 'Fred' });
await fred.save({ session });
let items = await OrderItems.insertMany(
[
{ order: order._id, itemName: 'Cheese', price: 1 },
{ order: order._id, itemName: 'Bread', price: 2 },
{ order: order._id, itemName: 'Milk', price: 3 }
],
{ session }
);
// update an item
let result1 = await OrderItems.updateOne(
{ order: order._id, itemName: 'Milk' },
{ $inc: { price: 1 } },
{ session }
);
log(result1);
// commit
await session.commitTransaction();
// start another
session.startTransaction();
// Update and abort
let result2 = await OrderItems.findOneAndUpdate(
{ order: order._id, itemName: 'Milk' },
{ $inc: { price: 1 } },
{ 'new': true, session }
);
log(result2);
await session.abortTransaction();
/*
* $lookup join - expect Milk to be price: 4
*
*/
let joined = await Order.aggregate([
{ '$match': { _id: order._id } },
{ '$lookup': {
'from': OrderItems.collection.name,
'foreignField': 'order',
'localField': '_id',
'as': 'orderitems'
}}
]);
log(joined);
} catch(e) {
console.error(e)
} finally {
mongoose.disconnect()
}
})()
Por lo tanto, generalmente recomendaría llamar a la variable session en minúsculas, ya que este es el nombre de la clave para el objeto "opciones" donde se requiere en todas las operaciones. Mantener esto en la convención de minúsculas también permite usar cosas como la asignación de objetos ES6:
const conn = await mongoose.connect(uri, opts);
...
let session = await conn.startSession();
session.startTransaction();
Además, la documentación de mangosta sobre transacciones es un poco engañosa, o al menos podría ser más descriptiva. A qué se refiere como db en los ejemplos es en realidad la instancia de Mongoose Connection, y no el Db subyacente o incluso la mongoose importación global ya que algunos pueden malinterpretar esto. Tenga en cuenta que en la lista y el extracto anterior esto se obtiene de mongoose.connect() y debe mantenerse dentro de su código como algo a lo que puede acceder desde una importación compartida.
Alternativamente, incluso puede obtener esto en código modular a través de mongoose.connection propiedad, en cualquier momento después se ha establecido una conexión. Por lo general, esto es seguro dentro de cosas como los controladores de ruta del servidor y similares, ya que habrá una conexión a la base de datos en el momento en que se llame al código.
El código también demuestra la session uso en los diferentes métodos del modelo:
let [order, other] = await Order.insertMany([
{ name: 'Bill' },
{ name: 'Ted' }
], { session });
let fred = new Order({ name: 'Fred' });
await fred.save({ session });
Todos los find() métodos basados y el update() o insert() y delete() todos los métodos basados tienen un "bloque de opciones" final donde se esperan esta clave y valor de sesión. El save() El único argumento del método es este bloque de opciones. Esto es lo que le dice a MongoDB que aplique estas acciones a la transacción actual en esa sesión a la que se hace referencia.
De la misma manera, antes de que se confirme una transacción, cualquier solicitud de find() o similar que no especifica esa session opción no ver el estado de los datos mientras esa transacción está en progreso. El estado de datos modificado solo está disponible para otras operaciones una vez que se completa la transacción. Tenga en cuenta que esto tiene efectos en las escrituras como se describe en la documentación.
Cuando se emite un "aborto":
// Update and abort
let result2 = await OrderItems.findOneAndUpdate(
{ order: order._id, itemName: 'Milk' },
{ $inc: { price: 1 } },
{ 'new': true, session }
);
log(result2);
await session.abortTransaction();
Cualquier operación en la transacción activa se elimina del estado y no se aplica. Como tales, no son visibles para las operaciones resultantes posteriores. En el ejemplo aquí, el valor en el documento se incrementa y mostrará un valor recuperado de 5 en la sesión actual. Sin embargo, después de session.abortTransaction() se revierte el estado anterior del documento. Tenga en cuenta que cualquier contexto global que no estaba leyendo datos en la misma sesión, no ve ese cambio de estado a menos que se confirme.
Eso debería dar una visión general. Hay más complejidad que se puede agregar para manejar diferentes niveles de fallas de escritura y reintentos, pero eso ya está ampliamente cubierto en la documentación y muchas muestras, o se puede responder a una pregunta más específica.
Salida
Como referencia, el resultado de la lista incluida se muestra aquí:
Mongoose: orders.deleteMany({}, {})
Mongoose: orderitems.deleteMany({}, {})
Mongoose: orders.insertMany([ { _id: 5bf775986c7c1a61d12137dd, name: 'Bill', __v: 0 }, { _id: 5bf775986c7c1a61d12137de, name: 'Ted', __v: 0 } ], { session: ClientSession("80f827fe077044c8b6c0547b34605cb2") })
Mongoose: orders.insertOne({ _id: ObjectId("5bf775986c7c1a61d12137df"), name: 'Fred', __v: 0 }, { session: ClientSession("80f827fe077044c8b6c0547b34605cb2") })
Mongoose: orderitems.insertMany([ { _id: 5bf775986c7c1a61d12137e0, order: 5bf775986c7c1a61d12137dd, itemName: 'Cheese', price: 1, __v: 0 }, { _id: 5bf775986c7c1a61d12137e1, order: 5bf775986c7c1a61d12137dd, itemName: 'Bread', price: 2, __v: 0 }, { _id: 5bf775986c7c1a61d12137e2, order: 5bf775986c7c1a61d12137dd, itemName: 'Milk', price: 3, __v: 0 } ], { session: ClientSession("80f827fe077044c8b6c0547b34605cb2") })
Mongoose: orderitems.updateOne({ order: ObjectId("5bf775986c7c1a61d12137dd"), itemName: 'Milk' }, { '$inc': { price: 1 } }, { session: ClientSession("80f827fe077044c8b6c0547b34605cb2") })
{
"n": 1,
"nModified": 1,
"opTime": {
"ts": "6626894672394452998",
"t": 139
},
"electionId": "7fffffff000000000000008b",
"ok": 1,
"operationTime": "6626894672394452998",
"$clusterTime": {
"clusterTime": "6626894672394452998",
"signature": {
"hash": "AAAAAAAAAAAAAAAAAAAAAAAAAAA=",
"keyId": 0
}
}
}
Mongoose: orderitems.findOneAndUpdate({ order: ObjectId("5bf775986c7c1a61d12137dd"), itemName: 'Milk' }, { '$inc': { price: 1 } }, { session: ClientSession("80f827fe077044c8b6c0547b34605cb2"), upsert: false, remove: false, projection: {}, returnOriginal: false })
{
"_id": "5bf775986c7c1a61d12137e2",
"order": "5bf775986c7c1a61d12137dd",
"itemName": "Milk",
"price": 5,
"__v": 0
}
Mongoose: orders.aggregate([ { '$match': { _id: 5bf775986c7c1a61d12137dd } }, { '$lookup': { from: 'orderitems', foreignField: 'order', localField: '_id', as: 'orderitems' } } ], {})
[
{
"_id": "5bf775986c7c1a61d12137dd",
"name": "Bill",
"__v": 0,
"orderitems": [
{
"_id": "5bf775986c7c1a61d12137e0",
"order": "5bf775986c7c1a61d12137dd",
"itemName": "Cheese",
"price": 1,
"__v": 0
},
{
"_id": "5bf775986c7c1a61d12137e1",
"order": "5bf775986c7c1a61d12137dd",
"itemName": "Bread",
"price": 2,
"__v": 0
},
{
"_id": "5bf775986c7c1a61d12137e2",
"order": "5bf775986c7c1a61d12137dd",
"itemName": "Milk",
"price": 4,
"__v": 0
}
]
}
]
