fix: adjust benchmarks parameters

Author: SockworkOrange

benchmark/BenchmarkRunner/Benchmarks/MysqlReadBenchmark.cs

@@ -16,8 +16,12 @@ public class MysqlReadBenchmark
 {
     private readonly string _connectionString = Config.GetMysqlConnectionString();
     private QuerySql _sqlcImpl = null!;
-    private const int CustomerCount = 500;
-    private const int QueriesToRun = 500;
+
+    [Params(500)]
+    public int CustomerCount { get; set; }
+
+    [Params(1000)]
+    public int QueriesToRun { get; set; }
 
     [Params(100, 1000)]
     public int Limit { get; set; }

benchmark/BenchmarkRunner/Benchmarks/MysqlWriteBenchmark.cs

@@ -8,19 +8,21 @@
 
 namespace BenchmarkRunner.Benchmarks;
 
-[SimpleJob(RuntimeMoniker.Net80, warmupCount: 2, iterationCount: 15)]
+[SimpleJob(RuntimeMoniker.Net80, warmupCount: 2, iterationCount: 10)]
 [MemoryDiagnoser]
 [MarkdownExporterAttribute.GitHub]
 [GroupBenchmarksBy(BenchmarkLogicalGroupRule.ByCategory)]
 [CategoriesColumn]
 public class MysqlWriteBenchmark
 {
-    private const int TotalRecords = 3000000; // 3 million records
     private readonly string _connectionString = Config.GetMysqlConnectionString();
     private QuerySql _sqlcImpl = null!;
     private Queries _efCoreImpl = null!;
     private List<QuerySql.AddOrderItemsArgs> _testOrderItems = null!;
 
+    [Params(2000000)]
+    public int TotalRecords { get; set; }
+
     [Params(100, 500, 1000)]
     public int BatchSize { get; set; }
 

benchmark/BenchmarkRunner/Benchmarks/PostgresqlReadBenchmark.cs

@@ -16,8 +16,12 @@ public class PostgresqlReadBenchmark
 {
     private readonly string _connectionString = Config.GetPostgresConnectionString();
     private QuerySql _sqlcImpl = null!;
-    private const int CustomerCount = 500;
-    private const int QueriesToRun = 500;
+
+    [Params(500)]
+    public int CustomerCount { get; set; }
+
+    [Params(500)]
+    public int QueriesToRun { get; set; }
 
     [Params(100, 1000)]
     public int Limit { get; set; }

benchmark/BenchmarkRunner/Benchmarks/PostgresqlWriteBenchmark.cs

@@ -7,19 +7,21 @@
 
 namespace BenchmarkRunner.Benchmarks;
 
-[SimpleJob(RuntimeMoniker.Net80, warmupCount: 2, iterationCount: 15)]
+[SimpleJob(RuntimeMoniker.Net80, warmupCount: 2, iterationCount: 10)]
 [MemoryDiagnoser]
 [MarkdownExporterAttribute.GitHub]
 [GroupBenchmarksBy(BenchmarkLogicalGroupRule.ByCategory)]
 [CategoriesColumn]
 public class PostgresqlWriteBenchmark
 {
-    private const int TotalRecords = 3000000; // 3 million records
     private readonly string _connectionString = Config.GetPostgresConnectionString();
     private QuerySql _sqlcImpl = null!;
     private Queries _efCoreImpl = null!;
     private List<QuerySql.AddOrderItemsArgs> _testOrderItems = null!;
 
+    [Params(2000000)]
+    public int TotalRecords { get; set; }
+
     [Params(100, 500, 1000)]
     public int BatchSize { get; set; }
 

benchmark/BenchmarkRunner/Benchmarks/SqliteReadBenchmark.cs

@@ -16,8 +16,12 @@ public class SqliteReadBenchmark
 {
     private readonly string _connectionString = Config.GetSqliteConnectionString();
     private QuerySql _sqlcImpl = null!;
-    private const int CustomerCount = 250;
-    private const int QueriesToRun = 500;
+
+    [Params(500)]
+    public int CustomerCount { get; set; }
+
+    [Params(500)]
+    public int QueriesToRun { get; set; }
 
     [Params(50, 500)]
     public int Limit { get; set; }

benchmark/BenchmarkRunner/Benchmarks/SqliteWriteBenchmark.cs

@@ -7,17 +7,19 @@
 
 namespace BenchmarkRunner.Benchmarks;
 
-[SimpleJob(RuntimeMoniker.Net80, warmupCount: 2, iterationCount: 15)]
+[SimpleJob(RuntimeMoniker.Net80, warmupCount: 2, iterationCount: 10)]
 [MemoryDiagnoser]
 [MarkdownExporterAttribute.GitHub]
 [GroupBenchmarksBy(BenchmarkLogicalGroupRule.ByCategory)]
 [CategoriesColumn]
 public class SqliteWriteBenchmark
 {
-    private const int TotalRecords = 2000000; // 2 million records
     private readonly string _connectionString = Config.GetSqliteConnectionString();
     private QuerySql _sqlcImpl = null!;
     private Queries _efCoreImpl = null!;
+
+    [Params(2000000)]
+    public int TotalRecords { get; set; }
     private List<QuerySql.AddOrderItemsArgs> _testOrderItems = null!;
 
     [Params(50, 100, 200)]

benchmark/BenchmarkRunner/Program.cs

@@ -22,19 +22,19 @@ public class Program
     private static readonly Dictionary<string, Dictionary<string, Func<Task>>> _benchmarkConfigs = new()
     {
         { "mysql", new()
-        { 
-            { "reads", _mysqlRunner.RunReadsAsync }, 
-            { "writes", _mysqlRunner.RunWritesAsync } 
+        {
+            { "reads", _mysqlRunner.RunReadsAsync },
+            { "writes", _mysqlRunner.RunWritesAsync }
         }},
         { "postgresql", new()
-        { 
-            { "reads", _postgresqlRunner.RunReadsAsync }, 
-            { "writes", _postgresqlRunner.RunWritesAsync } 
+        {
+            { "reads", _postgresqlRunner.RunReadsAsync },
+            { "writes", _postgresqlRunner.RunWritesAsync }
         }},
         { "sqlite", new()
-        { 
-            { "reads", _sqliteRunner.RunReadsAsync }, 
-            { "writes", _sqliteRunner.RunWritesAsync } 
+        {
+            { "reads", _sqliteRunner.RunReadsAsync },
+            { "writes", _sqliteRunner.RunWritesAsync }
         }}
     };
 
@@ -49,7 +49,7 @@ public static async Task Main(string[] args)
         rootCommand.AddOption(typeOption);
 
         rootCommand.SetHandler(
-            async (database, type) => await _benchmarkConfigs[database][type](), 
+            async (database, type) => await _benchmarkConfigs[database][type](),
             databaseOption, typeOption);
         await rootCommand.InvokeAsync(args);
     }

benchmark/BenchmarkRunner/TestSqlCapture.cs

@@ -8,7 +8,7 @@ public static async Task CleanupWriteTableAsync(string connectionString)
     {
         using var connection = new NpgsqlConnection(connectionString);
         await connection.OpenAsync();
-        using var cmd = new NpgsqlCommand("TRUNCATE TABLE sales.order_items CASCADE", connection);
+        using var cmd = new NpgsqlCommand("TRUNCATE TABLE sales.order_items", connection);
         await cmd.ExecuteNonQueryAsync();
     }
     public static async Task CleanupDatabaseAsync(string connectionString)