ApsaraDB for MongoDB完全相容MongoDB協議,本文為您介紹使用不同語言的程式碼來串連雲資料庫分區叢集執行個體。
前提條件
已擷取ApsaraDB for MongoDB分區叢集執行個體串連地址,如何擷取,請參見分區叢集執行個體串連說明。
根據您使用的語言下載並安裝官方驅動程式,更多資訊,請參見MongoDB Drivers 。
串連ApsaraDB for MongoDB分區叢集執行個體時,無需指定Demo中的replicaSet相關參數。
Node.js串連樣本
Node.js驅動相關資訊,請參見MongoDB Node.js Driver。
在用戶端執行如下命令,進行專案初始化。
mkdir node-mongodb-demo cd node-mongodb-demo npm init
執行如下命令,安裝驅動包以及工具包。
npm install mongodb node-uuid sprintf-js
擷取ApsaraDB for MongoDB分區叢集執行個體串連資訊。
Node.js Demo Code。
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 port2 = 3717; const username = "root"; const password = "*********"; // const replSetName = "mgset-*********"; const demoDb = "test"; const demoColl = "testColl"; // 官方建議使用分區叢集執行個體地址,確保高可用。 const url = sprintf("mongodb://%s:%s@%s:%d,%s:%d/admin", username, password, host1, port1, host2, port2); console.info("url:", url); const client = new MongoClient(url); // 擷取mongoClient。 async function run() { try { // 串連執行個體。 await client.connect(); // 取得資料庫控制代碼。 const database = client.db(demoDb); // 取得Collection控制代碼。 const collection = database.collection(demoColl); const demoName = "Node For Demo"; const doc = { "DEMO": demoName, "MESG": "Hello AliCoudDB 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);
PHP串連樣本
PHP相關資訊,請參見MongoDB PHP Driver。
安裝驅動包以及工具包。
$ pecl install mongodb $ echo "extension=mongodb.so" >> `php --ini | grep "Loaded Configuration" | sed -e "s|.*:\s*||"` $ composer require "mongodb/mongodb=^1.0.0"
擷取ApsaraDB for MongoDB分區叢集執行個體串連資訊。
PHP Demo Code。
<?php require 'vendor/autoload.php'; // include Composer goodies # 執行個體資訊。 $demo_seed1 = '**********.mongodb.test.aliyun-inc.com:3717'; $demo_seed2 = '**********.mongodb.test.aliyun-inc.com:3717'; $demo_replname = "mgset-**********"; $demo_user = 'root'; $demo_password = '**********'; $demo_db = 'admin'; # 根據執行個體資訊構造mongodb connection string。 # mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]] $demo_uri = 'mongodb://' . $demo_user . ':' . $demo_password . '@' . $demo_seed1 . ',' . $demo_seed2 . '/' . $demo_db; $client = new MongoDB\Client($demo_uri); $collection = $client->testDb->testColl; $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"; } ?>
Java串連樣本
相關連結:
官方Quick Start文檔。
下載Jar包。
擷取ApsaraDB for MongoDB分區叢集執行個體串連資訊。
Java Demo Code。
Maven配置。
<dependencies> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>3.12.10</version> </dependency> </dependencies>
Java Code。
package mongodb; import java.util.ArrayList; import java.util.List; import java.util.UUID; import org.bson.BsonDocument; import org.bson.BsonString; import org.bson.Document; import com.mongodb.MongoClient; import com.mongodb.MongoClientOptions; import com.mongodb.MongoClientURI; import com.mongodb.MongoCredential; import com.mongodb.ServerAddress; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCursor; import com.mongodb.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())); // 構建操作選項,requiredReplicaSetName屬性外的選項根據自己的實際需求配置,預設參數滿足大多數情境 MongoClientOptions options = MongoClientOptions.builder().socketTimeout(2000).connectionsPerHost(1).build(); return new MongoClient(seedList, credentials, options); } public static MongoClient createMongoDBClientWithURI() { // 另一種通過URI初始化 // mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]] 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()); } } finally { // 關閉Client,釋放資源 client.close(); } return; } }
Python串連樣本
相關文檔: pymongo 4.1.1。
安裝pymongo。
pip3 install pymongo
擷取ApsaraDB for MongoDB分區叢集執行個體串連資訊。
Python Demo Code。
import sys from pymongo import MongoClient uri = 'mongodb://%s:%s@dds-bp18365e467ea5c4****.mongodb.rds.aliyuncs.com:3717/admin' username = 'root' password = 'MongoDB****' client = MongoClient(uri % (username, password)) ret = client.admin.command('ping')['ok'] if ret: print('ping successfully!') else: print('ping failed!') sys.exit(1) db = client['baz'] coll = db['quz'] uuid = coll.insert_one({'hello': 'world'}).inserted_id print('Id: %s' % uuid) ret = coll.find_one({"_id": uuid}) print(ret)
C#串連樣本
C#驅動相關資訊,請參見MongoDB C# Driver。
在用戶端執行如下命令,安裝如下驅動包。
Install-Package mongocsharpdriver
擷取ApsaraDB for MongoDB分區叢集執行個體串連資訊。
C# Demo Code。
using MongoDB.Driver; using System; using System.Collections.Generic; namespace Aliyun { class Program { static void Main(string[] args) { //Mongo 執行個體資訊。 const string host1 = "dds-t4n**************.mongodb.singapore.rds.aliyuncs.com"; const int port1 = 3717; const string host2 = "dds-t4n**************.mongodb.singapore.rds.aliyuncs.com"; const int port2 = 3717; const string replicaSetName = "mgset-300******"; const string admin = "admin"; const string userName = "root"; const string passwd = "********"; try { Console.WriteLine("開始串連......."); MongoClientSettings settings = new MongoClientSettings(); List<MongoServerAddress> servers = new List<MongoServerAddress>(); servers.Add(new MongoServerAddress(host1, port1)); servers.Add(new MongoServerAddress(host2, port2)); settings.Servers = servers; //設定執行個體名稱。 settings.ReplicaSetName = replicaSetName; //設定逾時時間為3秒。 settings.ConnectTimeout = new TimeSpan(0, 0, 0, 3, 0); MongoCredential credentials = MongoCredential.CreateCredential(admin, userName, passwd); settings.Credential = credentials; MongoClient client = new MongoClient(settings); var server = client.GetServer(); MongoDatabase database = server.GetDatabase("test"); var collection = database.GetCollection<User>("test_collection"); User user = new User(); user.id = "1"; user.name = "mongo_test"; user.sex = "女"; //插入資料user。 collection.Insert(user); //擷取一條資料。 User result = collection.FindOne(); Console.WriteLine("id:" + result.id + " name:" + result.name + " sex:"+result.sex); Console.WriteLine("串連成功........."); } catch (Exception e) { Console.WriteLine("串連異常:"+e.Message); } } } class User { public string id { set; get; } public string name { set; get; } public string sex { set; get; } } }
Go串連樣本
Go驅動相關資訊,請參見MongoDB Go Driver。
安裝如下驅動包。
go get go.mongodb.org/mongo-driver
擷取ApsaraDB for MongoDB分區叢集執行個體串連資訊。
Go Demo Code。
package main import ( "context" "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" "log" ) func main() { // Create a Client to a MongoDB server and use Ping to verify that the // server is running. 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(writeconcern.New(writeconcern.WMajority(), writeconcern.J(true), writeconcern.WTimeout(1000))) 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!") }() // Call Ping to verify that the deployment is up and the Client was // configured successfully. As mentioned in the Ping documentation, this // reduces application resiliency as the server may be temporarily // unavailable when Ping is called. if err = client.Ping(context.TODO(), nil); err != nil { fmt.Println("ping failed!") log.Fatal(err) return } fmt.Println("ping successful!") // Specify the DefaultReadConcern option so any transactions started through // the session will have read concern majority. // The DefaultReadPreference and DefaultWriteConcern options aren't // specified so they will be inheritied from client and be set to primary // and majority, respectively. opts := options.Session().SetDefaultReadConcern(readconcern.Majority()) sess, err := client.StartSession(opts) if err != nil { fmt.Println("start session failed!") log.Fatal(err) return } defer func() { sess.EndSession(context.TODO()) fmt.Println("end session!") }() fmt.Println("start session successful!") txnOpts := options.Transaction() result, err := sess.WithTransaction( context.TODO(), func(sessCtx mongo.SessionContext) (interface{}, 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("insert result failed!") log.Fatal(err) return nil, err } id := res.InsertedIDs fmt.Println("Ids: ", id) fmt.Printf("insert result: %v\n", res) result := bson.M{} filter := bson.D{{"shardkey", 0}} if err := collection.FindOne(context.Background(), filter).Decode(&result); err != nil { fmt.Println("find failed!") log.Fatal(err) return nil, err } return result, err }, txnOpts) if err == nil { fmt.Printf("result: %v\n", result) } }