Merge pull request #7582 from Particular/sqltransport-sqlpersistence-v10

Update sqltransport-sqlpersistence sample to v10

Author: WilliamBZA

samples/sqltransport-sqlpersistence/Core_10/Receiver/Dapper/OrderSubmittedHandler.cs

@@ -0,0 +1,33 @@
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+namespace Dapper
+{
+    public class OrderSubmittedHandler(ILogger<OrderSubmittedHandler> logger) :
+        IHandleMessages<OrderSubmitted>
+    {
+        public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+        {
+            logger.LogInformation("Order {OrderId} worth {Value} persisted by Dapper", message.OrderId, message.Value);
+
+            #region StoreDataDapper
+
+            var session = context.SynchronizedStorageSession.SqlPersistenceSession();
+
+            var order = new SubmittedOrder
+            {
+                Id = $"Dapper-{message.OrderId}",
+                Value = message.Value,
+            };
+
+            var sql = @"insert into receiver.SubmittedOrder
+                                    (Id, Value)
+                        values      (@Id, @Value)";
+            return session.Connection.ExecuteAsync(sql: sql,
+                param: order,
+                transaction: session.Transaction);
+
+            #endregion
+        }
+    }
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/Dapper/SubmittedOrder.cs

@@ -0,0 +1,12 @@
+namespace Dapper
+{
+    #region SubmittedOrderDapper
+
+    public class SubmittedOrder
+    {
+        public string Id { get; set; }
+        public int Value { get; set; }
+    }
+
+    #endregion
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/EntityFramework/OrderSubmittedHandler.cs

@@ -0,0 +1,37 @@
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+namespace EntityFramework
+{
+    public class OrderSubmittedHandler(ILogger<OrderSubmittedHandler> logger) :
+        IHandleMessages<OrderSubmitted>
+    {
+        public async Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+        {
+            logger.LogInformation("Order {OrderId} worth {Value} persisted by EF", message.OrderId, message.Value);
+
+            #region StoreDataEf
+
+            var session = context.SynchronizedStorageSession.SqlPersistenceSession();
+
+            var order = new SubmittedOrder
+            {
+                Id = $"EF-{message.OrderId}",
+                Value = message.Value,
+            };
+
+            using (var dbContext = new SubmittedOrderDbContext(session.Connection))
+            {
+                dbContext.Database.UseTransaction(session.Transaction);
+
+                await dbContext.SubmittedOrder.AddAsync(order, context.CancellationToken);
+
+                await dbContext.SaveChangesAsync(context.CancellationToken);
+            }
+
+            #endregion
+        }
+    }
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/EntityFramework/SubmittedOrder.cs

@@ -0,0 +1,15 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace EntityFramework
+{
+    #region SubmittedOrderEF
+
+    [Table("SubmittedOrder", Schema = "receiver")]
+    public class SubmittedOrder
+    {
+        public string Id { get; set; }
+        public int Value { get; set; }
+    }
+
+    #endregion
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/EntityFramework/SubmittedOrderDbContext.cs

@@ -0,0 +1,26 @@
+using System.Data.Common;
+using Microsoft.EntityFrameworkCore;
+
+namespace EntityFramework
+{
+    #region SubmittedOrderDbContext
+
+    public class SubmittedOrderDbContext : DbContext
+    {
+        DbConnection connection;
+
+        public DbSet<SubmittedOrder> SubmittedOrder { get; set; }
+
+        public SubmittedOrderDbContext(DbConnection connection)
+        {
+            this.connection = connection;
+        }
+
+        protected override void OnConfiguring(DbContextOptionsBuilder options)
+        {
+            options.UseSqlServer(connection);
+        }
+    }
+
+    #endregion
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/OrderLifecycleSaga.cs

@@ -0,0 +1,34 @@
+using System;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+public class OrderLifecycleSaga(ILogger<OrderLifecycleSaga> logger) :
+    Saga<OrderLifecycleSaga.SagaData>,
+    IAmStartedByMessages<OrderSubmitted>,
+    IHandleTimeouts<OrderTimeout>
+{
+    protected override void ConfigureHowToFindSaga(SagaPropertyMapper<SagaData> mapper)
+    {
+        mapper.MapSaga(saga => saga.OrderId)
+            .ToMessage<OrderSubmitted>(msg => msg.OrderId);
+    }
+
+    public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+    {
+        Data.OrderId = message.OrderId;
+        return RequestTimeout<OrderTimeout>(context, TimeSpan.FromSeconds(5));
+    }
+
+    public Task Timeout(OrderTimeout state, IMessageHandlerContext context)
+    {
+        logger.LogInformation("Got timeout");
+        return Task.CompletedTask;
+    }
+
+    public class SagaData :
+        ContainSagaData
+    {
+        public Guid OrderId { get; set; }
+    }
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/OrderSubmittedHandler.cs

@@ -0,0 +1,15 @@
+using System.Threading.Tasks;
+using NServiceBus;
+
+public class OrderSubmittedHandler :
+    IHandleMessages<OrderSubmitted>
+{
+    public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+    {
+        var orderAccepted = new OrderAccepted
+        {
+            OrderId = message.OrderId
+        };
+        return context.Reply(orderAccepted);
+    }
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/OrderTimeout.cs

@@ -0,0 +1,3 @@
+public class OrderTimeout
+{
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/OrmLite/OrderSubmittedHandler.cs

@@ -0,0 +1,39 @@
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+using ServiceStack.OrmLite;
+
+namespace OrmLite
+{
+
+    public class OrderSubmittedHandler(ILogger<OrderSubmittedHandler> logger) :
+        IHandleMessages<OrderSubmitted>
+    {
+        static OrderSubmittedHandler()
+        {
+            OrmLiteConfig.DialectProvider = SqlServer2016Dialect.Provider;
+        }
+
+        public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+        {
+            logger.LogInformation("Order {OrderId} worth {Value} persisted by OrmLite", message.OrderId, message.Value);
+
+            #region StoreDataOrmLite
+
+            var session = context.SynchronizedStorageSession.SqlPersistenceSession();
+
+            var order = new SubmittedOrder
+            {
+                Id = $"OrmLite-{message.OrderId}",
+                Value = message.Value,
+            };
+
+            return session.Connection.UpdateAsync(
+                obj: order,
+                commandFilter: command => command.Transaction = session.Transaction,
+                context.CancellationToken);
+
+            #endregion
+        }
+    }
+}

samples/sqltransport-sqlpersistence/Core_10/Receiver/OrmLite/SubmittedOrder.cs

@@ -0,0 +1,15 @@
+namespace OrmLite
+{
+    using ServiceStack.DataAnnotations;
+
+    #region SubmittedOrderOrmLite
+
+    [Schema("receiver")]
+    public class SubmittedOrder
+    {
+        public string Id { get; set; }
+        public int Value { get; set; }
+    }
+
+    #endregion
+}