Расширяемость хранилища

Статья
03/05/2024

SqlWorkflowInstanceStore позволяет пользователям повышать уровень относящихся к приложению пользовательских свойств, которые могут использоваться для создания запросов к экземплярам в базе данных сохраняемости. Благодаря действию по повышению уровня свойства значение становится доступным в специальном представлении в базе данных. Свойства с повышенным уровнем (т.е. свойства, которые могут использоваться в пользовательских запросах), могут относиться к простым типам, например к Int64, Guid, String, DateTime или к сериализованному двоичному типу (byte[]).

Класс SqlWorkflowInstanceStore содержит метод Promote, который может использоваться для повышения уровня свойства, чтобы его можно было использовать в запросах. Ниже приведен подробный пошаговый пример расширения хранилища.

В данном образце сценария приложение обработки документов содержит рабочие процессы, в каждом из которых для обработки документов применяются пользовательские действия. Эти рабочие процессы содержат набор переменных состояния, которые необходимо сделать доступными для конечных пользователей. Для этого приложение обработки документов предоставляет расширение экземпляра типа PersistenceParticipant, используемое действиями для предоставления переменных состояния.
```
class DocumentStatusExtension : PersistenceParticipant
{
    public string DocumentId;
    public string ApprovalStatus;
    public string UserName;
    public DateTime LastUpdateTime;
}
```
Затем к узлу добавляется новое расширение.
```
static Activity workflow = CreateWorkflow();
WorkflowApplication application = new WorkflowApplication(workflow);
DocumentStatusExtension documentStatusExtension = new DocumentStatusExtension ();
application.Extensions.Add(documentStatusExtension);
```
Дополнительные сведения о добавлении пользовательского участника сохраняемости см. в примере участников сохраняемости.

Пользовательские действия в приложении DP заполняют различные поля состояния в методе Execute .

public override void Execute(CodeActivityContext context)
{
    // ...
    context.GetExtension<DocumentStatusExtension>().DocumentId = Guid.NewGuid();
    context.GetExtension<DocumentStatusExtension>().UserName = "John Smith";
    context.GetExtension<DocumentStatusExtension>().ApprovalStatus = "Approved";
    context.GetExtension<DocumentStatusExtension>().LastUpdateTime = DateTime.Now();
    // ...
}

Когда экземпляр рабочего процесса достигает точки сохраняемости, метод CollectValues участника сохраняемости DocumentStatusExtension сохраняет эти свойства в коллекции данных сохраняемости.

class DocumentStatusExtension : PersistenceParticipant
{
    const XNamespace xNS = XNamespace.Get("http://contoso.com/DocumentStatus");

    protected override void CollectValues(out IDictionary<XName, object> readWriteValues, out IDictionary<XName, object> writeOnlyValues)
    {
        readWriteValues = new Dictionary<XName, object>();
        readWriteValues.Add(xNS.GetName("UserName"), this.UserName);
        readWriteValues.Add(xNS.GetName("ApprovalStatus"), this.ApprovalStatus);
        readWriteValues.Add(xNS.GetName("DocumentId"), this.DocumentId);
        readWriteValues.Add(xNS.GetName("LastModifiedTime"), this.LastUpdateTime);

        writeOnlyValues = null;
    }
    // ...
}

Примечание.

Все эти свойства передаются в SqlWorkflowInstanceStore платформой сохраняемости через коллекцию SaveWorkflowCommand.InstanceData .

Приложение DP инициализирует хранилище экземпляров рабочих процессов SQL и вызывает метод "Повысить" , чтобы повысить уровень этих данных.
```
SqlWorkflowInstanceStore store = new SqlWorkflowInstanceStore(connectionString);

List<XName> variantProperties = new List<XName>()
{
    xNS.GetName("UserName"),
    xNS.GetName("ApprovalStatus"),
    xNS.GetName("DocumentId"),
    xNS.GetName("LastModifiedTime")
};

store.Promote("DocumentStatus", variantProperties, null);
```
На основе этих сведений о продвижении SqlWorkflowInstanceStore помещает свойства данных в столбцы представления InstancePromotedProperties .

Чтобы создать запрос к подмножеству данных из таблицы повышения уровня, приложение обработки данных добавляет пользовательское представление к представлению повышения уровня.

create view [dbo].[DocumentStatus] with schemabinding
as
    select  P.[InstanceId] as [InstanceId],
        P.Value1 as [UserName],
        P.Value2 as [ApprovalStatus],
        P.Value3 as [DocumentId],
        P.Value4 as [LastUpdatedTime]
from [System.Activities.DurableInstancing].[InstancePromotedProperties] as P
where P.PromotionName = N'DocumentStatus'
go

Представление [System.Activities.DurableInstancing.InstancePromotedProperties]

Имя столбца	Тип столбца	Description
InstanceId	GUID	Экземпляр рабочего процесса, которому принадлежит это повышение уровня.
НазваниеАкции	nvarchar(400)	Имя самого продвижения.
Value1, Value2, Value3,..,Value32	sql_variant	Значение самого свойства, уровень которого повышен. Большинство примитивных типов данных SQL, за исключением больших двоичных объектов BLOB и строк длиной более 8000 байт, помещается в sql_variant.
Value33, Value34, Value35, …, Value64	varbinary(max)	Значение свойств повышаемого уровня, явно объявленных, как varbinary(max).

Поделиться через

Расширяемость хранилища

Представление [System.Activities.DurableInstancing.InstancePromotedProperties]

Дополнительные ресурсы