async delete

microsoft · Jun 16, 2024 · 4cfba86 · 4cfba86
1 parent 66d3da9
commit 4cfba86
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/...rosoft.Health.Fhir.Shared.Tests.Integration/Persistence/SqlServerFhirStorageTestHelper.cs b/...rosoft.Health.Fhir.Shared.Tests.Integration/Persistence/SqlServerFhirStorageTestHelper.cs
@@ -218,15 +218,18 @@ public async Task DeleteDatabase(string databaseName, CancellationToken cancella
 
             try
             {
-                DbSetupSemaphore.Wait();
+                await DbSetupSemaphore.WaitAsync(cancellationToken);
                 try
                 {
                     SqlConnection.ClearAllPools();
-                    using var conn = _sqlConnectionBuilder.GetSqlConnection(_masterDatabaseName, null);
-                    conn.Open();
-                    using var cmd = new SqlCommand($"DROP DATABASE IF EXISTS {databaseName}", conn);
-                    cmd.ExecuteNonQuery();
-                    await Task.CompletedTask;
+
+                    await using SqlConnection connection = await _sqlConnectionBuilder.GetSqlConnectionAsync(_masterDatabaseName, null, cancellationToken);
+                    await connection.OpenAsync(cancellationToken);
+                    await using SqlCommand command = connection.CreateCommand();
+                    command.CommandTimeout = 15;
+                    command.CommandText = $"DROP DATABASE IF EXISTS {databaseName}";
+                    await command.ExecuteNonQueryAsync(cancellationToken);
+                    await connection.CloseAsync();
                 }
                 finally
                 {