admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-18 02:21:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: issue with postgres insert and paired item (#4020)

Browse Source 
fix: issue with postgres node and paired item
This commit is contained in:
Omar Ajoue
2022-09-05 11:22:51 +02:00
committed by GitHub
parent 6be999714f
commit 9314086b6a
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/nodes-base/nodes/Postgres/Postgres.node.functions.ts
View File

@@ -188,7 +188,7 @@ export async function pgQueryV2(
if (mode === 'multiple') { if (mode === 'multiple') {
return (await db.multi(pgp.helpers.concat(allQueries))) return (await db.multi(pgp.helpers.concat(allQueries)))
.map((result, i) => { .map((result, i) => {
return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray([...result]), { return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray(result), {
itemData: { item: i }, itemData: { item: i },
}); });
}) })
@@ -374,9 +374,9 @@ export async function pgInsertV2(
if (mode === 'multiple') { if (mode === 'multiple') {
const query = const query =
pgp.helpers.insert(getItemsCopy(items, columnNames, guardedColumns), cs) + returning; pgp.helpers.insert(getItemsCopy(items, columnNames, guardedColumns), cs) + returning;
return (await db.any(query)) const queryResult = await db.any(query);
.map((result, i) => { return queryResult.map((result, i) => {
return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray([...result]), { return this.helpers.constructExecutionMetaData(this.helpers.returnJsonArray(result), {
itemData: { item: i }, itemData: { item: i },
}); });
}) })