🐛 增加SqlSugar 使用SQLite 在Quartz锁库测试

anjoy8 · Jun 12, 2024 · f400a43 · f400a43
1 parent 35290f5
commit f400a43
Show file tree

Hide file tree

Showing 9 changed files with 205 additions and 35 deletions.
diff --git a/Blog.Core.Api/Blog.Core.xml b/Blog.Core.Api/Blog.Core.xml
diff --git a/Blog.Core.Api/appsettings.json b/Blog.Core.Api/appsettings.json
@@ -118,7 +118,7 @@
     {
       "ConnId": "Main2",
       "DBType": 2,
-      "Enabled": true,
+      "Enabled": false,
       "Connection": "WMBlog3.db", //sqlite只写数据库名就行
       "Slaves": [
         {
@@ -265,7 +265,7 @@
       "Enabled": false
     },
     "IpRateLimit": {
-      "Enabled": true
+      "Enabled": false
     },
     "EncryptionResponse": {
       "Enabled": true,

diff --git a/Blog.Core.Api/wwwroot/BlogCore.Data.json/TasksQz.tsv b/Blog.Core.Api/wwwroot/BlogCore.Data.json/TasksQz.tsv
@@ -3,7 +3,7 @@
     "Name": "博客管理",
     "JobGroup": "博客测试组",
     "TriggerType": 1,
-    "Cron": "0 */5 * * * ?",
+    "Cron": "0 */1 * * * ?",
     "AssemblyName": "Blog.Core.Tasks",
     "ClassName": "Job_Blogs_Quartz",
     "Remark": "",

diff --git a/Blog.Core.IServices/IGuestbookServices.cs b/Blog.Core.IServices/IGuestbookServices.cs
@@ -15,5 +15,7 @@ public partial interface IGuestbookServices : IBaseServices<Guestbook>
         Task<bool> TestTranPropagationNoTran();
 
         Task<bool> TestTranPropagationTran();
+        Task TestTranPropagationTran2();
+        Task TestTranPropagationTran3();
     }
 }
diff --git a/Blog.Core.IServices/IPasswordLibServices.cs b/Blog.Core.IServices/IPasswordLibServices.cs
@@ -9,5 +9,6 @@ public partial interface IPasswordLibServices :IBaseServices<PasswordLib>
         Task<bool> TestTranPropagation2();
         Task<bool> TestTranPropagationNoTranError();
         Task<bool> TestTranPropagationTran2();
+        Task<bool> TestTranPropagationTran3();
     }
 }
diff --git a/Blog.Core.Repository/UnitOfWorks/UnitOfWorkManage.cs b/Blog.Core.Repository/UnitOfWorks/UnitOfWorkManage.cs
@@ -51,21 +51,25 @@ public UnitOfWork CreateUnitOfWork()
 
         public void BeginTran()
         {
+            Console.WriteLine("Begin Transaction Before:" + GetDbClient().ContextID);
             lock (this)
             {
                 _tranCount++;
                 GetDbClient().BeginTran();
             }
+            Console.WriteLine("Begin Transaction After:" + GetDbClient().ContextID);
         }
 
         public void BeginTran(MethodInfo method)
         {
+            Console.WriteLine("Begin Transaction Before:" + GetDbClient().ContextID);
             lock (this)
             {
                 GetDbClient().BeginTran();
                 TranStack.Push(method.GetFullName());
                 _tranCount = TranStack.Count;
             }
+            Console.WriteLine("Begin Transaction After:" + GetDbClient().ContextID);
         }
 
         public void CommitTran()

diff --git a/Blog.Core.Services/GuestbookServices.cs b/Blog.Core.Services/GuestbookServices.cs
@@ -8,21 +8,25 @@
 using System.Threading.Tasks;
 using Blog.Core.Common.DB;
 using Blog.Core.Repository.UnitOfWorks;
+using SqlSugar;
 
 namespace Blog.Core.Services
 {
     public class GuestbookServices : BaseServices<Guestbook>, IGuestbookServices
     {
         private readonly IUnitOfWorkManage _unitOfWorkManage;
         private readonly IBaseRepository<PasswordLib> _passwordLibRepository;
-
         private readonly IPasswordLibServices _passwordLibServices;
+        private readonly ISqlSugarClient _db;
+        private SqlSugarScope db => _db as SqlSugarScope;
 
-        public GuestbookServices(IUnitOfWorkManage unitOfWorkManage, IBaseRepository<Guestbook> dal, IBaseRepository<PasswordLib> passwordLibRepository, IPasswordLibServices passwordLibServices)
+        public GuestbookServices(IUnitOfWorkManage unitOfWorkManage, IBaseRepository<Guestbook> dal,
+            IBaseRepository<PasswordLib> passwordLibRepository, IPasswordLibServices passwordLibServices, ISqlSugarClient db)
         {
             _unitOfWorkManage = unitOfWorkManage;
             _passwordLibRepository = passwordLibRepository;
             _passwordLibServices = passwordLibServices;
+            _db = db;
         }
 
         public async Task<MessageModel<string>> TestTranInRepository()
@@ -193,8 +197,9 @@ public async Task<bool> TestTranPropagationNoTran()
         public async Task<bool> TestTranPropagationTran()
         {
             var guestbooks = await base.Query();
+            guestbooks = await base.Query();
             Console.WriteLine($"first time : the count of guestbooks is :{guestbooks.Count}");
-
+            Console.WriteLine(base.Db.ContextID);
             var insertGuestbook = await base.Add(new Guestbook()
             {
                 username = "bbb",
@@ -207,5 +212,68 @@ public async Task<bool> TestTranPropagationTran()
 
             return true;
         }
+
+        [UseTran(Propagation = Propagation.Required)]
+        public async Task TestTranPropagationTran2()
+        {
+            await Db.Insertable(new Guestbook()
+            {
+                username = "bbb",
+                blogId = 1,
+                createdate = DateTime.Now,
+                isshow = true
+            }).ExecuteReturnSnowflakeIdAsync();
+
+
+            await Db.Insertable(new PasswordLib()
+            {
+                PLID = SnowFlakeSingle.Instance.NextId(),
+                IsDeleted = false,
+                plAccountName = "aaa",
+                plCreateTime = DateTime.Now
+            }).ExecuteReturnSnowflakeIdAsync();
+
+            await _passwordLibServices.TestTranPropagationTran2();
+
+            Console.WriteLine("完成");
+        }
+
+        public async Task TestTranPropagationTran3()
+        {
+            try
+            {
+                Console.WriteLine("Begin Transaction Before:" + db.ContextID);
+                db.BeginTran();
+                Console.WriteLine("Begin Transaction After:" + db.ContextID);
+
+                await db.Insertable(new Guestbook()
+                {
+                    username = "bbb",
+                    blogId = 1,
+                    createdate = DateTime.Now,
+                    isshow = true
+                }).ExecuteReturnSnowflakeIdAsync();
+
+
+                await db.Insertable(new PasswordLib()
+                {
+                    PLID = SnowFlakeSingle.Instance.NextId(),
+                    IsDeleted = false,
+                    plAccountName = "aaa",
+                    plCreateTime = DateTime.Now
+                }).ExecuteReturnSnowflakeIdAsync();
+
+                await _passwordLibServices.TestTranPropagationTran3();
+
+                db.CommitTran();
+                Console.WriteLine("完成");
+            }
+            catch (Exception e)
+            {
+                db.RollbackTran();
+                throw;
+            }
+
+        }
     }
 }
diff --git a/Blog.Core.Services/PasswordLibServices.cs b/Blog.Core.Services/PasswordLibServices.cs
@@ -5,17 +5,24 @@
 using Blog.Core.IRepository.Base;
 using Blog.Core.IServices;
 using Blog.Core.Model.Models;
+using Blog.Core.Repository.UnitOfWorks;
 using Blog.Core.Services.BASE;
+using SqlSugar;
 
 namespace Blog.Core.Services
 {
     public partial class PasswordLibServices : BaseServices<PasswordLib>, IPasswordLibServices
     {
         IBaseRepository<PasswordLib> _dal;
+        private readonly IUnitOfWorkManage _unitOfWorkManage;
+        private readonly ISqlSugarClient _db;
+        private SqlSugarScope db => _db as SqlSugarScope;
 
-        public PasswordLibServices(IBaseRepository<PasswordLib> dal)
+        public PasswordLibServices(IBaseRepository<PasswordLib> dal, IUnitOfWorkManage unitOfWorkManage, ISqlSugarClient db)
         {
             this._dal = dal;
+            _unitOfWorkManage = unitOfWorkManage;
+            _db = db;
             base.BaseDal = dal;
         }
 
@@ -24,6 +31,7 @@ public async Task<bool> TestTranPropagation2()
         {
             await _dal.Add(new PasswordLib()
             {
+                PLID = SnowFlakeSingle.Instance.NextId(),
                 IsDeleted = false,
                 plAccountName = "aaa",
                 plCreateTime = DateTime.Now
@@ -48,13 +56,33 @@ await _dal.Add(new PasswordLib()
         [UseTran(Propagation = Propagation.Nested)]
         public async Task<bool> TestTranPropagationTran2()
         {
-            await _dal.Add(new PasswordLib()
+            await db.Insertable(new PasswordLib()
             {
+                PLID = SnowFlakeSingle.Instance.NextId(),
                 IsDeleted = false,
                 plAccountName = "aaa",
                 plCreateTime = DateTime.Now
-            });
+            }).ExecuteReturnSnowflakeIdAsync();
+
+            throw new Exception("123");
+            return true;
+        }
+
+        public async Task<bool> TestTranPropagationTran3()
+        {
+            Console.WriteLine("Begin Transaction Before:" + db.ContextID);
+            db.BeginTran();
+            Console.WriteLine("Begin Transaction After:" + db.ContextID);
+            Console.WriteLine("");
+            await db.Insertable(new PasswordLib()
+            {
+                PLID = SnowFlakeSingle.Instance.NextId(),
+                IsDeleted = false,
+                plAccountName = "aaa",
+                plCreateTime = DateTime.Now
+            }).ExecuteReturnSnowflakeIdAsync();
 
+            throw new Exception("123");
             return true;
         }
     }