すべてのプロダクト
Search

このプロダクト

    ApsaraDB for MongoDB:プログラムコードを使用したレプリカセットインスタンスへの接続

    ドキュメントセンター

    ApsaraDB for MongoDB:プログラムコードを使用したレプリカセットインスタンスへの接続

    最終更新日:Dec 20, 2024

    ApsaraDB for MongoDBは、MongoDBプロトコルと完全に互換性があります。 このトピックでは、さまざまな言語でレプリカセットインスタンスに接続するために使用されるサンプルコードについて説明します。

    前提条件

    あなたの言語の公式ドライバパッケージをダウンロードしてインストールしてください。 詳細については、MongoDBドライバーをご参照ください。

    使用上の注意

    レプリカセットインスタンスのアカウントパスワードに特殊文字 (!) が含まれている場合 @ # $ % ^ & * ( ) _ + =) では、接続文字列でこれらの特殊文字をエスケープする必要があります。 特殊文字とエスケープ文字のマッピングを次の表に示します。

    特殊文字

    脱出キャラクター

    !

    % 21

    @

    % 40

    #

    % 23

    $

    % 24

    %

    % 25

    ^

    % 5e

    &

    % 26

    *

    % 2a

    (

    % 28

    )

    % 29

    _

    % 5f

    +

    % 2b

    =

    % 3d

    たとえば、元のパスワードがab @#cの場合、接続文字列のパスワードはab % 40% 23cに変換されます。

    Node.jsを使用してレプリカセットインスタンスに接続する

    Node.js Driver For MongoDBの詳細については、「MongoDB Node.js Driver」をご参照ください。

    1. クライアントで次のコマンドを実行して、プロジェクトを初期化します。 

      mkdir node-mongodb-demo
cd node-mongodb-demo
npm init -y

    2. 次のコマンドを実行して、ドライバーパッケージをインストールします。 

      npm install mongodb

    3. レプリカセットインスタンスへの接続に使用される情報を取得します。 詳細については、「レプリカセットインスタンスへの接続」をご参照ください。

    4. 次のサンプルコードをNode.jsとして保存します。 

      const MongoClient = require('mongodb').MongoClient;

// The database name and collection name. 
const demoDb = "test";
const demoColl = "testColl";

// To ensure high availability, we recommend that you use the connection string URI. 
// Ensure that the server where the code is executed can be connected to the ApsaraDB for MongoDB instance. 
// Escape the special characters if the password contains special characters. 
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);

// Obtain the MongoClient. 
const client = new MongoClient(url);

async function run() {
    try {
        // Connect to the instance. 
        await client.connect();

        // Obtain the database handle. 
        const database = client.db(demoDb);

        // Obtain the collection handle. 
        const collection = database.collection(demoColl);

        // Assemble a record. 
        const demoName = "Node For Demo";
        const doc = { "DEMO": demoName, "MESG": "Hello AliCloudDB For MongoDB" };
        console.info("ready insert document: ", doc);

        // Insert a record. 
        const result = await collection.insertOne(doc);
        console.log(
            `A document was inserted with the _id: ${result.insertedId}`,
        );

        // Read data. 
        const filter = { "DEMO": demoName };
        const findResult = await collection.find(filter);
        await findResult.forEach(console.dir);
      } finally {
          // Close the connection. 
          await client.close();
      }
}
run().catch(console.dir);

    5. ノードnode. jsコマンドを実行します。

    PHPを使用したレプリカセットインスタンスへの接続

    PHP Driver For MongoDBの詳細については、「MongoDB PHP Driver」をご参照ください。

    1. 次のコマンドを実行して、ドライバーパッケージをインストールします。 

      $ pecl install mongodb

# Obtain the INI file path of PHP. 
$ php --ini | grep "Loaded Configuration" | sed -e "s|.*:\s*||"

# Add the following information to the INI file. Skip this step if it already exists. 
$ extension=mongodb.so

# Create a project directory and access it. 
$ mkdir php-demo
$ cd php-demo

# Use the composer to install MongoDB dependencies. If the composer is not installed, you can download it at https://getcomposer.org/download. 
$ composer require mongodb/mongodb

    2. レプリカセットインスタンスへの接続に使用される情報を取得します。 詳細については、「レプリカセットインスタンスへの接続」をご参照ください。

    3. 次のサンプルコードをmain.phpとして保存します。 

      <?php

require 'vendor/autoload.php'; // include Composer goodies


// To ensure high availability, we recommend that you use the connection string URI. 
// Ensure that the server where the code is executed can be connected to the ApsaraDB for MongoDB instance. 
// Escape the special characters if the password contains special characters. 
$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';

// Create a MongoClient. 
$client = new MongoDB\Client($replicaset_url);
$collection = $client->$test_db->$test_coll;

// Insert a record. 
$result = $collection->insertOne(['name' => 'ApsaraDB for Mongodb', 'desc' => 'Hello, Mongodb']);
echo "Inserted with Object ID '{$result->getInsertedId()}'", "\n";

// Query the record. 
$result = $collection->find(['name' => 'ApsaraDB for Mongodb']);
foreach ($result as $entry) {
    echo $entry->_id, ': ', $entry->name, "\n";
}

?>

    4. php -f main.phpコマンドを実行します。

    Javaを使用したレプリカセットインスタンスへの接続

    Java Driver For MongoDBの詳細については、「MongoDB Java Driver」をご参照ください。

    この例ではIDE (IntelliJ IDEAおよびEclipse IDE) が使用されています。 IDE環境でレプリカセットインスタンスに接続するには、JDKがJDK 8以降である必要があります。

    1. レプリカセットインスタンスへの接続に使用される情報を取得します。 詳細については、「レプリカセットインスタンスへの接続」をご参照ください。

    2. Maven依存関係を追加します。 

      <dependencies>
        <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongodb-driver-sync</artifactId>
            <version>4.8.0</version>
        </dependency>
    </dependencies>

    3. 次のJavaサンプルコードを使用します。 

      // JDK 8 or later. 

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 ) {
        // To ensure high availability, we recommend that you use the connection string URI. 
        // Ensure that the server where the code is executed can be connected to the ApsaraDB for MongoDB instance. 
        // Escape the special characters if the password contains special characters. 
        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);

            // Insert a record. 
            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);
            }

            // Query the first record. 
            Document doc = collection.find(eq("DEMO", "Java for Demo")).first();
            System.out.println(doc.toJson());

            mongoClient.close();
        }
    }
}

    4. IDEツールで、[実行] をクリックします。

    Pythonを使用したレプリカセットインスタンスへの接続

    MongoDBのPythonドライバーの詳細については、「MongoDB Pythonドライバー」をご参照ください。

    この例では、Python 3.9が使用されています。

    1. PyMongoをインストールします。 

      pip install pymongo

    2. レプリカセットインスタンスへの接続に使用される情報を取得します。 詳細については、「レプリカセットインスタンスへの接続」をご参照ください。

    3. 次のサンプルコードをMain.pyとして保存します。 

      # Python 3.9 is used to run the code. 

from pymongo import MongoClient

# To ensure high availability, we recommend that you use the connection string URI. 
# Ensure that the server where the code is executed can be connected to the ApsaraDB for MongoDB instance. 
# Escape the special characters if the password contains special characters. 
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'

# Obtain the MongoClient. 
client = MongoClient(REPLICASET_URL)


# Insert a record. 
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)


# Query the record. 
for d in client.testDb.testColl.find(dict(DEMO="Python for demo")):
    print ('find documents:', d)

client.close()

    4. python3.9 Main.pyコマンドを実行します。

    C# を使用したレプリカセットインスタンスへの接続

    MongoDB用C# ドライバーの詳細については、「MongoDB C# ドライバー」をご参照ください。

    この例では、IDE (Visual Studio) が使用されています。

    1. Visual Studio (プロジェクト > NuGetパッケージの管理) でNuGetパッケージ管理ツールを使用して、次のパッケージをダウンロードします。 

      MongoDB.Driver

    2. レプリカセットインスタンスへの接続に使用される情報を取得します。 詳細については、「レプリカセットインスタンスへの接続」をご参照ください。

    3. 次のC# サンプルコードを使用します。 

      using MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Collections.Generic;

namespace Aliyun
{
    class Program
    {
        static void Main(string[] args)
        {
            // To ensure high availability, we recommend that you use the connection string URI. 
            // Ensure that the server where the code is executed can be connected to the ApsaraDB for MongoDB instance. 
            // Escape the special characters if the password contains special characters. 
            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
            {

                // Connect to the server and obtain the client. 
                MongoClient client = new MongoClient(replicaSetUrl);


                // Obtain a collection. 
                var database = client.GetDatabase(testDb);
                var collection = database.GetCollection<BsonDocument>(testColl);

                // Insert a record. 
                var document = new BsonDocument
                            {
                                { "name", "Csharp for Mongodb" },
                                { "desc", "Hello ApsaraDB For MongoDB" }
                            };
                collection.InsertOne(document);
                Console.WriteLine("Insert done\n");

                // Query the record. 
                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("connection failed:" + e.Message);

            }
        }
    }
}

    4. IDEツールで、[実行] をクリックします。

    Goを使用してレプリカセットインスタンスに接続する

    Go Driver For MongoDBの詳細については、「MongoDB Go Driver」をご参照ください。

    1. 次のコマンドを実行して、ドライバーパッケージをインストールします。 

      go get go.mongodb.org/mongo-driver

    2. レプリカセットインスタンスへの接続に使用される情報を取得します。 詳細については、「レプリカセットインスタンスへの接続」をご参照ください。

    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() {
    // To ensure high availability, we recommend that you use the connection string URI. 
    // Ensure that the server where the code is executed can be connected to the ApsaraDB for MongoDB instance. 
    // Escape the special characters if the password contains special characters. 
    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)

    // Connect to the server and obtain the client. 
    client, err := mongo.Connect(context.TODO(), clientOpts)
    if err != nil {
        fmt.Println("connect failed!")
        log.Fatal(err)
        return
    }
    fmt.Println("connect successful!")

    // Close the connection. 
    defer func() {
        if err = client.Disconnect(context.TODO()); err != nil {
            fmt.Println("disconnect failed!")
            log.Fatal(err)
        }
        fmt.Println("disconnect successful!")
    }()

    // Ping the server to verify that the connection is successful. 
    if err = client.Ping(context.TODO(), nil); err != nil {
        fmt.Println("ping failed!")
        log.Fatal(err)
        return
    }
    fmt.Println("ping successful!")

    // Insert a record. 
    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)

    // Query the record. 
    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コマンドを実行します。

    よくある質問

    プログラムコードを使用してインスタンスに接続するときにエラーをトラブルシューティングするにはどうすればよいですか?

    プログラムコードを使用してインスタンスに接続すると、次の側面からエラーをトラブルシューティングできます。

    • ネットワーク接続。 mongoシェルを使用して、ネットワーク接続テスト用のインスタンスに接続できます。 詳細については、「mongo shellを使用したレプリカセットインスタンスへの接続」をご参照ください。

    • コードの問題。 スムーズな接続を確認したら、コードとランタイム環境の構成で問題が発生していないか確認できます。