Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / RunTime / Tracking / SqlTrackingQuery.cs / 1305376 / SqlTrackingQuery.cs
using System; using System.Data; using System.Data.SqlClient; using System.Data.SqlTypes; using System.Collections; using System.Collections.Generic; using System.Text; using System.Xml; using System.Reflection; using System.IO; using System.Runtime.Serialization.Formatters.Binary; using System.ComponentModel.Design.Serialization; using System.Workflow.Runtime; using System.Workflow.ComponentModel; using System.Workflow.ComponentModel.Serialization; using System.Workflow.Runtime.Hosting; namespace System.Workflow.Runtime.Tracking { public sealed class SqlTrackingQuery { string _connectionString = null; public SqlTrackingQuery() { } public SqlTrackingQuery(string connectionString) { if (null == connectionString) throw new ArgumentNullException("connectionString"); _connectionString = connectionString; } public string ConnectionString { get { return _connectionString; } set { if (null == value) throw new ArgumentNullException("value"); _connectionString = value; } } public bool TryGetWorkflow(Guid workflowInstanceId, out SqlTrackingWorkflowInstance workflowInstance) { SqlCommand cmd = BuildCommand(workflowInstanceId); SqlDataReader reader = null; workflowInstance = null; try { cmd.Connection = GetConnection(); reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); // // There will only be 1 row if (reader.Read()) { workflowInstance = BuildInstance(reader); return true; } else return false; } finally { if (null != reader) reader.Close(); if (null != cmd && null != cmd.Connection && ConnectionState.Closed != cmd.Connection.State) cmd.Connection.Close(); } } public IListGetWorkflows(SqlTrackingQueryOptions options) { if (null == options) throw new ArgumentNullException("options"); if (null != options.TrackingDataItems) { foreach (TrackingDataItemValue val in options.TrackingDataItems) { if (null == val.QualifiedName) throw new ArgumentNullException("options.TrackingDataItems.QualifiedName"); if (null == val.FieldName) throw new ArgumentNullException("options.TrackingDataItems.FieldName"); } } SqlCommand cmd = BuildCommand(options); SqlDataReader reader = null; List inst = new List (); try { cmd.Connection = GetConnection(); reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); // // There will only be 1 row while (reader.Read()) { inst.Add(BuildInstance(reader)); } } finally { if (null != reader) reader.Close(); if (null != cmd && null != cmd.Connection && ConnectionState.Closed != cmd.Connection.State) cmd.Connection.Close(); } return inst; } private SqlTrackingWorkflowInstance BuildInstance(SqlDataReader reader) { return SqlTrackingQuery.BuildInstance(reader, _connectionString); } internal static SqlTrackingWorkflowInstance BuildInstance(SqlDataReader reader, string connectionString) { if (null == reader) throw new ArgumentNullException("reader"); if (reader.IsClosed) throw new ArgumentException(ExecutionStringManager.InvalidSqlDataReader, "reader"); SqlTrackingWorkflowInstance inst = new SqlTrackingWorkflowInstance(connectionString); inst.WorkflowInstanceId = reader.GetGuid(1); inst.WorkflowInstanceInternalId = reader.GetInt64(2); inst.Initialized = reader.GetDateTime(3); if (DBNull.Value == reader[4]) inst.InvokingWorkflowInstanceId = Guid.Empty; else inst.InvokingWorkflowInstanceId = reader.GetGuid(4); inst.Status = (WorkflowStatus)reader.GetInt32(5); // // Xaml only workflows do not have types if (!reader.IsDBNull(6)) { string fullName = reader.GetString(6), assemblyName = reader.GetString(7); inst.WorkflowType = Type.GetType(fullName + ", " + assemblyName, true, false); } return inst; } private SqlConnection GetConnection() { if (null == _connectionString) { throw new InvalidOperationException(ExecutionStringManager.MissingConnectionString); } SqlConnection conn = new SqlConnection(_connectionString); conn.Open(); return conn; } private SqlCommand BuildCommand(Guid workflowInstanceId) { SqlCommand cmd = new SqlCommand("[dbo].[GetWorkflows]"); cmd.CommandType = CommandType.StoredProcedure; SqlParameter param = new SqlParameter(); param.ParameterName = "@WorkflowInstanceId"; param.SqlDbType = SqlDbType.UniqueIdentifier; param.Value = workflowInstanceId; cmd.Parameters.Add(param); return cmd; } private SqlCommand BuildCommand(SqlTrackingQueryOptions opt) { SqlCommand cmd = new SqlCommand("[dbo].[GetWorkflows]"); cmd.CommandType = CommandType.StoredProcedure; SqlParameter param = new SqlParameter(); if (opt.WorkflowStatus.HasValue) { param.ParameterName = "@WorkflowStatusId"; param.SqlDbType = SqlDbType.TinyInt; param.Value = opt.WorkflowStatus.Value; cmd.Parameters.Add(param); // // If one of the range values is set we have a date range constraint if (DateTime.MinValue != opt.StatusMinDateTime || DateTime.MaxValue != opt.StatusMaxDateTime) { param = new SqlParameter(); param.ParameterName = "@StatusMinDateTime"; param.SqlDbType = SqlDbType.DateTime; if (opt.StatusMinDateTime < SqlDateTime.MinValue.Value) param.Value = SqlDateTime.MinValue.Value; else param.Value = opt.StatusMinDateTime; cmd.Parameters.Add(param); param = new SqlParameter(); param.ParameterName = "@StatusMaxDateTime"; param.SqlDbType = SqlDbType.DateTime; if (opt.StatusMaxDateTime > SqlDateTime.MaxValue.Value) param.Value = SqlDateTime.MaxValue.Value; else param.Value = opt.StatusMaxDateTime; cmd.Parameters.Add(param); } } if (null != opt.WorkflowType) { param = new SqlParameter("@TypeFullName", opt.WorkflowType.FullName); param.SqlDbType = SqlDbType.NVarChar; param.Size = 128; cmd.Parameters.Add(param); param = new SqlParameter("@AssemblyFullName", opt.WorkflowType.Assembly.FullName); param.SqlDbType = SqlDbType.NVarChar; param.Size = 128; cmd.Parameters.Add(param); } if (null != opt.TrackingDataItems && opt.TrackingDataItems.Count > 0) BuildArtifactParameters(cmd, opt.TrackingDataItems); return cmd; } private void BuildArtifactParameters(SqlCommand cmd, IList artifacts) { if (null == artifacts || 0 == artifacts.Count) return; StringBuilder sb = new StringBuilder(); XmlWriter writer = XmlWriter.Create(sb); try { writer.WriteStartDocument(); writer.WriteStartElement("TrackingDataItems"); foreach (TrackingDataItemValue art in artifacts) { writer.WriteStartElement("TrackingDataItem"); writer.WriteElementString("QualifiedName", art.QualifiedName); writer.WriteElementString("FieldName", art.FieldName); // // If data value is null don't write the node as // the proc sees no DataValue node as null and matches null rows. // This allows us to match null, "", and positive length strings if (null != art.DataValue) writer.WriteElementString("DataValue", art.DataValue); writer.WriteEndElement(); } writer.WriteEndElement(); writer.WriteEndDocument(); } finally { writer.Flush(); writer.Close(); } SqlParameter param = new SqlParameter(); param.ParameterName = "@TrackingDataItems"; param.SqlDbType = SqlDbType.NText; param.Value = sb.ToString(); cmd.Parameters.Add(param); } } public class SqlTrackingQueryOptions { private DateTime _min = DateTime.MinValue, _max = DateTime.MaxValue; private WorkflowStatus? _status = new Nullable (); private Type _type = null; private List _dataItems = new List (); public Type WorkflowType { get { return _type; } set { _type = value; } } public WorkflowStatus? WorkflowStatus { get { return _status; } set { _status = value; } } public DateTime StatusMinDateTime { get { return _min; } set { _min = value; } } public DateTime StatusMaxDateTime { get { return _max; } set { _max = value; } } public IList TrackingDataItems { get { return _dataItems; } } public void Clear() { _min = DateTime.MinValue; _max = DateTime.MaxValue; _status = new Nullable (); _type = null; _dataItems = new List (); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved. using System; using System.Data; using System.Data.SqlClient; using System.Data.SqlTypes; using System.Collections; using System.Collections.Generic; using System.Text; using System.Xml; using System.Reflection; using System.IO; using System.Runtime.Serialization.Formatters.Binary; using System.ComponentModel.Design.Serialization; using System.Workflow.Runtime; using System.Workflow.ComponentModel; using System.Workflow.ComponentModel.Serialization; using System.Workflow.Runtime.Hosting; namespace System.Workflow.Runtime.Tracking { public sealed class SqlTrackingQuery { string _connectionString = null; public SqlTrackingQuery() { } public SqlTrackingQuery(string connectionString) { if (null == connectionString) throw new ArgumentNullException("connectionString"); _connectionString = connectionString; } public string ConnectionString { get { return _connectionString; } set { if (null == value) throw new ArgumentNullException("value"); _connectionString = value; } } public bool TryGetWorkflow(Guid workflowInstanceId, out SqlTrackingWorkflowInstance workflowInstance) { SqlCommand cmd = BuildCommand(workflowInstanceId); SqlDataReader reader = null; workflowInstance = null; try { cmd.Connection = GetConnection(); reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); // // There will only be 1 row if (reader.Read()) { workflowInstance = BuildInstance(reader); return true; } else return false; } finally { if (null != reader) reader.Close(); if (null != cmd && null != cmd.Connection && ConnectionState.Closed != cmd.Connection.State) cmd.Connection.Close(); } } public IList GetWorkflows(SqlTrackingQueryOptions options) { if (null == options) throw new ArgumentNullException("options"); if (null != options.TrackingDataItems) { foreach (TrackingDataItemValue val in options.TrackingDataItems) { if (null == val.QualifiedName) throw new ArgumentNullException("options.TrackingDataItems.QualifiedName"); if (null == val.FieldName) throw new ArgumentNullException("options.TrackingDataItems.FieldName"); } } SqlCommand cmd = BuildCommand(options); SqlDataReader reader = null; List inst = new List (); try { cmd.Connection = GetConnection(); reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); // // There will only be 1 row while (reader.Read()) { inst.Add(BuildInstance(reader)); } } finally { if (null != reader) reader.Close(); if (null != cmd && null != cmd.Connection && ConnectionState.Closed != cmd.Connection.State) cmd.Connection.Close(); } return inst; } private SqlTrackingWorkflowInstance BuildInstance(SqlDataReader reader) { return SqlTrackingQuery.BuildInstance(reader, _connectionString); } internal static SqlTrackingWorkflowInstance BuildInstance(SqlDataReader reader, string connectionString) { if (null == reader) throw new ArgumentNullException("reader"); if (reader.IsClosed) throw new ArgumentException(ExecutionStringManager.InvalidSqlDataReader, "reader"); SqlTrackingWorkflowInstance inst = new SqlTrackingWorkflowInstance(connectionString); inst.WorkflowInstanceId = reader.GetGuid(1); inst.WorkflowInstanceInternalId = reader.GetInt64(2); inst.Initialized = reader.GetDateTime(3); if (DBNull.Value == reader[4]) inst.InvokingWorkflowInstanceId = Guid.Empty; else inst.InvokingWorkflowInstanceId = reader.GetGuid(4); inst.Status = (WorkflowStatus)reader.GetInt32(5); // // Xaml only workflows do not have types if (!reader.IsDBNull(6)) { string fullName = reader.GetString(6), assemblyName = reader.GetString(7); inst.WorkflowType = Type.GetType(fullName + ", " + assemblyName, true, false); } return inst; } private SqlConnection GetConnection() { if (null == _connectionString) { throw new InvalidOperationException(ExecutionStringManager.MissingConnectionString); } SqlConnection conn = new SqlConnection(_connectionString); conn.Open(); return conn; } private SqlCommand BuildCommand(Guid workflowInstanceId) { SqlCommand cmd = new SqlCommand("[dbo].[GetWorkflows]"); cmd.CommandType = CommandType.StoredProcedure; SqlParameter param = new SqlParameter(); param.ParameterName = "@WorkflowInstanceId"; param.SqlDbType = SqlDbType.UniqueIdentifier; param.Value = workflowInstanceId; cmd.Parameters.Add(param); return cmd; } private SqlCommand BuildCommand(SqlTrackingQueryOptions opt) { SqlCommand cmd = new SqlCommand("[dbo].[GetWorkflows]"); cmd.CommandType = CommandType.StoredProcedure; SqlParameter param = new SqlParameter(); if (opt.WorkflowStatus.HasValue) { param.ParameterName = "@WorkflowStatusId"; param.SqlDbType = SqlDbType.TinyInt; param.Value = opt.WorkflowStatus.Value; cmd.Parameters.Add(param); // // If one of the range values is set we have a date range constraint if (DateTime.MinValue != opt.StatusMinDateTime || DateTime.MaxValue != opt.StatusMaxDateTime) { param = new SqlParameter(); param.ParameterName = "@StatusMinDateTime"; param.SqlDbType = SqlDbType.DateTime; if (opt.StatusMinDateTime < SqlDateTime.MinValue.Value) param.Value = SqlDateTime.MinValue.Value; else param.Value = opt.StatusMinDateTime; cmd.Parameters.Add(param); param = new SqlParameter(); param.ParameterName = "@StatusMaxDateTime"; param.SqlDbType = SqlDbType.DateTime; if (opt.StatusMaxDateTime > SqlDateTime.MaxValue.Value) param.Value = SqlDateTime.MaxValue.Value; else param.Value = opt.StatusMaxDateTime; cmd.Parameters.Add(param); } } if (null != opt.WorkflowType) { param = new SqlParameter("@TypeFullName", opt.WorkflowType.FullName); param.SqlDbType = SqlDbType.NVarChar; param.Size = 128; cmd.Parameters.Add(param); param = new SqlParameter("@AssemblyFullName", opt.WorkflowType.Assembly.FullName); param.SqlDbType = SqlDbType.NVarChar; param.Size = 128; cmd.Parameters.Add(param); } if (null != opt.TrackingDataItems && opt.TrackingDataItems.Count > 0) BuildArtifactParameters(cmd, opt.TrackingDataItems); return cmd; } private void BuildArtifactParameters(SqlCommand cmd, IList artifacts) { if (null == artifacts || 0 == artifacts.Count) return; StringBuilder sb = new StringBuilder(); XmlWriter writer = XmlWriter.Create(sb); try { writer.WriteStartDocument(); writer.WriteStartElement("TrackingDataItems"); foreach (TrackingDataItemValue art in artifacts) { writer.WriteStartElement("TrackingDataItem"); writer.WriteElementString("QualifiedName", art.QualifiedName); writer.WriteElementString("FieldName", art.FieldName); // // If data value is null don't write the node as // the proc sees no DataValue node as null and matches null rows. // This allows us to match null, "", and positive length strings if (null != art.DataValue) writer.WriteElementString("DataValue", art.DataValue); writer.WriteEndElement(); } writer.WriteEndElement(); writer.WriteEndDocument(); } finally { writer.Flush(); writer.Close(); } SqlParameter param = new SqlParameter(); param.ParameterName = "@TrackingDataItems"; param.SqlDbType = SqlDbType.NText; param.Value = sb.ToString(); cmd.Parameters.Add(param); } } public class SqlTrackingQueryOptions { private DateTime _min = DateTime.MinValue, _max = DateTime.MaxValue; private WorkflowStatus? _status = new Nullable (); private Type _type = null; private List _dataItems = new List (); public Type WorkflowType { get { return _type; } set { _type = value; } } public WorkflowStatus? WorkflowStatus { get { return _status; } set { _status = value; } } public DateTime StatusMinDateTime { get { return _min; } set { _min = value; } } public DateTime StatusMaxDateTime { get { return _max; } set { _max = value; } } public IList TrackingDataItems { get { return _dataItems; } } public void Clear() { _min = DateTime.MinValue; _max = DateTime.MaxValue; _status = new Nullable (); _type = null; _dataItems = new List (); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- HtmlInputSubmit.cs
- HttpRequestCacheValidator.cs
- RegularExpressionValidator.cs
- _UriSyntax.cs
- SelectedDatesCollection.cs
- Timer.cs
- SHA1.cs
- AspNetCompatibilityRequirementsAttribute.cs
- WindowsButton.cs
- DesignerOptionService.cs
- Quaternion.cs
- HeaderPanel.cs
- InheritanceContextChangedEventManager.cs
- DispatcherFrame.cs
- DetailsViewDeletedEventArgs.cs
- NavigationEventArgs.cs
- HtmlEmptyTagControlBuilder.cs
- SurrogateSelector.cs
- OutputCacheSection.cs
- WebPartManagerInternals.cs
- Visitors.cs
- FileInfo.cs
- RequiredFieldValidator.cs
- BitmapEffect.cs
- EntityDataSourceEntityTypeFilterConverter.cs
- UnionExpr.cs
- DataGridViewCellStyle.cs
- TypeReference.cs
- System.Data_BID.cs
- UserPreferenceChangingEventArgs.cs
- DesignTimeTemplateParser.cs
- XmlArrayItemAttribute.cs
- Size3DValueSerializer.cs
- StandardCommands.cs
- UnsafeNativeMethods.cs
- ClipboardProcessor.cs
- WindowsToolbar.cs
- CodeGotoStatement.cs
- BamlResourceContent.cs
- DataSourceCache.cs
- Highlights.cs
- UdpUtility.cs
- HttpUnhandledOperationInvoker.cs
- CompareValidator.cs
- X509ImageLogo.cs
- GridSplitterAutomationPeer.cs
- ProfileGroupSettingsCollection.cs
- CachedPathData.cs
- InvalidOleVariantTypeException.cs
- RequestUriProcessor.cs
- Panel.cs
- SetUserPreferenceRequest.cs
- TextAdaptor.cs
- FamilyTypeface.cs
- DoubleAnimationBase.cs
- AssemblyCache.cs
- IntranetCredentialPolicy.cs
- IIS7UserPrincipal.cs
- NamedPipeHostedTransportConfiguration.cs
- EventDescriptorCollection.cs
- StorageModelBuildProvider.cs
- SecurityUtils.cs
- CoTaskMemHandle.cs
- SrgsOneOf.cs
- CssTextWriter.cs
- DispatcherSynchronizationContext.cs
- AutomationAttributeInfo.cs
- StringArrayConverter.cs
- GPStream.cs
- LookupBindingPropertiesAttribute.cs
- DataServiceQueryProvider.cs
- SqlDataSourceTableQuery.cs
- InstanceKey.cs
- ProcessThread.cs
- DataSourceSerializationException.cs
- SmtpCommands.cs
- XPathDocumentNavigator.cs
- XmlNavigatorStack.cs
- ErasingStroke.cs
- HTMLTagNameToTypeMapper.cs
- PreloadHost.cs
- WebPartEditorApplyVerb.cs
- DependencyObject.cs
- RectangleF.cs
- FastPropertyAccessor.cs
- IfAction.cs
- RNGCryptoServiceProvider.cs
- OrderedDictionary.cs
- CreateUserErrorEventArgs.cs
- Listbox.cs
- PolicyManager.cs
- RealizationContext.cs
- MemberAccessException.cs
- Part.cs
- LogSwitch.cs
- HttpListener.cs
- Matrix3DValueSerializer.cs
- Queue.cs
- DynamicDataResources.Designer.cs
- FlagsAttribute.cs