在 MongoDB 中更新数据

1
using MongoDB.Bson;
2
using MongoDB.Driver;
3
using MongoDB.Bson.Serialization.Conventions;
4
5
// Replace the uri string with your MongoDB deployment's connection string.
6
var uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
7
8
// instruct the driver to camelCase the fields in MongoDB
9
var pack = new ConventionPack { new CamelCaseElementNameConvention() };
10
ConventionRegistry.Register("elementNameConvention", pack, x => true);
11
12
var client = new MongoClient(uri);
13
14
// database and collection code goes here
15
var db = client.GetDatabase("sample_guides");
16
var coll = db.GetCollection<Comet>("comets");
17
18
// update code goes here
19
var filter = Builders<Comet>.Filter.Empty;
20
var update = Builders<Comet>.Update.Mul("radius", 1.60934);
21
var result = coll.UpdateMany(filter, update);
22
23
// display the results of your operation
24
Console.WriteLine($"Number of documents updated: {result.ModifiedCount}");
25
26
// class that maps to the fields of a document in the sample_guides.comets collection
27
class Comet
28
{
29
    public ObjectId Id { get; set; }
30
    public string Name { get; set; }
31
    public string OfficialName { get; set; }
32
    public double OrbitalPeriod { get; set; }
33
    public double Radius { get; set; }
34
    public double Mass { get; set; }
35
}

1
package main
2
3
import (
4
	"context"
5
	"fmt"
6
7
	"go.mongodb.org/mongo-driver/bson"
8
	"go.mongodb.org/mongo-driver/mongo"
9
	"go.mongodb.org/mongo-driver/mongo/options"
10
)
11
12
func main() {
13
	uri := "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"
14
15
	client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
16
	if err != nil {
17
		panic(err)
18
	}
19
20
	defer func() {
21
		if err = client.Disconnect(context.TODO()); err != nil {
22
			panic(err)
23
		}
24
	}()
25
26
	// database and colletion code goes here
27
	db := client.Database("sample_guides")
28
	coll := db.Collection("comets")
29
30
	// update code goes here
31
	filter := bson.D{{}}
32
	update := bson.D{{"$mul", bson.D{{"radius", 1.60934}}}}
33
34
	result, err := coll.UpdateMany(context.TODO(), filter, update)
35
	if err != nil {
36
		panic(err)
37
	}
38
39
	// display the results of your operation
40
	fmt.Printf("Number of documents updated: %d", result.ModifiedCount)
41
}

1
import com.mongodb.client.MongoClient;
2
import com.mongodb.client.MongoClients;
3
import com.mongodb.client.MongoCollection;
4
import com.mongodb.client.MongoDatabase;
5
import com.mongodb.client.result.UpdateResult;
6
import com.mongodb.client.model.Filters;
7
import com.mongodb.client.model.Updates;
8
9
import org.bson.Document;
10
import org.bson.conversions.Bson;
11
12
public class CrudUpdate {
13
    public static void main(String[] args) {
14
        String uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
15
16
        try (MongoClient mongoClient = MongoClients.create(uri)) {
17
            // database and collection code goes here
18
            MongoDatabase db = mongoClient.getDatabase("sample_guides");
19
            MongoCollection<Document> coll = db.getCollection("comets");
20
21
            // update code goes here
22
            Bson filter = Filters.empty();
23
            Bson update = Updates.mul("radius", 1.60934);
24
            UpdateResult result = coll.updateMany(filter, update);
25
26
            // display the results of your operation
27
            System.out.println("Number of documents updated: " + result.getModifiedCount());
28
        }
29
    }
30
}

1
const { MongoClient } = require("mongodb");
2
3
// Replace the uri string with your MongoDB deployment's connection string.
4
const uri =
5
  "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority";
6
7
const client = new MongoClient(uri);
8
9
async function run() {
10
  try {
11
    await client.connect();
12
    // database and collection code goes here
13
    const db = client.db("sample_guides");
14
    const coll = db.collection("comets");
15
16
    // update code goes here
17
    const filter = {};
18
    const updateDoc = {
19
      $mul: {
20
        radius: 1.60934,
21
      },
22
    };
23
24
    const result = await coll.updateMany(filter, updateDoc);
25
26
    // display the results of your operation
27
    console.log("Number of documents updated: " + result.modifiedCount);
28
  } finally {
29
    // Ensures that the client will close when you finish/error
30
    await client.close();
31
  }
32
}
33
run().catch(console.dir);

1
from pymongo import MongoClient
2
3
# Replace the uri string with your MongoDB deployment's connection string.
4
uri = "mongodb+srv://<user>:<password>@<cluster-url>?retryWrites=true&writeConcern=majority"
5
6
client = MongoClient(uri)
7
8
# database and collection code goes here
9
db = client.sample_guides
10
coll = db.comets
11
12
# update code goes here
13
doc = {"$mul": {"radius": 1.60934}}
14
result = coll.update_many({}, doc)
15
16
# display the results of your operation
17
print("Number of documents updated: ", result.modified_count)
18
19
# Close the connection to MongoDB when you're done.
20
client.close()