Templating for SQL SELECT query

.travis.yml

@@ -1,5 +1,6 @@
 language: node_js
 node_js:
+  - v8
   - v7
   - v6
 script: npm test && npm run integration-test

README.md

@@ -4,8 +4,7 @@
 # mssql-component
 MSSQL Component component for the [elastic.io platform](http://www.elastic.io "elastic.io platform")
 
-![image](https://cloud.githubusercontent.com/assets/56208/22904377/89b611c4-f23c-11e6-8b5d-783d62cf5caf.png)
-
+![image](https://user-images.githubusercontent.com/56208/29715706-b4930bdc-89a8-11e7-8a0d-969959d26dd6.png)
 
 ## Before you Begin
 
@@ -26,6 +25,9 @@ other types of configuration parameters are also supported, more infromation and
 ### SELECT Trigger and Action
 
 With this action you may fetch data out of the database, e.g. using ``SELECT`` statement. 
+
+![image](https://user-images.githubusercontent.com/56208/29715706-b4930bdc-89a8-11e7-8a0d-969959d26dd6.png)
+
 This trigger & action has no limitations on the number of rows so you may expect to get all of these
 via sequential fetching that is implemented within the node.js ``mssql`` driver.
 
@@ -39,7 +41,7 @@ select * from Leads where Created >= '%%EIO_LAST_POLL%%'
 
 ### INSERT/DELETE/UPDATE Action
 
-![image](https://cloud.githubusercontent.com/assets/56208/22904204/cef8cb06-f23b-11e6-998f-3fe65ab81540.png)
+![image](https://user-images.githubusercontent.com/56208/29715914-9c369ee0-89a9-11e7-89cb-a559f4a8861f.png)
 
 You may use this action to do the operations that are not producing output rows but do the database manipulations, 
 e.g. ``INSERT``, ``UPDATE`` or ``DELETE`` statements. Internally we use prepared statements, so all incoming data is
@@ -84,8 +86,8 @@ Component supports dynamic incomig metadata - as soon as your query is in place
 No known issues are there yet.
 
 ## TODOs
- * Support for templating in SELECT query
  * Support for BULK upload
+ * Support for DELETE and UPDATE statements
  * Support for binary attachments
 
 ## License

component.json

@@ -31,13 +31,16 @@
       "title": "SELECT",
       "description": "Executes a SELECT statement that fetches potentially multiple database rows from the database",
       "main": "./lib/actions/select.js",
-      "fields": {
-        "query": {
-          "label": "SQL Query",
-          "required": true,
-          "viewClass": "TextAreaWithNoteView",
-          "placeholder": "SELECT * FROM films WHERE title LIKE ${'%' + query + '%'}",
-          "note": "You can use properties of message body as <i>${values}</i> in your query"
+      "metadata": {
+        "in": {
+          "type": "object",
+          "properties": {
+            "query": {
+              "type": "string",
+              "title": "SQL Query",
+              "required": true
+            }
+          }
         }
       }
     }
@@ -48,13 +51,16 @@
       "description": "Executes a SELECT statement that fetches potentially multiple database rows from the database",
       "main": "./lib/actions/select.js",
       "type": "polling",
-      "fields": {
-        "query": {
-          "label": "SQL Query",
-          "required": true,
-          "viewClass": "TextAreaWithNoteView",
-          "placeholder": "SELECT * FROM films WHERE title LIKE ${'%' + query + '%'}",
-          "note": "You can use properties of message body as <i>${values}</i> in your insert or update or delete"
+      "metadata": {
+        "in": {
+          "type": "object",
+          "properties": {
+            "query": {
+              "type": "string",
+              "title": "SQL Query",
+              "required": true
+            }
+          }
         }
       }
     }

lib/actions/select.js

@@ -31,7 +31,7 @@ function init(cfg) {
  * @param cfg configuration that is account information and configuration field values
  */
 function processAction(msg, cfg, snapshot = {}) {
-    const originalSql = cfg.query;
+    const originalSql = cfg.query || msg.body.query;
     const now = new Date().toISOString();
     // Last poll should come from Snapshot, if not it's beginning of time
     const lastPoll = snapshot.lastPoll || new Date(0).toISOString();