1. Dotnet9首页
  2. .NET
  3. ORM
  4. EF Core

给 EF Core 查询增加 With NoLock

给 EF Core 查询增加 With NoLock

Intro

EF Core 在 3.x 版本中增加了 Interceptor,使得我们可以在发生低级别数据库操作时作为 EF Core 正常运行的一部分自动调用它们。例如,打开连接、提交事务或执行命令时。

所以我们可以自定义一个 Interceptor 来记录执行的 sql 语句,也可以通过 Interceptor 来实现 sql 语句的执行。

这里我们可以借助 Interceptor 实现对于查询语句的修改,自动给查询语句加 (WITH NOLOCK)WITH NOLOCK 等效于 READ UNCOMMITED(读未提交)的事务级别,这样会造成一定的脏读,但是从效率上而言,是比较高效的,不会因为别的事务长时间未提交而导致查询阻塞,所以对于大数据场景下,查询 SQL 加 NOLOCK 还是比较有意义的

NoLockInterceptor

继承 DbCommandInterceptor,重写查询 sql 执行之前的操作,在执行 sql 之前增加 WITH(NOLOCK),实现代码如下:

  1. public class QueryWithNoLockDbCommandInterceptor : DbCommandInterceptor
  2. {
  3. private static readonly Regex TableAliasRegex =
  4. new Regex(@"(?<tableAlias>AS \[[a-zA-Z]\w*\](?! WITH \(NOLOCK\)))",
  5. RegexOptions.Multiline | RegexOptions.Compiled | RegexOptions.IgnoreCase);

  6. public override InterceptionResult<object> ScalarExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<object> result)
  7. {
  8. command.CommandText = TableAliasRegex.Replace(
  9. command.CommandText,
  10. "${tableAlias} WITH (NOLOCK)"
  11. );
  12. return base.ScalarExecuting(command, eventData, result);
  13. }

  14. public override Task<InterceptionResult<object>> ScalarExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<object> result,
  15. CancellationToken cancellationToken = new CancellationToken())
  16. {
  17. command.CommandText = TableAliasRegex.Replace(
  18. command.CommandText,
  19. "${tableAlias} WITH (NOLOCK)"
  20. );
  21. return base.ScalarExecutingAsync(command, eventData, result, cancellationToken);
  22. }

  23. public override InterceptionResult<DbDataReader> ReaderExecuting(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result)
  24. {
  25. command.CommandText = TableAliasRegex.Replace(
  26. command.CommandText,
  27. "${tableAlias} WITH (NOLOCK)"
  28. );
  29. return result;
  30. }

  31. public override Task<InterceptionResult<DbDataReader>> ReaderExecutingAsync(DbCommand command, CommandEventData eventData, InterceptionResult<DbDataReader> result,
  32. CancellationToken cancellationToken = new CancellationToken())
  33. {
  34. command.CommandText = TableAliasRegex.Replace(
  35. command.CommandText,
  36. "${tableAlias} WITH (NOLOCK)"
  37. );
  38. return base.ReaderExecutingAsync(command, eventData, result, cancellationToken);
  39. }
  40. }

Interceptor 的使用

在注册 DbContext 服务的时候,可以配置 Interceptor,配置如下:

va var services = new ServiceCollection();
services.AddDbContext<TestDbContext>(options =>
{
    options
        .UseLoggerFactory(loggerFactory)
        .UseSqlServer(DbConnectionString)
        .AddInterceptors(new QueryWithNoLockDbCommandInterceptor())
        ;
}); 

使用效果

通过 loggerFactory 记录的日志查看查询执行的 sql 语句

给 EF Core 查询增加 With NoLock

可以看到查询语句自动加上了 WITH(NOLOCK)

Reference

原文出处:微信公众号【WeihanLi amazingdotnet】

原文链接:https://mp.weixin.qq.com/s/DsybYg1rJOpC3KRJToru5A

本文观点不代表Dotnet9立场,转载请联系原作者。

发表评论

登录后才能评论