mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-09-20 06:47:32 -07:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

feat(node): remove knex dependency from MySQL node

Browse source
This commit is contained in:
Eric Chang 2019-12-12 23:57:59 +08:00
parent c34f4841c2
commit a78da100f8
2 changed files with 21 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
packages/nodes-base/nodes/MySQL/MySQL.node.ts
View file

@ -5,7 +5,8 @@ import {
INodeType,
INodeTypeDescription,
} from 'n8n-workflow';
import * as knex from 'knex';
// @ts-ignore
import * as mysql2 from 'mysql2/promise';
import { copyInputItems } from './GenericFunctions';
@ -174,7 +175,7 @@ export class MySQL implements INodeType {
throw new Error('No credentials got returned!');
}
const client = knex({ client: 'mysql2', connection: credentials });
const connection = await mysql2.createConnection(credentials);
const items = this.getInputData();
const operation = this.getNodeParameter('operation', 0) as string;
let returnItems = [];
@ -187,18 +188,20 @@ export class MySQL implements INodeType {
const queryQueue = items.map((item, index) => {
const rawQuery = this.getNodeParameter('query', index) as string;
return client.raw(rawQuery);
return connection.query(rawQuery);
});
let queryResult = await Promise.all(queryQueue);
queryResult = queryResult.reduce((result, current) => {
if (Array.isArray(current[0])) {
return result.concat(current[0]);
queryResult = queryResult.reduce((collection, result) => {
const [rows, fields] = result;
if (Array.isArray(rows)) {
return collection.concat(rows);
}
result.push(current[0]);
collection.push(rows);
return result;
return collection;
}, []);
returnItems = this.helpers.returnJsonArray(queryResult as IDataObject[]);
@ -212,9 +215,12 @@ export class MySQL implements INodeType {
const columnString = this.getNodeParameter('columns', 0) as string;
const columns = columnString.split(',').map(column => column.trim());
const insertItems = copyInputItems(items, columns);
const insertData = await client.insert(insertItems).into(table);
const insertPlaceholder = `(${columns.map(column => '?').join(',')})`;
const insertSQL = `INSERT INTO ${table}(${columnString}) VALUES ${items.map(item => insertPlaceholder).join(',')};`;
const queryItems = insertItems.reduce((collection, item) => collection.concat(Object.values(item as any)), []);
const queryResult = await connection.query(insertSQL, queryItems);
returnItems = [{ json: { row_count: insertData[0] }}];
returnItems = this.helpers.returnJsonArray(queryResult[0] as IDataObject);
} else if (operation === 'update') {
// ----------------------------------
@ -231,15 +237,12 @@ export class MySQL implements INodeType {
}
const updateItems = copyInputItems(items, columns);
const queryQueue = updateItems.map((item) => {
return client(table)
.where(updateKey, '=', item[updateKey])
.update(item);
});
const updateSQL = `UPDATE ${table} SET ${columns.map(column => `${column} = ?`).join(',')} WHERE ${updateKey} = ?;`;
const queryQueue = updateItems.map((item) => connection.query(updateSQL, Object.values(item).concat(item[updateKey])));
let queryResult = await Promise.all(queryQueue);
await Promise.all(queryQueue);
returnItems = this.helpers.returnJsonArray(updateItems as IDataObject[]);
queryResult = queryResult.map(result => result[0]);
returnItems = this.helpers.returnJsonArray(queryResult as IDataObject[]);
} else {
throw new Error(`The operation "${operation}" is not supported!`);

1
packages/nodes-base/package.json
View file

@ -187,7 +187,6 @@
"gm": "^1.23.1",
"googleapis": "^42.0.0",
"imap-simple": "^4.3.0",
"knex": "^0.20.1",
"lodash.get": "^4.4.2",
"lodash.set": "^4.3.2",
"lodash.unset": "^4.5.2",