Estoy creando una clase de utilidad para NodeJs para ayudarme a administrar las transacciones de la base de datos.
Mi idea es crear un método como este:
transactionBlock(params) { let _db; return mySqlConnector.getConnection(params.db) .then(db => { _db = db; console.log(`beginTransaction`); return db.beginTransaction() }) .then(() => { return Promise.resolve(_db); }) .catch((e) => { console.log(`roolback`); _db.rollback(); }) .finally(() => { console.log(`commit`); _db.commit(); }) }y usarlo así:
const params = {db:"my_db"}; transactionBlock(params) .then(db =>{ console.log(`do query 1`); db.insert(....) console.log(`do query 2`); db.insert(....) console.log(`do query 3`); db.insert(....) })Esperaba que funcionara, pero obviamente el resultado es el siguiente:
beginTransaction commit do query 1 do query 2 do query 3 ¿Crees que es posible crear una función transactionBlock que devuelva una promesa donde el usuario puede hacer las consultas y, finalmente, si todas las consultas están bien, la función transactionBlock hace las confirmaciones?
Yo uso esto: npmjs.com/package/promise-mysql
Adiós gracias
El gran problema con su enfoque actual es que finally() siempre se ejecuta, ya sea que la cadena de promesa se resuelva o rechace, por lo que definitivamente no desea realizar la transacción allí.
Solo veo una opción aquí... requiere una función de devolución de llamada que represente el cuerpo de la transacción.
En general, también recomendaría usar la sintaxis async / await para mejorar la legibilidad.
const transactionBlock = async (connectionName, txBody) => { const db = await mySqlConnector.getConnection(connectionName); await db.beingTransaction(); try { await txBody(db); console.log("commit"); return db.commit(); // all good, commit } catch (err) { console.error("rollback", err); await db.rollback(); // keep the rejection chain going by re-throwing the error or a new one throw err; // or perhaps `new Error("DB error: " + err.message)` } };llamado así
try { await transactionBlock("my_db", async (db) => { console.log(`do query 1`); await db.insert(/* ... */); console.log(`do query 2`); await db.insert(/* ... */); console.log(`do query 3`); await db.insert(/* ... */); }); } catch (err) { console.error("oh no, something went wrong", err); }Si estuviera utilizando Typescript, las siguientes interfaces y tipos garantizarían un funcionamiento sin problemas
type TxBody = (db: Connection) => Promise<void>; type TransactionBlock = ( connectionName: string, txBody: TxBody ) => Promise<void>; const transactionBlock: TransactionBlock = async (connectionName, txBody) => { // ... };