Marten 7.0 命令执行管道重构解析

Marten 作为.NET生态中优秀的PostgreSQL文档数据库和事件存储库，在即将发布的7.0版本中对命令执行管道进行了重大重构。这次重构涉及多个核心组件的重新设计，旨在提升性能、简化架构并增强可靠性。

架构重构目标

本次重构主要围绕以下几个核心目标展开：

1. 性能优化：消除Lambda闭包带来的内存分配，采用更高效的执行策略
2. 现代API适配：利用NpgsqlBatch实现原生命令批处理
3. 参数处理改进：转向位置参数以提高查询效率
4. 可靠性增强：修复现有重试机制的问题
5. 连接管理：重新设计数据库连接生命周期管理
6. 框架集成：改善与Hot Chocolate等框架的兼容性

命令执行管道新设计

新版本引入了ISessionExecutor接口，取代了原有的IConnectionLifetime抽象：

public interface ISessionExecutor
{
    Task ExecutePagesAsync(IReadOnlyList<OperationPage> pages, 
                         IMartenSessionLogger logger, 
                         CancellationToken token);
    
    int Execute(NpgsqlCommand cmd);
    Task<int> ExecuteAsync(NpgsqlCommand command, CancellationToken token = new());
    DbDataReader ExecuteReader(NpgsqlCommand command);
    Task<DbDataReader> ExecuteReaderAsync(NpgsqlCommand command, 
                                        CancellationToken token = default);
}

这一设计将事务边界管理、连接生命周期等职责完全封装在实现类中，使上层调用更加简洁。主要实现包括：

• DefaultSessionExecutor：使用DbDataSource处理读取查询，对更新操作采用"快速打开连接-执行-提交/回滚-关闭连接"模式
• SerializedSessionExecutor：处理可序列化事务
• ExternalSessionExecutor：包装用户提供的连接和事务
• AmbientTransactionExecutor：处理环境事务

错误处理机制改进

移除了原有的IRetryPolicy接口，采用Polly作为重试策略实现。这一改变带来了以下优势：

1. 性能提升：通过静态Lambda减少闭包分配
2. 功能丰富：内置指数退避等高级策略
3. 配置灵活：支持用户自定义策略
4. 可靠性增强：正确处理连接重置等场景

关键技术改进点

1. 批处理优化：全面采用NpgsqlBatch替代旧版CommandBuilder，提升批量操作效率
2. 参数处理：转向位置参数，减少SQL解析开销
3. 租户处理：优化多租户场景下的tenant_id参数处理逻辑
4. SQL执行：保留QueueSqlCommand方法，确保事务一致性
5. 连接池管理：更精细的连接生命周期控制，避免连接泄漏

性能考量

重构后的架构在以下方面带来性能提升：

1. 减少中间对象分配
2. 批处理操作降低网络往返次数
3. 位置参数减少SQL解析开销
4. 更智能的连接复用策略
5. 准备语句的合理使用

向后兼容性

虽然这是一次重大变更，但团队通过以下方式降低迁移成本：

1. 保留核心API签名
2. 提供详细的迁移指南
3. 维护关键功能如QueueSqlCommand
4. 渐进式改进而非彻底重写

总结

Marten 7.0的命令执行管道重构是一次深思熟虑的架构演进，在保持核心功能的同时，通过现代化设计提升了性能、可靠性和扩展性。新架构特别适合高并发场景，为后续功能扩展奠定了坚实基础。对于现有用户，虽然需要一定的迁移工作，但获得的是更高效、更稳定的数据访问层实现。