如何在 DbCommandInterceptor 中使用 Service 或 DbContext？

Question

我有一个将数据从 MySql 数据库同步到 SQL Server 数据库的应用程序。

考虑这两个 DbContext 服务：

services.AddDbContext<SqlServerContext>(options => options
    .UseSqlServer(Configuration.GetConnectionString("SqlServer")));

services.AddDbContext<MySqlContext>(options => options
    .UseMySql(Configuration.GetConnectionString("MySql"))
    .AddInterceptors(new MySqlInterceptor()));

在MySqlInterceptor();我想注入/解析/使用Service 甚至SqlServerContext，以便获得修改CommandText 的配置。

有什么想法吗？

Answer 1

正如@vasil 在他的answer 中提到的那样：

根据您要覆盖的方法，您将收到 CommandEventData 方法定义中的对象 DbContext 作为属性。

在我的例子中，我想解决一个使用另一个 DbContext 的服务，但事实证明这很麻烦；因此，我最终将所需的设置放入 appsettings.json，并使用IConfiguration 服务获取设置值并将其发送到拦截器构造函数：

services.AddDbContext<MySqlContext>(options => options
    .UseMySql(Configuration.GetConnectionString("MySql"))
    .AddInterceptors(new MySqlInterceptor(Configuration["SettingValue"])));

---

注意：如果您找到了这个答案，并且正在寻找一种方法来解决 ConfigureService 方法中的服务，而无需调用 BuildServiceProvider，就像 David Fowler 在 @987654323 上所说的那样@，你会是：

在尝试构建容器的同时构建容器

你最终会得到：

2 个容器，其中一个永远不会被丢弃。

您可以按照 Nkosi 在他的 answer 中的建议进行操作：

services.AddScoped<IService>(x => 
    new Service(x.GetRequiredService<IOtherService>(),
                x.GetRequiredService<IAnotherOne>(), 
                ""));

Answer 2

根据您要覆盖的方法，您将在方法定义中收到CommandEventData 对象，该对象具有DbContext 作为属性。

关于服务和配置，您可以在注册前配置拦截器。
而不是这个：

services.AddDbContext<MySqlContext>(options => options
    .UseMySql(Configuration.GetConnectionString("MySql"))
    .AddInterceptors(new MySqlInterceptor()));

你可以的

var interceptor = new MySqlInterceptor(service1, service2 ... etc);
services.AddDbContext<MySqlContext>(options => options
 .UseMySql(Configuration.GetConnectionString("MySql"))
 .AddInterceptors(interceptor))

---

如何解析拦截器实例：
如果您需要自动连接拦截器的依赖项，您可以执行以下操作

services.AddTransient<Service1>();
services.AddTransient<Service2>();
services.AddTransient<MySqlInterceptor>();
// resolve the instalce of the interceptor
var serviceProvider = services.BuildServiceProvider();
var interceptor = serviceProvider.GetService<MySqlInterceptor>();
// configure mysql context and interceptor
services.AddDbContext<MySqlContext>(options => options
 .UseMySql(Configuration.GetConnectionString("MySql"))
 .AddInterceptors(interceptor))