diff --git a/storage/sqlite/package.json b/storage/sqlite/package.json
index c671502c..cc31580a 100644
--- a/storage/sqlite/package.json
+++ b/storage/sqlite/package.json
@@ -1,6 +1,6 @@
 {
     "name": "node-red-node-sqlite",
-    "version": "0.3.3",
+    "version": "0.3.4",
     "description": "A sqlite node for Node-RED",
     "dependencies": {
         "sqlite3": "^4.0.2"
diff --git a/storage/sqlite/sqlite.js b/storage/sqlite/sqlite.js
index 39c0bc68..540e21e4 100644
--- a/storage/sqlite/sqlite.js
+++ b/storage/sqlite/sqlite.js
@@ -51,14 +51,16 @@ module.exports = function(RED) {
             var doQuery = function(msg) {
                 if (node.sqlquery == "msg.topic"){
                     if (typeof msg.topic === 'string') {
-                        bind = Array.isArray(msg.payload) ? msg.payload : [];
-                        node.mydbConfig.db.all(msg.topic, bind, function(err, row) {
-                            if (err) { node.error(err,msg); }
-                            else {
-                                msg.payload = row;
-                                node.send(msg);
-                            }
-                        });
+                        if (msg.topic.length > 0) {
+                            bind = Array.isArray(msg.payload) ? msg.payload : [];
+                            node.mydbConfig.db.all(msg.topic, bind, function(err, row) {
+                                if (err) { node.error(err,msg); }
+                                else {
+                                    msg.payload = row;
+                                    node.send(msg);
+                                }
+                            });
+                        }
                     }
                     else {
                         node.error("msg.topic : the query is not defined as a string",msg);
@@ -67,13 +69,15 @@ module.exports = function(RED) {
                 }
                 if (node.sqlquery == "batch") {
                     if (typeof msg.topic === 'string') {
-                        node.mydbConfig.db.exec(msg.topic, function(err) {
-                            if (err) { node.error(err,msg);}
-                            else {
-                                msg.payload = [];
-                                node.send(msg);
-                            }
-                        });
+                        if (msg.topic.length > 0) {
+                            node.mydbConfig.db.exec(msg.topic, function(err) {
+                                if (err) { node.error(err,msg);}
+                                else {
+                                    msg.payload = [];
+                                    node.send(msg);
+                                }
+                            });
+                        }
                     }
                     else {
                         node.error("msg.topic : the query is not defined as string", msg);
@@ -81,43 +85,47 @@ module.exports = function(RED) {
                     }
                 }
                 if (node.sqlquery == "fixed"){
-                    if (typeof node.sql === 'string'){
-                        bind = Array.isArray(msg.payload) ? msg.payload : [];
-                        node.mydbConfig.db.all(node.sql, bind, function(err, row) {
-                            if (err) { node.error(err,msg); }
-                            else {
-                                msg.payload = row;
-                                node.send(msg);
-                            }
-                        });
+                    if (typeof node.sql === 'string') {
+                        if (msg.payload && msg.payload.length > 0) {
+                            bind = Array.isArray(msg.payload) ? msg.payload : [];
+                            node.mydbConfig.db.all(node.sql, bind, function(err, row) {
+                                if (err) { node.error(err,msg); }
+                                else {
+                                    msg.payload = row;
+                                    node.send(msg);
+                                }
+                            });
+                        }
                     }
                     else{
-                        if (node.sql === null || node.sql == ""){
+                        if (node.sql === null || node.sql == "") {
                             node.error("SQL statement config not set up",msg);
                             node.status({fill:"red",shape:"dot",text:"SQL config not set up"});
                         }
                     }
                 }
                 if (node.sqlquery == "prepared"){
-                    if (typeof node.sql === 'string' && typeof msg.params !== "undefined" && typeof msg.params === "object"){
-                        node.mydbConfig.db.all(node.sql, msg.params, function(err, row) {
-                            if (err) { node.error(err,msg); }
-                            else {
-                                msg.payload = row;
-                                node.send(msg);
-                            }
-                        });
+                    if (typeof node.sql === 'string' && typeof msg.params !== "undefined" && typeof msg.params === "object") {
+                        if (node.sql.length > 0) {
+                                node.mydbConfig.db.all(node.sql, msg.params, function(err, row) {
+                                if (err) { node.error(err,msg); }
+                                else {
+                                    msg.payload = row;
+                                    node.send(msg);
+                                }
+                            });
+                        }
                     }
-                    else{
-                        if (node.sql === null || node.sql == ""){
+                    else {
+                        if (node.sql === null || node.sql == "") {
                             node.error("Prepared statement config not set up",msg);
                             node.status({fill:"red",shape:"dot",text:"Prepared statement not set up"});
                         }
-                        if (typeof msg.params == "undefined"){
+                        if (typeof msg.params == "undefined") {
                             node.error("msg.params not passed");
                             node.status({fill:"red",shape:"dot",text:"msg.params not defined"});
                         }
-                        else if (typeof msg.params != "object"){
+                        else if (typeof msg.params != "object") {
                             node.error("msg.params not an object");
                             node.status({fill:"red",shape:"dot",text:"msg.params not an object"});
                         }