sql >> データベース >  >> NoSQL >> MongoDB

MongoDB一括挿入は重複を無視します

    別の方法は、 bulk.find().upsert().replaceOne() 代わりに:

    MongoClient.connect(mongoURL, function(err, db) {
        if(err) console.err(err)
        let col = db.collection('user_ids')
        let batch = col.initializeUnorderedBulkOp()
    
        ids.forEach(function(id) {        
            batch.find({ userid: id }).upsert().replaceOne({ 
                userid: id, 
                used: false,  
                group: argv.groupID 
            });
        });
    
        batch.execute(function(err, result) {
            if(err) {
                console.error(new Error(err))
                db.close()
            }
    
            // Do some work
    
            db.close()
        });
    });
    

    上記で、ドキュメントがクエリ{ userid: id }と一致する場合 新しいドキュメントに置き換えられます。そうでない場合は作成されるため、重複するキーエラーはスローされません。

    MongoDBサーバーバージョン3.2以降の場合は、 bulkWrite として:

    MongoClient.connect(mongoURL, function(err, db) {
    
        if(err) console.err(err)
    
        let col = db.collection('user_ids')
        let ops = []
        let counter = 0
    
        ids.forEach(function(id) {
            ops.push({
                "replaceOne": {
                    "filter": { "userid": id },
                    "replacement": { 
                        userid: id, 
                        used: false,  
                        group: argv.groupID 
                    },
                    "upsert": true
                }
            })
    
            counter++
    
            if (counter % 500 === 0) {
                col.bulkWrite(ops, function(err, r) {
                    // do something with result
                    db.close()
                })
                ops = []
            }
        })
    
        if (counter % 500 !== 0) {
            col.bulkWrite(ops, function(err, r) {
                // do something with result
                db.close()
            }
        } 
    })
    



    1. MongoDB-フィールド内の数字以外の文字を削除します

    2. mongoDBでのarrayFiltersパラメーターのしくみ

    3. MongoDBSSLレプリカのセットアップの問題-サポートされていない証明書

    4. spring-dataを使用したMongoDBからのランダムドキュメント