n8n/packages/nodes-base/nodes/Snowflake/GenericFunctions.ts
Michael Kret 91d7e16c81
n8n-3867-progressively-apply-prettier-to-all (#3873)
* 🔨 formatting nodes with prettier
2022-08-17 17:50:24 +02:00

62 lines
1.3 KiB
TypeScript

import { IDataObject, INodeExecutionData } from 'n8n-workflow';
import snowflake from 'snowflake-sdk';
export function connect(conn: snowflake.Connection) {
return new Promise((resolve, reject) => {
conn.connect((err, conn) => {
if (!err) {
// @ts-ignore
resolve();
} else {
reject(err);
}
});
});
}
export function destroy(conn: snowflake.Connection) {
return new Promise((resolve, reject) => {
conn.destroy((err, conn) => {
if (!err) {
// @ts-ignore
resolve();
} else {
reject(err);
}
});
});
}
export function execute(conn: snowflake.Connection, sqlText: string, binds: snowflake.InsertBinds) {
return new Promise((resolve, reject) => {
conn.execute({
sqlText,
binds,
complete: (err, stmt, rows) => {
if (!err) {
resolve(rows);
} else {
reject(err);
}
},
});
});
}
export function copyInputItems(items: INodeExecutionData[], properties: string[]): IDataObject[] {
// Prepare the data to insert and copy it to be returned
let newItem: IDataObject;
return items.map((item) => {
newItem = {};
for (const property of properties) {
if (item.json[property] === undefined) {
newItem[property] = null;
} else {
newItem[property] = JSON.parse(JSON.stringify(item.json[property]));
}
}
return newItem;
});
}