frodovdr/node-red-nodes
1
0
Fork 0
mirror of https://github.com/node-red/node-red-nodes.git synced 2025-03-01 10:37:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use mysql2 lib

Browse Source
This commit is contained in:
Dave Conway-Jones 2021-11-18 08:47:05 +00:00
parent 4868364860
commit a2737c2685
No known key found for this signature in database
GPG Key ID: 88BA2B8A411BE9FF
2 changed files with 3 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
storage/mysql/68-mysql.js
View File

@ -116,7 +116,7 @@ module.exports = function(RED) {
if (Array.isArray(msg.payload)) { if (Array.isArray(msg.payload)) {
bind = msg.payload; bind = msg.payload;
node.mydbConfig.pool.on('acquire', function(connection) { node.mydbConfig.pool.on('acquire', function(connection) {
connection.config.queryFormat = null; connection.config.queryFormat = null;
}); });
} }
else if (typeof msg.payload === 'object' && msg.payload !== null) { else if (typeof msg.payload === 'object' && msg.payload !== null) {
@ -142,34 +142,12 @@ module.exports = function(RED) {
node.error(err,msg); node.error(err,msg);
} }
else { else {
// if (rows.constructor.name === "OkPacket") {
// msg.payload = JSON.parse(JSON.stringify(rows));
// }
// else if (rows.constructor.name === "Array") {
// if (rows[0] && rows[0].constructor.name === "RowDataPacket") {
// msg.payload = rows.map(v => Object.assign({}, v));
// }
// else if (rows[0] && rows[0].constructor.name === "Array") {
// if (rows[0][0] && rows[0][0].constructor.name === "RowDataPacket") {
// msg.payload = rows.map(function(v) {
// if (!Array.isArray(v)) { return v; }
// v.map(w => Object.assign({}, w))
// });
// }
// else { msg.payload = rows; }
// }
// else { msg.payload = rows; }
// }
// else { msg.payload = rows; }
msg.payload = rows; msg.payload = rows;
send(msg); send(msg);
status = {fill:"green",shape:"dot",text:RED._("mysql.status.ok")}; status = {fill:"green",shape:"dot",text:RED._("mysql.status.ok")};
node.status(status); node.status(status);
} }
if (done) { done(); } if (done) { done(); }
// if (node.mydbConfig.pool._freeConnections.indexOf(node.mydbConfig.connection) === -1) {
// node.mydbConfig.connection.release();
// }
}); });
} }
else { else {

4
storage/mysql/package.json
View File

@ -1,9 +1,9 @@
{ {
"name": "node-red-node-mysql", "name": "node-red-node-mysql",
"version": "0.3.0", "version": "1.0.0-beta",
"description": "A Node-RED node to read and write to a MySQL database", "description": "A Node-RED node to read and write to a MySQL database",
"dependencies": { "dependencies": {
"mysql": "^2.18.1" "mysql2": "^2.3.3"
}, },
"repository": { "repository": {
"type": "git", "type": "git",