SmartSql使用教程（3）——SmartSql中的事務，及AOP的使用

一、引言

　　經過兩章的鋪墊，我們現在對SmartSql已經有了一定的了解，那么今天我們的主題是事務處理。事務處理是常用的一種特性，而SmartSql至少提供了兩種使用事務的方法。一種是通過Repository（動態倉儲）或者ITransaction的常規調用，一種是基於AOP提醒的動態代理方式。接下來我們一個個說。

　　

　　上圖是這一章的項目結構，這次的結構略微有點復雜，我一一解釋。

　　項目結構分為3個部分，Api部分分成了3個.NetCore MVC項目，三個項目分別是常規調用；基於.NetCore原生DI的AOP調用；基於Autofac的AOP調用，AOP部分的區別只是在DI的配置部分。

　　DomainService也就是業務邏輯層，這個沒什么好說的。

　　Data Access部分是實體與動態倉儲，而在這一章中。我們的動態倉儲項目有一個小的變動。先放圖

　　

　　通過圖片可以看到，原來我們放在Api項目中的Map和Config都放到了動態倉儲的項目。這個因為在當前項目中，我們有3個輸出項目。如果每個項目中都寫一套Maps就顯得很多此一舉。所以把它們統一的放到倉儲類庫里來，是一個很好的辦法（虎哥提供）。注：別忘記把文件設置成始終復制哦

 

二、 常規使用

　　用法寫在上面忽略了的DomainService中

using System;
using SmartSql.DbSession;
using SmartSqlSampleChapterThree.Entity;
using SmartSqlSampleChapterThree.Repository;

namespace SmartSqlSampleChapterThree.DomainService
{
    public class NormalUserDomainService : IUserDomainService
    {
        private const string DEFAULT_AVATAR = "https://smartsql.net/logo.png";

        private readonly IUserRepository _userRepository;
        private readonly IUserDetailRepository _userDetailRepository;
        private readonly ITransaction _transaction;

        public NormalUserDomainService(IUserRepository userRepository, IUserDetailRepository userDetailRepository, ITransaction transaction)
        {
            _userRepository = userRepository;
            _userDetailRepository = userDetailRepository;
            _transaction = transaction;
        }
        
        public User Register(string loginName, string password, string nickname)
        {
            try
            {
                _transaction.BeginTransaction();
                var user = new User
                {
                    LoginName = loginName,
                    Password = password,
                    Status = 1,
                    CreateTime = DateTime.Now,
                    ModifiedTime = DateTime.Now
                };

                user.Id = _userRepository.Insert(user);

                _userDetailRepository.Insert(new UserDetail
                {
                    UserId = user.Id,
                    Nickname = nickname,
                    Avatar = DEFAULT_AVATAR,
                    Sex = null,
                    CreateTime = DateTime.Now,
                    ModifiedTime = DateTime.Now
                });

                _transaction.CommitTransaction();
                return user;
            }
            catch
            {
                _transaction.RollbackTransaction();
                throw;
            }
        }
        
        // use transaction on repository's sql mapper
        public User RegisterUseRepository(string loginName, string password, string nickname)
        {
            try
            {
                _userRepository.SqlMapper.BeginTransaction();
        
                var user = new User
                {
                    LoginName = loginName,
                    Password = password,
                    Status = 1,
                    CreateTime = DateTime.Now,
                    ModifiedTime = DateTime.Now
                };
        
                user.Id = _userRepository.Insert(user);
        
                _userDetailRepository.Insert(new UserDetail
                {
                    UserId = user.Id,
                    Nickname = nickname,
                    Avatar = DEFAULT_AVATAR,
                    Sex = null,
                    CreateTime = DateTime.Now,
                    ModifiedTime = DateTime.Now
                });
        
                _userRepository.SqlMapper.CommitTransaction();
                return user;
            }
            catch
            {
                _userRepository.SqlMapper.RollbackTransaction();
                throw;
            }
        }
    }
}

　　在這個類中，我實現了兩次事務調用。在第一個方法中我們使用ITransaction接口提供的方法，調用了Begin-Commit-Rollback的事務過程。

　　第二個方法中，我直接使用了Repository.SqlMap.BeginTransaction()，這是因為IRepository包含了一個ISqlMap，而ISqlMap同時繼承了ITransaction。所以本質上這兩種方式是等價的。

 

三、AOP

1. Nuget依賴

　　SmartSql有一個獨立的Nuget包來支持AOP實現。名字就叫“SmartSql.AOP”

2. DomainService

　　使用了AOP后，我們的業務代碼就可以干凈很多。只需要在方法前加上[Transaction]特性就可以了。只要方法體中拋出異常，事務即會回滾。另外需要注意的地方是，AOP方法是需要用上virtual虛方法標識的。

        [Transaction]
        public virtual User Register(string loginName, string password, string nickname) 
　　　　 { 　　
　　　　　　 var user = new User { LoginName = loginName, Password = password, Status = 1, CreateTime = DateTime.Now, ModifiedTime = DateTime.Now };
　　　　　　 user.Id = _userRepository.Insert(user);
　　　　　　 _userDetailRepository.Insert(new UserDetail { UserId = user.Id, Nickname = nickname, Avatar = DEFAULT_AVATAR, Sex = null, CreateTime = DateTime.Now, ModifiedTime = DateTime.Now });
　　　　　　 return user;
　　　　 }

3. 原生配置

　　在Startup中稍稍修改一下ConfigureServices即可。

        public IServiceProvider ConfigureServices(IServiceCollection services)
        {
            services.AddMvc();

            /// 服務注冊 Begin

            /// 服務注冊 End

            return services.BuildAspectInjectorProvider();
        }

　　看一下上面代碼你會發現，只需要為ConfigureServices方法加一個IServiceProvider返回值。並在方法最后加一句return就可以了。

 

4. Autofac配置

　　在Autofac中與原生相比，略微有一些不同。

        public IServiceProvider ConfigureServices(IServiceCollection services)
        {  
            services.AddMvc();

            /// 服務注冊 Begin

            /// 服務注冊 End
            
            // autofac
            var builder = new ContainerBuilder();

            builder.RegisterDynamicProxy(config =>
            {
                config.Interceptors
                      .AddTyped<TransactionAttribute>(Predicates.ForNameSpace("SmartSqlSampleChapterThree.DomainService"));
            });
            builder.Populate(services);

            var container = builder.Build();
            return new AutofacServiceProvider(container);
        }

　　我在項目中很少使用Autofac，所以對它的特性也不是很了解。只是按照文檔做了最簡單的實現，這里還要特別感謝交流群的小伙伴（QQ群號：604762592）。是群里的一個小伙伴在使用Autofac的時候分享了他的使用方式。

　　這里在原生的基礎上，創建一個Autofac容器構建器，並在構建器中注冊一個動態代理。然后在攔截器中加上TransactionAttribute就可以了。

 

三、結語

　　以上就是SmartSql中事務處理的一些方法，希望可以幫助到你。

 

示例代碼鏈接在這里

　　

下期預告：TypeHandler類型處理器使用講解 And 如何自定義TypeHandler