shuttle / shuttle.core.data Goto Github PK

Add onto the IDatabaseGateway:

T Map<T>(IQuery query) where T : new();

This should do a best guess to create the type and set any matching public properties.

Or perhaps create a default mapper:

public static class Mapper
{
   public static T Map<T>(DataRow row) where T : new()
   {
      ...
   }

   public static T Map<T>(this IDatabaseGateway databaseGateway, IQuery query)
   {
      return Mapper.Map<T>(databaseGateway.GetSingleRowUsing(query));
   }
}

Hi.

We wrote unit test for shuttle publish to check if it can be enlisted in trasnaction scope without promoting DTC. This is the code of the test

using (var scope = new TransactionScope(TransactionScopeOption.Required))
            {
                using (var sqlConnection = new SqlConnection(ConfigurationManager.ConnectionStrings[0].ConnectionString))
                using (var command = new SqlCommand("INSERT INTO Test VALUES(@Description)", sqlConnection))
                {                    
                    command.Parameters.Add("Description", SqlDbType.VarChar, 100).Value = DateTime.UtcNow.Millisecond.ToString();

                _bus.Publish(new TestMessage() { FreeText = "Milan Svitlica" });

                sqlConnection.Open();
                command.ExecuteNonQuery();

                scope.Complete();
            }
        }`

But when executing on Sql server 2014, we got an error

24.08.2016 10:01:09:51380 117 Fatal Unhandled exception during event 'Shuttle.Esb.OnDispatchTransportMessage': Raising pipeline event 'Shuttle.Esb.OnDispatchTransportMessage' in stage 'Send' for observer 'Shuttle.Esb.DispatchTransportMessageObserver'. / Exception has been thrown by the target of an invocation. / Network access for Distributed Transaction Manager (MSDTC) has been disabled. Please enable DTC for network access in the security configuration for MSDTC using the Component Services Administrative tool. / The transaction manager has disabled its support for remote/network transactions. (Exception from HRESULT: 0x8004D024)
24.08.2016 10:01:09:53080 69 Error Shuttle.Core.Infrastructure.PipelineException: Raising pipeline event 'Shuttle.Esb.OnDispatchTransportMessage' in stage 'Send' for observer 'Shuttle.Esb.DispatchTransportMessageObserver'. ---> System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. ---> System.Transactions.TransactionManagerCommunicationException: Network access for Distributed Transaction Manager (MSDTC) has been disabled. Please enable DTC for network access in the security configuration for MSDTC using the Component Services Administrative tool. ---> System.Runtime.InteropServices.COMException: The transaction manager has disabled its support for remote/network transactions. (Exception from HRESULT:

Could you provide any advice here ? We would like to enlist shuttle publish in ambient transaction without promoting DTC since both our code and shuttle are using same database.

Currently IDatabaseContextCache.Get and IDatabaseContextCache.Contains uses a connection string to find the relevant context. This is somewhat conter-intuituve so for v11.0.0 it will be changed to use the name.

New methods (GetConnectionString and ContainsConnectionString) will be used to retrieve the relevant context using the connection string.

The query mapper can use a generic row mapper that does the actual mapping. Thw row mapper can be used when dealing with rows only.