logofclient/DataStore/DatabaseService.cs

using System;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;

namespace Logof_Client;

/// <summary>
/// Zentrale Datenbankverwaltung für Logof Client.
/// 
/// Zuständig für:
/// - PostgreSQL-Verbindung
/// - EF Core DbContext
/// - Datenbankmodelle
/// - Migrationen
/// - Verbindungstest
/// </summary>
public static class DatabseService
{
    private static DbContextOptions<LogofDbContext>? _options;

    /// <summary>
    /// Initialisiert die Datenbankverbindung.
    /// Sollte einmal beim Programmstart aufgerufen werden.
    /// </summary>
    public static void Initialize(string connectionString)
    {
        if (string.IsNullOrWhiteSpace(connectionString))
            throw new ArgumentException(
                "Kein Datenbank-Connection-String angegeben.",
                nameof(connectionString));

        var builder = new DbContextOptionsBuilder<LogofDbContext>();

        builder.UseNpgsql(connectionString);

        _options = builder.Options;
    }

    /// <summary>
    /// Erstellt einen neuen DbContext.
    /// </summary>
    public static LogofDbContext GetContext()
    {
        if (_options == null)
            throw new InvalidOperationException(
                "DB wurde noch nicht initialisiert. " +
                "Rufen Sie DB.Initialize(...) auf.");

        return new LogofDbContext(_options);
    }

    /// <summary>
    /// Testet die Verbindung zum Datenbankserver.
    /// </summary>
    public static async Task<bool> TestConnectionAsync()
    {
        try
        {
            await using var db = GetContext();
            return await db.Database.CanConnectAsync();
        }
        catch
        {
            return false;
        }
    }

    /// <summary>
    /// Erstellt bzw. aktualisiert das Datenbankschema
    /// anhand der vorhandenen EF-Core-Migrationen.
    /// </summary>
    public static async Task MigrateAsync()
    {
        await using var db = GetContext();

        await db.Database.MigrateAsync();
    }
}


// ============================================================================
// DATABASE CONTEXT
// ============================================================================

public class LogofDbContext : DbContext
{
    public DbSet<CustomerEx> Customers => Set<CustomerEx>();

    public LogofDbContext(
        DbContextOptions<LogofDbContext> options)
        : base(options)
    {
    }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);

        // --------------------------------------------------------------------
        // Customer
        // --------------------------------------------------------------------

        modelBuilder.Entity<CustomerEx>(entity =>
        {
            entity.ToTable("customers");

            entity.HasKey(x => x.Id);

            entity.Property(x => x.Id)
                .ValueGeneratedOnAdd();

            entity.Property(x => x.Name)
                .HasMaxLength(255)
                .IsRequired();

            entity.Property(x => x.Description)
                .HasMaxLength(4000);

            entity.Property(x => x.SenderAddress)
                .HasMaxLength(4000);

            entity.Property(x => x.Separator)
                .HasMaxLength(1)
                .IsRequired();

            // Optimistic Concurrency
            entity.Property(x => x.Version)
                .IsConcurrencyToken();

            entity.Property(x => x.CreatedAt)
                .IsRequired();

            entity.Property(x => x.UpdatedAt)
                .IsRequired();
        });
    }
}


// ============================================================================
// DATABASE MODELS
// ============================================================================

public class CustomerEx
{
    public long Id { get; set; }

    public string Name { get; set; } = "";

    public string Description { get; set; } = "";

    public string SenderAddress { get; set; } = "";

    public char Separator { get; set; } = ',';

    /// <summary>
    /// Wird bei jeder Änderung erhöht.
    /// Verhindert, dass zwei Benutzer sich gegenseitig
    /// Änderungen überschreiben.
    /// </summary>
    public long Version { get; set; } = 1;

    public DateTime CreatedAt { get; set; }

    public DateTime UpdatedAt { get; set; }
}