fix: sqlite schema.sql call

Author: SockworkOrange

benchmark/BenchmarkRunner/Utils/SqliteDatabaseHelper.cs

@@ -12,30 +12,34 @@ public static async Task CleanupWriteTableAsync(string connectionString)
         await connection.OpenAsync();
         using var cmd = new SqliteCommand("DROP TABLE IF EXISTS order_items", connection);
         await cmd.ExecuteNonQueryAsync();
-        var schemaPath = Path.Combine(AppContext.BaseDirectory, "schema.sql");
-        if (File.Exists(schemaPath))
-        {
-            await CreateSchemaAsync(connectionString, schemaPath);
-        }
+        await InitializeDatabaseAsync(connectionString);
     }
 
     public static async Task InitializeDatabaseAsync(string connectionString)
     {
         var schemaPath = Path.Combine(AppContext.BaseDirectory, "schema.sql");
-        if (!File.Exists(schemaPath))
-        {
-            throw new FileNotFoundException($"Schema file not found at {schemaPath}. Make sure schema.sql is copied to the output directory.");
-        }
-        await CreateSchemaAsync(connectionString, schemaPath);
+        if (File.Exists(schemaPath))
+            await CreateSchemaAsync(connectionString, schemaPath);
     }
 
     private static async Task CreateSchemaAsync(string connectionString, string schemaPath)
     {
         var schemaSql = await File.ReadAllTextAsync(schemaPath);
         using var connection = new SqliteConnection(connectionString);
         await connection.OpenAsync();
-        using var command = new SqliteCommand(schemaSql, connection);
-        await command.ExecuteNonQueryAsync();
+        
+        // Split the SQL by semicolons and execute each statement separately
+        // SQLite doesn't handle multiple statements in a single ExecuteNonQueryAsync call
+        var statements = schemaSql
+            .Split(';', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries)
+            .Where(s => !string.IsNullOrWhiteSpace(s))
+            .ToArray();
+        
+        foreach (var statement in statements)
+        {
+            using var command = new SqliteCommand(statement, connection);
+            await command.ExecuteNonQueryAsync();
+        }
     }
 
     public static void CleanupDatabase(string connectionString)