ApsaraDB for MongoDB完全相容MongoDB協議,本文介紹如何使用不同語言的程式碼串連MongoDB複本集執行個體。
前提條件
請根據您使用的語言下載並安裝官方驅動程式,更多資訊,請參見MongoDB Drivers 。
注意事項
如果複本集執行個體資料庫帳號的密碼中包含特殊字元!@#$%^&*()_+=
,您需要在串連串中對特殊字元進行轉義處理,對應如下:
特殊字元 | 逸出字元 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
樣本:密碼為ab@#c
時,在串連串中對特殊字元進行轉義處理,密碼對應為ab%40%23c
。
Node.js串連樣本
Node.js驅動相關資訊,請參見MongoDB Node.js Driver。
在用戶端執行如下命令,進行專案初始化。
mkdir node-mongodb-demo cd node-mongodb-demo npm init -y
執行如下命令,安裝驅動包。
npm install mongodb
擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明。
將如下範例程式碼儲存為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);
運行
node Node.js
。
PHP串連樣本
PHP驅動相關資訊,請參見MongoDB PHP Driver。
執行如下命令,安裝驅動包。
$ 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
擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明。
將如下範例程式碼儲存為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"; } ?>
運行
php -f main.php
。
Java串連樣本
Java驅動相關資訊,請參見MongoDB Java Driver。
本樣本測試的環境為IDE(IntelliJ IDEA和Eclipse IDE)。IDE環境下串連複本集執行個體,JDK需為JDK 8及以上版本。
擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明。
添加Maven依賴。
<dependencies> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongodb-driver-sync</artifactId> <version>4.8.0</version> </dependency> </dependencies>
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(); } } }
在IDE工具中單擊運行。
Python串連樣本
Python驅動相關資訊,請參見MongoDB Python Driver。
本樣本測試的環境為Python 3.9。
安裝pymongo。
pip install pymongo
擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明。
將如下範例程式碼儲存為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()
運行
python3.9 Main.py
。
C#串連樣本
C#驅動相關資訊,請參見MongoDB C# Driver。
本樣本測試的環境為IDE(Visual Studio)。
在Visual Studio中使用NuGet包管理工具(路徑: )下載如下包。
MongoDB.Driver
擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明。
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); } } } }
在IDE工具中單擊運行。
Go串連樣本
Go驅動相關資訊,請參見MongoDB Go Driver。
執行如下命令,安裝驅動包。
go get go.mongodb.org/mongo-driver
擷取ApsaraDB for MongoDB複本集執行個體串連資訊,如何擷取,請參見複本集執行個體串連說明。
將如下範例程式碼儲存為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) }
運行
go run main.go
。