Query interface and generator API sketch

lib/dialects/mysql/query-generator.js

@@ -243,6 +243,10 @@ module.exports = (function() {
       return query
     },
 
+    bulkInsertQuery: function(tableName, attrValueHashes) {
+      throwMethodUndefined('bulkInsertQuery')
+    },
+
     updateQuery: function(tableName, attrValueHash, where) {
       attrValueHash = Utils.removeNullValuesFromHash(attrValueHash, this.options.omitNull)
 

lib/dialects/postgres/query-generator.js

@@ -327,6 +327,10 @@ module.exports = (function() {
       return Utils._.template(query)(replacements)
     },
 
+    bulkInsertQuery: function(tableName, attrValueHashes) {
+      throwMethodUndefined('bulkInsertQuery')
+    },
+
     updateQuery: function(tableName, attrValueHash, where) {
       attrValueHash = Utils.removeNullValuesFromHash(attrValueHash, this.options.omitNull)
 

lib/dialects/query-generator.js

@@ -119,6 +119,14 @@ module.exports = (function() {
     },
 
     /*
+      Returns an insert into command for multiple values.
+      Parameters: table name + list of hashes of attribute-value-pairs.
+    */
+    bulkInsertQuery: function(tableName, attrValueHashes) {
+      throwMethodUndefined('bulkInsertQuery')
+    },
+
+    /*
       Returns an update query.
       Parameters:
         - tableName -> Name of the table

lib/dialects/sqlite/query-generator.js

@@ -125,6 +125,10 @@ module.exports = (function() {
       return Utils._.template(query)(replacements)
     },
 
+    bulkInsertQuery: function(tableName, attrValueHashes) {
+      throwMethodUndefined('bulkInsertQuery')
+    },
+
     updateQuery: function(tableName, attrValueHash, where) {
       attrValueHash = Utils.removeNullValuesFromHash(attrValueHash, this.options.omitNull)
 

lib/query-interface.js

@@ -260,6 +260,13 @@ module.exports = (function() {
     })
   }
 
+  QueryInterface.prototype.bulkInsert = function(tableName, records) {
+    var sql = this.QueryGenerator.bulkInsertQuery(tableName, records)
+    return queryAndEmit.call(this, sql, 'bulkInsert', {
+      success: function(objs) { objs.forEach(function(v) { v.isNewRecord = false }) }
+    })
+  }
+
   QueryInterface.prototype.update = function(dao, tableName, values, identifier) {
     var sql = this.QueryGenerator.updateQuery(tableName, values, identifier)
     return queryAndEmit.call(this, [sql, dao], 'update')
@@ -270,6 +277,11 @@ module.exports = (function() {
     return queryAndEmit.call(this, [sql, dao], 'delete')
   }
 
+  QueryInterface.prototype.bulkDelete = function(tableName, identifier) {
+    var sql = this.QueryGenerator.deleteQuery(tableName, identifier)
+    return queryAndEmit.call(this, sql, 'bulkDelete')
+  }
+
   QueryInterface.prototype.select = function(factory, tableName, options, queryOptions) {
     options = options || {}