C#示例

using MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Security.Cryptography.X509Certificates;
using System.Threading.Tasks;
 
public class MongoDBSecureWriter
{
    public static async Task Main()
    {
        var connectionString = "mongodb://rwuser:rwuserpassword@ip:port/{mydb}?authSource=admin&replicaSet=replica";
        var caCertPath = "/path/to/certs/ca.crt";  
        var collectionName = "testCollection";    
 
        try
        {
            var client = CreateSecureClient(connectionString, caCertPath);
            
            var database = client.GetDatabase("mydatabase");
            var collection = database.GetCollection<BsonDocument>(collectionName);
            
            var document = new BsonDocument
            {
                { "name", "Secure Test" },
                { "value", 42 },
                { "timestamp", DateTime.UtcNow }
            };
            
            await collection.InsertOneAsync(document);
            Console.WriteLine($"Insert doc ID: {document["_id"]}");
            
            // 验证写入
            var filter = Builders<BsonDocument>.Filter.Eq("_id", document["_id"]);
            var result = await collection.Find(filter).FirstOrDefaultAsync();
            Console.WriteLine($"result: {(result != null ? "success" : "fail")}");
        }
        catch (Exception ex)
        {
            Console.WriteLine($"Fail: {ex.Message}");
            if (ex.InnerException != null)
            {
                Console.WriteLine($"Exception: {ex.InnerException.Message}");
            }
        }
    }
 
    private static MongoClient CreateSecureClient(string connectionString, string caCertPath)
    {
        var caCert = new X509Certificate2(caCertPath);
        
        var settings = MongoClientSettings.FromConnectionString(connectionString);
 
        settings.SslSettings = new SslSettings
        {
            CheckCertificateRevocation = false,
            ClientCertificates = new[] { caCert }
        };
        settings.UseTls = true;
        settings.AllowInsecureTls = true;
 
        settings.MaxConnectionPoolSize = 100;
        settings.MinConnectionPoolSize = 10;
        
        return new MongoClient(settings);
    }
}

using MongoDB.Driver;
using MongoDB.Bson;
using System;
class Program
{
    static void Main(string[] args)
    {
        // Replace <YourConnectionString> with your MongoDB connection string
        var connectionString = "mongodb://rwuser:rwuserpassword@ip:port/{mydb}?authSource=admin&replicaSet=replica";
        
        // Create a MongoClient object
        var client = new MongoClient(connectionString);
        
        // Get a reference to the database
        var database = client.GetDatabase("testDatabase");
        
        // Get a reference to a collection
        var collection = database.GetCollection<BsonDocument>("testCollection");
        
        // Create a sample document
        var document = new BsonDocument
        {
            { "name", "DDS" },
            { "type", "Database" },
            { "count", 1 },
            { "versions", new BsonArray { "v3.4", "v4.0", "v4.2" } },
            { "info", new BsonDocument { { "x", 203 }, { "y", 102 } } }
        };
        
        // Insert the document into the collection
        collection.InsertOne(document);
        
        Console.WriteLine("Document inserted successfully!");
    }
}