全部產品
Search

搜尋本產品

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

    文件中心

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

    更新時間：Dec 12, 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。

    常見問題

    如何排查程式碼串連執行個體時報錯？

    通過程式碼串連執行個體時報錯，您可以從以下兩個方面排查：

    • 網路互連。您可以通過MongoShell串連執行個體，測試網路連通性。具體操作，請參見通過Mongo Shell串連MongoDB複本集執行個體。

    • 代碼問題。在確認網路通暢後，請檢查代碼以及運行環境配置是否存在問題。