2 writes to _com
System.Data (2)
fx\src\data\System\Data\SqlClient\SqlDependencyListener.cs (2)
142_com = new SqlCommand(); 201_com = null;
27 references to _com
System.Data (27)
fx\src\data\System\Data\SqlClient\SqlDependencyListener.cs (27)
143_com.Connection = _con; 146_com.CommandText = "select is_broker_enabled from sys.databases where database_id=db_id()"; 148if (!(bool) _com.ExecuteScalar()) { 155_com.Parameters.Add(_timeoutParam); 172_com.CommandText = _receiveQuery; 199if (_com != null) { 200_com.Dispose(); 307_com.BeginExecuteReader(callback, null); // NO LOCK NEEDED 318using (SqlDataReader reader = _com.EndExecuteReader(asyncResult)) { 446_com.CommandText = _beginConversationQuery; 448_concatQuery = _endConversationQuery + _com.CommandText; 582_com.CommandText = (null != _beginConversationQuery) ? _beginConversationQuery : _receiveQuery; // If we're doing the initial query, we won't have a conversation Guid to begin yet. 583if (_com.Parameters.Count > 1) { // Remove conversation param since next execute is only query. 584_com.Parameters.Remove(_conversationGuidParam); 586Debug.Assert(_com.Parameters.Count == 1, "Unexpected number of parameters!"); 589_com.CommandText = _concatQuery; // END query + WAITFOR RECEIVE query. 591if (_com.Parameters.Count == 1) { // Add parameter if previous execute was only query. 592_com.Parameters.Add(_conversationGuidParam); 594Debug.Assert(_com.Parameters.Count == 2, "Unexpected number of parameters!"); 791_com.Cancel(); // Cancel the pending command. No-op if connection closed. 855using (SqlDataReader reader = _com.ExecuteReader()) { 873if (_com.Parameters.Count > 1) { // Need to close dialog before completing. 881_com.CommandText = _endConversationQuery; 882_com.Parameters.Remove(_timeoutParam); 883_com.ExecuteNonQuery(); 901_com.CommandText = "BEGIN TRANSACTION; DROP SERVICE "+_escapedQueueName+"; DROP QUEUE "+_escapedQueueName+"; DROP PROCEDURE "+_sprocName+"; COMMIT TRANSACTION;"; 903_com.ExecuteNonQuery();