Insert now has a dynamic metadata

Author: zubairov

component.json

@@ -23,7 +23,8 @@
           "placeholder": "INSERT INTO films (code,title,kind) VALUES (@code:number,@title:string,@kind:string)",
           "note": "You can use parameters of message body as <i>@value:number</i> and type is <i>:type</i>"
         }
-      }
+      },
+      "dynamicMetadata": true
     },
     "selectAction": {
       "title": "SELECT",
@@ -51,11 +52,6 @@
           "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"
-        },
-        "batch": {
-          "label": "Bundle results in batches",
-          "required": false,
-          "viewClass": "CheckBoxView"
         }
       }
     }

lib/actions/insert.js

@@ -7,6 +7,12 @@ let pstmt;
 
 const VARS_REGEXP = /@([\w_$][\d\w_$]*:(string|boolean|date|number|bigint))/g;
 
+/**
+ * This function will be called during component intialization
+ *
+ * @param cfg
+ * @returns {Promise}
+ */
 function init(cfg) {
     const conString = cfg.uri;
     return co(function* gen() {
@@ -51,6 +57,44 @@ function init(cfg) {
     }.bind(this));
 }
 
+/**
+ * This function will be called to fetch metamodel for SQL query
+ *
+ * @param cfg
+ */
+function getMetaModel(cfg) {
+  return co(function* gen() {
+    const sql = cfg.query;
+    const result = {
+      in : {
+        type: 'object',
+        properties : {}
+      },
+      out : {}
+    };
+    if (sql && sql.length > 0) {
+      const vars = sql.match(VARS_REGEXP);
+      const fields = result.in.properties;
+      for(const tuple of vars) {
+        const [key,type] = tuple.split(':');
+        let jsType = 'string';
+        switch(type) {
+          case 'date':
+            jsType = 'string';
+            break;
+          case 'bigint':
+            jsType = 'number';
+            break;
+        }
+        fields[key.substr(1)] = {
+          type : jsType
+        };
+      }
+    }
+    return result;
+  });
+}
+
 /**
  * This method will be called from elastic.io platform providing following data
  *
@@ -68,3 +112,4 @@ function processAction(msg) {
 
 module.exports.process = processAction;
 module.exports.init = init;
+module.exports.getMetaModel = getMetaModel;

lib/actions/select.js

@@ -20,6 +20,7 @@ function init(cfg) {
         yield connection.connect();
     }.bind(this));
 }
+
 /**
  * This method will be called from elastic.io platform providing following data
  *
@@ -50,7 +51,7 @@ function processAction(msg, cfg) {
             this.emit('end');
         });
 
-      // Run it
+        // Run it
         yield request.query(sql);
     }.bind(this));
 }