SQL module can output named prepared statements

Author: mistic100

src/plugins/sql-support/plugin.js

@@ -21,6 +21,53 @@ QueryBuilder.defaults({
         is_not_empty:     '!= ""',
         is_null:          'IS NULL',
         is_not_null:      'IS NOT NULL'
+    },
+
+    sqlStatements: {
+        'question_mark': function() {
+            var bind_params = [];
+            return {
+                add: function(rule, value) {
+                    bind_params.push(value);
+                    return '?';
+                },
+                run: function() {
+                    return bind_params;
+                }
+            };
+        },
+
+        'numbered': function() {
+            var bind_index = 0;
+            var bind_params = [];
+            return {
+                add: function(rule, value) {
+                    bind_params.push(value);
+                    bind_index++;
+                    return '$' + bind_index;
+                },
+                run: function() {
+                    return bind_params;
+                }
+            };
+        },
+
+        'named': function() {
+            var bind_index = {};
+            var bind_params = {};
+            return {
+                add: function(rule, value) {
+                    if (!bind_index[rule.field]) bind_index[rule.field] = 0;
+                    bind_index[rule.field]++;
+                    var key = rule.field + '_' + bind_index[rule.field];
+                    bind_params[key] = value;
+                    return ':' + key;
+                },
+                run: function() {
+                    return bind_params;
+                }
+            };
+        }
     }
 });
 
@@ -37,8 +84,10 @@ QueryBuilder.extend({
      */
     getSQL: function(stmt, nl, data) {
         data = (data===undefined) ? this.getRules() : data;
-        stmt = (stmt===true || stmt===undefined) ? 'question_mark' : stmt;
-        nl =   (nl || nl===undefined) ? '\n' : ' ';
+        nl = (nl===true) ? '\n' : ' ';
+
+        if (stmt===true || stmt===undefined) stmt = 'question_mark';
+        if (typeof stmt == 'string') stmt = this.settings.sqlStatements[stmt]();
 
         var that = this,
             bind_index = 1,
@@ -93,15 +142,7 @@ QueryBuilder.extend({
                             }
 
                             if (stmt) {
-                                if (stmt == 'question_mark') {
-                                    value+= '?';
-                                }
-                                else {
-                                    value+= '$'+bind_index;
-                                }
-
-                                bind_params.push(v);
-                                bind_index++;
+                                value+= stmt.add(rule, v);
                             }
                             else {
                                 if (typeof v === 'string') {
@@ -123,7 +164,7 @@ QueryBuilder.extend({
         if (stmt) {
             return {
                 sql: sql,
-                params: bind_params
+                params: stmt.run()
             };
         }
         else {

tests/plugins.module.js

@@ -76,15 +76,27 @@ $(function(){
     });
 
     assert.deepEqual(
-      $b.queryBuilder('getSQL', false, false),
+      $b.queryBuilder('getSQL', false),
       basic_rules_sql_raw,
       'Should create SQL query'
     );
 
     assert.deepEqual(
-      $b.queryBuilder('getSQL', true, false),
+      $b.queryBuilder('getSQL', 'question_mark'),
       basic_rules_sql_stmt,
-      'Should create SQL query with statements'
+      'Should create SQL query with statements (?)'
+    );
+
+    assert.deepEqual(
+      $b.queryBuilder('getSQL', 'numbered'),
+      basic_rules_sql_stmt_num,
+      'Should create SQL query with statements (numbered)'
+    );
+
+    assert.deepEqual(
+      $b.queryBuilder('getSQL', 'named'),
+      basic_rules_sql_stmt_named,
+      'Should create SQL query with statements (named)'
     );
 
     assert.deepEqual(
@@ -306,13 +318,28 @@ $(function(){
   });
 
 
+  var basic_rules_sql_raw = {
+    sql: 'price < 10.25 AND name IS NULL AND ( category IN(\'mo\', \'mu\') OR id != \'1234-azer-5678\' ) '
+  };
+
   var basic_rules_sql_stmt = {
     sql: 'price < ? AND name IS NULL AND ( category IN(?, ?) OR id != ? ) ',
     params: [10.25, 'mo', 'mu', '1234-azer-5678']
   };
+  
+  var basic_rules_sql_stmt_num = {
+    sql: 'price < $1 AND name IS NULL AND ( category IN($2, $3) OR id != $4 ) ',
+    params: [10.25, 'mo', 'mu', '1234-azer-5678']
+  };
 
-  var basic_rules_sql_raw = {
-    sql: 'price < 10.25 AND name IS NULL AND ( category IN(\'mo\', \'mu\') OR id != \'1234-azer-5678\' ) '
+  var basic_rules_sql_stmt_named = {
+    sql: 'price < :price_1 AND name IS NULL AND ( category IN(:category_1, :category_2) OR id != :id_1 ) ',
+    params: {
+      price_1: 10.25,
+      category_1: 'mo',
+      category_2: 'mu',
+      id_1: '1234-azer-5678'
+    }
   };
 
   var basic_rules_mongodb = {'$and': [