From e308b0c1f9e35dc62d094684a69c8037592f108e Mon Sep 17 00:00:00 2001
From: tmdoit <tm@digitaloak.it>
Date: Thu, 19 Jul 2018 13:33:43 +0200
Subject: [PATCH] Add support for batch of SQL statements (#466)

* Add support for batch of SQL statements
---
 storage/sqlite/sqlite.html |  6 ++++--
 storage/sqlite/sqlite.js   | 21 +++++++++++++++++----
 2 files changed, 21 insertions(+), 6 deletions(-)

diff --git a/storage/sqlite/sqlite.html b/storage/sqlite/sqlite.html
index a38a0519..78a0d322 100644
--- a/storage/sqlite/sqlite.html
+++ b/storage/sqlite/sqlite.html
@@ -34,6 +34,7 @@
             <option value="msg.topic">Via msg.topic</option>
             <option value="fixed">Fixed Statement</option>
             <option value="prepared">Prepared Statement</option>
+            <option value="batch">Batch without response</option>
         </select>
     </div>
     <div class="form-row" style="margin-bottom: 0px;">
@@ -53,7 +54,8 @@
     <p>SQL Query <i>Via msg.topic</i> and <i>Fixed Statement</i> uses the <b>db.all</b> operation against the configured database. This does allow INSERTS, UPDATES and DELETES.
     By its very nature it is SQL injection... so <i>be careful out there...</i></p>
     <p>SQL Type <i>Prepared Statement</i> also uses <b>db.all</b> but sanitizes parameters passed, eliminating the possibility of SQL injection.</p>
-    <p>When using msg.topic <code>msg.topic</code> must hold the <i>query</i> for the database.</p>
+    <p>SQL Type <i>Batch without response</i> uses <b>db.exec</b> which runs all SQL statements in the provided string. No result rows are returned.</p>
+    <p>When using <i>Via msg.topic</i> or <i>Batch without response</i> <code>msg.topic</code> must hold the <i>query</i> for the database.</p>
     <p>When using Normal or Prepared the <i>query</i> must be entered in the node config.</p>
     <p>Pass in the parameters as an object in <code>msg.params</code> for Prepared.  Ex:<br />
     <code>msg.params = {<br />
@@ -111,7 +113,7 @@
             });
             
             $("#node-input-sqlquery").change(function() {
-                if ($("#node-input-sqlquery").val() == "msg.topic"){
+                if ($("#node-input-sqlquery").val() == "msg.topic" || $("#node-input-sqlquery").val() == "batch"){
                     $("#node-input-sqllabel").hide();
                     $("#node-input-sql-editor").hide();
                 }
diff --git a/storage/sqlite/sqlite.js b/storage/sqlite/sqlite.js
index bb5b8dd4..ffb0ab9f 100644
--- a/storage/sqlite/sqlite.js
+++ b/storage/sqlite/sqlite.js
@@ -55,10 +55,23 @@ module.exports = function(RED) {
                         });
                     }
                     else {
-                        if (typeof msg.topic !== 'string') {
-                            node.error("msg.topic : the query is not defined as a string",msg);
-                            node.status({fill:"red",shape:"dot",text:"msg.topic error"});
-                        }
+                        node.error("msg.topic : the query is not defined as a string",msg);
+                        node.status({fill:"red",shape:"dot",text:"msg.topic error"});
+                    }
+                }
+                if (this.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);
+                            }
+                        });
+                    }
+                    else {
+                        node.error("msg.topic : the query is not defined as string", msg);
+                        node.status({fill:"red", shape:"dot",text:"msg.topic error"});
                     }
                 }
                 if (this.sqlquery == "fixed"){