SqlTrackingQuery状态查询类.doc

1 SqlTrackingService的状态查询类1.通过SqlTrackingQuery的TryGetWorkflow方法得到SqlTrackingWorkflowInstance对象2.通过SqlTrackingWorkflowInstance对象的属性与集合访问各类具体信息3.不依赖在WorkflowRuntime与SqlTrackingService,该类只接对数据操作1.1 相关的类关系图System.Workflow.Runtime.Tracking.SqlTrackingQuerySystem.Workflow.Runtime.Tracking.SqlTrackingWorkflowInstanceSystem.Workflow.Runtime.Tracking.WorkflowTrackingRecordSystem.Workflow.Runtime.Tracking.TrackingWorkflowEventSystem.Workflow.Runtime.Tracking.ActivityTrackingRecordSystem.Workflow.ComponentModel.ActivityExecutionStatusSystem.Workflow.Runtime.Tracking.UserTrackingRecord System.Workflow.Activities.Rules.RuleActionTrackingEvent1.2 类的调用说明SqlTrackingWorkflowInstanceWorkflowEvents 属性ActivityEvents属性UserEvents 属性Status属性SqlTrackingQueryNew(数据连接串)TryGetWorkflow(实例GUID, out OBJ)WorkflowTrackingRecordEventArgsEventDateTimeTrackingWorkflowEventTrackingWorkflowSuspendedEventArgs:挂起TrackingWorkflowTerminatedEventArgs:终止TrackingWorkflowExceptionEventArgs:异常Aborted Changed CompletedCreated Exception IdleLoaded Persisted ResumedStarted Suspended Terminated UnloadedActivityTrackingRecordActivityTypeParentContextContextGuidEventDateTimeExecutionStatusQualifiedNameCanceling Closed Compensating Executing Faulting InitializedUserTrackingRecordActivityTypeParentContextContextGuidEventDateTimeQualifiedNameUserDataKeyUserDataRuleActionTrackingEventRuleNameConditionResult可能是这几种类型可能是该类型1.3 SqlTrackingQuery 查询对象1.3.1 成员GetWorkflows方法TryGetWorkflow(Guid ,out SqlTrackingWorkflowInstance)方法得到指定GUID的工作流状态对象ConnectionString属性连接字符串1.3.2 使用说明SqlTrackingQuery trackingQuery;SqlTrackingWorkflowInstance trackingInstance;trackingQuery = new SqlTrackingQuery(constring);System.Guid guid = new Guid(gid);bool b = trackingQuery.TryGetWorkflow(guid, out temp);使用SqlTrackingQuery的TryGetWorkflow方法返回SqlTrackingWorkflowInstance对SqlTrackingWorkflowInstance进行具体的查询操作具体操作见SqlTrackingWorkflowInstance1.4 SqlTrackingWorkflowInstance 查询返回的实例对象1.4.1 属性AutoRefreshInitializedInvokingWorkflowInstanceId StatusWorkflowDefinition WorkflowDefinitionUpdated WorkflowInstanceIdWorkflowInstanceInternalId WorkflowType 1.4.2 集合ActivityEvents当前WorkFlow实例Activity状态对象(ActivityTrackingRecord)的集合InvokedWorkflows 得到 SqlTrackingWorkflowInstance 对象的列表, that correspond to workflows that have been invoked by this workflow.UserEvents 业务状态对象(UserTrackingRecord)的集合WorkflowEvents WorkFlow状态对象(WorkflowTrackingRecord)的集合1.4.3 方法Refresh刷新当前状态1.5 WorkflowTrackingRecord 工作流状态AnnotationsGets the collection of annotations associated with the WorkflowTrackPoint that was matched.EventDateTime记录该实例状态的时间EventOrderEventOrder字段值TrackingWorkflowEvent状态说明,TrackingWorkflowEvent类型,值如下Aborted: Changed: Completed: Created: Exception: Idle: Loaded: Persisted: Resumed: Started: Suspended: Terminated: Unloaded: EventArgs当前工作流状态记录的EventArgs,可能返回TrackingWorkflowSuspendedEventArgs ： 挂起TrackingWorkflowTerminatedEventArgs：终止（异常就是引起终止的原因之一）TrackingWorkflowExceptionEventArgs：异常对不同的返回对象，会有不同的状态信息具体见得到工作流实例的挂起、终止、异常的具体信息 Shared Sub 得到实例运行状况列表(ByVal 实例Id As Guid) Dim sql As String = Initial Catalog=Tracking;Data Source=WXWINTERSQLEXPRESS;Integrated Security=SSPI; Dim 查询 As SqlTrackingQuery = New SqlTrackingQuery(sql) Dim 被查询的实例 As SqlTrackingWorkflowInstance = Nothing 查询.TryGetWorkflow(实例Id, 被查询的实例) If 被查询的实例 IsNot Nothing Then Console.WriteLine(工作流实例曾发生的状态列表:) Dim 实例状态 As WorkflowTrackingRecord For Each 实例状态 In 被查询的实例.WorkflowEvents Console.WriteLine(曾发生的状态 + 实例状态.TrackingWorkflowEvent.ToString) Console.WriteLine(该状态发生的时间 + 实例状态.EventDateTime.ToString) Console.WriteLine(EventOrder字段值: + 实例状态.EventOrder.ToString) 工作流实例可能会有如下状态 Aborted、 Changed、 Completed、 Created、 Exception、 Idle、 Loaded、 Persisted、 Resumed、 Started、 Suspended、 Terminated、 Unloaded、 Next End If End Sub1.6 WorkflowTrackingRecord.EventArgs实例挂起、终止、异常的具体信息TrackingWorkflowSuspendedEventArgs ： 挂起TrackingWorkflowTerminatedEventArgs：终止（异常就是引起终止的原因之一）TrackingWorkflowExceptionEventArgs：异常等TrackingWorkflow_Args对象，通过数据类型转换后可得到 挂起 / 终止 / 异常 的具体信息下例可配合两个工作流分别使用 void code1_ExecuteCode(object sender, EventArgs e) throw new ApplicationException(测试用错误:自定义错误信息); static void 查询实例的_挂起_终止_异常(Guid 实例ID) string sql = Initial Catalog=Tracking;Data Source=WXWINTERSQLEXPRESS;Integrated Security=SSPI; SqlTrackingQuery 查询= new SqlTrackingQuery(sql); SqlTrackingWorkflowInstance 被查询的实例; if (查询.TryGetWorkflow(实例ID, out 被查询的实例) foreach (WorkflowTrackingRecord 实例状态 in 被查询的实例.WorkflowEvents) Console.WriteLine(); Console.WriteLine(-); Console.WriteLine(实例ID + 被查询的实例.WorkflowInstanceId.ToString(); Console.WriteLine(结果描述: + 实例状态.TrackingWorkflowEvent.ToString(); Console.WriteLine(时间 + 实例状态.EventDateTime.ToString(); object 状态类型= 实例状态.EventArgs; /判断实例状态信息是否为挂起类型 if (状态类型 is TrackingWorkflowSuspendedEventArgs) TrackingWorkflowSuspendedEventArgs obj = (TrackingWorkflowSuspendedEventArgs)状态类型; Console.WriteLine(暂停信息: + obj.Error); /判断实例状态信息是否为终止类型 if (状态类型 is TrackingWorkflowTerminatedEventArgs) TrackingWorkflowTerminatedEventArgs obj = (TrackingWorkflowTerminatedEventArgs)状态类型; /如果是由异常引起的结止,显示该Exception信息,(Activity的) if (null != obj.Exception) Console.WriteLine(异常终止信息: + obj.Exception.Message.ToString(); /判断实例状态信息是否为异常类型 if (状态类型 is TrackingWorkflowExceptionEventArgs) TrackingWorkflowExceptionEventArgs obj = (TrackingWorkflowExceptionEventArgs)状态类型; Console.WriteLine(异常信息的Activity控件来源: + obj.OriginalActivityPath.ToString(); /如果Exception信息不为空，显示该信息(Activity的) if (null != obj.Exception) Console.WriteLine(异常信息: + obj.Exception.Message.ToString(); /END foreach /END if /END 查询实例的_挂起_终止_异常1.7 ActivityTrackingRecord 结点状态Activity状态对象ActivityTrackingRecord以集合成员的方式存于SqlTrackingWorkflowInstance的ActivityEvents集合中ActivityTypeActivity类型AnnotationsBodyContextGuidActivity上下文GUIDEventArgsEventDateTime该状态发生的时间EventOrderEventOrder字段值ExecutionStatus状态说明,ActivityExecutionStatus类型,值如下 Canceling: Closed: Compensating: Executing: Faulting: Initialized:ParentContextActivity容器对象GUIDQualifiedNameActivity名(开发时对象名) Shared Sub 得到Activity运行状况列表(ByVal 实例Id As Guid) Dim sql As String = Initial Catalog=Tracking;Data Source=WXWINTERSQLEXPRESS;Integrated Security=SSPI; Dim 查询 As SqlTrackingQuery = New SqlTrackingQuery(sql) Dim 被查询的实例 As SqlTrackingWorkflowInstance = Nothing 查询.TryGetWorkflow(实例Id, 被查询的实例) If 被查询的实例 IsNot Nothing Then Console.WriteLine(vbCrLf + Activity 曾发生的状态列表: + vbCrLf) Console.WriteLine() Dim Activity状态 As ActivityTrackingRecord For Each Activity状态 In 被查询的实例.ActivityEvents Console.WriteLine(Activity类型: + Activity状态.ActivityType.ToString) Console.WriteLine(Activity上下文GUID: + Activity状态.ContextGuid.ToString) Console.WriteLine(该状态发生的时间: + Activity状态.EventDateTime.ToString) Console.WriteLine(Activity曾发生的状态: + Activity状态.ExecutionStatus.ToString) Console.WriteLine(EventOrder字段值: + Activity状态.EventOrder.ToString) Console.WriteLine(Activity容器对象GUID: + Activity状态.ParentContextGuid.ToString) Console.WriteLine(Activity名(开发时对象名): + Activity状态.QualifiedName) Console.WriteLine() 此时，该WorkFlow 类本身也作为一个Activity被记录状态，他是所有Activity的容器 有些Activity可以成为另一个Activity的容器Activity可能会有如下状态 Canceling、Closed、Compensating、Executing、Faulting、Initialized Next End If1.8 UserTrackingRecord 用户状态用户状态:UserTrackingRecord以集合成员的方式存于SqlTrackingWorkflowInstance的UserEvents集合中ActivityTypeActivity类型AnnotationsGets the collection of annotations associated with the user event.BodyGets a list containing any additional data extracted from the workflow for the UserTrackPoint that was matchedContextGuid上下文IDEventArgsAlways a null reference (Nothing in Visual Basic) for a UserTrackingRecord.EventDateTime时间EventOrderGets or sets a value that indicates the order of the user event that matched the UserTrackPoint in the workflow instanceParentContextGuidParent上下文IDQualifiedName所属Activity,该状态信息是在那个Activity里用TrackData方法记录的UserData内容UserDataKey键值 p