2 writes to dbResourceAllocator
System.Workflow.Runtime (2)
Hosting\SqlWorkflowPersistenceService.cs (2)
88this.dbResourceAllocator = dbResourceAllocator; 106this.dbResourceAllocator = dbResourceAllocator;
36 references to dbResourceAllocator
System.Workflow.Runtime (36)
Hosting\SqlWorkflowPersistenceService.cs (36)
93this.connection = this.dbResourceAllocator.GetEnlistedConnection( 115conn = this.dbResourceAllocator.OpenNewConnection(); 176command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@uidInstanceID", item.InstanceId)); 177command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@state", item.SerializedActivity)); 178command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@status", item.Status)); 179command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@unlocked", item.Unlocked)); 180command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@blocked", item.Blocked)); 181command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@info", item.Info)); 182command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownedUntil", ownedUntil == DateTime.MaxValue ? SqlDateTime.MaxValue : ownedUntil)); 183command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownerID", DbOwnerId(ownerId))); 184command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@nextTimer", item.NextTimer)); 185DbParameter p1 = this.dbResourceAllocator.NewDbParameter(); 192DbParameter p2 = this.dbResourceAllocator.NewDbParameter(); 218command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("instanceID", instanceId)); 219command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("completedScopeID", scopeId)); 220command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("state", state)); 234command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@uidInstanceID", instanceId)); 235command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownerID", DbOwnerId(ownerId))); 258command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownedUntil", ownedUntil == DateTime.MaxValue ? SqlDateTime.MaxValue : ownedUntil)); 259command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownerID", DbOwnerId(ownerId))); 260command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@now", DateTime.UtcNow)); 307command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownedUntil", ownedUntil == DateTime.MaxValue ? SqlDateTime.MaxValue : ownedUntil)); 308command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownerID", DbOwnerId(ownerId))); 309DbParameter p2 = this.dbResourceAllocator.NewDbParameter(); 317DbParameter found = this.dbResourceAllocator.NewDbParameter(); 372command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownedUntil", ownedUntil == DateTime.MaxValue ? SqlDateTime.MaxValue : ownedUntil)); 373command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownerID", DbOwnerId(ownerId))); 374command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@now", DateTime.UtcNow)); 422command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@uidInstanceID", instanceStateId)); 423command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownerID", DbOwnerId(ownerId))); 424command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@ownedUntil", timeout == DateTime.MaxValue ? SqlDateTime.MaxValue : timeout)); 425DbParameter p1 = this.dbResourceAllocator.NewDbParameter(); 432DbParameter p2 = this.dbResourceAllocator.NewDbParameter(); 492command.Parameters.Add(this.dbResourceAllocator.NewDbParameter("@completedScopeID", scopeId)); 493DbParameter p1 = this.dbResourceAllocator.NewDbParameter(); 552connection = this.dbResourceAllocator.OpenNewConnection();