Skip to content

Commit 1810c48

Browse files
dhmacherdhmacher
committed
Initial commit
0 parents  commit 1810c48

File tree

1 file changed

+121
-0
lines changed

1 file changed

+121
-0
lines changed

‎QueryStore.sql

+121
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,121 @@
1+
WITH waits AS (
2+
SELECT plan_id, runtime_stats_interval_id,
3+
SUM((CASE WHEN wait_category=1 THEN total_query_wait_time_ms ELSE 0 END)) AS sos_scheduler_yield, -- CPU
4+
SUM((CASE WHEN wait_category=2 THEN total_query_wait_time_ms ELSE 0 END)) AS threadpool, -- Thread starvation
5+
SUM((CASE WHEN wait_category=3 THEN total_query_wait_time_ms ELSE 0 END)) AS lock, -- Locks
6+
SUM((CASE WHEN wait_category=4 THEN total_query_wait_time_ms ELSE 0 END)) AS latch, -- Latches
7+
SUM((CASE WHEN wait_category=5 THEN total_query_wait_time_ms ELSE 0 END)) AS pagelatch, -- Buffer latch
8+
SUM((CASE WHEN wait_category=6 THEN total_query_wait_time_ms ELSE 0 END)) AS pageiolatch, -- Buffer IO
9+
SUM((CASE WHEN wait_category=7 THEN total_query_wait_time_ms ELSE 0 END)) AS compile, -- Compile
10+
SUM((CASE WHEN wait_category=14 THEN total_query_wait_time_ms ELSE 0 END)) AS transaction_log, -- Logwrite, checkpoint, etc
11+
SUM((CASE WHEN wait_category=15 THEN total_query_wait_time_ms ELSE 0 END)) AS network, -- Async network IO, etc
12+
SUM((CASE WHEN wait_category=16 THEN total_query_wait_time_ms ELSE 0 END)) AS parallelism, -- CXPACKET, CXCONSUMER
13+
SUM((CASE WHEN wait_category=17 THEN total_query_wait_time_ms ELSE 0 END)) AS memory, -- Memory
14+
SUM((CASE WHEN wait_category=18 THEN total_query_wait_time_ms ELSE 0 END)) AS user_wait, -- WAITFOR
15+
SUM((CASE WHEN wait_category=21 THEN total_query_wait_time_ms ELSE 0 END)) AS other_io -- Async IO, backup IO, etc.
16+
FROM sys.query_store_wait_stats
17+
WHERE execution_type=0 -- success
18+
GROUP BY plan_id, runtime_stats_interval_id),
19+
20+
q AS (
21+
SELECT q.query_id,
22+
qp.plan_id,
23+
qt.query_sql_text,
24+
OBJECT_SCHEMA_NAME(q.[object_id])+N'.'+OBJECT_NAME(q.[object_id]) AS [object_name],
25+
(CASE WHEN q.[object_id]!=0 THEN q.last_compile_batch_offset_start ELSE 0 END) AS offset,
26+
x2.query_sql_text_no_params,
27+
ISNULL(x1.is_parameterized, 0) AS is_parameterized,
28+
q.query_parameterization_type_desc,
29+
qp.count_compiles AS compile_count,
30+
CAST(qrs.first_execution_time AS date) AS [date],
31+
32+
SUM(qrs.count_executions) AS execution_count,
33+
CAST(.001*SUM(qrs.avg_duration*qrs.count_executions)/SUM(qrs.count_executions) AS numeric(20, 2)) AS avg_duration_ms,
34+
CAST(.001*SUM(qrs.avg_cpu_time*qrs.count_executions)/SUM(qrs.count_executions) AS numeric(20, 2)) AS avg_cpu_ms,
35+
CAST(SUM(qrs.avg_logical_io_reads*qrs.count_executions)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_reads,
36+
MAX(qrs.max_dop) AS max_dop,
37+
CAST(1.*MAX(qrs.max_query_max_used_memory)*8 AS numeric(20, 1)) AS avg_memory_grant_kb,
38+
CAST(1.*SUM(qrs.avg_rowcount*qrs.count_executions)/SUM(qrs.count_executions) AS numeric(20, 0)) AS avg_rowcount,
39+
CAST(1.*SUM(qrs.avg_log_bytes_used*qrs.count_executions)/SUM(qrs.count_executions)/1024 AS numeric(20, 0)) AS avg_log_kb,
40+
CAST(1.*SUM(qrs.avg_tempdb_space_used*qrs.count_executions)/SUM(qrs.count_executions)/8 AS numeric(20, 1)) AS avg_tempdb_kb,
41+
42+
CAST(1.*SUM(w.sos_scheduler_yield)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_sos_scheduler_yield_wait_ms,
43+
CAST(1.*SUM(w.threadpool)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_threadpool_wait_ms,
44+
CAST(1.*SUM(w.lock)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_lock_wait_ms,
45+
CAST(1.*SUM(w.latch)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_latch_wait_ms,
46+
CAST(1.*SUM(w.pagelatch)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_pagelatch_wait_ms,
47+
CAST(1.*SUM(w.pageiolatch)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_pageiolatch_wait_ms,
48+
CAST(1.*SUM(w.compile)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_compile_wait_ms,
49+
CAST(1.*SUM(w.transaction_log)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_transaction_log_wait_ms,
50+
CAST(1.*SUM(w.network)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_network_wait_ms,
51+
CAST(1.*SUM(w.parallelism)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_parallelism_wait_ms,
52+
CAST(1.*SUM(w.memory)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_memory_wait_ms,
53+
CAST(1.*SUM(w.user_wait)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_user_wait_ms,
54+
CAST(1.*SUM(w.other_io)/SUM(qrs.count_executions) AS numeric(20, 1)) AS avg_other_io_wait_ms,
55+
56+
CAST(qp.query_plan AS xml) AS query_plan
57+
FROM sys.query_store_query AS q
58+
INNER JOIN sys.query_store_query_text AS qt ON q.query_text_id=qt.query_text_id
59+
OUTER APPLY (
60+
SELECT PATINDEX('%)[^,)]%', qt.query_sql_text) AS offset, 1 AS is_parameterized
61+
WHERE qt.query_sql_text LIKE '(@%)%'
62+
) AS x1
63+
CROSS APPLY (
64+
SELECT SUBSTRING(qt.query_sql_text, ISNULL(x1.offset, 0)+1, LEN(qt.query_sql_text)) AS query_sql_text_no_params
65+
) AS x2
66+
LEFT JOIN sys.query_store_plan AS qp ON q.query_id=qp.query_id
67+
LEFT JOIN sys.query_store_runtime_stats AS qrs ON qp.plan_id=qrs.plan_id AND qrs.execution_type=0 -- success
68+
LEFT JOIN waits AS w ON qp.plan_id=w.plan_id AND qrs.runtime_stats_interval_id=w.runtime_stats_interval_id
69+
WHERE q.is_internal_query=0
70+
71+
GROUP BY q.query_id,
72+
q.[object_id],
73+
qt.query_sql_text,
74+
x2.query_sql_text_no_params,
75+
qp.query_plan,
76+
q.last_compile_batch_offset_start,
77+
q.query_parameterization_type_desc,
78+
x1.is_parameterized,
79+
q.count_compiles,
80+
qp.plan_id,
81+
qp.count_compiles,
82+
CAST(qrs.first_execution_time AS date))
83+
84+
-------------------------------------------------------------------------------
85+
86+
SELECT ISNULL([object_name], N'') AS [Calling module],
87+
ISNULL(CAST(NULLIF(offset, 0) AS varchar(8)), '') AS [Module stmt],
88+
query_sql_text_no_params AS [Query, excl. parameters],
89+
(CASE is_parameterized WHEN 0 THEN '' ELSE 'Yes' END) AS [Parameterized],
90+
ISNULL(NULLIF(query_parameterization_type_desc, 'None'), '') AS [Param.type],
91+
compile_count AS [Compiles],
92+
[date] AS [Date],
93+
CONVERT(varchar(20), CAST(avg_duration_ms AS money), 1) AS [Avg duration, ms],
94+
CONVERT(varchar(20), CAST(avg_cpu_ms AS money), 1) AS [Avg cpu, ms],
95+
REPLACE(CONVERT(varchar(20), CAST(CAST(avg_reads AS bigint) AS money), 1), '.00', '') AS [Avg reads, pages],
96+
ISNULL(CAST(NULLIF(max_dop, 1) AS varchar(4)), '') AS [Max DOP],
97+
REPLACE(ISNULL(CONVERT(varchar(20), CAST(CAST(NULLIF(avg_memory_grant_kb, 0) AS bigint) AS money), 1), ''), '.00', '') AS [Avg mem.grant, kB],
98+
avg_rowcount AS [Avg rowcount],
99+
REPLACE(ISNULL(CONVERT(varchar(20), CAST(NULLIF(CAST(avg_log_kb AS bigint), 0) AS money), 1), ''), '.00', '') AS [Avg log, kB],
100+
REPLACE(ISNULL(CONVERT(varchar(20), CAST(NULLIF(CAST(avg_tempdb_kb AS bigint), 0) AS money), 1), ''), '.00', '') AS [Avg tempdb, kB],
101+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_sos_scheduler_yield_wait_ms, 0) AS money), 1), '') AS [Avg cpu waits, ms],
102+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_threadpool_wait_ms, 0) AS money), 1), '') AS [Avg threadpool waits, ms],
103+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_lock_wait_ms, 0) AS money), 1), '') AS [Avg lock waits, ms],
104+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_latch_wait_ms, 0) AS money), 1), '') AS [Avg latch waits, ms],
105+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_pagelatch_wait_ms, 0) AS money), 1), '') AS [Avg page latch waits, ms],
106+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_pageiolatch_wait_ms, 0) AS money), 1), '') AS [Avg pageio latch waits, ms],
107+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_compile_wait_ms, 0) AS money), 1), '') AS [Avg compile waits, ms],
108+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_transaction_log_wait_ms, 0) AS money), 1), '') AS [Avg log waits, ms],
109+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_network_wait_ms, 0) AS money), 1), '') AS [Avg network waits, ms],
110+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_parallelism_wait_ms, 0) AS money), 1), '') AS [Avg parallelism waits, ms],
111+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_memory_wait_ms, 0) AS money), 1), '') AS [Avg memory waits, ms],
112+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_user_wait_ms, 0) AS money), 1), '') AS [Avg user waits, ms],
113+
ISNULL(CONVERT(varchar(20), CAST(NULLIF(avg_other_io_wait_ms, 0) AS money), 1), '') AS [Avg other IO waits, ms],
114+
query_plan AS [Plan]
115+
FROM q
116+
117+
WHERE query_sql_text NOT LIKE '%sys.%'
118+
AND [date]>=DATEADD(day, -3, CAST(SYSDATETIME() AS date))
119+
120+
ORDER BY SUM(avg_cpu_ms) OVER (PARTITION BY query_id, plan_id) DESC, [date];
121+
--ORDER BY [object_name], offset, [date]

0 commit comments

Comments
 (0)