frodovdr/node-red-nodes
1
0
Fork 0
mirror of https://github.com/node-red/node-red-nodes.git synced 2023-10-10 13:36:58 +02:00
Code Issues Releases Wiki Activity

mysql - revert trying to fixup RowDataPackets introduced in 0.1.8

Browse Source
This commit is contained in:
Dave Conway-Jones 2021-05-10 08:53:08 +01:00
parent 2bd98c6887
commit b37d215659
No known key found for this signature in database
GPG Key ID: 88BA2B8A411BE9FF
2 changed files with 21 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -151,22 +151,26 @@ module.exports = function(RED) {
node.error(err,msg);
}
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(v => v.map(w => Object.assign({}, w)));
}
else { msg.payload = rows; }
}
else { msg.payload = rows; }
}
else { msg.payload = rows; }
// 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;
send(msg);
status = {fill:"green",shape:"dot",text:"OK"};
node.status(status);

2
storage/mysql/package.json
View File

@ -1,6 +1,6 @@
{
"name": "node-red-node-mysql",
"version": "0.1.8",
"version": "0.1.10",
"description": "A Node-RED node to read and write to a MySQL database",
"dependencies": {
"mysql": "^2.18.1"