Connection sample code for MongoDB drivers - Quick Start for Replica Set| Alibaba Cloud Documentation Center

Node.js

PHP

Java

Related links:

Official Quick Start
JAR package download

Obtain the information required to connect to an ApsaraDB for MongoDB instance.
For more information, see Overview of replica set instance connections.

Use the following Java sample code.

Maven configuration

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

Java sample 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 a 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()));
                // Construct operation options. Configure options other than requiredReplicaSetName based on your actual requirements. Default parameter settings can meet requirements in most scenarios.
                MongoClientOptions options = MongoClientOptions.builder().requiredReplicaSetName(ReplSetName)
                                .socketTimeout(2000).connectionsPerHost(1).build();
                return new MongoClient(seedList, credentials, options);
        }
         public static MongoClient createMongoDBClientWithURI() {
                // Use a URI to initialize the MongoClient.
                // 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 {
                        // Obtain 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

C#

Related links:MongoDB C# Driver.

Obtain the information required to connect to an ApsaraDB for MongoDB instance. For more information, see Overview of replica set instance connections.
Install the driver package.
```
mongocsharpdriver.dll
```

C# Demo Code.

using MongoDB.Driver;
using System;
using System.Collections.Generic;

namespace Aliyun
{
    class Program
    {
        static void Main(string[] args)
        {
            //Mongo Instance Information
            const string host1 = "dds-t4nffb7491eb87541.mongodb.singapore.rds.aliyuncs.com";
            const int port1 = 3717;
            const string host2 = "dds-t4nffb7491eb87542.mongodb.singapore.rds.aliyuncs.com";
            const int port2 = 3717;
            const string replicaSetName = "mgset-300374302";
            const string admin = "admin";
            const string userName = "root";
            const string passwd = "Lsx111222";

            try
            {
                Console.WriteLine("connecting...");
                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;
                //set ReplicaSetName
                settings.ReplicaSetName = replicaSetName;
                //set ConnectTimeout to 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 = "Female";
                //insert data user
                collection.Insert(user);
                //obtain a data
                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.Message);

            }
        }
    }
    class User
    {
        public string id { set; get; }
        public string name { set; get; }
        public string sex { set; get; }

    }
}