Limits analysis to each SPID's session

Yeehaw

Author: BlitzErik

sp_BlitzCache.sql

@@ -1682,6 +1682,7 @@ RAISERROR(N'Attempting to aggregate stored proc info from separate statements',
         SUM(b.LastReturnedRows) AS LastReturnedRows
     FROM ##bou_BlitzCacheProcs b
     WHERE b.QueryHash IS NOT NULL 
+	AND b.SPID = @@SPID
     GROUP BY b.SqlHandle
 )
 UPDATE b
@@ -1695,6 +1696,7 @@ FROM ##bou_BlitzCacheProcs b
 JOIN agg b2
 ON b2.SqlHandle = b.SqlHandle
 WHERE b.QueryHash IS NULL
+AND b.SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 /* Compute the total CPU, etc across our active set of the plan cache.
@@ -1760,6 +1762,7 @@ FROM (
                 LastExecutionTime
         FROM    ##bou_BlitzCacheProcs
         WHERE   PlanHandle IS NOT NULL
+		AND SPID = @@SPID
         GROUP BY PlanHandle,
                 TotalCPU,
                 TotalDuration,
@@ -1772,6 +1775,7 @@ FROM (
 ) AS y
 WHERE ##bou_BlitzCacheProcs.PlanHandle = y.PlanHandle
       AND ##bou_BlitzCacheProcs.PlanHandle IS NOT NULL
+	  AND ##bou_BlitzCacheProcs.SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -1817,6 +1821,7 @@ FROM (
                 PlanCreationTime,
                 LastExecutionTime
         FROM    ##bou_BlitzCacheProcs
+		WHERE SPID = @@SPID
         GROUP BY DatabaseName,
                 SqlHandle,
                 QueryHash,
@@ -1847,6 +1852,7 @@ SELECT  QueryHash ,
 INTO    #statements
 FROM    ##bou_BlitzCacheProcs p
         CROSS APPLY p.QueryPlan.nodes('//p:StmtSimple') AS q(n) 
+WHERE p.SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 WITH XMLNAMESPACES('http://schemas.microsoft.com/sqlserver/2004/07/showplan' AS p)
@@ -1890,6 +1896,7 @@ FROM (
                 COUNT(QueryHash) AS number_of_plans,
                 QueryHash
         FROM    ##bou_BlitzCacheProcs
+		WHERE SPID = @@SPID
         GROUP BY QueryHash
 ) AS x
 WHERE ##bou_BlitzCacheProcs.QueryHash = x.QueryHash
@@ -1915,6 +1922,7 @@ SET     QueryPlanCost = CASE WHEN QueryType LIKE '%Stored Procedure%' THEN
                                 END
 FROM    #statements s
 WHERE   s.QueryHash = ##bou_BlitzCacheProcs.QueryHash
+AND SPID = @@SPID
 OPTION (RECOMPILE);
 
 --Gather Stored Proc costs
@@ -1947,6 +1955,7 @@ RAISERROR(N'Gathering stored procedure costs', 0, 1) WITH NOWAIT;
   FROM QueryCostUpdate qcu
     JOIN  ##bou_BlitzCacheProcs AS b
   ON qcu.SqlHandle = b.SqlHandle
+  AND b.SPID = @@SPID
 OPTION (RECOMPILE);
 
 -- query level checks
@@ -1965,6 +1974,7 @@ SET     missing_index_count = query_plan.value('count(/p:QueryPlan/p:MissingInde
 		is_forced_serial = CASE WHEN query_plan.value('count(/p:QueryPlan/@NonParallelPlanReason)', 'int') > 0 THEN 1 END
 FROM    #query_plan qp
 WHERE   qp.QueryHash = ##bou_BlitzCacheProcs.QueryHash
+AND SPID = @@SPID
 OPTION (RECOMPILE);
 
 -- operator level checks
@@ -1989,6 +1999,7 @@ FROM   ##bou_BlitzCacheProcs p
 				   relop.exist('/p:RelOp/p:Warnings') AS relop_warnings
             FROM   #relop qs
        ) AS x ON p.SqlHandle = x.SqlHandle
+WHERE SPID = @@SPID
 OPTION (RECOMPILE);
 
 
@@ -2006,6 +2017,7 @@ SET	   p.function_count = x.function_count,
 	   p.clr_function_count = x.clr_function_count
 FROM ##bou_BlitzCacheProcs AS p
 JOIN x ON x.QueryHash = p.QueryHash
+AND SPID = @@SPID
 OPTION (RECOMPILE);
 
 
@@ -2021,6 +2033,7 @@ FROM   #relop qs
 WHERE [relop].exist('/p:RelOp/p:IndexScan[(@Lookup[.="1"])]') = 1
 ) AS x
 WHERE ##bou_BlitzCacheProcs.SqlHandle = x.SqlHandle
+AND SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -2036,6 +2049,7 @@ FROM   #relop qs
 WHERE [relop].exist('/p:RelOp[(@PhysicalOp[contains(., "Remote")])]') = 1
 ) AS x
 WHERE ##bou_BlitzCacheProcs.SqlHandle = x.SqlHandle
+AND SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 RAISERROR(N'Checking for expensive sorts', 0, 1) WITH NOWAIT;
@@ -2051,6 +2065,7 @@ FROM   #relop qs
 WHERE [relop].exist('/p:RelOp[(@PhysicalOp[.="Sort"])]') = 1
 ) AS x
 WHERE ##bou_BlitzCacheProcs.SqlHandle = x.SqlHandle
+AND SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 RAISERROR(N'Checking for icky cursors', 0, 1) WITH NOWAIT;
@@ -2062,6 +2077,7 @@ FROM ##bou_BlitzCacheProcs b
 JOIN #statements AS qs
 ON b.QueryHash = qs.QueryHash
 CROSS APPLY qs.statement.nodes('/p:StmtCursor') AS n1(fn)
+WHERE SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -2096,6 +2112,7 @@ SELECT
 FROM   #relop qs
 CROSS APPLY qs.relop.nodes('//p:TableScan') AS q(n)
 ) AS x ON b.SqlHandle = x.SqlHandle
+WHERE SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -2111,6 +2128,7 @@ FROM   #relop qs
 WHERE [relop].exist('/p:RelOp/p:IndexScan[(@Storage[.="ColumnStore"])]') = 1
 ) AS x
 WHERE ##bou_BlitzCacheProcs.SqlHandle = x.SqlHandle
+AND SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -2126,6 +2144,7 @@ CROSS APPLY relop.nodes('/p:RelOp/p:ComputeScalar/p:DefinedValues/p:DefinedValue
 WHERE n.fn.exist('/p:RelOp/p:ComputeScalar/p:DefinedValues/p:DefinedValue/p:ColumnReference[(@ComputedColumn[.="1"])]') = 1
 ) AS x
 WHERE ##bou_BlitzCacheProcs.SqlHandle = x.SqlHandle
+AND SPID = @@SPID
 OPTION (RECOMPILE)
 
 
@@ -2141,6 +2160,7 @@ FROM #relop AS r
 CROSS APPLY r.relop.nodes('/p:RelOp/p:Filter/p:Predicate/p:ScalarOperator/p:Compare/p:ScalarOperator/p:UserDefinedFunction') c(n) 
 ) x
 WHERE ##bou_BlitzCacheProcs.SqlHandle = x.SqlHandle
+AND SPID = @@SPID
 OPTION (RECOMPILE)
 
 RAISERROR(N'Checking modification queries that hit lots of indexes', 0, 1) WITH NOWAIT;
@@ -2193,6 +2213,7 @@ SET b.index_insert_count = iops.index_insert_count,
 	b.table_delete_count = iops.table_delete_count
 FROM ##bou_BlitzCacheProcs AS b
 JOIN iops ON  iops.SqlHandle = b.SqlHandle
+WHERE SPID = @@SPID
 OPTION(RECOMPILE);
 
 IF @v >= 12
@@ -2204,6 +2225,7 @@ BEGIN
     SET     downlevel_estimator = CASE WHEN statement.value('min(//p:StmtSimple/@CardinalityEstimationModelVersion)', 'int') < (@v * 10) THEN 1 END
     FROM    ##bou_BlitzCacheProcs p
             JOIN #statements s ON p.QueryHash = s.QueryHash 
+	WHERE SPID = @@SPID
 	OPTION (RECOMPILE) ;
 END ;
 
@@ -2233,6 +2255,7 @@ SELECT COUNT(DISTINCT QueryHash) AS distinct_plan_count,
        COUNT(QueryHash) AS number_of_plans,
        QueryHash
 FROM   ##bou_BlitzCacheProcs
+WHERE SPID = @@SPID
 GROUP BY QueryHash
 ) AS x
 WHERE ##bou_BlitzCacheProcs.QueryHash = x.QueryHash
@@ -2248,6 +2271,7 @@ SET     QueryType = QueryType + ' (parent ' +
 FROM    ##bou_BlitzCacheProcs p
         JOIN sys.dm_exec_procedure_stats s ON p.SqlHandle = s.sql_handle
 WHERE   QueryType = 'Statement'
+AND SPID = @@SPID
 
 /* Trace Flag Checks 2014 SP2 and 2016 SP1 only)*/
 RAISERROR(N'Trace flag checks', 0, 1) WITH NOWAIT;
@@ -2284,7 +2308,8 @@ OPTION (RECOMPILE);
 UPDATE p
 SET    p.trace_flags_session = tf.session_trace_flags
 FROM   ##bou_BlitzCacheProcs p
-JOIN #trace_flags tf ON tf.QueryHash = p.QueryHash --AND tf.SqlHandle = p.PlanHandle
+JOIN #trace_flags tf ON tf.QueryHash = p.QueryHash 
+WHERE SPID = @@SPID
 OPTION(RECOMPILE);
 
 IF @SkipAnalysis = 1
@@ -2401,6 +2426,7 @@ SET    frequent_execution = CASE WHEN ExecutionsPerMinute > @execution_threshold
 	   is_remote_query_expensive = CASE WHEN remote_query_cost >= QueryPlanCost * .05 THEN 1 END,
 	   is_forced_serial = CASE WHEN is_forced_serial = 1 AND QueryPlanCost > (@ctp / 2) THEN 1 END,
 	   is_unused_grant = CASE WHEN PercentMemoryGrantUsed <= @memory_grant_warning_percent AND MinGrantKB > @MinMemoryPerQuery THEN 1 END
+WHERE SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -2425,6 +2451,7 @@ UPDATE p
 FROM   ##bou_BlitzCacheProcs p
        CROSS APPLY sys.dm_exec_plan_attributes(p.PlanHandle) pa
 WHERE  pa.attribute = 'set_options' 
+AND SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -2434,6 +2461,7 @@ SET    is_cursor = CASE WHEN CAST(pa.value AS INT) <> 0 THEN 1 END
 FROM   ##bou_BlitzCacheProcs p
        CROSS APPLY sys.dm_exec_plan_attributes(p.PlanHandle) pa
 WHERE  pa.attribute LIKE '%cursor%' 
+AND SPID = @@SPID
 OPTION (RECOMPILE) ;
 
 
@@ -2491,6 +2519,7 @@ SET    Warnings = CASE WHEN QueryPlan IS NULL THEN 'We couldn''t find a plan for
 				  CASE WHEN index_ops >= 5 THEN ', ' + CONVERT(VARCHAR(10), index_ops) + ' Indexes Modified' ELSE '' END 
                   , 2, 200000) 
 				  END
+WHERE SPID = @@SPID
 				  OPTION (RECOMPILE) ;
 
 
@@ -2615,6 +2644,7 @@ BEGIN
           + N' ExecutionsPerMinute, PlanCreationTime, LastExecutionTime, PlanHandle, SqlHandle, QueryHash, StatementStartOffset, StatementEndOffset, MinReturnedRows, MaxReturnedRows, AverageReturnedRows, TotalReturnedRows, QueryText, QueryPlan, NumberOfPlans, NumberOfDistinctPlans, Warnings, '
           + N' SerialRequiredMemory, SerialDesiredMemory, MinGrantKB, MaxGrantKB, MinUsedGrantKB, MaxUsedGrantKB, PercentMemoryGrantUsed, AvgMaxMemoryGrant, QueryPlanCost '
           + N' FROM ##bou_BlitzCacheProcs '
+		  + N' WHERE SPID = @@SPID '
 
     SELECT @insert_sql += N' ORDER BY ' + CASE @SortOrder WHEN 'cpu' THEN N' TotalCPU '
                                                     WHEN 'reads' THEN N' TotalReads '
@@ -2696,7 +2726,8 @@ BEGIN
             QueryPlanHash,
             COALESCE(SetOptions, '''') AS [SET Options]
     FROM    ##bou_BlitzCacheProcs
-    WHERE   1 = 1 ' + @nl
+    WHERE   1 = 1 
+	AND SPID = @@SPID ' + @nl
 
     SELECT @sql += N' ORDER BY ' + CASE @SortOrder WHEN 'cpu' THEN ' TotalCPU '
                               WHEN 'reads' THEN ' TotalReads '