EF Core3.0+ 通过拦截器实现读写分离与SQL日志记录

前言

本文主要是讲解EF Core3.0+ 通过拦截器实现读写分离与SQL日志记录

注意拦截器只有EF Core3.0+ 支持,2.1请考虑上下文工厂的形式实现.

说点题外话..

一晃又大半年没更新技术博客..唉,去年一年发生了太多事情..博主真的 一言难尽..

有兴趣的可以去看看:记录一下,也许是转折,也许是结束,也许是新希望的一年

 

正文

1.通过拦截器实现读写分离

先讲一下本文实现的方式吧

SQL 通过数据库本身的功能 实现主从备份 大概原理如图:

 

 

 

 

EF Core在查询的时候通过DbCommandInterceptor 拦截器(PS:这个功能在EF6.0+中也实现了)来拦截对数据库的访问,从而切换主从数据库

下面直接上代码吧

首先我们创建一个类 继承DbCommandInterceptor:

 public class DbMasterSlaveCommandInterceptor : DbCommandInterceptor

    {private string _masterConnectionString;private string _slaveConnectionString;public DbMasterSlaveCommandInterceptor(string masterConnectionString, string slaveConnectionString){_masterConnectionString = masterConnectionString;_slaveConnectionString = slaveConnectionString;}
}

通过构造函数传递主库连接地址与从库地址(可有多个 通过"|"分割)

添加一个随机分配从表读取连接的方法(PS:这里只是demo所以很简陋的随机,如果正式要用,应包含权重判断,定时心跳从库连接情况,请自行修改):

 　　　　/// <summary>

        /// 通过随机数分配获取多个从库/// </summary>/// <returns></returns>private string GetSlaveConnectionString(){var readArr = _slaveConnectionString.Split(new char[] { '|' }, StringSplitOptions.RemoveEmptyEntries);var resultConn = string.Empty;if (readArr != null && readArr.Any()){resultConn = readArr[Convert.ToInt32(Math.Floor((double)new Random().Next(0, readArr.Length)))];}return resultConn;}

添加判断是否主从操作连接方法:

        private void UpdateToSlave(DbCommand command)

        {//判断是否配置了主从分离if (!string.IsNullOrWhiteSpace(GetSlaveConnectionString()))//如果配置了读写分离，就进入判断{//判断是否为插入语句(EF 插入语句会通过Reader执行并查询主键),否则进入if (command.CommandText.ToLower().StartsWith("insert", StringComparison.InvariantCultureIgnoreCase) == false){// 判断当前会话是否处于分布式事务中bool isDistributedTran = Transaction.Current != null &&Transaction.Current.TransactionInformation.Status !=TransactionStatus.Committed;//判断该 context 是否处于普通数据库事务中bool isDbTran = command.Transaction != null;//如果不处于事务中,则执行从服务器查询if (!isDbTran && !isDistributedTran){command.Connection.Close();command.Connection.ConnectionString = GetSlaveConnectionString();command.Connection.Open();}}}}

 

重载DbCommandInterceptor当中的拦截方法,代码如下:

        //如果是写入,则正常执行public override InterceptionResult<int> NonQueryExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<int> result){return base.NonQueryExecuting(command, eventData, result);}public override Task<InterceptionResult<int>> NonQueryExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<int> result, CancellationToken cancellationToken = default){return base.NonQueryExecutingAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<DbDataReader> ReaderExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result){this.UpdateToSlave(command);return base.ReaderExecuting(command, eventData, result);}public override Task<InterceptionResult<DbDataReader>> ReaderExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result, CancellationToken cancellationToken = default){this.UpdateToSlave(command);return base.ReaderExecutingAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<object> ScalarExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<object> result){this.UpdateToSlave(command);return base.ScalarExecuting(command, eventData, result);}public override Task<InterceptionResult<object>> ScalarExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<object> result, CancellationToken cancellationToken = default){this.UpdateToSlave(command);return base.ScalarExecutingAsync(command, eventData, result, cancellationToken);}

最后在EF core的上下文中注入拦截器(PS:我这里使用的Autofac模块注入):

                builder.Register(c =>{var optionsBuilder = new DbContextOptionsBuilder<TestEFContext>();//注入拦截器optionsBuilder.AddInterceptors(new DbMasterSlaveCommandInterceptor(WriteConnect, ReadConnect));//MaxBatchSize 处理批量操作BUGoptionsBuilder.UseMysql(WriteConnect, b=>b.MaxBatchSize(1));return optionsBuilder.Options;}).As<DbContextOptions<TestEFContex>>().SingleInstance();

这样就实现了通过拦截器实现读写分离.

 

2.通过拦截器实现SQL日志记录

同理,我们可以通过拦截器实现EF Core SQL语句的记录与调试

首先我们创建一个新的拦截器DBlogCommandInterceptor 如下:

public class DBlogCommandInterceptor : DbCommandInterceptor{//创建一个队列记录SQL执行时间static readonly ConcurrentDictionary<DbCommand, DateTime> MStartTime = new ConcurrentDictionary<DbCommand, DateTime>();private ILogger<DBlogCommandInterceptor> _logger { get; set; }//通过构造函数注入日志public DBlogCommandInterceptor(ILogger<DBlogCommandInterceptor> Logger){_logger = Logger;}
}

创建2个私有的方法,一个记录执行开始时间,一个记录SQL

　　　　　　//记录SQL开始执行的时间 private void OnStart(DbCommand command){MStartTime.TryAdd(command, DateTime.Now);}//通过_logger输出日志private void Log(DbCommand command){DateTime startTime;TimeSpan duration;//得到此command的开始时间MStartTime.TryRemove(command, out startTime);if (startTime != default(DateTime)){duration = DateTime.Now - startTime;}else{duration = TimeSpan.Zero;}var parameters = new StringBuilder();//循环获取执行语句的参数值foreach (DbParameter param in command.Parameters){parameters.AppendLine(param.ParameterName + " " + param.DbType + " = " + param.Value);}_logger.LogInformation("{starttime}开始执行SQL语句:{sql},参数:{canshu},执行时间{readtime}",startTime.ToString(), command.CommandText, parameters.ToString(), duration.TotalSeconds);}

最后重载拦截器的方法:

public override InterceptionResult<int> NonQueryExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<int> result){OnStart(command);return base.NonQueryExecuting(command, eventData, result);}public override Task<InterceptionResult<int>> NonQueryExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<int> result, CancellationToken cancellationToken = default){OnStart(command);return base.NonQueryExecutingAsync(command, eventData, result, cancellationToken);}public override int NonQueryExecuted(DbCommand command, CommandExecutedEventData eventData, int result){Log(command);return base.NonQueryExecuted(command, eventData, result);}public override Task<int> NonQueryExecutedAsync(DbCommand command, CommandExecutedEventData eventData, int result, CancellationToken cancellationToken = default){Log(command);return base.NonQueryExecutedAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<object> ScalarExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<object> result){OnStart(command);return base.ScalarExecuting(command, eventData, result);}public override Task<InterceptionResult<object>> ScalarExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<object> result, CancellationToken cancellationToken = default){OnStart(command);return base.ScalarExecutingAsync(command, eventData, result, cancellationToken);}public override object ScalarExecuted(DbCommand command, CommandExecutedEventData eventData, object result){Log(command);return base.ScalarExecuted(command, eventData, result);}public override Task<object> ScalarExecutedAsync(DbCommand command, CommandExecutedEventData eventData, object result, CancellationToken cancellationToken = default){Log(command);return base.ScalarExecutedAsync(command, eventData, result, cancellationToken);}public override InterceptionResult<DbDataReader> ReaderExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result){OnStart(command);return base.ReaderExecuting(command, eventData, result);}public override Task<InterceptionResult<DbDataReader>> ReaderExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result, CancellationToken cancellationToken = default){OnStart(command);return base.ReaderExecutingAsync(command, eventData, result, cancellationToken);}public override Task<DbDataReader> ReaderExecutedAsync(DbCommand command, CommandExecutedEventData eventData, DbDataReader result, CancellationToken cancellationToken = default){Log(command);return base.ReaderExecutedAsync(command, eventData, result, cancellationToken);}public override DbDataReader ReaderExecuted(DbCommand command, CommandExecutedEventData eventData, DbDataReader result){Log(command);return base.ReaderExecuted(command, eventData, result);}

这样,我们就实现了通过拦截器实现SQL日志记录~效果如下:

 

 调试SQL语句就方便了很多~

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/303894.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

oracle clob 查询换行,sqoop clob从Oracle导入到hive   回车换行导致记录增多

oracle clob 查询换行,sqoop clob从Oracle导入到hive   回车换行导致记录增多

sqoop clob从Oracle导入到hive 回车换行导致记录增多发布时间&#xff1a;2020-06-27 02:45:01来源&#xff1a;51CTO阅读&#xff1a;3159作者&#xff1a;jackwxhsqoop import --hive-import --hive-overwrite --connect jdbc:oracle:thin:192.168.92.136:1521:cyporcl --…
阅读更多...
对于scanf的使用一点体会心得

对于scanf的使用一点体会心得

今天非常的突发气象的在acm上面做了一下题目&#xff0c;悲剧的是多年不用c的人忘记了怎么样的使用scanf了&#xff0c;今天还学到了一点东西。 题目里面提示了输入两个数&#xff0c;规定第1&#xff5e;6列是第一个数的范围&#xff0c;第8&#xff5e;9列是第二个数的范围。…
阅读更多...
毕业二十年，为什么人和人之间的差距那么大？

毕业二十年，为什么人和人之间的差距那么大？

这是头哥侃码的第237篇原创最近天气逐渐转暖&#xff0c;身边的各种聚会也开始多了起来。找个周末&#xff0c;朋友之间喝点小酒&#xff0c;或者跟高中同学来一场久违的重逢&#xff0c;重温着曾经的回忆&#xff0c;加深着彼此之间的感情&#xff0c;想必都是不错的选择。什么…
阅读更多...
oracle查询案例,2道经典的oracle查询案例

oracle查询案例,2道经典的oracle查询案例

第一题&#xff1a;第一题&#xff1a;直接贴代码&#xff1a;select Id,Name,Money,(select Money from test1 a where a.Id decode(b.Id - 1,0,null,b.Id-1)) Money1 from test1 b;经典的子查询&#xff0c;注意的就是null值的处理问题&#xff0c;decode或者case是oracle很…
阅读更多...
乱

乱

在一起的时候很好&#xff0c;离开后就感觉像是路上的陌生人&#xff0c;没有交点的平行线&#xff0c;也许它们在很遥远的地方交汇了&#xff0c;也许是下辈子吧&#xff01; 你对我的好&#xff0c;我不是很清楚&#xff0c;你是伪装的&#xff0c;其实用的着那么辛苦吗&…
阅读更多...
oracle 12c 多线程,Oracle 12c(12.1)中性能优化功能增强之通过参数THREADED_EXECTION使用多线程模型...

oracle 12c 多线程,Oracle 12c(12.1)中性能优化功能增强之通过参数THREADED_EXECTION使用多线程模型...

1. 后台UNIX/Linux系统上&#xff0c;Oracle用多进程模型。例如&#xff1a;linux上一个常规安装的数据库会有如下进程列&#xff1a;$ ps -ef | grep [o]ra_oracle 15356 1 0 10:53 ? 00:00:00 ora_pmon_db12coracle 15358 1 0 10:53 ? 00:00:00 o…
阅读更多...
使用工作单元UnitOfWork实现事务

使用工作单元UnitOfWork实现事务

概述工作单元模式有如下几个特性&#xff1a;1、使用同一上下文2、跟踪实体的状态3、保障事务一致性。工作单元用来维护一个由已经被业务事物修改的业务对象组成的列表。Unit Of Work模式负责协调这些修改的持久化工作以及所有标记的并发问题。在数据访问层中采用Unit Of Work…
阅读更多...
MyEclipse配置Tomcat(图解)

MyEclipse配置Tomcat(图解)

1&#xff09; 安装完MyEclipse后&#xff0c;在Eclpise的菜单栏可看到MyEclipse一项&#xff0c; 下面的工具栏中可看到MyEclipse的Tomcat图标2&#xff09; 进行MyEclipse的配置&#xff0c; 从菜单栏中进入“Windows --> Preferences”3) 先要进行JDK的配置&#x…
阅读更多...
Python难懂？买一次西瓜就懂了！

Python难懂？买一次西瓜就懂了！

什么是code?code就就是一种语言&#xff0c;一种计算机能读懂的语言。计算机是一个傻*&#xff0c;他理解不了默认两可的任何东西。比如&#xff0c;你让你老公去买个西瓜&#xff0c;你老公会自己决定去哪里买&#xff0c;买几个&#xff0c;找个搞活动打折的买&#xff0c;总…
阅读更多...
制作oracle11g yum源,利用安装盘简单制作yum源

制作oracle11g yum源,利用安装盘简单制作yum源

第一步&#xff1a;创建一个新文件夹,并挂载光驱.[rootlocalhost ~]# mkdir /yum[rootlocalhost ~]# mount /dev/cdrom /mnt/cdrom第二步&#xff1a;安装工具包&#xff1a;[rootlocalhost ~]# rpm -ivh /mnt/cdrom/CentOS/createrepo-0.4.11-3.el5.noarch.rpm第三步&#xff…
阅读更多...
安全删除U盘时，遇到提示“无法停止‘通用卷’设备时解决方法

安全删除U盘时，遇到提示“无法停止‘通用卷’设备时解决方法

安全删除U盘时&#xff0c;大家常常会遇到提示“无法停止‘通用卷’设备&#xff0c;请稍候再停止该设备。” 这种情况下可以强行拔下U盘吗&#xff1f;当然不可以&#xff01;这时候如果强行拔除的话&#xff0c;很容易损坏计算机U口或者你的U盘。如果你的U盘上有重要的资料&a…
阅读更多...
宠粉老鱼皮带你 “入坑” GitHub！

宠粉老鱼皮带你 “入坑” GitHub！

昨天刚刚教大家 如何更快地访问 GitHub&#xff0c;按照惯例&#xff0c;今天不得来一个 GitHub 教程&#xff1f;最近&#xff0c;鱼皮在持续完善自己 GitHub 上的开源项目&#xff0c;也分享给了很多小伙伴&#xff0c;苦苦哀求大家可以给个 star。liyupi 的 GitHub但是&…
阅读更多...
linux中显示目录名,在linux下显示中文目录和文件名

linux中显示目录名,在linux下显示中文目录和文件名

选择一个一劳永逸的方法&#xff0c;就是修改/etc/下的fstab文件&#xff0c;我的fstab内容如下&#xff1a;/dev/hda9 / ext2 defaults 1 1/dev/hda8 /boot ext2 defaults 1 2none /dev/pts devpts gid5,mode620 0 0none /proc proc defaults 0 0none /dev/shm tmpfs defaults…
阅读更多...
统计学入门需掌握的四点思想

统计学入门需掌握的四点思想

大家晚上好&#xff0c;自从小天悄悄报名Power Query课程并利用休息时间学习&#xff0c;结果因为太嗨被超模君发现了之后&#xff0c;小天又多了一个任务&#xff1a;利用统计学知识处理和分析之前累积的大量数据。&#xff08;抱歉&#xff0c;暴露超模君老是鞭策我的事实了&…
阅读更多...
PIX的AAA认证配置

PIX的AAA认证配置

#vir telnet 10.1.1.1 (一般使用global地址) #access-list auth permit tcp any any eq http #access-list auth permit tcp any any eq telnet //http和telnet协议捆绑抓流量#aaa-server 3a protocol tacacst #aaa-server 3a host 20.1.1.241 //20.1.1.241是aaa服务器…
阅读更多...
UML常用图的几种关系的总结

UML常用图的几种关系的总结

在UML的类图中&#xff0c;常见的有以下几种关系: 泛化&#xff08;Generalization&#xff09;, 实现&#xff08;Realization&#xff09;, 关联&#xff08;Association), 聚合&#xff08;Aggregation&#xff09;, 组合(Composition), 依赖(Dependency)1. 泛化&…
阅读更多...
linux编程两个子进程,Linux中fork同时创建多个子进程的方法

linux编程两个子进程,Linux中fork同时创建多个子进程的方法

怎么创建多个进程呢&#xff1f;我说那还不容易&#xff0c;看下边代码://省略必要头文件int main(){pid_t pid[2];int i;printf("This is %d\n",getpid());for(i 0;i < 2;i ){if((pid[0] fork()) < 0){printf("Fork() Error!");exit(-1);}if(pid[…
阅读更多...
我为什么鼓励你读计算机博士

我为什么鼓励你读计算机博士

看过《水浒传》的朋友都知道&#xff0c;梁山的一百单八将因为各种理由加入了水寨&#xff0c;走上了劫富济贫、替天行道的路。我2006年从南京大学本科毕业以后&#xff0c;耳闻目睹了数百位计算机专业的博士&#xff08;生&#xff09;&#xff0c;他们选择读博士的理由可以说…
阅读更多...
重构者的20种死法

重构者的20种死法

最近涉及重构话题的文章不少啊&#xff0c;其实我也一直在憧憬重构&#xff0c;重构很绿色&#xff0c;重构很河蟹&#xff0c;重构令人很激动&#xff0c;重构可能让人死得很惨。 我在这里&#xff0c;就列举一下Refactorman的种种死法&#xff0c;以警后人&#xff1a; 一、一…
阅读更多...
一日一技：在Ocelot网关中统一配置Swagger

一日一技：在Ocelot网关中统一配置Swagger

概述Swagger 是一个规范和完整的框架&#xff0c;用于生成、描述、调用和可视化 RESTful 风格的 Web 服务。在Ocelot网关中&#xff0c;我们提供给前端的直接是Swagger&#xff0c;如果Swagger分布在各个API中&#xff0c;前端查看Swagger的时候非常不便&#xff0c;Ocelot与Sw…
阅读更多...
最新文章

Copyright @ 2022~2023