c# 链接mongDB集群实战开发3

<?xmlversion="1.0"encoding="utf-8"?>
<configuration>
<startup>
<supportedRuntimeversion="v4.0"sku=".NETFramework,Version=v4.5"/>
</startup>
<appSettings>
<addkey="LogLevel"value="trace"/>
<addkey="LogPath"value="E:\Tools\mongdb\FrmMongDB\FrmMongDB\logs"/>

<!--MongDb配置begin-->
<addkey="MongReplicaSetName"value="zuomm"/><!--设置副本集名称-->
<addkey="MongoServerAddress"value="127.0.0.1:1111|127.0.0.1:2222|127.0.0.1:3333"/><!--mongdb集群列表-->
<addkey="TimeOut"value="60"/><!--mongdb集群链接超时时间-->
<!--MongDb配置end-->
</appSettings>

</configuration>

///<summary>
///取得数据库连接字符串
///</summary>
///<paramname="connName">App.Config文件中AppSettings节中AppSettings对应的name</param>
///<returns>数据库连接字符串</returns>
privatestaticMongoServerGetConnStr()
{
List<MongoServerAddress>servers=newList<MongoServerAddress>();
stringreg=@"^(?'server'\d{1,}.\d{1,}.\d{1,}.\d{1,}):(?'port'\d{1,})$";
string[]ServerList=ConfigurationManager.AppSettings["MongoServerAddress"].Trim().Split('|');
foreach(stringserverinServerList)
{
MatchCollectionmc=Regex.Matches(server,reg);
if(mc!=null&&mc.Count>0)
servers.Add(newMongoServerAddress(mc[0].Groups["server"].ToString(),Convert.ToInt32(mc[0].Groups["port"].ToString())));
}

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

MongoClientSettingsset=newMongoClientSettings();

set.Servers=servers;

set.ReplicaSetName=ConfigurationManager.AppSettings["MongReplicaSetName"].Trim();//设置副本集名称

intTimeOut=ConvertUtil.ParseInt(ConfigurationManager.AppSettings["TimeOut"].Trim());//设置副本集名称

set.ConnectTimeout=newTimeSpan(0,0,0,TimeOut,0);//设置超时时间为5秒

set.ReadPreference=newReadPreference(ReadPreferenceMode.SecondaryPreferred);

MongoClientclient=newMongoClient(set);

returnclient.GetServer();
}

///<summary>
///MongDB批量insert语句
///</summary>
///<typeparamname="T">对象类型</typeparam>
///<paramname="_databaseName">数据库名称</param>
///<paramname="_collectionName">表名称</param>
///<paramname="entitys">对象</param>
///<paramname="errorMsg">返回错误</param>
///<returns></returns>
publicstaticIEnumerable<SafeModeResult>Execute<T>(string_databaseName,string_collectionName,IEnumerable<T>entitys,outstringerrorMsg)
{
errorMsg=string.Empty;
//取得数据库连接
IEnumerable<SafeModeResult>result=null;

try
{
if(null==entitys)
returnnull;
//获取连接的服务器集群
_server=GetConnStr();

//获取数据库或者创建数据库（不存在的话）。
MongoDatabasedatabase=_server.GetDatabase(_databaseName);

using(_server.RequestStart(database))//开始连接数据库。
{
MongoCollection<T>myCollection=database.GetCollection<T>(_collectionName);
result=myCollection.InsertBatch<T>(entitys);
}
}
catch(Exceptionex)
{
errorMsg=ex.ToString();
}
finally
{
}

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

returnresult;
}

///<summary>
///如果不清楚具体的数量，一般不要用这个函数。
///</summary>
///<typeparamname="T"></typeparam>
///<paramname="collectionName"></param>
///<returns></returns>
publicstaticList<T>GetAll<T>(string_databaseName,stringcollectionName,outstringerrorMsg)
{
errorMsg=string.Empty;
List<T>result=newList<T>();
try
{
//获取连接的服务器集群
_server=GetConnStr();

//获取数据库或者创建数据库（不存在的话）。
MongoDatabasedatabase=_server.GetDatabase(_databaseName);

using(_server.RequestStart(database))//开始连接数据库。
{
MongoCollection<T>myCollection=database.GetCollection<T>(collectionName);
result.AddRange(myCollection.FindAll());
}
}
catch(Exceptionex)
{
errorMsg=ex.ToString();
}
//记录日志
if(!string.IsNullOrEmpty(errorMsg))
{
LogUtil.Error("CommonLib.DbAccess.MongDBAccess","GetAll",errorMsg+"\n\r\t");
}
returnresult;
}