mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-12-24 20:24:05 -08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

⚡ Small improvements to CrateDb-Node

Browse source
This commit is contained in:
Jan Oberhauser 2020-08-03 08:21:42 +02:00
parent 6a8d22d2fa
commit 7d2f225a21
1 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
packages/nodes-base/nodes/CrateDb/CrateDb.node.ts
View file

@ -1,10 +1,19 @@
import { IExecuteFunctions } from 'n8n-core'; 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 * as pgPromise from 'pg-promise';
import { pgInsert, pgQuery, pgUpdate, getItemCopy } from '../Postgres/Postgres.node.functions';
export class CrateDb implements INodeType { export class CrateDb implements INodeType {
description: INodeTypeDescription = { description: INodeTypeDescription = {
displayName: 'CrateDB', displayName: 'CrateDB',
@ -254,7 +263,7 @@ export class CrateDb implements INodeType {
if (updateKeyValue === undefined) { if (updateKeyValue === undefined) {
throw new Error('No value found for update key!'); throw new Error('No value found for update key!');
} }
updatedKeys.push(updateKeyValue as string); updatedKeys.push(updateKeyValue as string);
@ -262,9 +271,9 @@ export class CrateDb implements INodeType {
queries.push(query); queries.push(query);
}); });
await db.any(pgp.helpers.concat(queries)); await db.any(pgp.helpers.concat(queries));
returnItems = this.helpers.returnJsonArray(getItemCopy(items, columns) as IDataObject[]); returnItems = this.helpers.returnJsonArray(getItemCopy(items, columns) as IDataObject[]);
} else { } else {
await pgp.end(); await pgp.end();