Update sample

Author: yang-xiaodong

samples/Sample.RabbitMQ.MySql/AppDbContext.cs

@@ -0,0 +1,29 @@
+using Microsoft.EntityFrameworkCore;
+
+namespace Sample.RabbitMQ.MySql
+{
+    public class Person
+    {
+        public int Id { get; set; }
+
+        public string Name { get; set; }
+
+        public int Age { get; set; }
+
+        public override string ToString()
+        {
+            return $"Name:{Name}, Age:{Age}";
+        }
+    }
+
+    public class AppDbContext : DbContext
+    {
+        public const string ConnectionString = "Server=127.0.0.1;Database=cap;Uid=root;Pwd=my-secret-pw;";
+        public DbSet<Person> Persons { get; set; }
+
+        protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
+        {
+            optionsBuilder.UseMySql(ConnectionString, ServerVersion.AutoDetect(ConnectionString));
+        }
+    }
+}

samples/Sample.RabbitMQ.MySql/Controllers/ValuesController.cs

@@ -52,7 +52,7 @@ public async Task<IActionResult> Delay(int delaySeconds)
         [Route("~/adonet/transaction")]
         public async Task<IActionResult> AdonetWithTransaction()
         {
-            using (var connection = new MySqlConnection(Startup.ConnectionString))
+            using (var connection = new MySqlConnection(AppDbContext.ConnectionString))
             {
                 using var transaction = await connection.BeginTransactionAsync(_capBus, true);
                 await connection.ExecuteAsync("insert into test(name) values('test')", transaction: (IDbTransaction)transaction.DbTransaction);
@@ -62,18 +62,18 @@ public async Task<IActionResult> AdonetWithTransaction()
             return Ok();
         }
 
-        //[Route("~/ef/transaction")]
-        //public async Task<IActionResult> EntityFrameworkWithTransaction([FromServices] AppDbContext dbContext)
-        //{
-        //    using (var trans = await dbContext.Database.BeginTransactionAsync(_capBus, autoCommit: false))
-        //    {
-        //        await dbContext.Persons.AddAsync(new Person() { Name = "ef.transaction" });
-        //        await _capBus.PublishAsync("sample.rabbitmq.mysql", DateTime.Now);
-        //        await dbContext.SaveChangesAsync();
-        //        await trans.CommitAsync();
-        //    }
-        //    return Ok();
-        //}
+        [Route("~/ef/transaction")]
+        public async Task<IActionResult> EntityFrameworkWithTransaction([FromServices] AppDbContext dbContext)
+        {
+            using (var trans = await dbContext.Database.BeginTransactionAsync(_capBus, autoCommit: false))
+            {
+                await dbContext.Persons.AddAsync(new Person() { Name = "ef.transaction" });
+                await _capBus.PublishAsync("sample.rabbitmq.mysql", DateTime.Now);
+                await dbContext.SaveChangesAsync();
+                await trans.CommitAsync();
+            }
+            return Ok();
+        }
 
         [NonAction]
         [CapSubscribe("sample.rabbitmq.mysql")]

samples/Sample.RabbitMQ.MySql/Sample.RabbitMQ.MySql.csproj

@@ -7,6 +7,7 @@
   <ItemGroup>
     <PackageReference Include="Dapper" Version="2.0.138" />
     <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="8.0.0" />
+    <PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="8.0.3" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" /> 
   </ItemGroup>
   <ItemGroup>

samples/Sample.RabbitMQ.MySql/Startup.cs

@@ -5,13 +5,13 @@ namespace Sample.RabbitMQ.MySql
 {
     public class Startup
     {
-        public const string ConnectionString = "";
-
         public void ConfigureServices(IServiceCollection services)
         {
+            services.AddDbContext<AppDbContext>();
+
             services.AddCap(x =>
             {
-                x.UseMySql(ConnectionString);
+                x.UseEntityFramework<AppDbContext>();
                 x.UseRabbitMQ("localhost");
                 x.UseDashboard();
             });

samples/Sample.RabbitMQ.MySql/appsettings.json

@@ -1,8 +1,8 @@
 {
   "Logging": {
     "LogLevel": {
-      "Default": "None",
-      //"DotNetCore.CAP": "Debug",
+      "Default": "Information",
+      "DotNetCore.CAP": "Debug",
       "Microsoft.AspNetCore.Hosting.Diagnostics": "Warning",
       "Microsoft.AspNetCore.Routing": "Warning"
     }