MongoDB学习笔记~MongoDBRepository仓储的实现
本文内容纲要：
回到目录
仓储大叔，只要是持久化的东西，都要把它和仓储撤上关系，为啥，为的是开发人员在使用时统一，高可用及方便在各种方式之间实现动态的切换，如ef与redis和mongoDB的切换，你完成可以通过IRepository接口再配合IOC来实现，方便致极！
之间写过一个redis仓储和xml仓储，感兴趣的同学可以先去看看，呵呵。
MongoDB在实现仓储时，先要知道一些概念，即它的一些connectionstring，即连接串
<connectionStrings>
<addname="NormTests"connectionString="mongodb://Username:Password@server:port/dbName/query"/>
</connectionStrings>
对于大叔的MongoDBRepository，把它进行了拆分，使用Appsetting进行分别的设置
<appSettingsfile="config.user">
<addkey="MongoDB_Host"value="localhost:27017"/>
<addkey="MongoDB_DbName"value=""/>
<addkey="MongoDB_UserName"value=""/>
<addkey="MongoDB_Password"value=""/>
</appSettings>
如果要配置读写分离，那么第一个host为主库，后面的为从库，如下面的字符串，将写操作定在主库，读操作定在各个从库
mongodb://server1,server2,server3/?slaveOk=true
下面看一下源代码
namespaceMongoDb.Data.Core
{
///<summary>
///通过MongoDb实现数据的持久化
///</summary>
///<typeparamname="TEntity"></typeparam>
publicclassMongoDBRepository<TEntity>:
IExtensionRepository<TEntity>whereTEntity:class
{
#regionConnectionString
privatestaticreadonlystring_connectionStringHost=ConfigurationManager.AppSettings["host"];
privatestaticreadonlystring_dbName=ConfigurationManager.AppSettings["dbName"];
privatestaticreadonlystring_userName=ConfigurationManager.AppSettings["userName"];
privatestaticreadonlystring_password=ConfigurationManager.AppSettings["password"];
publicstaticstringConnectionString(stringoptions)
{
vardatabase=_dbName;
varuserName=_userName;
varpassword=_password;
varauthentication=string.Empty;
varhost=string.Empty;
if(userName!=null)
{
authentication=string.Concat(userName,':',password,'@');
}
if(!string.IsNullOrEmpty(options)&&!options.StartsWith("?"))
{
options=string.Concat('?',options);
}
host=string.IsNullOrEmpty(_connectionStringHost)?"localhost":_connectionStringHost;
database=database??"Test";
//mongodb://[username:password@]host1[:port1][,host2[:port2],…[,hostN[:portN]]][/[database][?options]]
returnstring.Format("mongodb://{0}{1}/{2}{3}?{4}",authentication,host,database,options);
}
publicstaticstringConnectionString()
{
returnConnectionString(null);
}
#endregion
#regionPublicProperties
publicIMongoCollection<TEntity>Table
{
get
{
using(varmongo=Mongo.Create(ConnectionString()))
{
returnmongo.Database.GetCollection<TEntity>(typeof(TEntity).Name);
}
}
}
#endregion
#regionIRepository<TEntity>成员
publicvoidSetDbContext(IUnitOfWorkunitOfWork)
{
thrownewNotImplementedException();
}
publicvoidInsert(TEntityitem)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
vartable=mongo.Database.GetCollection<TEntity>(typeof(TEntity).Name);
table.Insert(item);
}
}
publicvoidDelete(TEntityitem)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
vartable=mongo.Database.GetCollection<TEntity>(typeof(TEntity).Name);
table.Delete(item);
}
}
publicvoidUpdate(TEntityitem)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
vartable=mongo.Database.GetCollection<TEntity>(typeof(TEntity).Name);
table.Save(item);
}
}
publicIQueryable<TEntity>GetModel()
{
using(varmongo=Mongo.Create(ConnectionString()))
{
returnmongo.Database.GetCollection<TEntity>(typeof(TEntity).Name).AsQueryable();
}
}
publicTEntityFind(paramsobject[]id)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
returnmongo.Database
.GetCollection<TEntity>(typeof(TEntity).Name)
.Find(new{ID=newObjectId(id[0].ToString())})
.FirstOrDefault();
}
}
#endregion
#regionIExtensionRepository<TEntity>成员
publicvoidInsert(IEnumerable<TEntity>item)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
vartable=mongo.Database.GetCollection<TEntity>(typeof(TEntity).Name);
item.ToList().ForEach(i=>
{
table.Insert(i);
});
}
}
publicvoidUpdate(IEnumerable<TEntity>item)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
vartable=mongo.Database.GetCollection<TEntity>(typeof(TEntity).Name);
item.ToList().ForEach(i=>
{
table.Save(i);
});
}
}
publicvoidDelete(IEnumerable<TEntity>item)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
vartable=mongo.Database.GetCollection<TEntity>(typeof(TEntity).Name);
item.ToList().ForEach(i=>
{
table.Delete(i);
});
}
}
publicvoidUpdate<T>(System.Linq.Expressions.Expression<Action<T>>entity)whereT:class
{
thrownewNotImplementedException();
}
publicIQueryable<TEntity>GetModel(System.Linq.Expressions.Expression<Func<TEntity,bool>>predicate)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
returnmongo.Database.GetCollection<TEntity>(typeof(TEntity).Name).AsQueryable().Where(predicate);
}
}
publicTEntityFind(System.Linq.Expressions.Expression<Func<TEntity,bool>>predicate)
{
using(varmongo=Mongo.Create(ConnectionString()))
{
returnmongo.Database.GetCollection<TEntity>(typeof(TEntity).Name).AsQueryable().FirstOrDefault(predicate);
}
}
publicvoidBulkInsert(IEnumerable<TEntity>item,boolisRemoveIdentity)
{
thrownewNotImplementedException();
}
publicvoidBulkInsert(IEnumerable<TEntity>item)
{
thrownewNotImplementedException();
}
publicvoidBulkUpdate(IEnumerable<TEntity>item,paramsstring[]fieldParams)
{
thrownewNotImplementedException();
}
publicvoidBulkDelete(IEnumerable<TEntity>item)
{
thrownewNotImplementedException();
}
publiceventAction<SavedEventArgs>AfterSaved;
publiceventAction<SavedEventArgs>BeforeSaved;
publicIQueryable<TEntity>GetModel(Frameworks.Entity.Core.Specification.ISpecification<TEntity>specification)
{
thrownewNotImplementedException();
}
publicTEntityFind(Frameworks.Entity.Core.Specification.ISpecification<TEntity>specification)
{
returnGetModel(specification).FirstOrDefault();
}
publicIQueryable<TEntity>GetModel(Action<IOrderable<TEntity>>orderBy,Frameworks.Entity.Core.Specification.ISpecification<TEntity>specification)
{
varlinq=newOrderable<TEntity>(GetModel(specification));
orderBy(linq);
returnlinq.Queryable;
}
#endregion
#regionIRepositoryAsync<TEntity>成员
publicTaskInsertAsync(TEntityitem)
{
thrownewNotImplementedException();
}
publicTaskDeleteAsync(TEntityitem)
{
thrownewNotImplementedException();
}
publicTaskUpdateAsync(TEntityitem)
{
thrownewNotImplementedException();
}
publicTaskInsertAsync(IEnumerable<TEntity>item)
{
thrownewNotImplementedException();
}
publicTaskUpdateAsync(IEnumerable<TEntity>item)
{
thrownewNotImplementedException();
}
publicTaskDeleteAsync(IEnumerable<TEntity>item)
{
thrownewNotImplementedException();
}
publicTaskBulkInsertAsync(IEnumerable<TEntity>item,boolisRemoveIdentity)
{
thrownewNotImplementedException();
}
publicTaskBulkInsertAsync(IEnumerable<TEntity>item)
{
thrownewNotImplementedException();
}
publicTaskBulkUpdateAsync(IEnumerable<TEntity>item,paramsstring[]fieldParams)
{
thrownewNotImplementedException();
}
publicTaskBulkDeleteAsync(IEnumerable<TEntity>item)
{
thrownewNotImplementedException();
}
#endregion
#regionIOrderableRepository<TEntity>成员
publicIQueryable<TEntity>GetModel(Action<IOrderable<TEntity>>orderBy)
{
varlinq=newOrderable<TEntity>(GetModel());
orderBy(linq);
returnlinq.Queryable;
}
publicIQueryable<TEntity>GetModel(Action<IOrderable<TEntity>>orderBy,System.Linq.Expressions.Expression<Func<TEntity,bool>>predicate)
{
varlinq=newOrderable<TEntity>(GetModel(predicate));
orderBy(linq);
returnlinq.Queryable;
}
#endregion
}
}
回到目录
本文内容总结：
原文链接：https://www.cnblogs.com/lori/p/4402018.html