1 write to _escapedQueueName
System.Data (1)
fx\src\data\System\Data\SqlClient\SqlDependencyListener.cs (1)
140
_escapedQueueName
= SqlConnection.FixupDatabaseTransactionName(_queue); // Properly escape to prevent SQL Injection.
12 references to _escapedQueueName
System.Data (12)
fx\src\data\System\Data\SqlClient\SqlDependencyListener.cs (12)
161
_receiveQuery = "WAITFOR(RECEIVE TOP (1) message_type_name, conversation_handle, cast(message_body AS XML) as message_body from " +
_escapedQueueName
+ "), TIMEOUT @p2;";
374
+ " RECEIVE TOP(0) conversation_handle FROM "+
_escapedQueueName
+";"
375
+ " IF (SELECT COUNT(*) FROM "+
_escapedQueueName
+" WHERE message_type_name = 'http://schemas.microsoft.com/SQL/ServiceBroker/DialogTimer') > 0"
378
+ " DROP SERVICE " +
_escapedQueueName
+ ";"
380
+ " DROP QUEUE " +
_escapedQueueName
+ ";"
423
+ " CREATE QUEUE "+
_escapedQueueName
+" WITH ACTIVATION (PROCEDURE_NAME="+_sprocName+", MAX_QUEUE_READERS=1, EXECUTE AS OWNER);"
427
+ " CREATE SERVICE "+
_escapedQueueName
+" ON QUEUE "+
_escapedQueueName
+" ([http://schemas.microsoft.com/SQL/Notifications/PostQueryNotification]);"
430
+ " GRANT SEND ON SERVICE::"+
_escapedQueueName
+" TO sql_dependency_subscriber;"
433
+ " BEGIN DIALOG @dialog_handle FROM SERVICE "+
_escapedQueueName
+" TO SERVICE "+nameLiteral;
901
_com.CommandText = "BEGIN TRANSACTION; DROP SERVICE "+
_escapedQueueName
+"; DROP QUEUE "+
_escapedQueueName
+"; DROP PROCEDURE "+_sprocName+"; COMMIT TRANSACTION;";