Implement Test Container for PostgreSQL

EconDataLens.Tests/EconDataLens.Tests.csproj

@@ -15,9 +15,11 @@
           <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>
         <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.12.0"/>
+        <PackageReference Include="Npgsql" Version="9.0.3" />
         <PackageReference Include="NUnit" Version="4.2.2"/>
         <PackageReference Include="NUnit.Analyzers" Version="4.4.0"/>
         <PackageReference Include="NUnit3TestAdapter" Version="4.6.0"/>
+        <PackageReference Include="Testcontainers.PostgreSql" Version="4.7.0" />
     </ItemGroup>
 
     <ItemGroup>
@@ -31,9 +33,9 @@
     </ItemGroup>
 
     <ItemGroup>
-        <Content Include="Fixtures/**">
+        <Content Include="TestData/**">
             <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
         </Content>
-    </ItemGroup>
+   </ItemGroup>
 
 </Project>

EconDataLens.Tests/Services/CpiAreaParserTests.cs → EconDataLens.Tests/EtlParserTests/CpiAreaParserTests.cs

@@ -4,7 +4,7 @@
 using EconDataLens.Services;
 using Microsoft.Extensions.Options;
 
-namespace EconDataLens.Tests.Services;
+namespace EconDataLens.Tests.EtlParserTests;
 
 public class CpiAreaParserTests
 {
@@ -35,7 +35,7 @@ public void SetUp()
    [Test]
    public async Task ParseCpiAreaAsync_HeaderOnly_YieldsNoResults()
    {
-      var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.area.empty");
+      var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.area.empty");
 
       var rows = new List<CpiArea>();
 
@@ -48,7 +48,7 @@ public async Task ParseCpiAreaAsync_HeaderOnly_YieldsNoResults()
    [Test]
    public async Task ParseCpiAreaAsync_FileWithRecords_YieldsResults()
    {
-      var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.area.sample");
+      var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.area.sample");
 
       var rows = new List<CpiArea>();
 

EconDataLens.Tests/Services/CpiDataParserTests.cs → EconDataLens.Tests/EtlParserTests/CpiDataParserTests.cs

@@ -5,7 +5,7 @@
 using Microsoft.Extensions.Options;
 
 
-namespace EconDataLens.Tests.Services;
+namespace EconDataLens.Tests.EtlParserTests;
 
 public class CpiDataParserTests
 {
@@ -36,7 +36,7 @@ public void SetUp()
     [Test]
     public async Task ParseCpiFootnoteAsync_HeaderOnly_YieldsNoResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.data.0.Current.empty");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.data.0.Current.empty");
         var rows = new List<CpiData>();
 
         await foreach (var row in _parser.ParseCpiDataAsync(path))
@@ -49,7 +49,7 @@ public async Task ParseCpiFootnoteAsync_HeaderOnly_YieldsNoResults()
     [Test]
     public async Task ParseCpiDataAsync_FileWithRecords_YieldsResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.data.0.Current.sample");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.data.0.Current.sample");
         var rows = new List<CpiData>();
 
         await foreach (var row in _parser.ParseCpiDataAsync(path))

EconDataLens.Tests/Services/CpiFootnoteParserTests.cs → EconDataLens.Tests/EtlParserTests/CpiFootnoteParserTests.cs

@@ -4,7 +4,7 @@
 using EconDataLens.Services;
 using Microsoft.Extensions.Options;
 
-namespace EconDataLens.Tests.Services;
+namespace EconDataLens.Tests.EtlParserTests;
 
 [TestFixture]
 public class CpiFootnoteParserTests
@@ -37,7 +37,7 @@ public void SetUp()
     public async Task ParseCpiFootnoteAsync_HeaderOnly_YieldsNoResults()
     {
         // Arrange
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.footnote.empty");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.footnote.empty");
 
         // Act
         var rows = new List<CpiFootnote>();
@@ -53,7 +53,7 @@ public async Task ParseCpiFootnoteAsync_HeaderOnly_YieldsNoResults()
     public async Task ParseCpiFootnoteAsync_FileWithRecords_YieldsResults()
     {
         // Arrange
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.footnote.sample");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.footnote.sample");
 
         // Act
         var rows = new List<CpiFootnote>();

EconDataLens.Tests/Services/CpiItemParserTests.cs → EconDataLens.Tests/EtlParserTests/CpiItemParserTests.cs

@@ -4,7 +4,7 @@
 using EconDataLens.Services;
 using Microsoft.Extensions.Options;
 
-namespace EconDataLens.Tests.Services;
+namespace EconDataLens.Tests.EtlParserTests;
 
 public class CpiItemParserTests
 {
@@ -35,7 +35,7 @@ public void SetUp()
     [Test]
     public async Task ParseCpiItemAsync_HeaderOnly_YieldsNoResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.item.empty");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.item.empty");
         var rows = new List<CpiItem>();
 
         await foreach (var row in _parser.ParseCpiItemsAsync(path))
@@ -47,7 +47,7 @@ public async Task ParseCpiItemAsync_HeaderOnly_YieldsNoResults()
     [Test]
     public async Task ParseCpiItemAsync_FileWithRecords_YieldsResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.item.sample");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.item.sample");
         var rows = new List<CpiItem>();
 
         await foreach (var row in _parser.ParseCpiItemsAsync(path))

EconDataLens.Tests/Services/CpiPeriodParserTests.cs → EconDataLens.Tests/EtlParserTests/CpiPeriodParserTests.cs

@@ -4,7 +4,7 @@
 using EconDataLens.Services;
 using Microsoft.Extensions.Options;
 
-namespace EconDataLens.Tests.Services;
+namespace EconDataLens.Tests.EtlParserTests;
 
 public class CpiPeriodParserTests
 {
@@ -35,7 +35,7 @@ public void SetUp()
     [Test]
     public async Task ParseCpiPeriodAsync_HeaderOnly_YieldsNoResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.period.empty");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.period.empty");
         var rows = new List<CpiPeriod>();
 
         await foreach (var row in _parser.ParseCpiPeriodsAsync(path))
@@ -47,7 +47,7 @@ public async Task ParseCpiPeriodAsync_HeaderOnly_YieldsNoResults()
     [Test]
     public async Task ParseCpiPeriodAsync_FileWithRecords_YieldsResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.period.sample");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.period.sample");
         var rows = new List<CpiPeriod>();
 
         await foreach (var row in _parser.ParseCpiPeriodsAsync(path))

EconDataLens.Tests/Services/CpiSeriesParserTests.cs → EconDataLens.Tests/EtlParserTests/CpiSeriesParserTests.cs

@@ -4,7 +4,7 @@
 using EconDataLens.Services;
 using Microsoft.Extensions.Options;
 
-namespace EconDataLens.Tests.Services;
+namespace EconDataLens.Tests.EtlParserTests;
 
 public class CpiSeriesParserTests
 {
@@ -35,7 +35,7 @@ public void SetUp()
     [Test]
     public async Task ParseCpiSeriesAsync_HeaderOnly_YieldsNoResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.series.empty");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.series.empty");
         var rows = new List<CpiSeries>();
 
         await foreach (var row in _parser.ParseCpiSeriesAsync(path))
@@ -47,7 +47,7 @@ public async Task ParseCpiSeriesAsync_HeaderOnly_YieldsNoResults()
     [Test]
     public async Task ParseCpiSeriesAsync_FileWithRecords_YieldsResults()
     {
-        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "Fixtures", "cu.series.sample");
+        var path = Path.Combine(TestContext.CurrentContext.TestDirectory, "TestData", "cu.series.sample");
         var rows = new List<CpiSeries>();
 
         await foreach (var row in _parser.ParseCpiSeriesAsync(path))

EconDataLens.Tests/PostgresFixture.cs

@@ -0,0 +1,40 @@
+using EconDataLens.Data;
+using Microsoft.EntityFrameworkCore;
+using Testcontainers.PostgreSql;
+
+namespace EconDataLens.Tests;
+
+[SetUpFixture]
+public class PostgresFixture
+{
+    private PostgreSqlContainer _container = default!;
+    public static string ConnectionString { get; private set; } = string.Empty;
+
+    [OneTimeSetUp]
+    public async Task OneTimeSetUp()
+    {
+        _container = new PostgreSqlBuilder()
+            .WithImage("postgres:17-alpine")
+            .WithDatabase("econ_test")
+            .WithUsername("postgres")
+            .WithPassword("postgres")
+            .WithCleanUp(true)
+            .Build();
+
+        await _container.StartAsync();
+        ConnectionString = _container.GetConnectionString();
+
+        var options = new DbContextOptionsBuilder<EconDataLensDbContext>()
+            .UseNpgsql(ConnectionString)
+            .Options;
+
+        await using var ctx = new EconDataLensDbContext(options);
+        await ctx.Database.MigrateAsync();
+    }
+
+    [OneTimeTearDown]
+    public async Task OneTimeTearDown()
+    {
+        await _container.DisposeAsync();
+    }
+}

EconDataLens.Tests/Smoke/DbSmokeTest.cs

@@ -0,0 +1,36 @@
+using Microsoft.EntityFrameworkCore;
+using EconDataLens.Core.Entities.Cpi;
+using EconDataLens.Data;
+
+namespace EconDataLens.Tests.Smoke;
+
+public class DbSmokeTests
+{
+    private static EconDataLensDbContext CreateDb()
+    {
+        var opts = new DbContextOptionsBuilder<EconDataLensDbContext>()
+            .UseNpgsql(PostgresFixture.ConnectionString)
+            .UseSnakeCaseNamingConvention()
+            .Options;
+
+        return new EconDataLensDbContext(opts);
+    }
+
+    [Test]
+    public async Task Can_Migrate_And_Do_Basic_CRUD()
+    {
+        await using var db = CreateDb();
+
+        // Insert
+        db.CpiArea.Add(new CpiArea { AreaCode = "ZZZ0", AreaName = "Test Area" });
+        await db.SaveChangesAsync();
+
+        // Query
+        var found = await db.CpiArea.AsNoTracking().CountAsync(a => a.AreaCode == "ZZZ0");
+        Assert.That(found, Is.EqualTo(1));
+
+        // Cleanup (optional)
+        db.CpiArea.RemoveRange(db.CpiArea.Where(a => a.AreaCode == "ZZZ0"));
+        await db.SaveChangesAsync();
+    }
+}