Marten项目中的FetchForWriting方法异常问题分析

问题背景

Marten是一个.NET平台上的PostgreSQL文档数据库和事件存储库。在最新版本中，当配置为使用聚合体(aggregate)的身份映射(identity map)时，FetchForWriting方法在传递预期版本号(expected version)参数时会抛出InvalidCastException异常。

问题现象

当开发者同时满足以下两个条件时会出现异常：

1. 配置了UseIdentityMapForAggregates = true
2. 调用FetchForWriting方法时传入了预期版本号参数

异常信息显示系统无法将生成的文档存储类型转换为预期的接口类型。

技术分析

根本原因

问题出在FetchingInlinedPlan<TDoc, TId>类的实现中。当使用身份映射时，代码直接尝试将存储提供者强制转换为IDocumentStorage<TDoc, TId>接口，但实际生成的存储类型是一个修订版本(revisioned)的存储提供者，导致类型转换失败。

解决方案对比

原始代码直接进行强制类型转换：

storage = (IDocumentStorage<TDoc, TId>)session.Options.Providers.StorageFor<TDoc>();

修正后的代码使用Marten内置的类型解析方法：

storage = session.Options.ResolveCorrectedDocumentStorage<TDoc, TId>(DocumentTracking.IdentityOnly);

后者更加安全可靠，因为它：

1. 考虑了文档跟踪策略
2. 正确处理了修订版本存储的特殊情况
3. 与Marten内部的其他方法保持一致性

影响范围

该问题仅影响：

• 使用事件溯源(event sourcing)功能的场景
• 配置了身份映射的聚合体
• 调用带版本号参数的FetchForWriting方法

常规的文档存储操作不受影响。

最佳实践建议

1. 在使用事件溯源功能时，建议全面测试各种配置组合
2. 对于关键业务代码，考虑添加单元测试覆盖版本控制场景
3. 更新到包含此修复的Marten版本后，验证相关功能

技术深度解析

Marten的事件溯源功能通过投影(projection)将事件流转换为聚合体状态。当配置了UseIdentityMapForAggregates时，系统会为聚合体维护一个身份映射缓存，以提高性能并确保会话内的对象一致性。

修订版本控制是事件溯源中的重要概念，它确保并发修改时数据的一致性。FetchForWriting方法中的expectedStartingVersion参数就是用于实现乐观并发控制的。

修复后的实现正确处理了身份映射与修订版本控制的交互，确保了类型系统的安全性，同时保持了Marten框架的灵活性和扩展性。