node-red-node-mysql - npm Package Compare versions

Comparing version 0.1.1 to 0.1.2

68-mysql.js

@@ -22,5 +22,4 @@
         function checkVer() {
-            node.connection.query("SELECT version();", [], function(err, rows) {
+            node.pool.query("SELECT version();", [], function(err, rows, fields) {
                 if (err) {
-                    node.connection.release();
                     node.error(err);
@@ -88,9 +87,9 @@ node.status({fill:"red",shape:"ring",text:"Bad Ping"});
 
-        this.on('close', function (done) {
+        this.on('close', function(done) {
             if (this.tick) { clearTimeout(this.tick); }
             if (this.check) { clearInterval(this.check); }
             node.connected = false;
-            node.connection.release();
+            // node.connection.release();
             node.emit("state"," ");
-            node.pool.end(function (err) { done(); });
+            node.pool.end(function(err) { done(); });
         });
@@ -135,7 +134,7 @@ }
                             bind=msg.payload;
-                            node.mydbConfig.connection.config.queryFormat = function (query, values) {
-                                if (!values){
+                            node.mydbConfig.connection.config.queryFormat = function(query, values) {
+                                if (!values) {
                                     return query;
                                 }
-                                return query.replace(/\:(\w+)/g, function (txt, key) {
+                                return query.replace(/\:(\w+)/g, function(txt, key) {
                                     if (values.hasOwnProperty(key)) {
@@ -146,5 +145,5 @@ return this.escape(values[key]);
                                 }.bind(this));
-                            };          
+                            };
                         }
-                        node.mydbConfig.connection.query(msg.topic, bind, function(err, rows) {
+                        node.mydbConfig.pool.query(msg.topic, bind, function(err, rows) {
                             if (err) {
@@ -156,3 +155,3 @@ status = {fill:"red",shape:"ring",text:"Error: "+err.code};
                             else {
-                                if (rows.constructor.name === "OkPacket") {
+                                if ( (rows.constructor.name === "OkPacket") || (rows.constructor.name === "Array")) {
                                     msg.payload = JSON.parse(JSON.stringify(rows));
@@ -165,2 +164,3 @@ }
                             }
+                            //node.mydbConfig.connection.release();
                         });
@@ -183,3 +183,3 @@ }
 
-            node.on('close', function () {
+            node.on('close', function() {
                 if (node.tout) { clearTimeout(node.tout); }
@@ -186,0 +186,0 @@ node.mydbConfig.removeAllListeners();

package.json

 {
     "name": "node-red-node-mysql",
-    "version": "0.1.1",
+    "version": "0.1.2",
     "description": "A Node-RED node to read and write to a MySQL database",
@@ -5,0 +5,0 @@ "dependencies": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Native code

Supply chain risk

Contains native code (e.g., compiled binaries or shared libraries). Including native code can obscure malicious behavior.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

18975

increased by29.1%

Number of package files

7

increased by40%

Worsened metrics

Number of medium supply chain risk alerts

1

increased byInfinity%

No dependency changes