CS2-SimpleAdmin/CS2-SimpleAdmin/Database/Migration.cs

using Microsoft.Extensions.Logging;
using MySqlConnector;

namespace CS2_SimpleAdmin.Database;

public class Migration(Database database)
{
    public void ExecuteMigrations()
    {
        var migrationsDirectory = CS2_SimpleAdmin.Instance.ModuleDirectory + "/Database/Migrations";

        var files = Directory.GetFiles(migrationsDirectory, "*.sql")
                             .OrderBy(f => f);

        using var connection = database.GetConnection();

        // Create sa_migrations table if not exists
        using var cmd = new MySqlCommand("""
		                                             CREATE TABLE IF NOT EXISTS `sa_migrations` (
		                                                 `id` INT PRIMARY KEY AUTO_INCREMENT,
		                                                 `version` VARCHAR(255) NOT NULL
		                                             );
		                                 """, connection);

        cmd.ExecuteNonQuery();

        // Get the last applied migration version
        var lastAppliedVersion = GetLastAppliedVersion(connection);

        foreach (var file in files)
        {
            var version = Path.GetFileNameWithoutExtension(file);

            // Check if the migration has already been applied
            if (string.Compare(version, lastAppliedVersion, StringComparison.OrdinalIgnoreCase) <= 0) continue;
            var sqlScript = File.ReadAllText(file);

            using var cmdMigration = new MySqlCommand(sqlScript, connection);
            cmdMigration.ExecuteNonQuery();

            // Update the last applied migration version
            UpdateLastAppliedVersion(connection, version);

            CS2_SimpleAdmin._logger?.LogInformation($"Migration \"{version}\" successfully applied.");
        }
    }

    private static string GetLastAppliedVersion(MySqlConnection connection)
    {
        using var cmd = new MySqlCommand("SELECT `version` FROM `sa_migrations` ORDER BY `id` DESC LIMIT 1;", connection);
        var result = cmd.ExecuteScalar();
        return result?.ToString() ?? string.Empty;
    }

    private static void UpdateLastAppliedVersion(MySqlConnection connection, string version)
    {
        using var cmd = new MySqlCommand("INSERT INTO `sa_migrations` (`version`) VALUES (@Version);", connection);
        cmd.Parameters.AddWithValue("@Version", version);
        cmd.ExecuteNonQuery();
    }
}