Merge pull request #2944 from Adedba/2887-sp_BlitzWho---Add-@GetOuterCommand-to-get-contents-of-the-inputbuffer-per-session_id

2887 sp blitz who add @get outer command to get contents of the inputbuffer per session

Author: BrentOzar

sp_BlitzWho.sql

@@ -21,6 +21,7 @@ ALTER PROCEDURE dbo.sp_BlitzWho
 	@MinBlockingSeconds INT = 0 ,
 	@CheckDateOverride DATETIMEOFFSET = NULL,
 	@ShowActualParameters BIT = 0,
+	@GetOuterCommand BIT = 0,
 	@Version     VARCHAR(30) = NULL OUTPUT,
 	@VersionDate DATETIME = NULL OUTPUT,
     @VersionCheckMode BIT = 0,
@@ -161,6 +162,7 @@ IF @OutputDatabaseName IS NOT NULL AND @OutputSchemaName IS NOT NULL AND @Output
 	[session_id] [smallint] NOT NULL,
 	[database_name] [nvarchar](128) NULL,
 	[query_text] [nvarchar](max) NULL,
+	[outer_command] NVARCHAR(4000) NULL,
 	[query_plan] [xml] NULL,
 	[live_query_plan] [xml] NULL,
 	[cached_parameter_info] [nvarchar](max) NULL,
@@ -277,6 +279,13 @@ IF @OutputDatabaseName IS NOT NULL AND @OutputSchemaName IS NOT NULL AND @Output
 		ALTER TABLE ' + @ObjectFullName + N' ADD live_parameter_info NVARCHAR(MAX) NULL;';
 	EXEC(@StringToExecute);
 
+	/* If the table doesn't have the new outer_command column, add it. See Github #2887. */
+	SET @ObjectFullName = @OutputDatabaseName + N'.' + @OutputSchemaName + N'.' +  @OutputTableName;
+	SET @StringToExecute = N'IF NOT EXISTS (SELECT * FROM ' + @OutputDatabaseName + N'.sys.all_columns 
+		WHERE object_id = (OBJECT_ID(''' + @ObjectFullName + N''')) AND name = ''outer_command'')
+		ALTER TABLE ' + @ObjectFullName + N' ADD outer_command NVARCHAR(4000) NULL;';
+	EXEC(@StringToExecute);
+
 	/* Delete history older than @OutputTableRetentionDays */
 	SET @OutputTableCleanupDate = CAST( (DATEADD(DAY, -1 * @OutputTableRetentionDays, GETDATE() ) ) AS DATE);
 	SET @StringToExecute = N' IF EXISTS(SELECT * FROM '
@@ -574,7 +583,64 @@ SELECT @BlockingCheck = N'SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
 						FROM sys.sysprocesses AS sys1
 						JOIN sys.sysprocesses AS sys2
 						ON sys1.spid = sys2.blocked;
+						'+CASE
+							WHEN (@GetOuterCommand = 1 AND (NOT EXISTS(SELECT 1 FROM sys.all_objects WHERE [name] = N'dm_exec_input_buffer'))) THEN N'
+						DECLARE @session_id SMALLINT;
+						DECLARE @Sessions TABLE 
+						(
+							session_id INT
+						);
+
+						DECLARE @inputbuffer TABLE 
+						(
+						ID INT IDENTITY(1,1),
+						session_id INT,
+						event_type	NVARCHAR(30),
+						parameters	SMALLINT,
+						event_info	NVARCHAR(4000)
+						);
+
+						DECLARE inputbuffer_cursor
+						
+						CURSOR LOCAL FAST_FORWARD
+						FOR 
+						SELECT session_id
+						FROM sys.dm_exec_sessions
+						WHERE session_id <> @@SPID
+						AND is_user_process = 1;
+						
+						OPEN inputbuffer_cursor;
+						
+						FETCH NEXT FROM inputbuffer_cursor INTO @session_id;
+						
+						WHILE (@@FETCH_STATUS = 0)
+						BEGIN;
+							BEGIN TRY;
+
+								INSERT INTO @inputbuffer ([event_type],[parameters],[event_info])
+								EXEC sp_executesql
+									N''DBCC INPUTBUFFER(@session_id) WITH NO_INFOMSGS;'',
+									N''@session_id SMALLINT'',
+									@session_id;
+						
+								UPDATE @inputbuffer 
+								SET session_id = @session_id 
+								WHERE ID = SCOPE_IDENTITY();
 
+							END TRY
+							BEGIN CATCH
+								RAISERROR(''DBCC inputbuffer failed for session %d'',0,0,@session_id) WITH NOWAIT;
+							END CATCH;
+						
+							FETCH NEXT FROM inputbuffer_cursor INTO @session_id
+						
+						END;
+						
+						CLOSE inputbuffer_cursor;
+						DEALLOCATE inputbuffer_cursor;'
+						ELSE N''
+						END+
+						N' 
 
 						DECLARE @LiveQueryPlans TABLE
 						(
@@ -583,7 +649,6 @@ SELECT @BlockingCheck = N'SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
 						);
 
 						'
-
 IF EXISTS (SELECT * FROM sys.all_columns WHERE object_id = OBJECT_ID('sys.dm_exec_query_statistics_xml') AND name = 'query_plan')
 BEGIN
 	SET @BlockingCheck = @BlockingCheck + N'
@@ -610,6 +675,10 @@ BEGIN
 			               ELSE query_stats.statement_end_offset
 			             END - query_stats.statement_start_offset )
 			              / 2 ) + 1), dest.text) AS query_text ,
+						  '+CASE
+								WHEN @GetOuterCommand = 1 THEN N'CAST(event_info AS NVARCHAR(4000)) AS outer_command,'
+							ELSE N''
+							END+N'
 			       derp.query_plan ,
 						    qmg.query_cost ,										   		   
 						    s.status ,
@@ -729,6 +798,14 @@ BEGIN
 
     SET @StringToExecute += 			 
 	    N'FROM sys.dm_exec_sessions AS s
+			 '+
+			 CASE
+				WHEN @GetOuterCommand = 1 THEN CASE
+													WHEN EXISTS(SELECT 1 FROM sys.all_objects WHERE [name] = N'dm_exec_input_buffer') THEN N'OUTER APPLY sys.dm_exec_input_buffer (s.session_id, 0) AS ib'
+													ELSE N'LEFT JOIN @inputbuffer ib ON s.session_id = ib.session_id'
+												END
+				ELSE N''
+			 END+N'
 			 LEFT JOIN sys.dm_exec_requests AS r
 			 ON   r.session_id = s.session_id
 			 LEFT JOIN ( SELECT DISTINCT
@@ -815,6 +892,10 @@ IF @ProductVersionMajor >= 11
 			               ELSE query_stats.statement_end_offset
 			             END - query_stats.statement_start_offset )
 			              / 2 ) + 1), dest.text) AS query_text ,
+						  '+CASE
+								WHEN @GetOuterCommand = 1 THEN N'CAST(event_info AS NVARCHAR(4000)) AS outer_command,'
+							ELSE N''
+							END+N'
 			       derp.query_plan ,
 				   CAST(COALESCE(qs_live.Query_Plan, ''<?No live query plan available. To turn on live plans, see https://www.BrentOzar.com/go/liveplans ?>'') AS XML) AS live_query_plan ,
 					STUFF((SELECT DISTINCT N'', '' + Node.Data.value(''(@Column)[1]'', ''NVARCHAR(4000)'') + N'' {'' + Node.Data.value(''(@ParameterDataType)[1]'', ''NVARCHAR(4000)'') + N''}: '' + Node.Data.value(''(@ParameterCompiledValue)[1]'', ''NVARCHAR(4000)'')
@@ -992,7 +1073,16 @@ IF @ProductVersionMajor >= 11
     END /* IF @ExpertMode = 1 */
 
     SET @StringToExecute += 	
-	    N' FROM sys.dm_exec_sessions AS s
+	    N' FROM sys.dm_exec_sessions AS s'+
+			 CASE
+				WHEN @GetOuterCommand = 1 THEN CASE
+													WHEN EXISTS(SELECT 1 FROM sys.all_objects WHERE [name] = N'dm_exec_input_buffer') THEN N'
+		OUTER APPLY sys.dm_exec_input_buffer (s.session_id, 0) AS ib'
+													ELSE N'
+		LEFT JOIN @inputbuffer ib ON s.session_id = ib.session_id'
+											   END
+				ELSE N''
+			 END+N'
 	    LEFT JOIN sys.dm_exec_requests AS r
 					    ON   r.session_id = s.session_id
 	    LEFT JOIN ( SELECT DISTINCT
@@ -1146,7 +1236,8 @@ IF @OutputDatabaseName IS NOT NULL AND @OutputSchemaName IS NOT NULL AND @Output
 	,[elapsed_time]
 	,[session_id]
 	,[database_name]
-	,[query_text]
+	,[query_text]'
+	+ CASE WHEN @GetOuterCommand = 1 THEN N',[outer_command]' ELSE N'' END + N'
 	,[query_plan]'
     + CASE WHEN @ProductVersionMajor >= 11 THEN N',[live_query_plan]' ELSE N'' END 
 	+ CASE WHEN @ProductVersionMajor >= 11 THEN N',[cached_parameter_info]'  ELSE N'' END