Add EntityFrameworkSqlServerExtensions.CreateDatabase() method.

Author: GillesTourreau

src/Directory.Build.props

@@ -12,6 +12,7 @@
     <PackageLicenseExpression>MIT</PackageLicenseExpression>
     <PackageReleaseNotes>
       2.2.0
+      - Add SqlServer.CreateDatabase() method to create database from an Entity Framework DbContext.
       - Add SqlServer.CreateEmptyDatabaseAsync() method.
       - Add SqlServer.DeleteDatabaseAsync() method.
       - Add SqlServer.ExecuteScriptAsync() method.

src/Testing.Databases.SqlServer.EntityFramework/EntityFrameworkSqlServerExtensions.cs

@@ -15,13 +15,33 @@ namespace PosInformatique.Testing.Databases.SqlServer
     public static class EntityFrameworkSqlServerExtensions
     {
         /// <summary>
-        /// Deploy a database using a DACPAC file.
+        /// Creates a database using the specified Entity Framework <paramref name="context"/>.
         /// </summary>
-        /// <remarks>If a database  already exists, it will be deleted.</remarks>
+        /// <remarks>If the database already exists, it will be deleted.</remarks>
         /// <param name="server"><see cref="SqlServer"/> instance where the database will be created.</param>
         /// <param name="name">Name of the database to create.</param>
         /// <param name="context"><see cref="DbContext"/> which represents the database to create.</param>
         /// <returns>An instance of the <see cref="SqlServerDatabase"/> which represents the deployed database.</returns>
+        public static SqlServerDatabase CreateDatabase(this SqlServer server, string name, DbContext context)
+        {
+            var database = server.GetDatabase(name);
+
+            context.Database.SetConnectionString(database.ConnectionString);
+
+            context.Database.EnsureDeleted();
+            context.Database.EnsureCreated();
+
+            return database;
+        }
+
+        /// <summary>
+        /// Creates a database using the specified Entity Framework <paramref name="context"/>.
+        /// </summary>
+        /// <remarks>If the database already exists, it will be deleted.</remarks>
+        /// <param name="server"><see cref="SqlServer"/> instance where the database will be created.</param>
+        /// <param name="name">Name of the database to create.</param>
+        /// <param name="context"><see cref="DbContext"/> which represents the database to create.</param>
+        /// <returns>A <see cref="Task"/> which represents the asynchronous operation and contains an instance of the <see cref="SqlServerDatabase"/> that represents the deployed database.</returns>
         public static async Task<SqlServerDatabase> CreateDatabaseAsync(this SqlServer server, string name, DbContext context)
         {
             var database = server.GetDatabase(name);

tests/Testing.Databases.SqlServer.EntityFramework.Tests/EntityFrameworkSqlServerExtensionsTest.cs

@@ -24,7 +24,7 @@ public async Task Create_WithNoExistingDatabase()
             var server = new SqlServer(ConnectionString);
             server.DeleteDatabase(nameof(EntityFrameworkSqlServerExtensionsTest));
 
-            var database = await server.CreateDatabaseAsync(nameof(EntityFrameworkSqlServerExtensionsTest), dbContext);
+            var database = server.CreateDatabase(nameof(EntityFrameworkSqlServerExtensionsTest), dbContext);
 
             database.ConnectionString.Should().Be("Data Source=(localDB)\\posinfo-tests;Initial Catalog=EntityFrameworkSqlServerExtensionsTest;Integrated Security=True");
 
@@ -52,6 +52,60 @@ public async Task Create_WithAlreadyExistingDatabase()
 
             emptyDatabase.ExecuteNonQuery("CREATE TABLE [MustBeDeleted] ([Id] INT)");
 
+            var database = server.CreateDatabase(nameof(EntityFrameworkSqlServerExtensionsTest), dbContext);
+
+            database.ConnectionString.Should().Be("Data Source=(localDB)\\posinfo-tests;Initial Catalog=EntityFrameworkSqlServerExtensionsTest;Integrated Security=True");
+
+            var tables = await database.GetTablesAsync();
+
+            tables.Should().HaveCount(1);
+
+            tables[0].Name.Should().Be("Entity");
+
+            tables[0].Columns.Should().HaveCount(2);
+            tables[0].Columns[0].Name.Should().Be("Id");
+            tables[0].Columns[1].Name.Should().Be("Name");
+        }
+
+        [Fact]
+        public async Task CreateAsync_WithNoExistingDatabase()
+        {
+            var optionsBuilder = new DbContextOptionsBuilder<DbContextTest>()
+                .UseSqlServer("Data Source=OtherServer;");
+
+            using var dbContext = new DbContextTest(optionsBuilder.Options);
+
+            var server = new SqlServer(ConnectionString);
+            await server.DeleteDatabaseAsync(nameof(EntityFrameworkSqlServerExtensionsTest));
+
+            var database = await server.CreateDatabaseAsync(nameof(EntityFrameworkSqlServerExtensionsTest), dbContext);
+
+            database.ConnectionString.Should().Be("Data Source=(localDB)\\posinfo-tests;Initial Catalog=EntityFrameworkSqlServerExtensionsTest;Integrated Security=True");
+
+            var tables = await database.GetTablesAsync();
+
+            tables.Should().HaveCount(1);
+
+            tables[0].Name.Should().Be("Entity");
+
+            tables[0].Columns.Should().HaveCount(2);
+            tables[0].Columns[0].Name.Should().Be("Id");
+            tables[0].Columns[1].Name.Should().Be("Name");
+        }
+
+        [Fact]
+        public async Task CreateAsync_WithAlreadyExistingDatabase()
+        {
+            var optionsBuilder = new DbContextOptionsBuilder<DbContextTest>()
+                .UseSqlServer("Data Source=OtherServer;");
+
+            using var dbContext = new DbContextTest(optionsBuilder.Options);
+
+            var server = new SqlServer(ConnectionString);
+            var emptyDatabase = await server.CreateEmptyDatabaseAsync(nameof(EntityFrameworkSqlServerExtensionsTest));
+
+            await emptyDatabase.ExecuteNonQueryAsync("CREATE TABLE [MustBeDeleted] ([Id] INT)");
+
             var database = await server.CreateDatabaseAsync(nameof(EntityFrameworkSqlServerExtensionsTest), dbContext);
 
             database.ConnectionString.Should().Be("Data Source=(localDB)\\posinfo-tests;Initial Catalog=EntityFrameworkSqlServerExtensionsTest;Integrated Security=True");