From 7d2f225a217b4d020aee20b1ccf32f17f26a3912 Mon Sep 17 00:00:00 2001 From: Jan Oberhauser Date: Mon, 3 Aug 2020 08:21:42 +0200 Subject: [PATCH] :zap: Small improvements to CrateDb-Node --- .../nodes-base/nodes/CrateDb/CrateDb.node.ts | 21 +++++++++++++------ 1 file changed, 15 insertions(+), 6 deletions(-) diff --git a/packages/nodes-base/nodes/CrateDb/CrateDb.node.ts b/packages/nodes-base/nodes/CrateDb/CrateDb.node.ts index b4ac194e3b..daddda1294 100644 --- a/packages/nodes-base/nodes/CrateDb/CrateDb.node.ts +++ b/packages/nodes-base/nodes/CrateDb/CrateDb.node.ts @@ -1,10 +1,19 @@ import { IExecuteFunctions } from 'n8n-core'; -import { IDataObject, INodeExecutionData, INodeType, INodeTypeDescription } from 'n8n-workflow'; +import { + IDataObject, + INodeExecutionData, + INodeType, + INodeTypeDescription, +} from 'n8n-workflow'; + +import { + getItemCopy, + pgInsert, + pgQuery, +} from '../Postgres/Postgres.node.functions'; import * as pgPromise from 'pg-promise'; -import { pgInsert, pgQuery, pgUpdate, getItemCopy } from '../Postgres/Postgres.node.functions'; - export class CrateDb implements INodeType { description: INodeTypeDescription = { displayName: 'CrateDB', @@ -254,7 +263,7 @@ export class CrateDb implements INodeType { if (updateKeyValue === undefined) { throw new Error('No value found for update key!'); - } + } updatedKeys.push(updateKeyValue as string); @@ -262,9 +271,9 @@ export class CrateDb implements INodeType { queries.push(query); }); - + await db.any(pgp.helpers.concat(queries)); - + returnItems = this.helpers.returnJsonArray(getItemCopy(items, columns) as IDataObject[]); } else { await pgp.end();