ABP 结合 MongoDB 集成依赖注入

鲍鲍鱼 發表於 2019-9-14 12:13:00

1.我们再ABP项目添加一个.NET Core类库  类库名自定定义，我这里定义为 TexHong_EMWX.MongoDb
添加NuGet包。
ABP
mongocsharpdriver
<img src="https://img2018.cnblogs.com/blog/1428124/201909/1428124-20190914115906163-1535050405.png">
 
 
添加 AbpMongoDbConfigurationExtensions.cs
<div class="cnblogs_code">
<pre> /// <summary>
/// 定义扩展方法 <see cref="IModuleConfigurations"/> 允许配置ABP MongoDB模块
/// </summary>
public static class AbpMongoDbConfigurationExtensions
{
 /// <summary>
 /// 用于配置ABP MongoDB模块。
 /// </summary>
 public static IAbpMongoDbModuleConfiguration AbpMongoDb(this IModuleConfigurations configurations)
 {
 return configurations.AbpConfiguration.Get<IAbpMongoDbModuleConfiguration>();
 }
}</pre>
</div>
添加 AbpMongoDbModuleConfiguration.cs
<div class="cnblogs_code">
<pre> internal class AbpMongoDbModuleConfiguration : IAbpMongoDbModuleConfiguration
{
 public string ConnectionString { get; set; }

 public string DatabaseName { get; set; }
}</pre>
</div>
添加  IAbpMongoDbModuleConfiguration
<div class="cnblogs_code">
<pre>public interface IAbpMongoDbModuleConfiguration
{
 string ConnectionString { get; set; }

 string DatabaseName { get; set; }
}</pre>
</div>
 
添加 MongoDbRepositoryBase.cs
<div class="cnblogs_code">
<pre>/// <summary>
/// Implements IRepository for MongoDB.
/// </summary>
/// <typeparam name="TEntity">Type of the Entity for this repository</typeparam>
public class MongoDbRepositoryBase<TEntity> : MongoDbRepositoryBase<TEntity, int>, IRepository<TEntity>
 where TEntity : class, IEntity<int>
{
 public MongoDbRepositoryBase(IMongoDatabaseProvider databaseProvider)
 : base(databaseProvider)
 {
 }
}
/// <summary>
/// Implements IRepository for MongoDB.
/// </summary>
/// <typeparam name="TEntity">Type of the Entity for this repository</typeparam>
/// <typeparam name="TPrimaryKey">Primary key of the entity</typeparam>
public class MongoDbRepositoryBase<TEntity, TPrimaryKey> : AbpRepositoryBase<TEntity, TPrimaryKey>
 where TEntity : class, IEntity<TPrimaryKey>
{
 public virtual MongoDatabase Database
 {
 get { return _databaseProvider.Database; }
 }
 public virtual MongoCollection<TEntity> Collection
 {
 get
 {
 return _databaseProvider.Database.GetCollection<TEntity>(typeof(TEntity).Name);
 }
 }
 private readonly IMongoDatabaseProvider _databaseProvider;
 public MongoDbRepositoryBase(IMongoDatabaseProvider databaseProvider)
 {
 _databaseProvider = databaseProvider;
 }

 public override IQueryable<TEntity> GetAll()
 {
 return Collection.AsQueryable();
 }

 public override TEntity Get(TPrimaryKey id)
 {
 var query = MongoDB.Driver.Builders.Query<TEntity>.EQ(e => e.Id, id);
 var entity = Collection.FindOne(query);
 if (entity == null)
 {
 throw new EntityNotFoundException("There is no such an entity with given primary key. Entity type: " + typeof(TEntity).FullName + ", primary key: " + id);
 }
 return entity;
 }
 public override TEntity FirstOrDefault(TPrimaryKey id)
 {
 var query = MongoDB.Driver.Builders.Query<TEntity>.EQ(e => e.Id, id);
 return Collection.FindOne(query);
 }
 public override TEntity Insert(TEntity entity)
 {
 Collection.Insert(entity);
 return entity;
 }
 public override TEntity Update(TEntity entity)
 {
 Collection.Save(entity);
 return entity;
 }
 public override void Delete(TEntity entity)
 {
 Delete(entity.Id);
 }
 public override void Delete(TPrimaryKey id)
 {
 var query = MongoDB.Driver.Builders.Query<TEntity>.EQ(e => e.Id, id);
 Collection.Remove(query);
 }
}</pre>
</div>
添加 MongoDbUnitOfWork.cs 
<div class="cnblogs_code">
<pre>/// <summary>
/// Implements Unit of work for MongoDB.
/// </summary>
public class MongoDbUnitOfWork : UnitOfWorkBase, ITransientDependency
{
 /// <summary>
 /// Gets a reference to MongoDB Database.
 /// </summary>
 public MongoDatabase Database { get; private set; }

 private readonly IAbpMongoDbModuleConfiguration _configuration;

 /// <summary>
 /// Constructor.
 /// </summary>
 public MongoDbUnitOfWork(
 IAbpMongoDbModuleConfiguration configuration,
 IConnectionStringResolver connectionStringResolver,
 IUnitOfWorkFilterExecuter filterExecuter,
 IUnitOfWorkDefaultOptions defaultOptions)
 : base(
 connectionStringResolver,
 defaultOptions,
 filterExecuter)
 {
 _configuration = configuration;
 BeginUow();
 }

#pragma warning disable
 protected override void BeginUow()
 {
 //TODO: MongoClientExtensions.GetServer(MongoClient)' is obsolete: 'Use the new API instead.
 Database = new MongoClient(_configuration.ConnectionString)
 .GetServer()
 .GetDatabase(_configuration.DatabaseName);
 }
#pragma warning restore

 public override void SaveChanges()
 {

 }

#pragma warning disable 1998
 public override async Task SaveChangesAsync()
 {

 }
#pragma warning restore 1998

 protected override void CompleteUow()
 {

 }

#pragma warning disable 1998
 protected override async Task CompleteUowAsync()
 {

 }
#pragma warning restore 1998
 protected override void DisposeUow()
 {

 }
}</pre>
</div>
添加  UnitOfWorkMongoDatabaseProvider.cs
<div class="cnblogs_code">
<pre>/// <summary>
/// Implements <see cref="IMongoDatabaseProvider"/> that gets database from active unit of work.
/// </summary>
public class UnitOfWorkMongoDatabaseProvider : IMongoDatabaseProvider, ITransientDependency
{
 public MongoDatabase Database { get { return _mongoDbUnitOfWork.Database; } }

 private readonly MongoDbUnitOfWork _mongoDbUnitOfWork;

 public UnitOfWorkMongoDatabaseProvider(MongoDbUnitOfWork mongoDbUnitOfWork)
 {
 _mongoDbUnitOfWork = mongoDbUnitOfWork;
 }
}</pre>
</div>
添加 IMongoDatabaseProvider.cs
<div class="cnblogs_code">
<pre>public interface IMongoDatabaseProvider
{
 /// <summary>
 /// Gets the <see cref="MongoDatabase"/>.
 /// </summary>
 MongoDatabase Database { get; }
}</pre>
</div>
添加 TexHong_EMWXMongoDBModule.cs
  
<div class="cnblogs_code">
<pre>/// <summary>
/// This module is used to implement "Data Access Layer" in MongoDB.
/// </summary>

public class TexHong_EMWXMongoDBModule : AbpModule
{
 public override void PreInitialize()
 {
 IocManager.Register<IAbpMongoDbModuleConfiguration, AbpMongoDbModuleConfiguration>();
 // 配置 MonggoDb 数据库地址与名称
 IAbpMongoDbModuleConfiguration abpMongoDbModuleConfiguration = Configuration.Modules.AbpMongoDb();
 abpMongoDbModuleConfiguration.ConnectionString = "mongodb://admin:123qwe@118.126.93.113:27017/texhong_em";
 abpMongoDbModuleConfiguration.DatabaseName = "texhong_em";
 }

 public override void Initialize()
 {
 IocManager.RegisterAssemblyByConvention(typeof(TexHong_EMWXMongoDBModule).GetAssembly());
 IocManager.Register<MongoDbRepositoryBase<User, long>>();
 }
}</pre>
</div>
最后项目的架构
<img src="https://img2018.cnblogs.com/blog/1428124/201909/1428124-20190914115551484-1245025969.png">
 
 
 
添加单元测试  MongoDbAppService_Tests.cs 
<div class="cnblogs_code">
<pre> public class MongoDbAppService : TexHong_EMWXTestBase
{
 private readonly MongoDbRepositoryBase<User,long> _mongoDbUserRepositoryBase;

 public MongoDbAppService()
 {
 this._mongoDbUserRepositoryBase = Resolve<MongoDbRepositoryBase<User, long>>();
 }

 public async Task CreateUsers_Test()
 {
 long Id = (DateTime.Now.Ticks - 621356256000000000) / 10000;
 await _mongoDbUserRepositoryBase.InsertAndGetIdAsync(new User() { Id= Id, Name = "123", EmailConfirmationCode = "1111", UserName = "2222" });
 User user = _mongoDbUserRepositoryBase.Get(Id);
 }
}</pre>
</div>
注意单元测试要引用 MongoDb项目。
同时在TestModule.cs属性依赖 DependsOn 把Mongodb 的 Module添加进去，不然会导致运行失败无法注入。
<img src="https://img2018.cnblogs.com/blog/1428124/201909/1428124-20190914121041494-1059399615.png">
 
源码下载：https://download.csdn.net/download/liaoyide/11742718
  
来源：https://www.cnblogs.com/liaoyd/p/11514672.html

頁: [1]

琼殿技术论坛's Archiver

ABP 结合 MongoDB 集成依赖注入