如何:创建自定义持久性参与者
下列过程包含持久性参与者的创建步骤。 有关持久性参与者的示例实现,请参阅参与持久性示例和存储扩展性主题。
创建一个派生自 PersistenceParticipant 或 PersistenceIOParticipant 类的类。 除能够参与 I/O 操作以外,PersistenceIOParticipant 类还提供与 PersistenceParticipant 类相同的扩展点。 请完成以下一个或多个步骤。
实现 CollectValues 方法。 CollectValues 方法具有两个字典参数,其中一个用于存储读/写值,另一个用于存储只写值(稍后在查询中使用)。 在此方法中,应使用特定于持久性参与者的数据填充这些字典。 每个字典都包含值的名称和值自身,前者作为键,后者作为 InstanceValue 对象。
readWriteValues 字典中的值打包为 InstanceValue 对象。 只写字典中的值打包为设置了 InstanceValueOptions.Optional 和 InstanceValueOption.WriteOnly 的 InstanceValue 对象。 所有持久性参与者的 CollectValues 实现提供的各 InstanceValue 必须具有唯一的名称。
protected virtual void CollectValues(out IDictionary<XName,Object> readWriteValues, out IDictionary<XName,Object> writeOnlyValues) { }
实现 MapValues 方法。 MapValues 方法采用的两个参数类似于 CollectValues 方法接收到的参数。 在 CollectValues 阶段收集的所有值都通过这些字典参数传递。 MapValues 阶段添加的新值添加到只写值中。 只写字典用于向外部源提供不直接与实例值相关联的数据。 所有持久性参与者的 MapValues 方法实现提供的各个值必须具有唯一的名称。
protected virtual IDictionary<XName,Object> MapValues(IDictionary<XName,Object> readWriteValues,IDictionary<XName,Object> writeOnlyValues) { }
MapValues 方法提供 CollectValues 不实现的功能,因为它允许由另一个持久性参与者提供另一个值的依赖项,该参与者尚未经过 CollectValues 的处理。
实现 PublishValues 方法。 PublishValues 方法接收一个包含从持久性存储加载的所有值的字典。
protected virtual void PublishValues(IDictionary<XName,Object> readWriteValues) { }
如果参与者是持久性 I/O 参与者,请实现 BeginOnSave 方法。 在执行保存操作期间,将调用此方法。 在此方法中,应执行持久保存(保存)工作流实例的附加 I/O。 如果主机正将事务用于相应的持久性命令,则会在 Transaction.Current 中提供相同事务。 此外,持久性 IO 参与者可公布事务一致性需求,在这种情况中,主机将为持久性段创建一个事务(如果不会在其他情况下使用该事务)。
protected virtual IAsyncResult BeginOnSave(IDictionary<XName,Object> readWriteValues, IDictionary<XName,Object> writeOnlyValues, TimeSpan timeout, AsyncCallback callback, Object state) { }
如果参与者是持久性 I/O 参与者,请实现 BeginOnLoad 方法。 在执行加载操作期间,将调用此方法。 在此方法中,应执行加载工作流实例的附加 I/O。 如果主机正将事务用于相应的持久性命令,则会在 Transaction.Current 中提供相同事务。 此外,持久性 I/O 参与者可公布事务一致性需求,在这种情况中,主机将为持久性段创建一个事务(如果不会在其他情况下使用该事务)。
protected virtual IAsyncResult BeginOnLoad(IDictionary<XName,Object> readWriteValues, TimeSpan timeout, AsyncCallback callback, Object state) { }