すべてのプロダクト
Search

このプロダクト

    ApsaraDB for MongoDB:異なる言語のプログラムコードを使用してApsaraDB for MongoDBスタンドアロンインスタンスに接続する

    ドキュメントセンター

    ApsaraDB for MongoDB:異なる言語のプログラムコードを使用してApsaraDB for MongoDBスタンドアロンインスタンスに接続する

    最終更新日:Jun 13, 2024

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

    前提条件

    • インスタンスの接続文字列が取得されます。 詳細については、「インスタンスへの接続」をご参照ください。

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

    Node.js

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

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

      mkdirノード-mongodb-デモ
cdノード-mongodb-デモ
npm init

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

      npm install mongodb node-uuid sprintf-js

    3. スタンドアロンインスタンスの接続情報を取得します。

    4. 次のNode.jsサンプルコードを使用します。 

      const sprintf = require("sprintf-js").sprintf;
const MongoClient = require('mongodb').MongoClient;
const host1 = "dds-********** .mongodb.rds.aliyuncs.com";
const port1 = 3717;
const host2 = "dds-********** .mongodb.rds.aliyuncs.com";
constポート2 = 3717;
// データベースアカウントをnode-testに設定します。
const username = "node-test";
const password = "*********";
const replSetName = "mgset-*********";
const demoDb = "テスト";
const demoColl = "testColl";
 
const url = sprintf("mongodb:// % s:% s @ % s:% d,% s:% d/admin?replicaSet=% s" 、
        username、password、host1、port1、host2、port2、replSetName);
console.info("url:" 、url);
const client = new MongoClient(url);
// MongoClientを取得します。 
async関数run() {
    try {
        // スタンドアロンインスタンスに接続します。 
        await client.connect();
        // データベースハンドルを取得します。 
        const database = client.db(demoDb);
        // collection ハンドルを取得します。 
        const collection = database.collection(demoColl);
        const demoName = "デモ用ノード";
        const doc = { "DEMO": demoName、"MESG": "Hello AliCoudDB For MongoDB" };
        console.info("ready insert document: ", doc);
        // データを挿入します。 
        const result = await collection.insertOne(doc);
        console.log (
            '_id: ${result.insertedId} でドキュメントが挿入されました' 、
        );
        // データを読み取ります。 
        const filter = { "DEMO": demoName };
        const findResult = await collection.find (フィルター);
        await findResult.forEach(console.dir);
      } 最後に{
          // 接続を閉じます。 
          await client.close();
      }
}
run().catch(console.dir);

    PHP

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

    1. Install the driver package and toolkit. 

      $ pecl install mongodb
$echo "extension=mongodb.so" >> 'php -- ini | grep "Loaded Configuration" | sed -e "s |.*:\s * |"'
$composerには "mongodb/mongodb=^ 1.0.0"
      が必要です

    2. スタンドアロンインスタンスの接続情報を取得します。

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

      <?php
'vendor/autoload.php' が必要です。// Composerグッズを含める
# インスタンス情報を指定します。 
$demo_seed1 = '********* .mongodb.test.aliyun-inc.com:3717';
$demo_seed2 = '********* .mongodb.test.aliyun-inc.com:3717';
$demo_replname = "mgset-**********";
# データベースアカウントをphp-testに設定します。
$demo_user = 'php-test';
$demo_password = '**********';
$demo_db = 'admin';
# インスタンス情報に基づいてMongoDB接続文字列を作成します。 
# mongodb://[username:password @]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[データベース][? オプション]]
$demo_uri = 'mongodb:// 'です。 $demo_user。 ':' . $demo_passwordです。 '@' .
    $demo_seed1 . ',' . $demo_seed2です。 '/' . $demo_db。 '?replicaSet=' 。 $demo_replname;
$client = new MongoDB\Client($demo_uri);
$collection = $client->testDb->testColl;
$result = $collection->insertOne(['name' => 'ApsaraDB for Mongodb', 'desc' => 'Hello, Mongodb']);
echo "オブジェクトIDで挿入されます '{$result->getInsertedId()}'", "\n";
$result = $collection->find(['name' => 'ApsaraDB for Mongodb']);
foreach ($entryとして $result) {
    echo $entry->_id, ': ', $entry->name, "\n";
}
?>

    Java

    MongoDB用Javaドライバーの詳細については、公式ドキュメントを参照するか、次のリンクからドライバーのパッケージをダウンロードしてください。

    1. スタンドアロンインスタンスの接続情報を取得します。

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

      • Maven設定 

        <dependencies>
    <dependency>
        <groupId>org.mongodb</groupId>
        <artifactId>mongo-java-driver</artifactId>
        <version>3.12.10</version>
    </dependency>
</dependencies>

      • Javaデモコード 

        java.util.ArrayListをインポートします。java.util.Listをインポートします。java.util.UUIDをインポートします。org.bson.BsonDocumentをインポートします。org.bson.BsonStringをインポートします。org.bson.Documentをインポートします。import com.mo ngodb.MongoClient;
import com.mo ngodb.MongoClientOptions;
com.mo ngodb.MongoClientURIをインポートします。import com.mo ngodb.MongoCredential;
com.mo ngodb.ServerAddressをインポートします。com.mo ngodb.client.MongoCollectionをインポートします。com.mo ngodb.client.MongoCursorをインポートします。com.mo ngodb.client.MongoDatabaseをインポートします。
 public class Main {
        public static ServerAddress seed1 = new ServerAddress("********** .mongodb.tbc3.newtest.rdstest.aliyun-inc.com" 、
                        27017);
        public static ServerAddress seed2 = new ServerAddress("********** .mongodb.tbc3.newtest.rdstest.aliyun-inc.com" 、
                        27017);
        public static String username = "demouser";
        public static String password = "**********";
        public static String ReplSetName = "mgset-**********";
        public static String DEFAULT_DB = "admin";
        public static String DEMO_DB = "test";
        public static String DEMO_COLL = "testColl";
         public static MongoClient createMongoDBClient() {
                // seed リストを構築します。 
                List<ServerAddress> seedList = new ArrayList<ServerAddress>();
                seedList.add(seed1);
                seedList.add(seed2);
                // 認証情報を作成します。 
                List<MongoCredential> credentials = new ArrayList<MongoCredential>();
                credentials.add(MongoCredential.createScramSha1Credential(username, DEFAULT_DB,
                                password.toCharArray()));
                // 操作オプションを構築します。 Configure options other than requiredReplicaSetName based on your actual requirements. デフォルトのパラメーター設定は、ほとんどのシナリオの要件を満たすことができます。 
                MongoClientOptions options = MongoClientOptions.builder().requiredReplicaSetName(ReplSetName)
                                .socketTimeout(2000).connectionsPerHost(1).build();
                return new MongoClient(seedList, credentials, options);
        }
         public static MongoClient createMongoDBClientWithURI() {
                // MongoClient を初期化するために URI を使用します。 
                // mongodb://[username:password @]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[データベース][? オプション]]
                MongoClientURI connectionString = new MongoClientURI("mongodb://" + username + ":" + password + "@"
                                + seed1 + "," + seed2 + "/" + DEFAULT_DB + "?replicaSet=" + ReplSetName);
                return new MongoClient(connectionString);
        }
         public static void main(String args[]) {
                MongoClient client = createMongoDBClient();
                //または
                // MongoClient client = createMongoDBClientWithURI();
                try {
                        // collection ハンドルを取得します。 
                        MongoDatabase database = client.getDatabase(DEMO_DB);
                        MongoCollection<Document> collection = database.getCollection(DEMO_COLL);
                        // データを挿入します。 
                        Document doc = new Document();
                        String demoname = "JAVA:" + UUID.randomUUID();
                        doc.append("DEMO", demoname);
                        doc.append("MESG", "Hello AliCoudDB For MongoDB");
                        collection.insertOne(doc);
                        System.out.println("insert document: " + doc);
                        // データを読み取ります。 
                        BsonDocument filter = new BsonDocument();
                        filter.append("DEMO", new BsonString(demoname));
                        MongoCursor<Document> cursor = collection.find(filter).iterator();
                        while (cursor.hasNext()) {
                                System.out.println("find document: " + cursor.next());
                        }
                } 最後に{
                        // クライアントをオフにしてリソースを解放します。 
                        client.close();
                }
                戻る;
        }
}

    Python

    MongoDB用のPythonドライバーの詳細については、「APIドキュメント」をご参照ください。

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

      pip3インストールpymongo

    2. スタンドアロンインスタンスの接続情報を取得します。

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

      import sys
pymongoインポートからMongoClient
uri = 'mongodb:// % s:% s @ dds-bp18365e467ea5c4 **** .mongodb.rds.aliyuncs.com:3717/admin'
# データベースアカウントをpython-testに設定します。
username = 'python-test'
password = 'MongoDB ****'
client = MongoClient(uri % (ユーザー名、パスワード))
ret = client.admin.com mand('ping')['ok']
if ret:
    プリント (「pingに成功! 」)
else:
    印刷 (「pingに失敗しました! 」)
    sys.exit (1)

db=クライアント ['baz']
coll = db['quz']
uuid = coll.insert_one({'hello': 'world'}).inserted_id
プリント ('Id: % s' % uuid)
ret = coll.find_one({"_id": uuid})
プリント (ret)

    C#

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

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

      インストール-パッケージmongocsharpdriver

    2. スタンドアロンインスタンスの接続情報を取得します。

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

      MongoDB.Driverの使用 
      
システムを使用して;
System.Collections.Generic; の使用

名前空間Aliyun
{
    class Program
    {
        static void Main(string[] args)
        {
            // インスタンス情報を指定します。 
            const文字列host1 = "dds-t4n *************** .mongodb.singapore.rds.aliyuncs.com";
            const int port1 = 3717;
            const文字列host2 = "dds-t4n *************** .mongodb.singapore.rds.aliyuncs.com";
            const int port2 = 3717;
            const文字列replicaSetName = "mgset-300 ******";
            const文字列admin = "admin";
            // データベースアカウントをc-testに設定します。 
            const文字列userName = "c-test";
            const string passwd = "********";

            try
            {
                Console.WriteLine("connecting...")
                MongoClientSettings settings=新しいMongoClientSettings();
                リスト <MongoServerAddress> servers = newリスト <MongoServerAddress>();
                サーバー追加 (新しいMongoServerAddress(host1, port1));
                サーバー追加 (新しいMongoServerAddress(host2、port2));
                サーバー=サーバー;
                // インスタンス名を指定します。 
                設定。ReplicaSetName = replicaSetName;
                // タイムアウト時間を3秒に設定します。 
                設定。ConnectTimeout = new TimeSpan(0、0、0、0、3、0);
                MongoCredential資格情報=MongoCredential.CreateCredential(admin, userName, passwd);
                settings.Credential=資格情報;
                MongoClientクライアント=新しいMongoClient (設定);
                var server = client.GetServer();
                MongoDatabase database = server.GetDatabase("test");
                var collection = database.GetCollection <ユーザー>("test_collection");
                User user = new User();
                user.id = "1";
                user.name = "mongo_test";
                user.sex = "female";
                // データユーザーを挿入します。 
                collection.Insert (ユーザー);
                // データエントリを取得します。 
                User result = collection.FindOne();
                Console.WriteLine("id:" + result.id + "name:" + result.name + "sex:" + result.sex);
                Console.WriteLine("connection successful...");
            }
            catch (Exception e)
            {
                Console.WriteLine("connection failed:" + e. メッセージ);

            }
        }
    }
    クラスUser
    {
        public string id { set; get; }
        パブリック文字列名 {set; get; }
        public string sex { set; get; }

    }
}

    Go

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

    1. 次のドライバーパッケージをインストールします。 

      go ge t go.mongodb.org/mongo-driver

    2. スタンドアロンインスタンスの接続情報を取得します。

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

      パッケージメイン

import (import (import)
    「コンテキスト」
    "fmt"
    「go.mongodb.org/mongo-driver/bson」
    「go.mongodb.org/mongo-driver/mongo」
    「go.mongodb.org/mongo-driver/mongo/options」
    「go.mongodb.org/mongo-driver/mongo/readconcern」
    「ログ」
)

func main() {
    // MongoDBサーバーにクライアントを作成し、Pingを使用して
    // サーバーが実行中です。
    // データベースアカウントをgo-testに設定します。
    clientOpts := options.Client().ApplyURI("mongodb:// go-test:**** @ dds-bp1 ******* .mongodb.rds.aliyuncs.com:3717/admin")
    client, err := mongo.Connect(context.TODO(), clientOpts)
    if err! =nil {
        fmt.Println("connect failed!")
        log.Fatal(err)
        リターン
    }
    fmt.Println("connect successful!")

    defer func() {
        if err = client.Disconnect(context.TODO()); err! =nil {
            fmt.Println("切断に失敗しました!")
            log.Fatal(err)
        }
        fmt.Println("切断成功!")
    }()

    // Pingを呼び出して、デプロイが有効でクライアントが有効であることを確認します。
    // 正常に設定されました。 Pingのドキュメントで述べたように、この
    // サーバーが一時的に存在する可能性があるため、アプリケーションの復元力が低下します
    // Pingが呼び出されたときは利用できません。
    if err = client.Ping(context.TODO(), nil); err! =nil {
        fmt.Println("ping failed!")
        log.Fatal(err)
        リターン
    }
    fmt.Println("ping successful!")

    // DefaultReadConcernオプションを指定して、トランザクションが開始されるようにします。
    // セッションには読み取り懸念の過半数があります。
    // DefaultReadPreferenceオプションとDefaultWriteConcernオプションはありません
    // クライアントから継承され、プライマリに設定されるように指定します
    // と過半数。
    opts := options.Session().SetDefaultReadConcern(readcon. Majority())
    sess, err := client.StartSession(opts)
    if err! =nil {
        fmt.Println("セッションの開始に失敗しました!")
        log.Fatal(err)
        リターン
    }
    defer func() {
        sess.EndSession(context.TODO())
        fmt.Println("end session!")
    }()
    fmt.Println("セッションの開始が成功!")

    txnOpts := options.Transaction()
    result, err := sess.WithTransaction (
        context.TODO(),
        func(sessCtx mongo.SessionContext) (インターフェイス {}, error) {
            collection := client.Database("baz").Collection("qux")
            res, err := collection.InsertOne(context.Background(), bson.M{"hello": "world"})
            if err! =nil {
                fmt.Println("結果の挿入に失敗しました!")
                log.Fatal(err)
                リターンnil, err
            }
            id := res.InsertedID
            fmt.Println("Id: ", id)
            fmt.Printf("insert result: % v\n", res)

            結果:= bson.M{}
            フィルター:= bson.D{{"_id", res.InsertedID}}
            if err := collection.FindOne(context.Background(), filter).Decode(&result); err! =nil {
                fmt.Println("found failed!")
                log.Fatal(err)
                リターンnil, err
            }
            return result, err
        },
        txnOpts)
    if err == nil {
        fmt.Printf("result: % v\n", result)
    }
}