bulk.insert(doc) 默认值无法插入 MongoDB nodejs

如何解决bulk.insert(doc) 默认值无法插入 MongoDB nodejs

我已经插入了 100k 条记录，我已经成功地批量上传了记录。但是，如果我使用 bulk.insert(doc)，则不会使用 mongoose 和 Nodejs 插入默认值。像 createdAt 和 updatedAt 字段作为未插入的默认值。我试图添加选项 setDefaultsOnInsert: true bulk.insert 没有选项来添加值。目前，我添加了我的代码。请帮我提前。

代码

let data = req.body;
    var bulk = callDispositionModel.collection.initializeOrderedBulkOp();
    var counter=0
    data.forEach(doc1 => {
        bulk.insert(doc1);
        if (counter % 5000 == 0) {
            bulk.execute();
            bulk = callDispositionModel.collection.initializeUnorderedBulkOp();
            counter = 0;
        }

    counter++
    })

    if (counter > 0) {
        bulk.execute(function(err,result) {
        if(err){
            console.log(`err `,err)
        }else{
            console.log(`result `,result)
            return res.send({success: true,message:'data uploaded successfully')
        }
        });
    }

架构或模型

let dispositionSchema = new mongoose.Schema({
    name : {type: String,default: null},mobile : {type : String,remarks : {type: String,default:null},duration: {type : String,amount : {type : Number,default: 0},date : {type : String,time : {type : String,createdAt: {type: Date,default: Date.now },updatedAt: {type: Date,default: Date.now }
});

const disposition = mongoose.model('disposition',dispositionSchema);
export default disposition;

数据

在mongodb中插入数据

{
    "_id" : ObjectId("6098e6d007e2804b9c1f8317"),"name" : "senthil","amount" : 0
}
{
    "_id" : ObjectId("6098e6d007e2804b9c1f8316"),"name" : "periyas","amount" : 0
}
  

但是，我已经预料到了输出

预期数据

{
    "_id" : ObjectId("6098e6d007e2804b9c1f8317"),"amount" : 0,"mobile" : null,"remarks" : null,"createdAt": "2021-05-07T13:55:34.233Z"
},{
    "_id" : ObjectId("6098e6d007e2804b9c1f8316"),"createdAt": "2021-05-07T13:55:34.233Z"
}

解决方法

有一个批量插入支持request in mongoose github，由版主阅读comment之一：

initializeUnorderedBulkOp() 和 initializeOrderedBulkOp() api 方法，已被 mongodb “软弃用”。它已被 bulkWrite() API 取代，后者是 MongoDB 核心 CRUD 规范的一部分，因此得到了更广泛的实现。特别是，从 4.9.0 开始，mongoose 有一个 Model.bulkWrite() 函数，它具有验证、强制转换、promise 和 ref depopulating 功能。

您可以使用 bulkWrite() 类似的东西：

let data = req.body;
let bulk = [];    
data.forEach((doc1) => {
    bulk.push({ "insertOne": { "document": doc1 } });
    if (bulk.length === 5000) {
        callDispositionModel.bulkWrite(bulk).then((result) => {});
        bulk = [];
    }
})
if (bulk.length > 0) {
    callDispositionModel.bulkWrite(bulk).then((res) => {
        console.log(res.insertedCount);
        return res.send({success: true,message: 'all data uploaded successfully'})
    });
}

,

改变

let dispositionSchema = new mongoose.Schema({
 name : {type: String,default: null},mobile : {type : String,remarks : {type: String,default:null},duration: {type : String,amount : {type : Number,default: 0},date : {type : String,time : {type : String,createdAt: {type: Date,default: Date.now },updatedAt: {type: Date,default: Date.now }
});

到

let dispositionSchema = new mongoose.Schema({
 name : {type: String,default: Date.now }
},{ timestamps: { createdAt: 'createdAt',updatedAt: 'updatedAt'} });

More detail here

,

您现在可以在 Schema 上设置时间戳选项，让 Mongoose 为您处理：

var dispositionSchema = new Schema({..},{ timestamps: true });