MongoDB学习笔记~MongoDBRepository仓储的实现

xiaozhuaia

　　回到目录
　　仓储大叔，只要是持久化的东西，都要把它和仓储撤上关系，为啥，为的是开发人员在使用时统一，高可用及方便在各种方式之间实现动态的切换，如ef与redis和mongoDB的切换，你完成可以通过IRepository接口再配合IOC来实现，方便致极！
　　之间写过一个redis仓储和xml仓储，感兴趣的同学可以先去看看，呵呵。
　　MongoDB在实现仓储时，先要知道一些概念，即它的一些connectionstring，即连接串



  


　　对于大叔的MongoDBRepository，把它进行了拆分，使用Appsetting进行分别的设置



  
  
   
   
   
  
　　如果要配置读写分离，那么第一个host为主库，后面的为从库，如下面的字符串，将写操作定在主库，读操作定在各个从库



mongodb://server1,server2,server3/?slaveOk=true
　　下面看一下源代码



namespace MongoDb.Data.Core
{
///
/// 通过MongoDb实现数据的持久化
///
///
public class MongoDBRepository :
IExtensionRepository where TEntity : class
{
#region ConnectionString
private static readonly string _connectionStringHost = ConfigurationManager.AppSettings["host"];
private static readonly string _dbName = ConfigurationManager.AppSettings["dbName"];
private static readonly string _userName = ConfigurationManager.AppSettings["userName"];
private static readonly string _password = ConfigurationManager.AppSettings["password"];
public static string ConnectionString(string options)
{
var database = _dbName;
var userName = _userName;
var password = _password;
var authentication = string.Empty;
var host = 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]]
return string.Format("mongodb://{0}{1}/{2}{3}?{4}", authentication, host, database, options);
}
public static string ConnectionString()
{
return ConnectionString(null);
}
#endregion
#region Public Properties
public IMongoCollection Table
{
get
{
using (var mongo = Mongo.Create(ConnectionString()))
{
return mongo.Database.GetCollection(typeof(TEntity).Name);
}
}
}
#endregion
#region IRepository 成员
public void SetDbContext(IUnitOfWork unitOfWork)
{
throw new NotImplementedException();
}
public void Insert(TEntity item)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
var table = mongo.Database.GetCollection(typeof(TEntity).Name);
table.Insert(item);
}
}
public void Delete(TEntity item)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
var table = mongo.Database.GetCollection(typeof(TEntity).Name);
table.Delete(item);
}
}
public void Update(TEntity item)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
var table = mongo.Database.GetCollection(typeof(TEntity).Name);
table.Save(item);
}
}
public IQueryable GetModel()
{
using (var mongo = Mongo.Create(ConnectionString()))
{
return mongo.Database.GetCollection(typeof(TEntity).Name).AsQueryable();
}
}
public TEntity Find(params object[] id)
{
  using (var mongo = Mongo.Create(ConnectionString()))
             {
                return mongo.Database
                    .GetCollection(typeof(TEntity).Name)
                    .Find(new { ID = new ObjectId(id[0].ToString()) })
                    .FirstOrDefault();
             }
}
#endregion
#region IExtensionRepository 成员
public void Insert(IEnumerable item)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
var table = mongo.Database.GetCollection(typeof(TEntity).Name);
item.ToList().ForEach(i =>
{
table.Insert(i);
});
}
}
public void Update(IEnumerable item)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
var table = mongo.Database.GetCollection(typeof(TEntity).Name);
item.ToList().ForEach(i =>
{
table.Save(i);
});
}
}
public void Delete(IEnumerable item)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
var table = mongo.Database.GetCollection(typeof(TEntity).Name);
item.ToList().ForEach(i =>
{
table.Delete(i);
});
}
}
public void Update(System.Linq.Expressions.Expression entity) where T : class
{
throw new NotImplementedException();
}
public IQueryable GetModel(System.Linq.Expressions.Expression predicate)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
return mongo.Database.GetCollection(typeof(TEntity).Name).AsQueryable().Where(predicate);
}
}
public TEntity Find(System.Linq.Expressions.Expression predicate)
{
using (var mongo = Mongo.Create(ConnectionString()))
{
return mongo.Database.GetCollection(typeof(TEntity).Name).AsQueryable().FirstOrDefault(predicate);
}
}
public void BulkInsert(IEnumerable item, bool isRemoveIdentity)
{
throw new NotImplementedException();
}
public void BulkInsert(IEnumerable item)
{
throw new NotImplementedException();
}
public void BulkUpdate(IEnumerable item, params string[] fieldParams)
{
throw new NotImplementedException();
}
public void BulkDelete(IEnumerable item)
{
throw new NotImplementedException();
}
public event Action AfterSaved;
public event Action BeforeSaved;
public IQueryable GetModel(Frameworks.Entity.Core.Specification.ISpecification specification)
{
throw new NotImplementedException();
}
public TEntity Find(Frameworks.Entity.Core.Specification.ISpecification specification)
{
return GetModel(specification).FirstOrDefault();
}
public IQueryable GetModel(Action orderBy, Frameworks.Entity.Core.Specification.ISpecification specification)
{
var linq = new Orderable(GetModel(specification));
orderBy(linq);
return linq.Queryable;
}
#endregion
#region IRepositoryAsync 成员
public Task InsertAsync(TEntity item)
{
throw new NotImplementedException();
}
public Task DeleteAsync(TEntity item)
{
throw new NotImplementedException();
}
public Task UpdateAsync(TEntity item)
{
throw new NotImplementedException();
}
public Task InsertAsync(IEnumerable item)
{
throw new NotImplementedException();
}
public Task UpdateAsync(IEnumerable item)
{
throw new NotImplementedException();
}
public Task DeleteAsync(IEnumerable item)
{
throw new NotImplementedException();
}
public Task BulkInsertAsync(IEnumerable item, bool isRemoveIdentity)
{
throw new NotImplementedException();
}
public Task BulkInsertAsync(IEnumerable item)
{
throw new NotImplementedException();
}
public Task BulkUpdateAsync(IEnumerable item, params string[] fieldParams)
{
throw new NotImplementedException();
}
public Task BulkDeleteAsync(IEnumerable item)
{
throw new NotImplementedException();
}
#endregion
#region IOrderableRepository 成员
public IQueryable GetModel(Action orderBy)
{
var linq = new Orderable(GetModel());
orderBy(linq);
return linq.Queryable;
}
public IQueryable GetModel(Action orderBy, System.Linq.Expressions.Expression predicate)
{
var linq = new Orderable(GetModel(predicate));
orderBy(linq);
return linq.Queryable;
}
#endregion
}
}
　　回到目录