Estoy tratando de actualizar algunas filas a la vez.
Estoy esperando que se escriban todas las consultas antes de ejecutarlas todas en una sola consulta. Sin embargo, necesito que la consulta devuelva algunos valores después de la actualización. Estoy usando el método returning() para eso.
No puedo obtener todos los valores devueltos a la vez como una matriz después de ejecutar la consulta. Si uso un then() directamente en la función de transacción, devuelve los valores devueltos uno por uno y mi promesa no funcionará. También aumenta considerablemente el tiempo de ejecución.
¿Cómo obtengo todos los valores devueltos de mi solicitud de actualización a la vez en una lista?
return await knex.transaction(trx => { const queries = []; data.forEach(pair => { const query = knex('pair') .where('symbol', pair.s) .update({ last_price: pair.c, }) .returning(['id']) .transacting(trx) //.then(function (updated) { // ... doing it one by one here //}) queries.push(query); }); return Promise.all(queries) // Once all queries are written .then(() => { trx.commit // We try to execute them all .catch((e) => { trx.rollback // And rollback in case any of them goes wrong console.error(e) }); })Encontré una solución sin usar trx.commit() :
async function updateDB(data) { return await knex.transaction(async (trx) => { const queries = []; data.forEach(item => { const query = knex('core_exchangepair') .where('symbol_slug', item.s) .transacting(trx) .update({ last_price: item.c, }) .returning(['id']) queries.push(query); }); try { return await Promise.all(queries); } catch (e) { console.error(e); return e; } }) }La espera después del regreso es innecesaria. Debe esperar su Promise.all antes de devolverlo, por lo que su función trx debe ser asíncrona.