执行批量操作

1
// Bulk write operation
2
3
// Import MongoClient from the MongoDB node driver package
4
const { MongoClient } = require("mongodb");
5
6
// Replace the uri string with your MongoDB deployment's connection string
7
const uri = "<connection string uri>";
8
9
const client = new MongoClient(uri);
10
11
async function run() {
12
  try {
13
    const database = client.db("sample_mflix");
14
    const theaters = database.collection("theaters");
15
16
    // Insert a new document into the "theaters" collection
17
    const result = await theaters.bulkWrite([
18
      {
19
        insertOne: {
20
          document: {
21
            location: {
22
              address: {
23
                street1: "3 Main St.",
24
                city: "Anchorage",
25
                state: "AK",
26
                zipcode: "99501",
27
              },
28
            },
29
          },
30
        },
31
      },
32
      {
33
        insertOne: {
34
          document: {
35
            location: {
36
              address: {
37
                street1: "75 Penn Plaza",
38
                city: "New York",
39
                state: "NY",
40
                zipcode: "10001",
41
              },
42
            },
43
          },
44
        },
45
      },
46
      {
47
        // Update documents that match the specified filter
48
        updateMany: {
49
          filter: { "location.address.zipcode": "44011" },
50
          update: { $set: { is_in_ohio: true } },
51
          upsert: true,
52
        },
53
      },
54
      {
55
        // Delete a document that matches the specified filter
56
        deleteOne: { filter: { "location.address.street1": "221b Baker St" } },
57
      },
58
    ]);
59
    // Log the result of the bulk write operation 
60
    console.log(result);
61
  } finally {
62
    // Close the database connection when the operations are completed or if an error occurs
63
    await client.close();
64
  }
65
}
66
run().catch(console.dir);

1
import { MongoClient } from "mongodb";
2
3
// Replace the uri string with your MongoDB deployment's connection string.
4
const uri = "<connection string uri>";
5
6
const client = new MongoClient(uri);
7
8
interface Address {
9
  street1: string;
10
  city: string;
11
  state: string;
12
  zipcode: string;
13
}
14
15
interface Theater {
16
  location: { address: Address };
17
  is_in_ohio?: boolean;
18
}
19
20
async function run() {
21
  try {
22
    const database = client.db("sample_mflix");
23
    const theaters = database.collection<Theater>("theaters");
24
25
    const result = await theaters.bulkWrite([
26
      {
27
        insertOne: {
28
          document: {
29
            location: {
30
              address: {
31
                street1: "3 Main St.",
32
                city: "Anchorage",
33
                state: "AK",
34
                zipcode: "99501",
35
              },
36
            },
37
          },
38
        },
39
      },
40
      {
41
        insertOne: {
42
          document: {
43
            location: {
44
              address: {
45
                street1: "75 Penn Plaza",
46
                city: "New York",
47
                state: "NY",
48
                zipcode: "10001",
49
              },
50
            },
51
          },
52
        },
53
      },
54
      {
55
        updateMany: {
56
          // Important: You lose type safety when you use dot notation in queries
57
          filter: { "location.address.zipcode": "44011" },
58
          update: { $set: { is_in_ohio: true } },
59
          upsert: true,
60
        },
61
      },
62
      {
63
        deleteOne: {
64
          filter: { "location.address.street1": "221b Baker St" },
65
        },
66
      },
67
    ]);
68
69
    console.log(result);
70
  } finally {
71
    await client.close();
72
  }
73
}
74
run().catch(console.dir);