Dapper UOW+事物AOP

本文实现Dapper操作数据统一提交和事物的AOP操作

1、新建个core项目

2、添加DbSession类

using System;
using System.Data;
using System.Data.Common;namespace DapperUowTests.Data
{public sealed class DbSession : IDisposable{public IDbConnection Connection { get; }public IDbTransaction Transaction { get; set; }public DbSession(DbConnection connection){Connection = connection;Connection.Open();}public void Dispose() => Connection?.Dispose();}
}

2、添加IUnitOfWork接口

using System;namespace DapperUowTests.Data
{public interface IUnitOfWork : IDisposable{void BeginTransaction();void Commit();void Rollback();}
}

3、实现接口UnitOfWork

using System.ComponentModel.Composition;
using System.Data;namespace DapperUowTests.Data
{public sealed class UnitOfWork : IUnitOfWork{private readonly DbSession _session;public UnitOfWork(DbSession session){_session = session;}public void BeginTransaction(){_session.Transaction = _session.Connection.BeginTransaction();}public void Commit(){_session.Transaction.Commit();Dispose();}public void Rollback(){_session.Transaction.Rollback();Dispose();}public void Dispose() => _session.Transaction?.Dispose();}
}

4、添加数据操作类NotificationRepository

using System;
using System.Collections.Generic;
using Dapper;namespace DapperUowTests.Data
{public class NotificationRepository{private DbSession _session;public NotificationRepository(DbSession session){_session = session;}public IEnumerable<NotificationModel> Get(){return _session.Connection.Query<NotificationModel>("SELECT * FROM [Notifications]", null, _session.Transaction);}public void Save(NotificationModel model){_session.Connection.Execute("INSERT INTO [Notifications] VALUES(NEWID(), 'Title', 'URL', GETDATE())", null, _session.Transaction);}}public class NotificationModel{public Guid Id { get; set; }public string Title { get; set; }public string Url { get; set; }public DateTime Date { get; set; }}
}

5、Startup添加以上注入

services.AddScoped<DbConnection>(provider =>{return new System.Data.SqlClient.SqlConnection("Data Source=.;Initial Catalog=dbTest;UID=sa;PWD=123456;MultipleActiveResultSets=True");});
services.AddScoped<DbSession>();
services.AddTransient<IUnitOfWork, UnitOfWork>();
services.AddTransient<NotificationRepository>();

6、添加事物AOP TransactionsAttribute，这里是用的PostSharp做的一个AOP实现，他的底层是IL写的，这是他的官方文档PostSharp Documentation - PostSharp 6.10 Documentation

/// <summary>/// 事物AOP/// </summary>[PSerializable][ProvideAspectRole(StandardRoles.TransactionHandling)][AspectRoleDependency(AspectDependencyAction.Order, AspectDependencyPosition.After, StandardRoles.Caching)]public class TransactionsAttribute : MethodInterceptionAspect{public override void OnInvoke(MethodInterceptionArgs args){if (args.Instance is ControllerBase cb){var unitOfWorkService = cb.HttpContext.RequestServices.GetService(typeof(IUnitOfWork)) as IUnitOfWork;//必须要用当前的作用域进行手动的获取注入接口，因为我上面的DbSession是Scoped的注入方式unitOfWorkService.BeginTransaction();base.OnInvoke(args);unitOfWorkService.Commit();}}}

6、添加HomeController

    [ApiController][Route("")]public class HomeController : ControllerBase{[HttpGet("")]public IEnumerable<NotificationModel> Get([FromServices] NotificationRepository repository){return repository.Get();}[HttpPost("")][Transactions]//这里保存运用事物操作public IActionResult Post([FromServices] NotificationRepository repository){repository.Save(new NotificationModel{Date = DateTime.Now,Id = Guid.NewGuid(),Title = "Teste",Url = "Teste"});return Ok();}}

数据库表结构

CREATE TABLE [dbo].[Notifications] ([Id] uniqueidentifier  NOT NULL,[Title] varchar(255) COLLATE Chinese_PRC_CI_AS  NULL,[Url] varchar(255) COLLATE Chinese_PRC_CI_AS  NULL,[Date] datetime  NULL
)

Dapper UOW+事物AOP相关推荐

Spring aop切面插入事物回滚
 <tx:advice id="txadvice" transaction-manager="transactionM ...
Spring AOP 的底层实现
实例代码 demo code 创建一个配置类去扫描包,开启 AspectJ 的自动代理支持 @Configuration @EnableAspectJAutoProxy @ComponentScan( ...
Springboot集成Shiro+Redis后，@Transactional注解不起作用
为什么80%的码农都做不了架构师?>>> 使用Springboot构建 mybatis+Shiro+Redis+Druid 的前后端分离web项目, 具体可以参考博客https ...
SpringBoot-AOP切面处理
2019独角兽企业重金招聘Python工程师标准>>> 应用Spring的过程中,最大最核心的必须要数AOP啦,比如,向同一水平面上的相同业务操作,我们就可以使用AOP来完成,快速方 ...
myeclipse搭建SSH框架
搭建SSH框架 Struts+hibernater+spring架构(myeclipse) 右击,首先加入spring,加入hibernater,再加入struts2 复制jar包(把tomcat发布 ...
java 数据源调用_实战分享: Spring boot 调用之间实现动态数据源
需求: 根据项目部署在不同的域名,在同一套系统下,分别访问不同的数据库 (当然在看别人帖子的时候,也发现了不同接口访问不同数据源问题,就是分库动态数据源需求了,其实实现都一样) 业务描述: 部署的时候 ...
SpringCloud学习笔记027---SpringBoot集成MyBatis_实现多数据源_可以自定义数据库类型
JAVA技术交流QQ群:170933152 1.可以静态配置数据库 2.也可以动态切换数据库项目提交测试,趁着中当间的这个空档期,把springboot的多数据源配置学习一下,总体来说多数据源配置有 ...
去年12月份挑错经验总结
接手别人做了一半的项目时,由于不了解会犯个种问题,以下12月份个人出bug及学习总结的情况,高手见笑了 IFrame部分: Iframe标记的使用格式是: <Iframe src="U ...
Sping的基础知识总结（01）
配置文件 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://w ...

Dapper UOW+事物AOP

Dapper UOW+事物AOP相关推荐

最新文章

热门文章