全部產品
Search
文件中心

:通過程式碼串連MongoDB複本集執行個體

更新時間:Jun 19, 2024

ApsaraDB for MongoDB完全相容MongoDB協議,本文介紹如何使用不同語言的程式碼串連MongoDB複本集執行個體。

前提條件

請根據您使用的語言下載並安裝官方驅動程式,更多資訊,請參見MongoDB Drivers

注意事項

如果複本集執行個體資料庫帳號的密碼中包含特殊字元!@#$%^&*()_+=,您需要在串連串中對特殊字元進行轉義處理,對應如下:

特殊字元

逸出字元

!

%21

@

%40

#

%23

$

%24

%

%25

^

%5e

&

%26

*

%2a

(

%28

)

%29

_

%5f

+

%2b

=

%3d

樣本:密碼為ab@#c時,在串連串中對特殊字元進行轉義處理,密碼對應為ab%40%23c

Node.js串連樣本

Node.js驅動相關資訊,請參見MongoDB Node.js Driver

  1. 在用戶端執行如下命令,進行專案初始化。

    mkdir node-mongodb-demo
    cd node-mongodb-demo
    npm init -y
  2. 執行如下命令,安裝驅動包。

    npm install mongodb
  3. 擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明

  4. 將如下範例程式碼儲存為Node.js。

    const MongoClient = require('mongodb').MongoClient;
    
    // 庫名稱和集合名稱。
    const demoDb = "test";
    const demoColl = "testColl";
    
    // 建議使用複本集高可用地址,確保高可用。
    // 確保執行代碼的伺服器和MongoDB執行個體網路是連通的。
    // 如果密碼中包含特殊字元,請進行轉義處理。
    const url = "mongodb://root:****@dds-2ze043****.mongodb.rds.aliyuncs.com:3717,dds-2ze043****.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-63****"
    
    console.info("url:", url);
    
    // 擷取mongoClient。
    const client = new MongoClient(url);
    
    async function run() {
        try {
            //串連執行個體。
            await client.connect();
    
            //取得資料庫控制代碼。
            const database = client.db(demoDb);
    
            //取得集合控制代碼。
            const collection = database.collection(demoColl);
    
            //組裝記錄。
            const demoName = "Node For Demo";
            const doc = { "DEMO": demoName, "MESG": "Hello AliCloudDB For MongoDB" };
            console.info("ready insert document: ", doc);
    
            //插入一條記錄。
            const result = await collection.insertOne(doc);
            console.log(
                `A document was inserted with the _id: ${result.insertedId}`,
            );
    
            //讀取資料。
            const filter = { "DEMO": demoName };
            const findResult = await collection.find(filter);
            await findResult.forEach(console.dir);
          } finally {
              //關閉串連。
              await client.close();
          }
    }
    run().catch(console.dir);
                            
  5. 運行node Node.js

PHP串連樣本

PHP驅動相關資訊,請參見MongoDB PHP Driver

  1. 執行如下命令,安裝驅動包。

    $ pecl install mongodb
    
    # 擷取PHP的ini檔案路徑。
    $ php --ini | grep "Loaded Configuration" | sed -e "s|.*:\s*||"
    
    # 在ini檔案中添加如下資訊,如果已經有則不用添加。
    $ extension=mongodb.so
    
    # 建立並進入工程目錄。
    $ mkdir php-demo
    $ cd php-demo
    
    # 使用composer安裝mongodb依賴。若未安裝composer,可通過https://getcomposer.org/download/路徑下載。
    $ composer require mongodb/mongodb
  2. 擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明

  3. 將如下範例程式碼儲存為main.php。

    <?php
    
    require 'vendor/autoload.php'; // include Composer goodies
    
    
    // 建議使用複本集高可用地址,確保高可用。
    // 確保執行代碼的伺服器和MongoDB執行個體網路是連通的。
    // 如果密碼中包含特殊字元,請進行轉義處理。
    $replicaset_url = 'mongodb://root:****@dds-2ze043****.mongodb.rds.aliyuncs.com:3717,dds-2ze043****.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-63****';
    $test_db = 'test';
    $test_coll = 'testColl';
    
    // 建立mongoclient。
    $client = new MongoDB\Client($replicaset_url);
    $collection = $client->$test_db->$test_coll;
    
    // 插入一條記錄。
    $result = $collection->insertOne(['name' => 'ApsaraDB for Mongodb', 'desc' => 'Hello, Mongodb']);
    echo "Inserted with Object ID '{$result->getInsertedId()}'", "\n";
    
    // 查詢記錄。
    $result = $collection->find(['name' => 'ApsaraDB for Mongodb']);
    foreach ($result as $entry) {
        echo $entry->_id, ': ', $entry->name, "\n";
    }
    
    ?>
  4. 運行php -f main.php

Java串連樣本

Java驅動相關資訊,請參見MongoDB Java Driver

本樣本測試的環境為IDE(IntelliJ IDEA和Eclipse IDE)。IDE環境下串連複本集執行個體,JDK需為JDK 8及以上版本。

  1. 擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明

  2. 添加Maven依賴。

    <dependencies>
            <dependency>
                <groupId>org.mongodb</groupId>
                <artifactId>mongodb-driver-sync</artifactId>
                <version>4.8.0</version>
            </dependency>
        </dependencies>
  3. Java範例程式碼。

    // JDK 8及以上。
    
    import static com.mongodb.client.model.Filters.eq;
    import org.bson.Document;
    import com.mongodb.MongoException;
    import com.mongodb.client.MongoClient;
    import com.mongodb.client.MongoClients;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoDatabase;
    import com.mongodb.client.result.InsertOneResult;
    
    public class Main {
        public static void main( String[] args ) {
            // 建議使用複本集高可用地址,確保高可用。
            // 確保執行代碼的伺服器和MongoDB執行個體網路是連通的。
            // 如果密碼中包含特殊字元,請進行轉義處理。
            String uri = "mongodb://root:****@dds-2ze043****.mongodb.rds.aliyuncs.com:3717,dds-2ze043****.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-63****";
            String demoDb = "test";
            String demoColl = "testColl";
    
            try (MongoClient mongoClient = MongoClients.create(uri)) {
                MongoDatabase database = mongoClient.getDatabase(demoDb);
                MongoCollection<Document> collection = database.getCollection(demoColl);
    
                // 寫入一條記錄。
                try {
                    InsertOneResult result = collection.insertOne(new Document()
                            .append("DEMO", "Java for Demo")
                            .append("MESG", "Hello AliCloudDB For MongoDB"));
                    System.out.println("Success! Inserted document id: " + result.getInsertedId());
                } catch (MongoException me) {
                    System.err.println("Unable to insert due to an error: " + me);
                }
    
                // 查詢第一條記錄。
                Document doc = collection.find(eq("DEMO", "Java for Demo")).first();
                System.out.println(doc.toJson());
    
                mongoClient.close();
            }
        }
    }
  4. 在IDE工具中單擊運行。

Python串連樣本

Python驅動相關資訊,請參見MongoDB Python Driver

本樣本測試的環境為Python 3.9。

  1. 安裝pymongo。

    pip install pymongo
  2. 擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明

  3. 將如下範例程式碼儲存為Main.py。

    # 代碼運行環境為python3.9。
    
    from pymongo import MongoClient
    
    # 建議使用複本集高可用地址,確保高可用。
    # 確保執行代碼的伺服器和MongoDB執行個體網路是連通的。
    # 如果密碼中包含特殊字元,請進行轉義處理。
    REPLICASET_URL = 'mongodb://root:****@dds-2ze043****.mongodb.rds.aliyuncs.com:3717,dds-2ze043****.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-63****'
    testDb = 'test'
    testColl = 'testColl'
    
    # 擷取mongoclient。
    client = MongoClient(REPLICASET_URL)
    
    
    # 插入一條記錄。
    doc = dict(DEMO="Python for demo", MESG="Hello ApsaraDB For MongoDB")
    doc_id = client.testDb.testColl.insert_one(doc).inserted_id
    print ('doc_id:', doc_id)
    
    
    # 查詢記錄。
    for d in client.testDb.testColl.find(dict(DEMO="Python for demo")):
        print ('find documents:', d)
    
    client.close()
  4. 運行python3.9 Main.py

C#串連樣本

C#驅動相關資訊,請參見MongoDB C# Driver

本樣本測試的環境為IDE(Visual Studio)。

  1. 在Visual Studio中使用NuGet包管理工具(路徑:專案 > 管理NuGet包)下載如下包。

    MongoDB.Driver
  2. 擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明

  3. C#範例程式碼。

    using MongoDB.Bson;
    using MongoDB.Driver;
    using System;
    using System.Collections.Generic;
    
    namespace Aliyun
    {
        class Program
        {
            static void Main(string[] args)
            {
                // 建議使用複本集高可用地址,確保高可用。
                // 確保執行指令碼的機器和執行個體網路是通常的。
                // 如密碼包含特殊字元,則需要轉義。
                const string replicaSetUrl = "mongodb://root:****@dds-2ze043****.mongodb.rds.aliyuncs.com:3717,dds-2ze043****.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-63****";
                const string testDb = "test";
                const string testColl = "testColl";
    
                try
                {
    
                    // 建立串連擷取client。
                    MongoClient client = new MongoClient(replicaSetUrl);
    
    
                    // 擷取集合。
                    var database = client.GetDatabase(testDb);
                    var collection = database.GetCollection<BsonDocument>(testColl);
    
                    // 插入一條記錄。
                    var document = new BsonDocument
                                {
                                    { "name", "Csharp for Mongodb" },
                                    { "desc", "Hello ApsaraDB For MongoDB" }
                                };
                    collection.InsertOne(document);
                    Console.WriteLine("Insert done\n");
    
                    // 查詢記錄。
                    var cursor = collection.Find(new BsonDocument{ { "name", "Csharp for Mongodb" } }).ToCursor();
                    foreach (var doc in cursor.ToEnumerable())
                    {
                        Console.WriteLine(doc);
                    }
                }
                catch (Exception e)
                {
                    Console.WriteLine("串連異常:" + e.Message);
    
                }
            }
        }
    }
  4. 在IDE工具中單擊運行。

Go串連樣本

Go驅動相關資訊,請參見MongoDB Go Driver

  1. 執行如下命令,安裝驅動包。

    go get go.mongodb.org/mongo-driver
  2. 擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明

  3. 將如下範例程式碼儲存為main.go。

    package main
    
    import (
        "context"
        "fmt"
        "go.mongodb.org/mongo-driver/bson"
        "go.mongodb.org/mongo-driver/mongo"
        "go.mongodb.org/mongo-driver/mongo/options"
        "log"
    )
    
    func main() {
        // 建議使用複本集高可用地址,確保高可用。
        // 確保執行代碼的伺服器和MongoDB執行個體網路是連通的。
        // 如果密碼中包含特殊字元,請進行轉義處理。
        replicaSetUrl := "mongodb://root:****@dds-2ze043****.mongodb.rds.aliyuncs.com:3717,dds-2ze043****.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-63****"
        testDb := "test"
        testColl := "testColl"
    
    
        clientOpts := options.Client().ApplyURI(replicaSetUrl)
    
        // 串連Server,擷取client。
        client, err := mongo.Connect(context.TODO(), clientOpts)
        if err != nil {
            fmt.Println("connect failed!")
            log.Fatal(err)
            return
        }
        fmt.Println("connect successful!")
    
        // 結束時中斷連線。
        defer func() {
            if err = client.Disconnect(context.TODO()); err != nil {
                fmt.Println("disconnect failed!")
                log.Fatal(err)
            }
            fmt.Println("disconnect successful!")
        }()
    
        // 向Server發送Ping命令,驗證串連成功。
        if err = client.Ping(context.TODO(), nil); err != nil {
            fmt.Println("ping failed!")
            log.Fatal(err)
            return
        }
        fmt.Println("ping successful!")
    
        // 插入一條記錄。
        collection := client.Database(testDb).Collection(testColl)
        res, err := collection.InsertOne(context.Background(), bson.M{"hello": "world"})
        if err != nil {
            fmt.Println("insert result failed!")
            log.Fatal(err)
            return
        }
        id := res.InsertedID
        fmt.Println("Id: ", id)
        fmt.Printf("insert result: %v\n", res)
    
        // 查詢記錄。
        result := bson.M{}
        filter := bson.D{{"_id", res.InsertedID}}
        if err := collection.FindOne(context.Background(), filter).Decode(&result); err != nil {
            fmt.Println("find failed!")
            log.Fatal(err)
            return
        }
        fmt.Printf("result: %v\n", result)
    }
                            
  4. 運行go run main.go