Perform Bulk Operations

You can perform bulk write operations on a collection by using the BulkWrite() method.

Example

Tip

Read the Usage Examples to learn how to run this example.

This example uses the following Restaurant struct as a model for documents in the restaurants collection:

type Restaurant struct {	Name         string	RestaurantId string        `bson:"restaurant_id,omitempty"`	Cuisine      string        `bson:"cuisine,omitempty"`	Address      interface{}   `bson:"address,omitempty"`	Borough      string        `bson:"borough,omitempty"`	Grades       []interface{} `bson:"grades,omitempty"`}

The omitempty struct tag omits the corresponding field from the inserted document when left empty.

The following example performs the following in order on the restaurants collection:

Matches a document in which the name is "Cafe Tomato" and replaces it with a new document
Matches a document in which the name is "Cafe Zucchini" and updates the value to "Zucchini Land"

coll := client.Database("sample_restaurants").Collection("restaurants")
// Creates write models that specify replace and update operationsmodels := []mongo.WriteModel{	mongo.NewReplaceOneModel().SetFilter(bson.D{{"name", "Cafe Tomato"}}).		SetReplacement(Restaurant{Name: "Cafe Zucchini", Cuisine: "French"}),	mongo.NewUpdateOneModel().SetFilter(bson.D{{"name", "Cafe Zucchini"}}).		SetUpdate(bson.D{{"$set", bson.D{{"name", "Zucchini Land"}}}}),}
// Specifies that the bulk write is orderedopts := options.BulkWrite().SetOrdered(true)
// Runs a bulk write operation for the specified write operationsresults, err := coll.BulkWrite(context.TODO(), models, opts)

View a fully runnable example

Expected Result

After you run the full example, you can find the following document in the restaurants collection:

{  "_id": ObjectId("..."),  "name": "Zucchini Land",  "cuisine": "French"}

For an example on how to find a document, see Find a Document.

Additional Information

To learn more about performing bulk write operations on a collection and handling potential errors, see Bulk Operations.

API Documentation

Back

Delete Many

Open a Change Stream