NODE-540 implemented bypassDocumentValidation

Author: christkv

lib/bulk/ordered.js

@@ -286,6 +286,8 @@ function OrderedBulkOperation(topology, collection, options) {
     , promiseLibrary: promiseLibrary
 		// Fundamental error
 		, err: null
+    // Bypass validation
+    , bypassDocumentValidation: typeof options.bypassDocumentValidation == 'boolean' ? options.bypassDocumentValidation : false
   }
 }
 
@@ -434,6 +436,11 @@ var executeCommands = function(self, callback) {
 		finalOptions.serializeFunctions = true
 	}
 
+  // Is the bypassDocumentValidation options specific
+  if(self.s.bypassDocumentValidation == true) {
+    finalOptions.bypassDocumentValidation = true;
+  }
+
   try {
     if(batch.batchType == common.INSERT) {
       self.s.topology.insert(self.s.collection.namespace, batch.operations, finalOptions, resultHandler);

lib/bulk/unordered.js

@@ -295,6 +295,8 @@ var UnorderedBulkOperation = function(topology, collection, options) {
     , collection: collection
     // Promise Library
     , promiseLibrary: promiseLibrary
+    // Bypass validation
+    , bypassDocumentValidation: typeof options.bypassDocumentValidation == 'boolean' ? options.bypassDocumentValidation : false
   }
 }
 
@@ -422,6 +424,11 @@ var executeBatch = function(self, batch, callback) {
 		finalOptions.serializeFunctions = true
 	}
 
+  // Is the bypassDocumentValidation options specific
+  if(self.s.bypassDocumentValidation == true) {
+    finalOptions.bypassDocumentValidation = true;
+  }
+
   try {
     if(batch.batchType == common.INSERT) {
       self.s.topology.insert(self.s.collection.namespace, batch.operations, finalOptions, resultHandler);

lib/collection.js

@@ -355,6 +355,7 @@ define.classMethod('find', {callback: false, promise:false, returns: [Cursor]});
  * @param {boolean} [options.j=false] Specify a journal write concern.
  * @param {boolean} [options.serializeFunctions=false] Serialize functions on any object.
  * @param {boolean} [options.forceServerObjectId=false] Force server to assign _id values instead of driver.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~insertWriteOpCallback} [callback] The command result callback
  * @return {Promise} returns Promise if no callback passed
  */
@@ -511,6 +512,7 @@ define.classMethod('insertMany', {callback: true, promise:true});
  * @param {boolean} [options.j=false] Specify a journal write concern.
  * @param {boolean} [options.serializeFunctions=false] Serialize functions on any object.
  * @param {boolean} [options.ordered=true] Execute write operation in ordered or unordered fashion.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~bulkWriteOpCallback} [callback] The command result callback
  * @return {Promise} returns Promise if no callback passed
  */
@@ -680,6 +682,7 @@ define.classMethod('bulkWrite', {callback: true, promise:true});
  * @param {boolean} [options.j=false] Specify a journal write concern.
  * @param {boolean} [options.serializeFunctions=false] Serialize functions on any object.
  * @param {boolean} [options.forceServerObjectId=false] Force server to assign _id values instead of driver.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~insertWriteOpCallback} [callback] The command result callback
  * @return {Promise} returns Promise if no callback passed
  * @deprecated Use insertOne, insertMany or bulkWrite
@@ -730,6 +733,7 @@ define.classMethod('insert', {callback: true, promise:true});
  * @param {(number|string)} [options.w=null] The write concern.
  * @param {number} [options.wtimeout=null] The write concern timeout.
  * @param {boolean} [options.j=false] Specify a journal write concern.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~updateWriteOpCallback} [callback] The command result callback
  * @return {Promise} returns Promise if no callback passed
  */
@@ -778,6 +782,7 @@ define.classMethod('updateOne', {callback: true, promise:true});
  * @param {(number|string)} [options.w=null] The write concern.
  * @param {number} [options.wtimeout=null] The write concern timeout.
  * @param {boolean} [options.j=false] Specify a journal write concern.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~updateWriteOpCallback} [callback] The command result callback
  * @return {Promise} returns Promise if no callback passed
  */
@@ -910,6 +915,7 @@ var updateDocuments = function(self, selector, document, options, callback) {
  * @param {boolean} [options.j=false] Specify a journal write concern.
  * @param {boolean} [options.upsert=false] Update operation is an upsert.
  * @param {boolean} [options.multi=false] Update one/all documents with operation.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~writeOpCallback} [callback] The command result callback
  * @throws {MongoError}
  * @return {Promise} returns Promise if no callback passed
@@ -955,6 +961,7 @@ define.classMethod('update', {callback: true, promise:true});
  * @param {(number|string)} [options.w=null] The write concern.
  * @param {number} [options.wtimeout=null] The write concern timeout.
  * @param {boolean} [options.j=false] Specify a journal write concern.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~deleteWriteOpCallback} [callback] The command result callback
  * @return {Promise} returns Promise if no callback passed
  */
@@ -2194,6 +2201,11 @@ var findAndModify = function(self, query, sort, doc, options, callback) {
     queryObject.writeConcern = finalOptions.writeConcern;
   }
 
+  // Have we specified bypassDocumentValidation
+  if(typeof finalOptions.bypassDocumentValidation == 'boolean') {
+    queryObject.bypassDocumentValidation = finalOptions.bypassDocumentValidation;
+  }
+
   // Execute the command
   self.s.db.command(queryObject
     , options, function(err, result) {
@@ -2257,6 +2269,7 @@ define.classMethod('findAndRemove', {callback: true, promise:true});
  * @param {boolean} [options.explain=false] Explain returns the aggregation execution plan (requires mongodb 2.6 >).
  * @param {boolean} [options.allowDiskUse=false] allowDiskUse lets the server know if it can use disk to store temporary results for the aggregation (requires mongodb 2.6 >).
  * @param {number} [options.maxTimeMS=null] maxTimeMS specifies a cumulative time limit in milliseconds for processing operations on the cursor. MongoDB interrupts the operation at the earliest following interrupt point.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~resultCallback} callback The command result callback
  * @return {(null|AggregationCursor)}
  */
@@ -2296,6 +2309,12 @@ Collection.prototype.aggregate = function(pipeline, options, callback) {
 
   // Build the command
   var command = { aggregate : this.s.name, pipeline : pipeline};
+
+  // If we have bypassDocumentValidation set
+  if(typeof options.bypassDocumentValidation == 'boolean') {
+    command.bypassDocumentValidation = options.bypassDocumentValidation;
+  }
+
   // If we have allowDiskUse defined
   if(options.allowDiskUse) command.allowDiskUse = options.allowDiskUse;
   if(typeof options.maxTimeMS == 'number') command.maxTimeMS = options.maxTimeMS;
@@ -2764,6 +2783,7 @@ function processScope (scope) {
  * @param {object} [options.scope=null] Can pass in variables that can be access from map/reduce/finalize.
  * @param {boolean} [options.jsMode=false] It is possible to make the execution stay in JS. Provided in MongoDB > 2.0.X.
  * @param {boolean} [options.verbose=false] Provide statistics on job execution time.
+ * @param {boolean} [options.bypassDocumentValidation=false] Allow driver to bypass schema validation in MongoDB 3.2 or higher.
  * @param {Collection~resultCallback} [callback] The command result callback
  * @throws {MongoError}
  * @return {Promise} returns Promise if no callback passed
@@ -2826,6 +2846,11 @@ var mapReduce = function(self, map, reduce, options, callback) {
       options.readPreference = 'primary';
   }
 
+  // Is bypassDocumentValidation specified
+  if(typeof options.bypassDocumentValidation == 'boolean') {
+    mapCommandHash.bypassDocumentValidation = options.bypassDocumentValidation;
+  }
+
   // Execute command
   self.s.db.command(mapCommandHash, {readPreference:options.readPreference}, function (err, result) {
     if(err) return handleCallback(callback, err);