Testcontainers

phongnguyend · phongnguyend · commit 258e9f53d487 · 2025-07-13T09:20:14.000+07:00
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BaseTest.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BaseTest.cs
@@ -6,12 +6,13 @@ namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 public abstract class BaseTest : IDisposable
 {
     protected readonly ITestOutputHelper _output;
-
+    protected readonly SqlServerFixture _fixture;
     protected readonly TestDbContext _context;
 
-    protected BaseTest(ITestOutputHelper output, string dbPrefixName, string schema = "")
+    protected BaseTest(ITestOutputHelper output, SqlServerFixture fixture, string dbPrefixName, string schema = "")
     {
         _output = output;
+        _fixture = fixture;
         _context = GetDbContext(dbPrefixName, schema);
         _context.Database.EnsureCreated();
     }
@@ -21,13 +22,8 @@ public void Dispose()
         _context.Database.EnsureDeleted();
     }
 
-    protected string GetConnectionString(string dbPrefixName)
-    {
-        return $"Server=127.0.0.1;Database={dbPrefixName}.{Guid.NewGuid()};User Id=sa;Password=sqladmin123!@#;Encrypt=False";
-    }
-
     protected TestDbContext GetDbContext(string dbPrefixName, string schema)
     {
-        return new TestDbContext(GetConnectionString(dbPrefixName), schema);
+        return new TestDbContext(_fixture.GetConnectionString(dbPrefixName), schema);
     }
 }
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkDeleteTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkDeleteTests.cs
@@ -6,9 +6,10 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkDeleteTests : BaseTest
 {
-    public BulkDeleteTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkDelete")
+    public BulkDeleteTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkDelete")
     {
         var tran = _context.Database.BeginTransaction();
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkInsertTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkInsertTests.cs
@@ -5,9 +5,10 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkInsertTests : BaseTest
 {
-    public BulkInsertTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkInsert")
+    public BulkInsertTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkInsert")
     {
     }
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkMatchTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkMatchTests.cs
@@ -5,12 +5,13 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkMatchTests : BaseTest
 {
     private readonly List<Customer> _customers;
     private readonly List<Contact> _contacts;
 
-    public BulkMatchTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkMatch")
+    public BulkMatchTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkMatch")
     {
         var tran = _context.Database.BeginTransaction();
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkMergeTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkMergeTests.cs
@@ -6,9 +6,10 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkMergeTests : BaseTest
 {
-    public BulkMergeTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkMerge")
+    public BulkMergeTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkMerge")
     {
     }
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkUpdateTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/BulkUpdateTests.cs
@@ -7,9 +7,10 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkUpdateTests : BaseTest
 {
-    public BulkUpdateTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkUpdate")
+    public BulkUpdateTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkUpdate")
     {
     }
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/DirectDeleteTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/DirectDeleteTests.cs
@@ -6,9 +6,10 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class DirectDeleteTests : BaseTest
 {
-    public DirectDeleteTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.DirectDelete")
+    public DirectDeleteTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.DirectDelete")
     {
         var tran = _context.Database.BeginTransaction();
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/DirectInsertTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/DirectInsertTests.cs
@@ -5,9 +5,10 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class DirectInsertTests : BaseTest
 {
-    public DirectInsertTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.DirectInsert")
+    public DirectInsertTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.DirectInsert")
     {
     }
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/DirectUpdateTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/DirectUpdateTests.cs
@@ -6,9 +6,10 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class DirectUpdateTests : BaseTest
 {
-    public DirectUpdateTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.DirectUpdate")
+    public DirectUpdateTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.DirectUpdate")
     {
     }
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/TempTableTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/DbContextExtensions/TempTableTests.cs
@@ -6,6 +6,7 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;
 
+[Collection("SqlServerCollection")]
 public class TempTableTests : BaseTest
 {
     private readonly static List<CustomerDto> _customers = new List<CustomerDto>
@@ -58,7 +59,7 @@ public class TempTableTests : BaseTest
         }
     };
 
-    public TempTableTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.TempTable")
+    public TempTableTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.TempTable")
     {
     }
 
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/EntityFrameworkCore.SqlServer.SimpleBulks.Tests.csproj b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/EntityFrameworkCore.SqlServer.SimpleBulks.Tests.csproj
@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+﻿<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
     <TargetFramework>net8.0</TargetFramework>
@@ -15,6 +15,7 @@
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.5.0" />
+    <PackageReference Include="Testcontainers.MsSql" Version="4.6.0" />
     <PackageReference Include="xunit" Version="2.4.2" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5">
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BaseTest.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BaseTest.cs
@@ -7,13 +7,15 @@ namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.SqlConnectionExtension
 public abstract class BaseTest : IDisposable
 {
     protected readonly ITestOutputHelper _output;
+    private readonly SqlServerFixture _fixture;
     protected readonly TestDbContext _context;
     protected readonly SqlConnection _connection;
 
-    protected BaseTest(ITestOutputHelper output, string dbPrefixName, string schema = "")
+    protected BaseTest(ITestOutputHelper output, SqlServerFixture fixture, string dbPrefixName, string schema = "")
     {
         _output = output;
-        var connectionString = GetConnectionString(dbPrefixName);
+        _fixture = fixture;
+        var connectionString = _fixture.GetConnectionString(dbPrefixName);
         _context = GetDbContext(connectionString, schema);
         _context.Database.EnsureCreated();
         _connection = new SqlConnection(connectionString);
@@ -24,11 +26,6 @@ public void Dispose()
         _context.Database.EnsureDeleted();
     }
 
-    protected string GetConnectionString(string dbPrefixName)
-    {
-        return $"Server=127.0.0.1;Database={dbPrefixName}.{Guid.NewGuid()};User Id=sa;Password=sqladmin123!@#;Encrypt=False";
-    }
-
     protected TestDbContext GetDbContext(string connectionString, string schema)
     {
         return new TestDbContext(connectionString, schema);
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BulkDeleteTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BulkDeleteTests.cs
@@ -6,11 +6,12 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.SqlConnectionExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkDeleteTests : BaseTest
 {
     private string _schema = "";
 
-    public BulkDeleteTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkDelete")
+    public BulkDeleteTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkDelete")
     {
         TableMapper.Register(typeof(SingleKeyRow<int>), _schema, "SingleKeyRows");
         TableMapper.Register(typeof(CompositeKeyRow<int, int>), _schema, "CompositeKeyRows");
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BulkInsertTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BulkInsertTests.cs
@@ -5,11 +5,12 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.SqlConnectionExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkInsertTests : BaseTest
 {
     private string _schema = "";
 
-    public BulkInsertTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkInsert")
+    public BulkInsertTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkInsert")
     {
         TableMapper.Register(typeof(SingleKeyRow<int>), _schema, "SingleKeyRows");
         TableMapper.Register(typeof(CompositeKeyRow<int, int>), _schema, "CompositeKeyRows");
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BulkUpdateTests.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlConnectionExtensions/BulkUpdateTests.cs
@@ -7,11 +7,12 @@
 
 namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.SqlConnectionExtensions;
 
+[Collection("SqlServerCollection")]
 public class BulkUpdateTests : BaseTest
 {
     private string _schema = "";
 
-    public BulkUpdateTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkUpdate")
+    public BulkUpdateTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkUpdate")
     {
         TableMapper.Register(typeof(SingleKeyRow<int>), _schema, "SingleKeyRows");
         TableMapper.Register(typeof(CompositeKeyRow<int, int>), _schema, "CompositeKeyRows");
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlServerCollection.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlServerCollection.cs
@@ -0,0 +1,8 @@
+﻿namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests;
+
+[CollectionDefinition("SqlServerCollection")]
+public class SqlServerCollection : ICollectionFixture<SqlServerFixture>
+{
+    // This class has no code, and is never created.
+    // Its purpose is to apply [CollectionDefinition] and ICollectionFixture<T>.
+}
diff --git a/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlServerFixture.cs b/src/EntityFrameworkCore.SqlServer.SimpleBulks.Tests/SqlServerFixture.cs
@@ -0,0 +1,59 @@
+﻿using Microsoft.Data.SqlClient;
+using Testcontainers.MsSql;
+
+namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests;
+
+public class SqlServerFixture : IAsyncLifetime
+{
+    private bool UseContainer => true;
+
+    public MsSqlContainer? Container { get; }
+
+    public SqlServerFixture()
+    {
+        if (!UseContainer)
+        {
+            return;
+        }
+
+        Container = new MsSqlBuilder()
+            .WithImage("mcr.microsoft.com/mssql/server:2022-latest")
+            .Build();
+    }
+
+    public async Task InitializeAsync()
+    {
+        if (!UseContainer)
+        {
+            return;
+        }
+
+        await Container!.StartAsync();
+    }
+
+    public async Task DisposeAsync()
+    {
+        if (!UseContainer)
+        {
+            return;
+        }
+
+        await Container!.DisposeAsync();
+    }
+
+    public string GetConnectionString(string dbPrefixName)
+    {
+        if (!UseContainer)
+        {
+            return $"Server=127.0.0.1;Database={dbPrefixName}.{Guid.NewGuid()};User Id=sa;Password=sqladmin123!@#;Encrypt=False";
+        }
+
+        var connectionString = new SqlConnectionStringBuilder(Container!.GetConnectionString())
+        {
+            InitialCatalog = $"{dbPrefixName}.{Guid.NewGuid()}"
+        }.ToString();
+
+        return connectionString;
+    }
+}
+

Original file line number	Diff line number	Diff line change
`@@ -6,12 +6,13 @@ namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;`
`6`	`6`	`public abstract class BaseTest : IDisposable`
`7`	`7`	`{`
`8`	`8`	`protected readonly ITestOutputHelper _output;`
`9`		`-`
	`9`	`+ protected readonly SqlServerFixture _fixture;`
`10`	`10`	`protected readonly TestDbContext _context;`
`11`	`11`
`12`		`- protected BaseTest(ITestOutputHelper output, string dbPrefixName, string schema = "")`
	`12`	`+ protected BaseTest(ITestOutputHelper output, SqlServerFixture fixture, string dbPrefixName, string schema = "")`
`13`	`13`	`{`
`14`	`14`	`_output = output;`
	`15`	`+ _fixture = fixture;`
`15`	`16`	`_context = GetDbContext(dbPrefixName, schema);`
`16`	`17`	`_context.Database.EnsureCreated();`
`17`	`18`	`}`
`@@ -21,13 +22,8 @@ public void Dispose()`
`21`	`22`	`_context.Database.EnsureDeleted();`
`22`	`23`	`}`
`23`	`24`
`24`		`- protected string GetConnectionString(string dbPrefixName)`
`25`		`- {`
`26`		`- return $"Server=127.0.0.1;Database={dbPrefixName}.{Guid.NewGuid()};User Id=sa;Password=sqladmin123!@#;Encrypt=False";`
`27`		`- }`
`28`		`-`
`29`	`25`	`protected TestDbContext GetDbContext(string dbPrefixName, string schema)`
`30`	`26`	`{`
`31`		`- return new TestDbContext(GetConnectionString(dbPrefixName), schema);`
	`27`	`+ return new TestDbContext(_fixture.GetConnectionString(dbPrefixName), schema);`
`32`	`28`	`}`
`33`	`29`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,9 +6,10 @@`
`6`	`6`
`7`	`7`	`namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;`
`8`	`8`
	`9`	`+[Collection("SqlServerCollection")]`
`9`	`10`	`public class BulkDeleteTests : BaseTest`
`10`	`11`	`{`
`11`		`- public BulkDeleteTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkDelete")`
	`12`	`+ public BulkDeleteTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkDelete")`
`12`	`13`	`{`
`13`	`14`	`var tran = _context.Database.BeginTransaction();`
`14`	`15`
Original file line number	Diff line number	Diff line change
`@@ -5,9 +5,10 @@`
`5`	`5`
`6`	`6`	`namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;`
`7`	`7`
	`8`	`+[Collection("SqlServerCollection")]`
`8`	`9`	`public class BulkInsertTests : BaseTest`
`9`	`10`	`{`
`10`		`- public BulkInsertTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkInsert")`
	`11`	`+ public BulkInsertTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkInsert")`
`11`	`12`	`{`
`12`	`13`	`}`
`13`	`14`
Original file line number	Diff line number	Diff line change
`@@ -5,12 +5,13 @@`
`5`	`5`
`6`	`6`	`namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;`
`7`	`7`
	`8`	`+[Collection("SqlServerCollection")]`
`8`	`9`	`public class BulkMatchTests : BaseTest`
`9`	`10`	`{`
`10`	`11`	`private readonly List<Customer> _customers;`
`11`	`12`	`private readonly List<Contact> _contacts;`
`12`	`13`
`13`		`- public BulkMatchTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkMatch")`
	`14`	`+ public BulkMatchTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkMatch")`
`14`	`15`	`{`
`15`	`16`	`var tran = _context.Database.BeginTransaction();`
`16`	`17`
Original file line number	Diff line number	Diff line change
`@@ -7,9 +7,10 @@`
`7`	`7`
`8`	`8`	`namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;`
`9`	`9`
	`10`	`+[Collection("SqlServerCollection")]`
`10`	`11`	`public class BulkUpdateTests : BaseTest`
`11`	`12`	`{`
`12`		`- public BulkUpdateTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.BulkUpdate")`
	`13`	`+ public BulkUpdateTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.BulkUpdate")`
`13`	`14`	`{`
`14`	`15`	`}`
`15`	`16`
Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@`
`6`	`6`
`7`	`7`	`namespace EntityFrameworkCore.SqlServer.SimpleBulks.Tests.DbContextExtensions;`
`8`	`8`
	`9`	`+[Collection("SqlServerCollection")]`
`9`	`10`	`public class TempTableTests : BaseTest`
`10`	`11`	`{`
`11`	`12`	`private readonly static List<CustomerDto> _customers = new List<CustomerDto>`
`@@ -58,7 +59,7 @@ public class TempTableTests : BaseTest`
`58`	`59`	`}`
`59`	`60`	`};`
`60`	`61`
`61`		`- public TempTableTests(ITestOutputHelper output) : base(output, "EFCoreSimpleBulksTests.TempTable")`
	`62`	`+ public TempTableTests(ITestOutputHelper output, SqlServerFixture fixture) : base(output, fixture, "EFCoreSimpleBulksTests.TempTable")`
`62`	`63`	`{`
`63`	`64`	`}`
`64`	`65`