.net,个人封装MONGODDB的操作。

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using MongoDB.Driver; 

namespace CDPWIB.DAL

{

public class MongoConnectionFactory

{

//private static readonly string _connectionString = "mongodb://username:pwd@localhost:27000";

private static readonly string _connectionString = System.Configuration.ConfigurationSettings.AppSettings["entmongoconectionstring"]; 

//{ConnectionMode=Automatic;ConnectTimeout=00:00:30;Credentials={{DBNAME@USERNAME}};GuidRepresentation=CSharpLegacy;IPv6=False;MaxConnectionIdleTime=00:10:00;MaxConnectionLifeTime=00:30:00;MaxConnectionPoolSize=100;MinConnectionPoolSize=0;ReadPreference=Primary;ReplicaSetName=;SecondaryAcceptableLatency=00:00:00.0150000;Servers=10.10.10.252:27000;SocketTimeout=00:00:00;Ssl=False;SslVerifyCertificate=True;WaitQueueSize=500;WaitQueueTimeout=00:02:00WriteConcern=w=1;}

//public static MongoClientSettings clintser = new MongoClientSettings

//{

// //Credentials = new List<MongoCredential>

// //{

// // MongoCredential.CreateMongoCRCredential("USERNAME", "DBNAME", "DB")

// //},

// MaxConnectionLifeTime = new TimeSpan(0, 5, 0),

// MaxConnectionIdleTime = new TimeSpan(0, 2, 0),

// MinConnectionPoolSize = 0,

// MaxConnectionPoolSize = 1000,

// SocketTimeout = new TimeSpan(0, 2, 0),

// WaitQueueTimeout = new TimeSpan(0, 0, 30), 

// //Server = new MongoServerAddress("10.10.10.252", 27000),

// Server = new MongoServerAddress("127.0.0.1", 27000),

// //WaitQueueTimeout = new TimeSpan(0, 2, 0),

// //

// ConnectTimeout = new TimeSpan(0, 0, 30),

//}; 

public static MongoClientSettings clintser = new MongoClientSettings

{

Credentials = new List<MongoCredential>

{

//MongoCredential.CreateMongoCRCredential("usename", "db", "pwd")

},

MaxConnectionLifeTime = new TimeSpan(, , ),

MaxConnectionIdleTime = new TimeSpan(, , ),

MinConnectionPoolSize = ,

MaxConnectionPoolSize = ,

SocketTimeout = new TimeSpan(, , ),

WaitQueueTimeout = new TimeSpan(, , ), 

//Server = new MongoServerAddress("10.10.10.252", 27000),

Server = new MongoServerAddress("127.0.0.1", ),

//WaitQueueTimeout = new TimeSpan(0, 2, 0),

//

ConnectTimeout = new TimeSpan(, , ),

};

private static MongoClient mongoClient = new MongoClient(clintser); 

private static MongoServer mongoServer = mongoClient.GetServer(); 

public static MongoClient GetMongoClient()

{

return mongoClient;

} 

public static MongoServer GetMongoServer()

{

//var seting = mongoServer.Settings;

//seting.ConnectTimeout = new TimeSpan(0, 2, 0);

//seting.MinConnectionPoolSize = 100;

//seting.MaxConnectionPoolSize = 1000;

//seting.SocketTimeout = new TimeSpan(0, 2, 0);

//seting.WaitQueueTimeout = new TimeSpan(0, 2, 0); 

return mongoServer;

} 

public static MongoDatabase GetMongoDataBase(string dbname)

{ 

return GetMongoServer().GetDatabase(dbname);

} 

public static MongoCollection<T> GetMongoCollction<T>(MongoDatabase database, string collectionname)

{ 

return database.GetCollection<T>(collectionname);

}

public static MongoCollection<T> GetMongoCollction<T>(string databasename, string collectionname)

{

MongoDatabase database = GetMongoDataBase(databasename);

return database.GetCollection<T>(collectionname);

} 

public static MongoCollection<T> GetMongoCollction<T>(string databasename)

{

MongoDatabase database = GetMongoDataBase(databasename);

return database.GetCollection<T>(typeof(T).Name);

} 

public static MongoCollection GetMongoCollction(string databasename, string collectionname)

{

MongoDatabase database = GetMongoDataBase(databasename);

return database.GetCollection(collectionname);

} 

public static MongoCollection<T> GetMongoCollction<T>(MongoDatabase database, Type type)

{

return database.GetCollection<T>(type.Name);

}

public static MongoCollection<T> GetMongoCollction<T>(string databasename, Type type)

{

MongoDatabase database = mongoServer.GetDatabase(databasename);

return database.GetCollection<T>(type.Name);

} 

}

}