Connect to MongoDB Instance Through Program Code

Last Updated：2021-08-30

Baidu Could Database MongoDB is fully compatible with the MongoDB protocol. This article introduces examples of various programs connecting to the database.

Preparations

Acquire the cloud database MongoDB connection address according to your instance type.
Download and install the official driver according to your language. For more information, see MongoDB Drivers.

Descriptions:

The connection Demo given in this article is only applicable to the MongoDB intranet connection address provided by Baidu Cloud.

During the connection to a sharded cluster instance, you do not need to specify the replicaSet related parameters in the following Demo.

Node.js Linking Example

PHP Linking Examples

Java Linking Example

Related link: Download Jar package.

Obtain the cloud database MongoDB connection information.
Java Demo Code.

Maven Configuration

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

Java Code.

import java.util.ArrayList;
import java.util.List;
import java.util.UUID;

import com.mongodb.*;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import com.mongodb.client.MongoDatabase;
import org.bson.BsonDocument;
import org.bson.BsonString;
import org.bson.Document;

public class App {
    public static ServerAddress seed1 = new ServerAddress("*********.mongodb.gz.baidubce.com",
            27017);
    public static ServerAddress seed2 = new ServerAddress("*********.mongodb.gz.baidubce.com",
            27017);
    public static String username = "root";
    public static String password = "*********";
    public static String ReplSetName = "rep-******";
    public static String DEFAULT_DB = "admin";
    public static String DEMO_DB = "test";
    public static String DEMO_COLL = "testColl";
    public static MongoClient createMongoDBClient() {
        // Build a Seed list.
        List<ServerAddress> seedList = new ArrayList<ServerAddress>();
        seedList.add(seed1);
        seedList.add(seed2);
        // Build the authentication information.
        List<MongoCredential> credentials = new ArrayList<MongoCredential>();
        credentials.add(MongoCredential.createScramSha1Credential(username, DEFAULT_DB,
                password.toCharArray()));
        // Build the operation options. The options beyond the requiredReplicaSetName attribute are configured according to their actual requirements, and the default parameters meet most scenarios.
        MongoClientOptions options = MongoClientOptions.builder().requiredReplicaSetName(ReplSetName)
                .socketTimeout(2000).connectionsPerHost(1).build();
        return new MongoClient(seedList, credentials, options);
    }
    public static MongoClient createMongoDBClientWithURI() {
        // The other type is initialized by 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 Collecton 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 DocDB 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 Linking Example

C# Linking Example

Related link: MongoDB C# Driver.

Install the following driver package.

mongocsharpdriver.dll

Obtain the MongoDB connection information of the cloud database.
C# Demo Code。

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

namespace Baiduyun
{
    class Program
    {
        static void Main(string[] args)
        {
            //Mongo Instance Information
            const string host1 = "*********.mongodb.gz.baidubce.com";
            const int port1 = 27017;
            const string host2 = "*********.mongodb.gz.baidubce.com";
            const int port2 = 27017;
            const string replicaSetName = "rep-******";
            const string admin = "admin";
            const string userName = "root";
            const string passwd = "*********";

            try
            {
                Console.WriteLine("Start the connection.......");
                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 a replica cluster name
                settings.ReplicaSetName = replicaSetName;
                // Set the timeout period to 3 seconds
                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);
                // Get a data.
                User result = collection.FindOne();
                Console.WriteLine("id:" + result.id + " name:" + result.name + " sex:"+result.sex);
                Console.WriteLine(“connection succeeded.........");
            }
            catch (Exception e)
            {
                Console.WriteLine(“connection Exceptional/Exception:"+
            }
        }
    }
    class User
    {
        public string id { set; get; }
        public string name { set; get; }
        public string sex { set; get; }

    }
}

百度智能云

Cloud Database MONGODB