c#鏈接mongDB集群實(shí)戰(zhàn)開發(fā)3

 /// 

 /// 取得數(shù)據(jù)庫連接字符串
 /// 
 /// App.Config文件中AppSettings節(jié)中 AppSettings 對應(yīng)的name
 /// 數(shù)據(jù)庫連接字符串
 private static MongoServer GetConnStr()
 {
 List servers = new List();
 string reg = @"^(?'server'\d{1,}.\d{1,}.\d{1,}.\d{1,}):(?'port'\d{1,})$";
 string[] ServerList = ConfigurationManager.AppSettings["MongoServerAddress"].Trim().Split('|');
 foreach (string server in ServerList)
 {
 MatchCollection mc = Regex.Matches(server, reg);
 if (mc != null && mc.Count > 0)
 servers.Add(new MongoServerAddress(mc[0].Groups["server"].ToString(), Convert.ToInt32(mc[0].Groups["port"].ToString())));
 }

 if (servers == null || servers.Count < 1)
 return null;

 MongoClientSettings set = new MongoClientSettings();

 set.Servers = servers;

 set.ReplicaSetName = ConfigurationManager.AppSettings["MongReplicaSetName"].Trim();//設(shè)置副本集名稱

 int TimeOut =ConvertUtil.ParseInt(ConfigurationManager.AppSettings["TimeOut"].Trim());//設(shè)置副本集名稱

 set.ConnectTimeout = new TimeSpan(0, 0, 0, TimeOut, 0);//設(shè)置超時時間為5秒

 set.ReadPreference = new ReadPreference(ReadPreferenceMode.SecondaryPreferred);

 MongoClient client = new MongoClient(set);

 return client.GetServer();
 }
set.ReadPreference = new ReadPreference(ReadPreferenceMode.SecondaryPreferred); 這句代碼可以根據(jù)自己需要修改。

 /// 

 /// MongDB 批量insert語句
 /// 
 /// 對象類型
 /// 數(shù)據(jù)庫名稱
 /// 表名稱
 /// 對象
 /// 返回錯誤
 /// 
 public static IEnumerable Execute(string _databaseName, string _collectionName, IEnumerable entitys, out string errorMsg)
 {
 errorMsg = string.Empty;
 //取得數(shù)據(jù)庫連接
 IEnumerable result = null;

 try
 {
 if (null == entitys)
 return null;
 //獲取連接的服務(wù)器集群
 _server = GetConnStr();

 //獲取數(shù)據(jù)庫或者創(chuàng)建數(shù)據(jù)庫（不存在的話）。
 MongoDatabase database = _server.GetDatabase(_databaseName);

 using (_server.RequestStart(database))//開始連接數(shù)據(jù)庫。
 {
 MongoCollection myCollection = database.GetCollection(_collectionName);
 result = myCollection.InsertBatch(entitys);
 }
 }
 catch (Exception ex)
 {
 errorMsg = ex.ToString();
 }
 finally
 {
 }

 //記錄日志
 if (!string.IsNullOrEmpty(errorMsg))
 {
 LogUtil.Error("CommonLib.DbAccess.MongDBAccess", "Execute", errorMsg + "\n\r\t");
 }

 return result;
 }

/// 

 /// 如果不清楚具體的數(shù)量，一般不要用這個函數(shù)。
 /// 
 /// 
 /// 
 /// 
 public static List GetAll(string _databaseName, string collectionName,out string errorMsg)
 {
 errorMsg = string.Empty;
 List result = new List();
 try
 {
 //獲取連接的服務(wù)器集群
 _server = GetConnStr();

 //獲取數(shù)據(jù)庫或者創(chuàng)建數(shù)據(jù)庫（不存在的話）。
 MongoDatabase database = _server.GetDatabase(_databaseName);
 
 using (_server.RequestStart(database))//開始連接數(shù)據(jù)庫。
 {
 MongoCollection myCollection = database.GetCollection(collectionName);
 result.AddRange(myCollection.FindAll());
 }
 }
 catch (Exception ex )
 {
 errorMsg = ex.ToString();
 }
 //記錄日志
 if (!string.IsNullOrEmpty(errorMsg))
 {
 LogUtil.Error("CommonLib.DbAccess.MongDBAccess", "GetAll", errorMsg + "\n\r\t");
 }
 return result;
 }