Update samples

Author: yang-xiaodong

samples/Sample.Kafka.PostgreSql/Controllers/ValuesController.cs

@@ -4,6 +4,7 @@
 using Dapper;
 using DotNetCore.CAP;
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore;
 using Npgsql;
 
 namespace Sample.Kafka.PostgreSql.Controllers
@@ -24,7 +25,7 @@ public async Task<IActionResult> Stop([FromServices] IBootstrapper bootstrapper)
             await bootstrapper.DisposeAsync();
             return Ok();
         }
-         
+
 
         [Route("~/delay/{delaySeconds:int}")]
         public async Task<IActionResult> Delay(int delaySeconds)
@@ -64,6 +65,22 @@ public IActionResult AdonetWithTransaction()
             return Ok();
         }
 
+        [Route("~/ef/transaction")]
+        public IActionResult EntityFrameworkWithTransaction([FromServices] AppDbContext dbContext)
+        {
+            using (dbContext.Database.BeginTransaction(producer, false))
+            {
+                dbContext.Persons.Add(new Person() { Name = "ef.transaction", Age = 11 });
+
+                dbContext.SaveChanges();
+
+                producer.Publish("sample.kafka.postgrsql", DateTime.UtcNow);
+
+                dbContext.Database.CommitTransaction();
+            }
+            return Ok();
+        }
+
 
         [CapSubscribe("sample.kafka.postgrsql")]
         public void Test2(DateTime value)

samples/Sample.Kafka.PostgreSql/Sample.Kafka.PostgreSql.csproj

@@ -8,6 +8,7 @@
 
   <ItemGroup>
     <PackageReference Include="Dapper" Version="2.0.138" />
+    <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="8.0.11" />
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\..\src\DotNetCore.CAP.Dashboard\DotNetCore.CAP.Dashboard.csproj" />

samples/Sample.Kafka.PostgreSql/Startup.cs

@@ -1,4 +1,6 @@
 using Microsoft.AspNetCore.Builder;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Storage;
 using Microsoft.Extensions.DependencyInjection;
 
 namespace Sample.Kafka.PostgreSql
@@ -9,8 +11,15 @@ public class Startup
 
         public void ConfigureServices(IServiceCollection services)
         {
+            services.AddDbContext<AppDbContext>((sp, opt) =>
+            {
+                opt.UseNpgsql(DbConnectionString)
+                 .ReplaceService<IRelationalConnection, CapNpgsqlRelationalConnection>();
+            });
+
             services.AddCap(x =>
             {
+                //x.UseEntityFramework<AppDbContext>();
                 //docker run --name postgres -p 5432:5432 -e POSTGRES_PASSWORD=mysecretpassword -d postgres
                 x.UsePostgreSql(DbConnectionString);