プログラムコードを使用してシャードクラスタインスタンスに接続する - ApsaraDB for MongoDB

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

前提条件

シャードクラスタインスタンスの接続文字列が取得されます。詳細については、「シャードクラスターインスタンスへの接続」をご参照ください。
あなたの言語の公式ドライバパッケージがダウンロードされてインストールされます。詳細については、MongoDBドライバーをご参照ください。

説明

シャードクラスターインスタンスに接続するには、次のコードでreplicaSet関連のパラメーターを指定する必要はありません。

Node.js

PHP

Java

関連リンク：

ApsaraDB for MongoDB インスタンスに接続するために必要な情報を取得します。

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

Maven設定

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

Java code

パッケージmongodb;
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 shardingConnectTest {
    public static ServerAddress seed1 = new ServerAddress("11.238.XX.XX." 、
            3717);
    public static ServerAddress seed2 = new ServerAddress("11.238.XX.XX." 、
            3717);
    public static String username = "autotest";
    public static String password = "autotest";
// 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().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);
        return new MongoClient(connectionString);
    }
    public static void main(String args[]) {
        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

C#

Go

関連リンク: MongoDB Go Driver

次のドライバーパッケージをインストールします。
```
go ge t go.mongodb.org/mongo-driver
```
ApsaraDB for MongoDBインスタンスに接続するために必要な情報を取得します。

次の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」
    「go.mongodb.org/mongo-driver/mongo/readpref」
    「go.mongodb.org/mongo-driver/mongo/writeconcern」
    「ログ」
)

func main() {
    // MongoDBサーバーにクライアントを作成し、Pingを使用して
    // サーバーが実行中です。

    clientOpts := options.Client().ApplyURI("mongodb:// root:**** @ s-bp1 ******* .mongodb.rds.aliyuncs.com:3717、s-bp2 ******* .mongodb.rds.aliyuncs.com:3717/admin")
    clientOpts.SetReadPreference(readpref.PrimaryPreferred())
    clientOpts.SetWriteConcern (writecocern. New (writecocern. WMajority(), writecocern. J(true), writecocern. WTimeout(1000)))
    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オプションはありません
    // クライアントからinheritiedされ、プライマリに設定されるように指定します
    // と過半数。
    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.InsertMany(context.Background(), []interface {}{ bson.M{"shardkey": 0}, bson.M{"shardkey": 1}, bson.M{"shardkey": 2}})
            if err! =nil {
                fmt.Println("結果の挿入に失敗しました!")
                log.Fatal(err)
                リターンnil, err
            }
            id := res.InsertedIDs
            fmt.Println("id:", id)
            fmt.Printf("insert result: % v\n", res)

            結果:= bson.M{}
            フィルター:= bson.D{{"shardkey", 0}}
            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)
    }
}