Add the CreateEmptyDatabaseAsync() and DeleteDatabaseAsync() methods.

Author: GillesTourreau

src/Directory.Build.props

@@ -11,6 +11,10 @@
     <PackageReadmeFile>README.md</PackageReadmeFile>
     <PackageLicenseExpression>MIT</PackageLicenseExpression>
     <PackageReleaseNotes>
+      2.2.0
+      - Add SqlServer.CreateEmptyDatabaseAsync() method.
+      - Add SqlServer.DeleteDatabaseAsync() method.
+
       2.1.0
       - PosInformatique.Testing.Databases.SqlServer target the .NET Standard 2.0 platform.
       - PosInformatique.Testing.Databases.SqlServer.Dac target the .NET Core 6.0 and .NET Framework 4.6.2

src/Testing.Databases.SqlServer/SqlServer.cs

@@ -51,6 +51,21 @@ public SqlServerDatabase CreateEmptyDatabase(string name)
             return this.GetDatabase(name);
         }
 
+        /// <summary>
+        /// Creates an empty database asynchronously in the SQL Server instance with the specified <paramref name="name"/>.
+        /// If the database already exists, it will be delete.
+        /// </summary>
+        /// <param name="name">Name of the database to create.</param>
+        /// <param name="cancellationToken"><see cref="CancellationToken"/> used to cancel the asynchronous operation.</param>
+        /// <returns>A <see cref="Task"/> which represents the asynchronous operation and contains an instance of <see cref="SqlServerDatabase"/> which allows to execute SQL commands/queries.</returns>
+        public async Task<SqlServerDatabase> CreateEmptyDatabaseAsync(string name, CancellationToken cancellationToken = default)
+        {
+            await this.DeleteDatabaseAsync(name, cancellationToken);
+            await this.Master.ExecuteNonQueryAsync($"CREATE DATABASE [{name}]", cancellationToken);
+
+            return this.GetDatabase(name);
+        }
+
         /// <summary>
         /// Deletes a database in the SQL server instance with the specified <paramref name="name"/>.
         /// If the database does not exists, no exception is thrown.
@@ -62,6 +77,19 @@ public void DeleteDatabase(string name)
             this.Master.ExecuteNonQuery($"IF EXISTS (SELECT 1 FROM [sys].[databases] WHERE [name] = '{name}') DROP DATABASE [{name}]");
         }
 
+        /// <summary>
+        /// Deletes a database asynchronously in the SQL server instance with the specified <paramref name="name"/>.
+        /// If the database does not exists, no exception is thrown.
+        /// </summary>
+        /// <param name="name">Name of the database to delete.</param>
+        /// <param name="cancellationToken"><see cref="CancellationToken"/> used to cancel the asynchronous operation.</param>
+        /// <returns>A <see cref="Task"/> which represents the asynchronous operation.</returns>
+        public async Task DeleteDatabaseAsync(string name, CancellationToken cancellationToken = default)
+        {
+            await this.Master.ExecuteNonQueryAsync($"IF EXISTS (SELECT 1 FROM [sys].[databases] WHERE [name] = '{name}') ALTER DATABASE [{name}] SET SINGLE_USER WITH ROLLBACK IMMEDIATE", cancellationToken);
+            await this.Master.ExecuteNonQueryAsync($"IF EXISTS (SELECT 1 FROM [sys].[databases] WHERE [name] = '{name}') DROP DATABASE [{name}]", cancellationToken);
+        }
+
         /// <summary>
         /// Gets an instance of the <see cref="SqlServerDatabase"/> for the database specified with the <paramref name="name"/>.
         /// </summary>

tests/Testing.Databases.SqlServer.Tests/SqlServerTest.cs

@@ -6,8 +6,11 @@
 
 namespace PosInformatique.Testing.Databases.SqlServer.Tests
 {
+    [Collection("PosInformatique.Testing.Databases.SqlServer.Tests")]
     public class SqlServerTest
     {
+        private const string ConnectionString = $"Data Source=(localDB)\\posinfo-tests; Initial Catalog={nameof(SqlServerTest)}; Integrated Security=True";
+
         [Theory]
         [InlineData("Data Source=TheServer; Initial Catalog=TheDB; User ID=TheID; Password=ThePassword", "Data Source=TheServer;Initial Catalog=master;User ID=TheID;Password=ThePassword")]
         [InlineData("Data Source=TheServer; Initial Catalog=TheDB; Integrated Security=True", "Data Source=TheServer;Initial Catalog=master;Integrated Security=True")]
@@ -18,5 +21,24 @@ public void Constructor(string connectionString, string expectedMasterConnection
             server.Master.ConnectionString.Should().Be(expectedMasterConnectionString);
             server.Master.Server.Should().BeSameAs(server);
         }
+
+        [Fact]
+        public async Task CreateAndDeleteAsync()
+        {
+            var server = new SqlServer(ConnectionString);
+
+            var database = await server.CreateEmptyDatabaseAsync("CreateAndDeleteDB", CancellationToken.None);
+
+            database.ConnectionString.Should().Be("Data Source=(localDB)\\posinfo-tests;Initial Catalog=CreateAndDeleteDB;Integrated Security=True");
+
+            var table = await server.Master.ExecuteQueryAsync("SELECT * FROM [sys].[databases] WHERE [name] = 'CreateAndDeleteDB'");
+            table.Rows.Should().HaveCount(1);
+
+            // Delete the database
+            await server.DeleteDatabaseAsync("CreateAndDeleteDB", CancellationToken.None);
+
+            table = await server.Master.ExecuteQueryAsync("SELECT * FROM [sys].[databases] WHERE [name] = 'CreateAndDeleteDB'");
+            table.Rows.Should().BeEmpty();
+        }
     }
 }