Tengo una inserción de nodo-postgres de varias filas que me está dando problemas. Es una consulta parametrizada que utiliza una expresión de tabla común para actualizar una tabla principal y dos tablas con claves externas. La consulta funciona con los parámetros de la tabla principal, pero cuando trato de parametrizar las tablas de claves externas, que son de varias filas, arroja el error de sintaxis.
Primero, tengo esta función que toma una matriz y devuelve una cadena de valores.
const buildValues = (id, values) => { return values .map(val => "(" + id + ", '" + val + "', " + false + ")") .join(", "); };Aquí está mi consulta:
app.post('/api/saveperson', function (req, res) { pg.connect(connectionString, (err, client, done) => { const insertPerson = ` WITH x AS ( INSERT INTO people (title, notes, name) VALUES ($1, $2, $3) RETURNING personId ), b AS ( INSERT INTO sports (personid, name, favorite) VALUES $4 ) INSERT INTO instructions (personid, name, favorite) VALUES $5; `; client.query(insertPerson, [ req.body.title , req.body.notes , req.body.name , queries.buildValues("SELECT personId FROM x", req.body.sports) , queries.buildValues("SELECT personId FROM x", req.body.instructions) ] ) .then( () => client.end()) .catch( err => console.log(err)); }); return res.json(req.body); });No estoy seguro de si esta es la mejor solución, pero terminé usando la biblioteca pg-promise en lugar de solo pg . Luego uso una transacción y una consulta encadenada:
db.tx(t => { // BEGIN has been executed return t.one( `INSERT INTO people (title, notes, name) VALUES ($[title], $[notes], $[name]) RETURNING personid`, req.body) .then(data => { let sportsQueries = req.body.sports.map(sport => { return t.none(`INSERT INTO sports (personid, name) VALUES ($1, $2)`, [data.personid, sport]); }); let instructionsQueries = req.body.instructions.map(ins => { return t.none(`INSERT INTO instructions (personid, instruction) VALUES ($1, $2)`, [data.personid, ins]); }); return t.batch(sportsQueries.concat(instructionsQueries)); }); }) .then(data => { // Success, and COMMIT has been executed }) .catch(error => { // Failure, and ROLLBACK has been executed })