如何创建连接字符串管理器来检测服务器是否可用，如果不可用则返回缓存连接字符串

Question

我有一个偶尔连接的应用程序，其中有一个存储有关产品信息的服务器。我使用数据库缓存在本地存储此信息，因此当连接不可用时，应用程序在尝试读取数据库时仍然可以工作。

由于数据库已配置并且我无权修改表，因此我没有实现 2 路更新，它只下载快照。一个附带问题是是否可以创建数据库缓存并仅与客户端计算机上的跟踪列进行双向同步？我无法向服务器添加任何列或表。我知道这可能是一个单独的帖子的问题，但如果这是真的，那么它将完全改变我对这个问题的方向，到一个单独的模块检测和同步数据库并处理抛出的任何同步错误并始终连接到缓存。

我正在使用通用存储库，我想知道处理连接是否可用以及根据此状态使用本地或远程数据库的最佳实践是什么。

我是否应该向通用存储库添加一个接口来处理返回正确的字符串，并让存储库知道它是否处于活动状态？我需要根据连接状态启用/禁用某些功能，因此我还需要在某个地方有一个属性，以便在使用此存储库时可以有一种方法将各种控件启用状态绑定到此状态。

相反，我是否应该有一个包含 IRepository 和 IConnectionStringManager 等的包装器，然后根据可用性处理馈送和初始化存储库连接字符串？该包装器将公开存储库和所需的任何状态属性。

我想我不确定是否应该将我的程序设置为使用 IRepository 以及幕后的所有自动连接感知，或者我是否应该拥有包含 IRepository 和 IConnectionStringManager 的 IRepositoryManager。

也许这两个选项都是错误的？

Answer 1

我喜欢实体框架允许您提供连接字符串作为其上下文的构造函数参数的方式。这样，您就可以在创建上下文时利用依赖项注入框架应用特殊逻辑，并且只需更改一处代码（假设您使用 DI 原则）。您可以对存储库实现执行类似的操作。

更新

由于您使用的是实体框架，因此它在代码中可能看起来像这样：

// DI Bindings, Ninject style
Bind<Func<MyContext>>().ToMethod(
    c => new MyContext(
             c.Kernel.Get<IConnectionManager>().IsOnline()
                 ? OnlineConnectionString 
                 : OfflineConnectionString));

// Usage
public class ThingRepository : IThingRepository 
{
    private Func<MyContext> _getContext;
    public ThingRepository(Func<MyContext> getContext)
    {
        _getContext = getContext;
    }

    public IEnumerable<Thing> GetAllThings()
    {
        using(var context = _getContext())
        {
            return context.Things.ToList();
        }
    }
}

或者，如果您更喜欢使用更明确的工厂实现：

public interface IMyContextFactory
{
    MyContextFactory Get();
}

public class MyContextFactory : IMyContextFactory
{
    private const string OnlineConnectionString = "...";
    private const string OfflineConnectionString = "...";
    private IConnectionManager _connectionManager;
    public MyContextFactory(IConnectionManager connectionManager)
    {
        _connectionManager = connectionManager;
    }
    public MyContextFactory Get() 
    {
        var connectionString = _connectionManager.IsOnline() 
            ? OnlineConnectionString 
            : OfflineConnectionString
        return new MyContext(connectionString);
    }
}

// DI Bindings, Ninject style
Bind<IMyContextFactory>().To<MyContextFactory>();

// Usage
public class ThingRepository : IThingRepository 
{
    private IMyContextFactory _myContextFactory;
    public ThingRepository(IMyContextFactory myContextFactory)
    {
        _myContextFactory = myContextFactory;
    }

    public IEnumerable<Thing> GetAllThings()
    {
        using(var context = _myContextFactory.Get())
        {
            return context.Things.ToList();
        }
    }
}