MongoDB driver connection

Related links

MongoDB Drivers

Connection String URI Format

Note: The connection examples in this document ONLY apply to the connection string provided on the MongoDB console.

Node.js connection example

Related links

MongoDB Node.js Driver

Item initialization

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

Install driver package and toolkit

npm install mongodb node-uuid sprintf-js –save

Obtain ApsaraDB for MongoDB connection information

See Retrieve seven MongoDB connection elements.

Node.js Demo Code

'use strict';
var uuid = require('node-uuid');
var sprintf = require("sprintf-js").sprintf;
var mongoClient = require('mongodb').MongoClient;
var host1 = "demotest-1.mongodb.tbc3.newtest.rdstest.aliyun-inc.com";
var port1 = 27017;
var host2 = "demotest-2.mongodb.tbc3.newtest.rdstest.aliyun-inc.com";
var port2 = 27017;
var username = "demouser";
var password = "123456";
var replSetName = "mgset-1441984991";
var demoDb = "test";
var demoColl = "testColl";
// Officially recommended solution
var url = sprintf("mongodb://%s:%d,%s:%d/%s?replicaSet=%s", host1, port1, host2, port2, demoDb, replSetName);
console.info("url:", url);
// Retrieve mongoClient.
mongoClient.connect(url, function(err, db) {
    if(err) {
        console.error("connect err:", err);
        return 1;
    }
    // Authorization. Here, the username is based on the admin database authorization.
    var adminDb = db.admin();
    adminDb.authenticate(username, password, function(err, result) {
        if(err) {
            console.error("authenticate err:", err);
            return 1;
        }
        // Get the Collection handle.
        var collection = db.collection(demoColl);
        var demoName = "NODE:" + uuid.v1();
        var doc = {"DEMO": demoName, "MESG": "Hello AliCoudDB For MongoDB"};
        console.info("ready insert document: ", doc);
        // Insert data.
        collection.insertOne(doc, function(err, data) {
            if(err) {
                console.error("insert err:", err);
                return 1;
            }
            console.info("insert result:", data["result"]);
            // Read data.
            var filter = {"DEMO": demoName};
            collection.find(filter).toArray(function(err, items) {
                if(err) {
                    console.error("find err:", err);
                    return 1;
                }
                console.info("find document: ", items);
                //Close the client and release resources.
                db.close();
            });
        });
    });
});

PHP connection example

Related links

Mongodb php driver

Install driver package and toolkit

$ pecl install mongodb
$ echo "extension=mongodb.so" >> `php --ini | grep "Loaded Configuration" | sed -e "s|.*:\s*||"`
$ composer require "mongodb/mongodb=^1.0.0"

Obtain ApsaraDB for MongoDB connection information

See Retrieve seven MongoDB connection elements.

PHP Demo Code

<?php
require 'vendor/autoload.php'; // include Composer goodies
    # Instance information
    $demo_seed1 = 'demotest-1.mongodb.test.aliyun-inc.com:3717';
    $demo_seed2 = 'demotest-2.mongodb.test.aliyun-inc.com:3717';
    $demo_replname = "mgset-1441984463";
    $demo_user = 'root';
    $demo_password = '123456';
    $demo_db = 'admin';
    # Construct the mongodb connection string based on instance information.
    # mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
    $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 "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 connection example

Related links

Official Quick start.

JAR package Download.

Obtain ApsaraDB for MongoDB connection information

See Retrieve seven MongoDB connection elements.

Java Demo Code

Maven configuration

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

Java Code

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 Main {
    public static ServerAddress seed1 = new ServerAddress("demotest-1.mongodb.tbc3.newtest.rdstest.aliyun-inc.com", 27017);
    public static ServerAddress seed2 = new ServerAddress("demotest-2.mongodb.tbc3.newtest.rdstest.aliyun-inc.com", 27017);
    public static String username = "demouser";
    public static String password = "123456";
    public static String ReplSetName = "mgset-1441984463";
    public static String DEFAULT_DB = "admin";
    public static String DEMO_DB = "test";
    public static String DEMO_COLL = "testColl";
    public static MongoClient createMongoDBClient() {
        // Construct the Seed list.
        List<ServerAddress> seedList = new ArrayList<ServerAddress>();
        seedList.add(seed1);
        seedList.add(seed2);
        // Construct authentication information.
        List<MongoCredential> credentials = new ArrayList<MongoCredential>();
        credentials.add(MongoCredential.createScramSha1Credential(username,
                DEFAULT_DB, password.toCharArray()));
        // For the construction operation options, you can configure options besides the requiredReplicaSetName attribute based on your actual needs, but the default parameters are sufficient in most of the scenarios.
        MongoClientOptions options = MongoClientOptions.builder()
                .requiredReplicaSetName(ReplSetName).socketTimeout(2000)
                .connectionsPerHost(1).build();
        return new MongoClient(seedList, credentials, options);
    }
    public static MongoClient createMongoDBClientWithURI() {
        //Initialize the other through URI.
        //mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
        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();
        //or
        //MongoClient client = createMongoDBClientWithURI();
        try {
            // Get the Collection handle.
            MongoDatabase database = client.getDatabase(DEMO_DB);
            MongoCollection<Document> collection = database.getCollection(DEMO_COLL);
            // Insert data.
            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);
            // Read data.
            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 {
            //Close the client and release resources.
            client.close();
        }
        return ;
    }
}

Python connection example

Related links

pymongo download address

Official documentation

Install PyMongo

pip install pymongo

Obtain ApsaraDB for MongoDB connection information

See Retrieve seven MongoDB connection elements.

Python Demo Code

import uuid
    from pymongo import MongoClient
    #Two URLs
    CONN_ADDR1 = 'demotest-1.mongodb.tbc3.newtest.rdstest.aliyun-inc.com:27017'
    CONN_ADDR2 = 'demotest-2.mongodb.tbc3.newtest.rdstest.aliyun-inc.com:27017'
    REPLICAT_SET = 'mgset-1441984463'
    username = 'demouser'
    password = '123456'
    #Retrieve mongoclient
    client = MongoClient([CONN_ADDR1, CONN_ADDR2], replicaSet=REPLICAT_SET)
    #Authorization. Here, the user is based on the admin database authorization.
    client.admin.authenticate(username, password)
    #Use "collection:testColl" from the test database as an example, insert doc, and then search by DEMO name.
    demo_name = 'python-' + str(uuid.uuid1())
    print 'demo_name:', demo_name
    doc = dict(DEMO=demo_name, MESG="Hello ApsaraDB For MongoDB")
    doc_id = client.test.testColl.insert(doc)
    print 'doc_id:', doc_id
    for d in client.test.testColl.find(dict(DEMO=demo_name)):
        print 'find documents:', d