[bugfix] turn off mongodb auto cast ObjectID

Author: 高鸣飞

lib/define/mongodb.js

@@ -52,17 +52,20 @@ insert(table, sets, callback) {
   if (this._readonly) {
     return errNotAllowd(callback)
   }
-  this._conn.collection(table).insert(_.cloneDeep(sets), (err, result) => {
-    if (err) {
-      return callback(err)
-    }
-    if (result.constructor === Object) {
-      result = [result]
-    }
-    return callback(err, {
-      affected_rows: result.length,
-      docs: result,
-    }, null)
+  this._conn.collection(table).insert(
+    _.cloneDeep(sets),
+    {castIds: false},
+    (err, result) => {
+      if (err) {
+        return callback(err)
+      }
+      if (result.constructor === Object) {
+        result = [result]
+      }
+      return callback(err, {
+        affected_rows: result.length,
+        docs: result,
+      }, null)
   })
 }
 
@@ -85,7 +88,7 @@ update(table, sets, where, callback) {
       update_doc['$set'] = sets
   }
   this._conn.collection(table)
-    .update(where, update_doc, {multi: true}, (err, result) => {
+    .update(where, update_doc, {multi: true, castIds: false}, (err, result) => {
       if (err) {
         return callback(err)
       }
@@ -112,7 +115,7 @@ delete(table, where, callback) {
   if (this._readonly) {
     return errNotAllowd(callback)
   }
-  this._conn.collection(table).remove(where, (err, result) => {
+  this._conn.collection(table).remove(where, {castIds: false}, (err, result) => {
     if (err) {
       return callback(err)
     }
@@ -137,6 +140,7 @@ select(table, fields, where, callback) {
     return callback(err)
   }
   let _fields = fields === '*' ? {} : fields
+  _fields.castIds = false
   this._conn.collection(table).find(where, _fields, (err, docs) => {
     return callback(err, docs, null)
   })
@@ -157,7 +161,9 @@ find(table, options, where, callback) {
   } catch (err) {
     return callback(err)
   }
-  this._conn.collection(table).find(where, options, (err, docs) => {
+  let _options = _.cloneDeep(options)
+  _options.castIds = false
+  this._conn.collection(table).find(where, _options, (err, docs) => {
     return callback(err, docs, null)
   })
 }
@@ -177,7 +183,9 @@ findOneAndUpdate(table, options, sets, where, callback) {
   } catch (err) {
     return callback(err)
   }
-  this._conn.collection(table).findOneAndUpdate(where, sets, 
+  let _options = _.cloneDeep(options)
+  _options.castIds = false
+  this._conn.collection(table).findOneAndUpdate(where, sets, _options,
     (err, updated_doc) => {
       return callback(err, updated_doc, null)
   })
@@ -204,7 +212,9 @@ aggregate(table, options, pipeline, callback) {
   } catch (err) {
     return callback(err)
   }
-  this._conn.collection(table).aggregate(pipeline, options, (err, docs) => {
+  let _options = _.cloneDeep(options)
+  _options.castIds = false
+  this._conn.collection(table).aggregate(pipeline, _options, (err, docs) => {
     return callback(err, docs, null)
   })
 }
@@ -223,7 +233,9 @@ count(table, options, where, callback) {
   } catch (err) {
     return callback(err)
   }
-  this._conn.collection(table).count(where, options, (err, count) => {
+  let _options = _.cloneDeep(options)
+  _options.castIds = false
+  this._conn.collection(table).count(where, _options, (err, count) => {
     return callback(err, count, null)
   })
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sqlx",
-  "version": "4.3.1",
+  "version": "4.3.2",
   "description": "Database driver with extended features like mysql changelog/oplog, connection auto release.",
   "main": "index.js",
   "directories": {