快捷導(dǎo)航

MongoDB使用引用的示例

更新時間：2026年03月17日 10:21:47 作者：Victor356

在MongoDB中,引用（Reference）是一種在文檔之間建立關(guān)系的方式,與嵌入式文檔不同,引用是通過存儲其他集合中文檔的標(biāo)識符來建立關(guān)系,這種方式類似于SQL中的外鍵,適用于需要多個獨(dú)立集合之間,本文介紹MongoDB什么是引用,感興趣的朋友跟隨小編一起看看吧

在MongoDB中，引用（Reference）是一種在文檔之間建立關(guān)系的方式。與嵌入式文檔不同，引用是通過存儲其他集合中文檔的標(biāo)識符來建立關(guān)系。這種方式類似于SQL中的外鍵，適用于需要多個獨(dú)立集合之間建立關(guān)系的場景。

引用的特點(diǎn)

分離數(shù)據(jù)：引用將相關(guān)數(shù)據(jù)分離到不同的集合中，有助于減少數(shù)據(jù)冗余。
獨(dú)立更新：引用允許獨(dú)立更新相關(guān)數(shù)據(jù)，而不需要更新整個文檔。
適合一對多和多對多關(guān)系：引用特別適用于復(fù)雜的數(shù)據(jù)模型，比如一對多和多對多關(guān)系。

使用引用的示例

以下示例展示了如何在MongoDB中使用引用。我們將使用Node.js和MongoDB的驅(qū)動進(jìn)行操作。

安裝MongoDB的Node.js驅(qū)動

npm install mongodb

插入包含引用的數(shù)據(jù)

const { MongoClient, ObjectId } = require('mongodb');
async function insertData() {
    const uri = "mongodb://localhost:27017";
    const client = new MongoClient(uri, { useUnifiedTopology: true });
    try {
        await client.connect();
        const db = client.db('myDatabase');
        const usersCollection = db.collection('users');
        const ordersCollection = db.collection('orders');
        await usersCollection.deleteMany({}); // 清空用戶集合
        await ordersCollection.deleteMany({}); // 清空訂單集合
        // 插入用戶數(shù)據(jù)
        const users = await usersCollection.insertMany([
            { name: "Alice" },
            { name: "Bob" },
            { name: "Charlie" }
        ]);
        // 插入訂單數(shù)據(jù)，并使用用戶的ObjectId作為引用
        await ordersCollection.insertMany([
            { userId: users.insertedIds[0], amount: 50.5, date: new Date("2022-01-01") },
            { userId: users.insertedIds[0], amount: 100.0, date: new Date("2022-02-01") },
            { userId: users.insertedIds[1], amount: 75.0, date: new Date("2022-01-15") },
            { userId: users.insertedIds[2], amount: 200.0, date: new Date("2022-03-01") }
        ]);
        console.log("Data inserted");
    } finally {
        await client.close();
    }
}
insertData().catch(console.error);

在上面的代碼中，orders 集合中的每個文檔都包含一個 userId 字段，該字段引用了 users 集合中的用戶文檔的 _id。

查詢包含引用的數(shù)據(jù)

async function queryData() {
    const uri = "mongodb://localhost:27017";
    const client = new MongoClient(uri, { useUnifiedTopology: true });
    try {
        await client.connect();
        const db = client.db('myDatabase');
        const usersCollection = db.collection('users');
        const ordersCollection = db.collection('orders');
        // 查詢某個用戶及其所有訂單
        console.log("\nQuery a user and their orders:");
        let user = await usersCollection.findOne({ name: "Alice" });
        let orders = await ordersCollection.find({ userId: user._id }).toArray();
        console.log({ user, orders });
        // 查詢所有訂單及其對應(yīng)的用戶信息
        console.log("\nQuery all orders and their corresponding users:");
        let results = await ordersCollection.aggregate([
            {
                $lookup: {
                    from: 'users',  // 要關(guān)聯(lián)的集合
                    localField: 'userId',  // orders 集合中的字段
                    foreignField: '_id',  // users 集合中的字段
                    as: 'user'  // 輸出數(shù)組字段
                }
            },
            {
                $unwind: '$user'  // 展開數(shù)組
            }
        ]).toArray();
        console.log(results);
    } finally {
        await client.close();
    }
}
queryData().catch(console.error);

在這個示例中，我們演示了如何查詢包含引用的數(shù)據(jù)：

查詢某個用戶及其所有訂單。
查詢所有訂單及其對應(yīng)的用戶信息。

運(yùn)行這個腳本后，你會得到如下結(jié)果（示例輸出）：

// 查詢某個用戶及其所有訂單
Query a user and their orders:
{
  user: { _id: new ObjectId("..."), name: 'Alice' },
  orders: [
    { _id: new ObjectId("..."), userId: new ObjectId("..."), amount: 50.5, date: 2022-01-01T00:00:00.000Z },
    { _id: new ObjectId("..."), userId: new ObjectId("..."), amount: 100, date: 2022-02-01T00:00:00.000Z }
  ]
}
// 查詢所有訂單及其對應(yīng)的用戶信息
Query all orders and their corresponding users:
[
  {
    _id: new ObjectId("..."),
    userId: new ObjectId("..."),
    amount: 50.5,
    date: 2022-01-01T00:00:00.000Z,
    user: { _id: new ObjectId("..."), name: 'Alice' }
  },
  {
    _id: new ObjectId("..."),
    userId: new ObjectId("..."),
    amount: 100,
    date: 2022-02-01T00:00:00.000Z,
    user: { _id: new ObjectId("..."), name: 'Alice' }
  },
  {
    _id: new ObjectId("..."),
    userId: new ObjectId("..."),
    amount: 75,
    date: 2022-01-15T00:00:00.000Z,
    user: { _id: new ObjectId("..."), name: 'Bob' }
  },
  {
    _id: new ObjectId("..."),
    userId: new ObjectId("..."),
    amount: 200,
    date: 2022-03-01T00:00:00.000Z,
    user: { _id: new ObjectId("..."), name: 'Charlie' }
  }
]

其他語言示例

類似的操作可以在其他編程語言中實(shí)現(xiàn)，如Python。以下是Python的示例代碼：

安裝PyMongo

在終端中運(yùn)行以下命令來安裝PyMongo：

pip install pymongo

插入數(shù)據(jù)

from pymongo import MongoClient
from datetime import datetime
def insert_data():
    client = MongoClient('mongodb://localhost:27017/')
    db = client['myDatabase']
    users_collection = db['users']
    orders_collection = db['orders']
    users_collection.delete_many({})  # 清空用戶集合
    orders_collection.delete_many({})  # 清空訂單集合
    # 插入用戶數(shù)據(jù)
    users = users_collection.insert_many([
        { "name": "Alice" },
        { "name": "Bob" },
        { "name": "Charlie" }
    ])
    # 插入訂單數(shù)據(jù)，并使用用戶的ObjectId作為引用
    orders_collection.insert_many([
        { "userId": users.inserted_ids[0], "amount": 50.5, "date": datetime(2022, 1, 1) },
        { "userId": users.inserted_ids[0], "amount": 100.0, "date": datetime(2022, 2, 1) },
        { "userId": users.inserted_ids[1], "amount": 75.0, "date": datetime(2022, 1, 15) },
        { "userId": users.inserted_ids[2], "amount": 200.0, "date": datetime(2022, 3, 1) }
    ])
    print("Data inserted")
insert_data()

查詢數(shù)據(jù)

def query_data():
    client = MongoClient('mongodb://localhost:27017/')
    db = client['myDatabase']
    users_collection = db['users']
    orders_collection = db['orders']
    # 查詢某個用戶及其所有訂單
    print("\nQuery a user and their orders:")
    user = users_collection.find_one({ "name": "Alice" })
    orders = list(orders_collection.find({ "userId": user['_id'] }))
    print({ "user": user, "orders": orders })
    # 查詢所有訂單及其對應(yīng)的用戶信息
    print("\nQuery all orders and their corresponding users:")
    pipeline = [
        {
            '$lookup': {
                'from': 'users',  # 要關(guān)聯(lián)的集合
                'localField': 'userId',  # orders 集合中的字段
                'foreignField': '_id',  # users 集合中的字段
                'as': 'user'  # 輸出數(shù)組字段
            }
        },
        {
            '$unwind': '$user'  # 展開數(shù)組
        }
    ]
    results = list(orders_collection.aggregate(pipeline))
    for result in results:
        print(result)
query_data()

到此這篇關(guān)于MongoDB使用引用的示例的文章就介紹到這了,更多相關(guān)MongoDB使用引用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: