From 9314086b6a84ce0f24992827ab316dee4709d118 Mon Sep 17 00:00:00 2001 From: Omar Ajoue Date: Mon, 5 Sep 2022 11:22:51 +0200 Subject: [PATCH] fix: issue with postgres insert and paired item (#4020) fix: issue with postgres node and paired item --- .../nodes-base/nodes/Postgres/Postgres.node.functions.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/packages/nodes-base/nodes/Postgres/Postgres.node.functions.ts b/packages/nodes-base/nodes/Postgres/Postgres.node.functions.ts index f0991c930a..90004397fa 100644 --- a/packages/nodes-base/nodes/Postgres/Postgres.node.functions.ts +++ b/packages/nodes-base/nodes/Postgres/Postgres.node.functions.ts @@ -188,7 +188,7 @@ export async function pgQueryV2( if (mode === 'multiple') { return (await db.multi(pgp.helpers.concat(allQueries))) .map((result, i) => { - return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray([...result]), { + return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray(result), { itemData: { item: i }, }); }) @@ -374,9 +374,9 @@ export async function pgInsertV2( if (mode === 'multiple') { const query = pgp.helpers.insert(getItemsCopy(items, columnNames, guardedColumns), cs) + returning; - return (await db.any(query)) - .map((result, i) => { - return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray([...result]), { + const queryResult = await db.any(query); + return queryResult.map((result, i) => { + return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray(result), { itemData: { item: i }, }); })