jdescopingtool/NEW/src/JdeScoping.Database/DatabaseMigrator.cs

using DbUp;
using DbUp.Engine;
using Microsoft.Extensions.Configuration;

namespace JdeScoping.Database;

/// <summary>
/// Handles database migrations using DbUp.
/// </summary>
public class DatabaseMigrator : IDatabaseMigrator
{
    private readonly string _connectionString;

    /// <summary>
    /// Initializes a new instance of the DatabaseMigrator class.
    /// </summary>
    /// <param name="configuration">Application configuration containing connection strings.</param>
    /// <exception cref="InvalidOperationException">Thrown when SqlServer connection string is not configured.</exception>
    public DatabaseMigrator(IConfiguration configuration)
    {
        _connectionString = configuration.GetConnectionString("SqlServer")
            ?? throw new InvalidOperationException("SqlServer connection string not configured");
    }

    /// <inheritdoc />
    public DatabaseUpgradeResult Migrate()
    {
        EnsureDatabase.For.SqlDatabase(_connectionString);

        var upgrader = DeployChanges.To
            .SqlDatabase(_connectionString)
            .WithScriptsEmbeddedInAssembly(typeof(DatabaseMigrator).Assembly)
            .WithTransaction()
            .LogToConsole()
            .Build();

        return upgrader.PerformUpgrade();
    }
}