如何使用多个数据库连接和存储库模式

Question

我有一个带有 EF 和存储库模式的 c# 项目。

对于单个数据库，一切正常，但我有不同的模型，它们与不同的数据库相关，例如 User 模型数据来自控制面板数据库，其他模型也来自不同的数据库。

这里我为项目使用通用存储库模式。现在初始化模型时如何将数据库连接字符串发送到存储库？

这是我的存储库模式：

public  class Repository<C,T> : IRepository<T> where T : class where C : DbContext, new()
{
    private C _context = new C();
    public C context
    {

        get
        {

            //if (_context == null)
            //{
            //    _context = new C();
            //    _context.Database.Connection.ConnectionString = "the new connectionstring";
            //}
            //return dataContext;
            return _context;
        }
        set { _context = value; }
    }
    private IDbSet<T> _entities;
    private IDbSet<T> Entities
    {
        get
        {
            if (_entities == null)
                _entities = context.Set<T>();
            return _entities;
        }
    }

这是我的服务类

public class UserService: Repository<DyeingContext,User> , IUserRepository
{
    public UserService()
    {
        DyeingContext d = new DyeingContext(DataBase.ControlPanal);
    }
    //private readonly IRepository<User> _useRepository = new Repository<User>(new DyeingContext(DataBase.ControlPanal));   
}``

这是我的上下文类

 public partial class DyeingContext:DbContext
{
  public  DyeingContext(string pDbName):base(GetTheContext(pDbName))
  {

  }

    public DyeingContext():base()
    {
        //throw new NotImplementedException();
    }

    public static string GetTheContext(string pDbName)
  {
      return ConnectionSettings.GetConnectionStringByDbName(pDbName);
  }
}

我无法在此处获取连接字符串

DyeingContext d = new DyeingContext(DataBase.ControlPanal);

它说

通过 system.argumentexception 类型异常的数据库连接

有没有办法将多个连接字符串传递到存储库？

我应该如何以及在哪里初始化我的连接字符串以及如何通过存储库传递它？

Answer 1

我不确定您是否收到上述 cmets 的答复。但这是我将如何实现它。

1- 为每个数据库创建一个 dbContext 具体类。两者都继承自 EF DbContext。

2- 在配置文件中，为每个数据库创建一个连接字符串键。然后将该键作为 ctr 参数提供给每个 dbContext 类。如下：

public DB1Context()
            : base("db1") // connection string key
        {
            this.Configuration.LazyLoadingEnabled = false;
            this.Configuration.ProxyCreationEnabled = false;
        }

public DB2Context()
            : base("db2") // connection string key
        {
            this.Configuration.LazyLoadingEnabled = false;
            this.Configuration.ProxyCreationEnabled = false;
        }

3- 每个数据库都必须有自己的存储库。例如，AccountRepository 继承自基础存储库。它的 db 上下文在构造函数 init 上提供，如下所示。

 public class AccountRepository : DataRepositoryBase<Account>, IAccountRepository
    {
        private DB1Context db1Context = new DB1Context();
        public AccountRepository()
        {
            this.DBContext = db1Context;
        }
    }

这样，您可以通过其存储库与多个数据库进行通信。同一个引擎/服务可以注入来自不同数据库的存储库。