実行時にdbContextにコンストラクタパラメータを渡し、Unityにそのようなものを登録するにはどうすればいいですか？

Question

UnitOfWork、Repository、DIなど、あらゆる種類の良いものを実装しようとしています。 DIのためにUnityを使用しています。ここに私のジレンマがあります。私は同じスキーマを持ついくつか（現在3つ）のデータベースを持っていますが、明らかにビジネス上の理由から異なるデータを持っています（私はそれらをGroupDB1、GroupDB2、およびGroupDB3と呼んでいます）。私はまた別のスキーマを持つマスターデータベース（DifferentDB）を持っています。私のdbcontextは、実行時にさまざまなシナリオで異なるデータベースを使用する必要があります。私はそれらをすべて一緒に働かせる方法を知りません。

は、ここに私のdbContexts

public partial class GroupDB2 : DataContext 
{ 
    public GroupDB2() : base("name=GroupDB2") 
    { 
    } 
    public IDbSet<T> Set<T>() where T : EntityBase { return base.Set<T>(); } 

    protected override void OnModelCreating(DbModelBuilder modelBuilder) 
    { 
     //...... 
    } 
} 

public partial class MasterDB : DataContext 
{ 
    public MasterDB() : base("name=MasterDB") 
    { 
    } 
    public IDbSet<T> Set<T>() where T : EntityBase { return base.Set<T>(); } 

    protected override void OnModelCreating(DbModelBuilder modelBuilder) 
    { 
     //...... 
    } 
} 

、ここで私の他のインタフェースと実装されています。私はアンチパターンについて多くを読んでいるので

public class DataContext : DbContext, IDataContextAsync 
{ 
    private readonly Guid _instanceId; 
    bool _disposed; 

    public DataContext(string nameOrConnectionString) : base(nameOrConnectionString) 
    { 
     _instanceId = Guid.NewGuid(); 
     //Configuration.LazyLoadingEnabled = false; 
     //Configuration.ProxyCreationEnabled = false; 
    } 
} 

public interface IDataContext : IDisposable 
{ 
    int SaveChanges(); 
} 


public interface IDataContextAsync : IDataContext 
{ 
    Task<int> SaveChangesAsync(CancellationToken cancellationToken); 
    Task<int> SaveChangesAsync(); 
} 

public interface IRepository<T> where T : class 
{ 
    IDataContextAsync Context { get; } 
    IDbSet<T> DbSet { get; } 
    void Add(T entity); 
    void Delete(T entity); 
    void Delete(dynamic id); 
    T FindOne(Expression<Func<T, bool>> predicate); 
    IQueryable<T> FindBy(Expression<Func<T, bool>> predicate); 
    IQueryable<T> GetAll(); 
    void Update(T entity); 
} 

public interface IRepositoryAsync<TEntity> : IRepository<TEntity> where TEntity : class 
{ 
    Task<TEntity> FindAsync(params object[] keyValues); 
    Task<TEntity> FindAsync(CancellationToken cancellationToken, params object[] keyValues); 
    Task<bool> DeleteAsync(params object[] keyValues); 
    Task<bool> DeleteAsync(CancellationToken cancellationToken, params object[] keyValues); 
} 

public static IUnityContainer InitializeContainer(IUnityContainer _container) 
{ 
    container = _container; 

    .... 
    .... 

    container.RegisterType<IDataContextAsync, DataContext>(new InjectionConstructor("name=MasterDB")); 
    container.RegisterType<IUnitOfWorkAsync, UnitOfWork>();// ("Async"); 

    // Here is where I have no clue how do I register and resolve the correct entity context based on some conditions 
    // Like ConnectionStringService.GetConnectionString(for some condition); 

    //container.RegisterType<IDataContextAsync, DataContext>("GroupDB", new InjectionConstructor(xxxxxx)); 
    //container.RegisterType<IDataContextAsync, DataContext>("DifferentDB", new InjectionConstructor(yyyyyy)); 

    .... 
    .... 

    return container; 
} 

私は困惑しています

var result = container.Resolve<MyObject>(
    new ParameterOverride("x", ExpectedValue) 
     .OnType<MyOtherObject>()); 

行うには消極的です。どんな助けも高く評価されます。ありがとう。

babu。

Answer 1

私は少し工夫されているかもしれない例を考え出しましたが、私はそれがあなたに最も柔軟性を与えると信じています。例here全体を見ることができます。デザインタイムのみのサポートやランタイムのみのサポートが必要な場合は、おそらくそれを少しきれいにすることができます。

設計時の分解能では、追加のジェネリックパラメータをトークンとして使用して、接続先のデータストアを識別します。これにより、1つのデータストアに固有の作業単位および/またはリポジトリを（コンストラクタインジェクションを介して）解決することができます。ランタイム解決のため

MyService(IUnitOfWork<Group2Token> unitOfWork) { /* ... */ } 

、これは、文字列トークンでワークの所望の単位のインスタンスを取得するために管理クラスを使用します。

MyService(IUnitOfWorkManager unitOfWorkManager) 
{ 
    _unitOfWork = unitOfWorkManager.GetUnitOfWork("Group2"); 
} 

管理者は、アレイにすべてのという名前登録を解決するためのユニティのビルトインサポートを使用しています。その詳細はquestion and answerにあります。

使い捨てのものの登録にはHierarchicalLifetimeManagerを使用することをお勧めします。子コンテナを組み合わせて使用​​する場合は、自動廃棄メカニズムを使用します。このquestion and answerの詳細情報