Как получить экземпляр SqlPersistence, настроенный со строкой соединения в EventStore Джонатана Оливера?

Question

Код ниже будет создавать eventstore для именованного соединения.

var es = Wireup.Init()         
    .UsingSqlPersistence("DB") 
    .Build(); 

мне нужно что-то вроде:

var es = Wireup.Init()         
    .UsingSqlPersistence("Data Source=TEST;Initial Catalog=App") 
    .Build(); 

Самый простой способ я нашел для создания пользовательских IConnectionFactory, но это не выглядит правильно. Какие-либо предложения?

Answer 1

Я не нашел способ сделать это с помощью любого из встроенных классов, но есть интерфейс, о котором вы говорили, более или менее прост в использовании.

Используя код joliver, я реализовал строку подключения завода следующим образом:

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Data.Common; 
using System.Configuration; 
using System.Data; 
using EventStore.Persistence.SqlPersistence; 
using EventStore.Persistence; 

namespace Project.Factories 
{ 
    public class ConnectionStringConnectionFactory : IConnectionFactory 
    { 
     private static readonly IDictionary<string, DbProviderFactory> CachedFactories = 
      new Dictionary<string, DbProviderFactory>(); 

     private string m_connectionString; 
     private string m_providerName; 

     private string m_replicaConnectionString; 
     private string m_replicaProviderName; 

     public ConnectionStringConnectionFactory(string connectionString, string providerName) 
      : this(connectionString, providerName, connectionString, providerName) 
     { 

     } 

     public ConnectionStringConnectionFactory(
      string connectionString, 
      string providerName, 
      string replicaConnectionString, 
      string replicaProviderName) 
     { 
      m_connectionString = connectionString; 
      m_providerName = providerName; 
      m_replicaConnectionString = replicaConnectionString; 
      m_replicaProviderName = replicaProviderName; 
     } 


     public virtual IDbConnection OpenMaster(Guid streamId) 
     { 
      return this.Open(streamId, m_connectionString, m_providerName); 
     } 

     public virtual IDbConnection OpenReplica(Guid streamId) 
     { 
      return this.Open(streamId, m_replicaConnectionString, m_replicaProviderName); 
     } 

     protected virtual IDbConnection Open(Guid streamId, string connectionString, string providerName) 
     { 
      return new ConnectionScope(connectionString,() => this.Open(connectionString, providerName)); 
     } 

     protected virtual IDbConnection Open(string connectionString, string providerName) 
     { 
      var factory = this.GetFactory(providerName); 
      var connection = factory.CreateConnection(); 
      if (connection == null) 
       throw new ConfigurationErrorsException("Invalid provider name"); 

      connection.ConnectionString = connectionString; 

      try 
      { 
       connection.Open(); 
      } 
      catch (Exception e) 
      { 
       throw new StorageUnavailableException(e.Message, e); 
      } 

      return connection; 
     } 

     protected virtual DbProviderFactory GetFactory(string providerName) 
     { 
      lock (CachedFactories) 
      { 
       DbProviderFactory factory; 
       if (CachedFactories.TryGetValue(providerName, out factory)) 
        return factory; 

       factory = DbProviderFactories.GetFactory(providerName); 
       return CachedFactories[providerName] = factory; 
      } 
     } 

     public ConnectionStringSettings Settings 
     { 
      get { return new ConnectionStringSettings("Default", m_connectionString, m_providerName); } 
     } 
    } 
} 

Чтобы использовать это просто передать на заводе:

var fac = new ConnectionStringConnectionFactory(
      "Your Connection String", 
      "System.Data.SqlClient"); 

Wireup.Init().UsingSqlPersistence(fac) 

Если вы хотите, вы можете обернуть, что метод расширения :

Wireup.Init().UsingSqlPersistenceWithConnectionString("") 

Answer 2

Создан запрос на растяжение для поддержки конфигурации с подключением ионная струна.

https://github.com/NEventStore/NEventStore/pull/358

Если не будут приняты, вы можете использовать код, чтобы включить конфигурацию с строки подключения в вашем собственном проекте, это всего лишь несколько строк кода.

ОБНОВЛЕНИЕ: Запрос на увольнение принимается и доступен с версии 5.1 NEventstore. Который теперь доступен на nuget.