frodovdr
/
node-red-nodes
mirror of https://github.com/node-red/node-red-nodes.git
1
0
Fork 0
Code Issues Releases Wiki Activity

let mysql report errors to catch node

This commit is contained in:
Dave Conway-Jones 2015-11-01 15:04:42 +00:00
parent 2ef447dfeb
commit e1b02c90dd
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -46,7 +46,7 @@ module.exports = function(RED) {
node.connection.connect(function(err) { node.connection.connect(function(err) {
node.connecting = false; node.connecting = false;
if (err) { if (err) {
node.warn(err); node.error(err);
node.tick = setTimeout(doConnect, reconnect); node.tick = setTimeout(doConnect, reconnect);
} else { } else {
node.connected = true; node.connected = true;
@ -103,7 +103,7 @@ module.exports = function(RED) {
//console.log("query:",msg.topic); //console.log("query:",msg.topic);
var bind = Array.isArray(msg.payload) ? msg.payload : []; var bind = Array.isArray(msg.payload) ? msg.payload : [];
node.mydbConfig.connection.query(msg.topic, bind, function(err, rows) { node.mydbConfig.connection.query(msg.topic, bind, function(err, rows) {
if (err) { node.warn(err); } if (err) { node.error(err,msg); }
else { else {
msg.payload = rows; msg.payload = rows;
node.send(msg); node.send(msg);

4
storage/mysql/package.json
View File

@ -1,9 +1,9 @@
{ {
"name" : "node-red-node-mysql", "name" : "node-red-node-mysql",
"version" : "0.0.6", "version" : "0.0.7",
"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.7.*" "mysql" : "2.9.*"
}, },
"repository" : { "repository" : {
"type":"git", "type":"git",