update RepoDBcorrect write read scenarios in benchmark (added Scenari…

…oTimestamp field)
PragmaticFlow · Sep 17, 2024 · 5a7dfd6 · 5a7dfd6
1 parent 4144f56
commit 5a7dfd6
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/benchmarks/TimescaleBenchmark/ReadScenario.cs b/benchmarks/TimescaleBenchmark/ReadScenario.cs
@@ -58,6 +58,7 @@ public ScenarioProps Create(string connectionString, DateTime startTime, string
                 .Select(i => new PointDbRecord
                 { 
                     Time = startTime.AddSeconds(-5 * i),
+                    ScenarioTimestamp = TimeSpan.Zero,
                     Step = fakePoint.Step,
                     Scenario = fakePoint.Scenario,
 

diff --git a/benchmarks/TimescaleBenchmark/WriteScenario.cs b/benchmarks/TimescaleBenchmark/WriteScenario.cs
@@ -22,13 +22,18 @@ public ScenarioProps Create(string connectionString)
             {
                 await using var connection = new NpgsqlConnection(connectionString);
 
-                var curTime = DateTime.UtcNow;
+                var curTime = DateTime.UtcNow; 
 
                 fakePoint.Time = curTime;
+                fakePoint.ScenarioTimestamp = TimeSpan.Zero;
                 fakePoint.SessionId = ctx.ScenarioInfo.InstanceNumber.ToString();
                 fakePoint.CurrentOperation = NBomber.Contracts.Stats.OperationType.Bombing;
-
-                await connection.BinaryBulkInsertAsync(SqlQueries.StepStatsTable, Enumerable.Repeat(fakePoint, 5));
+                try
+                {
+                    await connection.BinaryBulkInsertAsync(SqlQueries.StepStatsTable, Enumerable.Repeat(fakePoint, 5));
+                }
+                catch (Exception ex) 
+                { }
 
                 return Response.Ok();
             });