如何复制nHibernate生成的特定实体SQL增删改查询？

在C#应用中，我们使用NHibernate及Fluent NHibernate，需要捕获针对SQLite数据库执行的特定INSERT、UPDATE、DELETE查询以实现增量复制，且仅复制影响特定实体类型的操作。

经过多次搜索与测试，尚未找到可行方案，以下是已尝试的两种方式及各自局限：

已尝试的方案及问题 #

1. 重写Interceptor的OnPrepareStatement方法 #

此方法可以获取NHibernate生成的原始SQL，但无法关联到操作对应的实体上下文，无法判断该SQL是否影响目标实体类型：

public override SqlString OnPrepareStatement(SqlString sql)
{
    // 仅能拿到原始SQL，无实体关联信息
    Console.WriteLine(sql);
    return base.OnPrepareStatement(sql);
}

2. 使用NHibernate Event Listeners #

通过实现IPreUpdateEventListener、IPostInsertEventListener等监听接口，可以获取操作对应的实体上下文及详细元数据，但无法直接获取NHibernate生成的原始执行SQL：

public class QueryListener(Configuration cfg) : IPreUpdateEventListener, IPostUpdateEventListener, IPreInsertEventListener, IPostInsertEventListener
{
    public void Register()
    {
        cfg.EventListeners.PreUpdateEventListeners = [.. cfg.EventListeners.PreUpdateEventListeners, this];
        cfg.EventListeners.PostUpdateEventListeners = [.. cfg.EventListeners.PostUpdateEventListeners, this];
        cfg.EventListeners.PreInsertEventListeners = [.. cfg.EventListeners.PreInsertEventListeners, this];
        cfg.EventListeners.PostInsertEventListeners = [.. cfg.EventListeners.PostInsertEventListeners, this];
    }

    public void OnPostUpdate(PostUpdateEvent @event)
    {
        // 无法直接获取对应SQL
    }

    public bool OnPreUpdate(PreUpdateEvent @event)
    {
        // 无法直接获取对应SQL
        return false;
    }

    public bool OnPreInsert(PreInsertEvent @event)
    {
        // 无法直接获取对应SQL
        return false;
    }

    public void OnPostInsert(PostInsertEvent @event)
    {
        // 无法直接获取对应SQL
    }

    #region Async methods
    public Task OnPostUpdateAsync(PostUpdateEvent @event, CancellationToken cancellationToken)
    {
        OnPostUpdate(@event);
        return Task.CompletedTask;
    }

    public Task<bool> OnPreUpdateAsync(PreUpdateEvent @event, CancellationToken cancellationToken)
    {
        return Task.FromResult(OnPreUpdate(@event));
    }

    public Task<bool> OnPreInsertAsync(PreInsertEvent @event, CancellationToken cancellationToken)
    {
        return Task.FromResult(OnPreInsert(@event));
    }

    public Task OnPostInsertAsync(PostInsertEvent @event, CancellationToken cancellationToken)
    {
        OnPostInsert(@event);
        return Task.CompletedTask;
    } 
    #endregion
}

我们希望实现增量同步机制，恳请提供可行的解决方案。

内容的提问来源于stack exchange，提问作者pp-mluthi