Added execution summary to analysis

spaghettidba · Sep 14, 2022 · b5bad04 · b5bad04
1 parent 1c0c223
commit b5bad04
Show file tree

Hide file tree

Showing 3 changed files with 276 additions and 82 deletions.
diff --git a/WorkloadTools/Consumer/Analysis/AnalysisConsumer.cs b/WorkloadTools/Consumer/Analysis/AnalysisConsumer.cs
@@ -41,7 +41,10 @@ public int UploadIntervalMinutes
 		public bool SqlNormalizerTruncateTo4000 { get; set; }
 		public bool SqlNormalizerTruncateTo1024 { get; set; }
 
-		public override void ConsumeBuffered(WorkloadEvent evt)
+        public bool WriteDetail { get; set; } = true;
+        public bool WriteSummary { get; set; } = true;
+
+        public override void ConsumeBuffered(WorkloadEvent evt)
         {
             if(analyzer == null)
             {
@@ -51,7 +54,8 @@ public override void ConsumeBuffered(WorkloadEvent evt)
                     ConnectionInfo = this.ConnectionInfo,
 					MaximumWriteRetries = this.MaximumWriteRetries,
 					TruncateTo1024 = this.SqlNormalizerTruncateTo1024,
-					TruncateTo4000 = this.SqlNormalizerTruncateTo4000
+					TruncateTo4000 = this.SqlNormalizerTruncateTo4000,
+                    WriteDetail = this.WriteDetail
 				};
             }
 

diff --git a/WorkloadTools/Consumer/Analysis/DatabaseSchema.sql b/WorkloadTools/Consumer/Analysis/DatabaseSchema.sql
@@ -45,6 +45,43 @@ CREATE TABLE [{SchemaName}].[WorkloadDetails](
 )
 
 
+
+IF OBJECT_ID('{SchemaName}.WorkloadSummary') IS NULL
+
+CREATE TABLE [{SchemaName}].[WorkloadSummary](
+	[application_id] [int] NOT NULL,
+	[database_id] [int] NOT NULL,
+	[host_id] [int] NOT NULL,
+	[login_id] [int] NOT NULL,
+
+    [min_cpu_us] [bigint] NULL,
+    [max_cpu_us] [bigint] NULL,
+    [sum_cpu_us] [bigint] NULL,
+
+    [min_reads] [bigint] NULL,
+    [max_reads] [bigint] NULL,
+    [sum_reads] [bigint] NULL,
+
+    [min_writes] [bigint] NULL,
+    [max_writes] [bigint] NULL,
+    [sum_writes] [bigint] NULL,
+
+    [min_duration_us] [bigint] NULL,
+    [max_duration_us] [bigint] NULL,
+    [sum_duration_us] [bigint] NULL,
+
+    [execution_count] [bigint] NULL,
+
+    CONSTRAINT PK_WorkloadSummary PRIMARY KEY CLUSTERED (
+        [application_id], 
+        [database_id], 
+        [host_id], 
+        [login_id]
+    )
+)
+
+
+
 IF OBJECT_ID('{SchemaName}.Applications') IS NULL
 
 CREATE TABLE [{SchemaName}].[Applications](