diff --git a/lib/www/server/lib/db/plan/patch.js b/lib/www/server/lib/db/plan/patch.js index d9d9e0d..0146a6f 100644 --- a/lib/www/server/lib/db/plan/patch.js +++ b/lib/www/server/lib/db/plan/patch.js @@ -4,6 +4,7 @@ async function patch (projectId, sequence, payload, opts = {}) { const client = await setSurvey(projectId); try { + transaction.begin(client); const text = ` UPDATE planned_lines @@ -23,8 +24,10 @@ async function patch (projectId, sequence, payload, opts = {}) { const values = [ sequence, p.sequence, p.fsp, p.lsp, p.ts0, p.ts1, p.name, p.remarks, p.meta ]; await client.query(text, values); + + transaction.commit(client); } catch (err) { - transaction.rollback(err); + transaction.rollback(client); throw err; } finally { client.release();