bulkwrite mongodb code example

Example 1: mongodb bulkwrite nodejs

const { MongoClient } = require("mongodb");
// Replace the uri string with your MongoDB deployment's connection string.
const uri =
  "mongodb+srv://<user>:<password>@<cluster-url>?writeConcern=majority";
const client = new MongoClient(uri);
async function run() {
  try {
    await client.connect();
    const database = client.db("sample_mflix");
    const theaters = database.collection("theaters");
    const result = await theaters.bulkWrite([
      { insertOne:
        {
          "document": {
            location: {
              address: { street1: '3 Main St.', city: 'Anchorage', state: 'AK', zipcode: '99501' },
            }
          }
        }
      },
      { insertOne:
        {
          "document": {
            location: {
              address: { street1: '75 Penn Plaza', city: 'New York', state: 'NY', zipcode: '10001' },
            }
          }
        }
      },
      { updateMany:
        {
          "filter": { "location.address.zipcode" : "44011" },
          "update": { $set : { "street2" : "25th Floor" } },
          "upsert": true
        }
      },
      { deleteOne :
        { "filter" : { "location.address.street1" : "221b Baker St"} }
      },
    ]);
    console.log(result);
  } finally {
    await client.close();
  }
}
run().catch(console.dir)

Example 2: mongodb bulk update

const bulk = db.items.initializeUnorderedBulkOp();
bulk.find( { status: "D" } ).update( { $set: { status: "I", points: "0" } } );
bulk.find( { item: null } ).update( { $set: { item: "TBD" } } );
bulk.execute();