C#中如何使用EF Core的查询拦截？修改查询SQL？

using Microsoft.EntityFrameworkCore.Diagnostics;
using System.Data.Common;
using System.Text;

public class SqlServerNolockInterceptor : DbCommandInterceptor
{
    public override InterceptionResult<DbDataReader> ReaderExecuting(
        DbCommand command,
        CommandEventData eventData,
        InterceptionResult<DbDataReader> result)
    {
        // 只处理 SELECT 语句
        if (command.CommandText.StartsWith("SELECT", StringComparison.OrdinalIgnoreCase))
        {
            // 修改 SQL，添加 WITH (NOLOCK)
            var modifiedSql = new StringBuilder();
            var fromIndex = command.CommandText.IndexOf("FROM ", StringComparison.OrdinalIgnoreCase);
            if (fromIndex >= 0)
            {
                var tableNameStart = fromIndex + 5;
                var tableNameEnd = command.CommandText.IndexOf(' ', tableNameStart);
                var tableName = tableNameEnd > 0 
                    ? command.CommandText.Substring(tableNameStart, tableNameEnd - tableNameStart) 
                    : command.CommandText.Substring(tableNameStart).Trim();

                // 避免重复添加
                if (!command.CommandText.Contains($"[{tableName}] WITH (NOLOCK)", StringComparison.OrdinalIgnoreCase))
                {
                    var withNolock = $"[{tableName}] WITH (NOLOCK)";
                    modifiedSql.Append(command.CommandText.Substring(0, tableNameStart));
                    modifiedSql.Append(withNolock);
                    if (tableNameEnd > 0)
                        modifiedSql.Append(command.CommandText.Substring(tableNameEnd));

                    command.CommandText = modifiedSql.ToString();
                }
            }
        }

        return result;
    }
}

using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;

services.AddDbContext<MyDbContext>(options =>
    options.UseSqlServer(connectionString)
           .UseInterceptors(new SqlServerNolockInterceptor()));

protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
    optionsBuilder.UseSqlServer("YourConnectionString")
                  .UseInterceptors(new SqlServerNolockInterceptor());
}

await context.Database.BeginTransactionAsync(IsolationLevel.ReadUncommitted);