Maurosoft.Net.RepositoryPattern 1.0.6

Maurosoft Repository Pattern

Una libreria per .NET 9 che fornisce un’implementazione pulita ed estensibile del Repository Pattern per l’accesso a più database.
Aggiunge un livello di astrazione utilizzando RepoDB.Net e Dapper, offrendo un approccio unificato per interagire con SQL Server, MySQL e ClickHouse.
(Il supporto a PostgreSQL è attualmente in sviluppo 🚧)

✨ Funzionalità

• 🔗 Implementazione unificata del Repository Pattern
• ⚡ Registrazione semplificata repository tramite classe base
• 🛠 Supporto per più ORM: RepoDB.Net e Dapper
• 🗄 Compatibile con:
  • Microsoft SQL Server
  • MySQL
  • ClickHouse
  • PostgreSQL (in arrivo)
• ⚡ Ottimizzata per .NET 9
• ♻️ Supporto a transazioni con unit of work
• 🧩 Estendibile facilmente per nuovi provider

📦 Installazione

Aggiungi il pacchetto tramite NuGet:

dotnet add package Maurosoft.Net.RepositoryPattern

⚙️ Configurazione

La libreria utilizza un approccio multi–database configurabile tramite appsettings.json.

È possibile definire uno o più endpoint, ciascuno con il relativo provider, connection string e l’eventuale abilitazione del supporto alle Unit of Work.

Esempio di configurazione:

{
  "Database": {
    "Default": "PrimarySql",
    "Endpoints": {
      "PrimarySql": {
        "Provider": "SqlServer",
        "UnitOfWork": true,
        "ConnectionString": "Data Source=server1;Initial Catalog=app;User Id=sa;Password=Pass@word1!;TrustServerCertificate=True;MultipleActiveResultSets=True;Application Name=Repository Pattern Library"
      },
      "SecondarySql": {
        "Provider": "SqlServer",
        "UnitOfWork": false,
        "ConnectionString": "Data Source=server2;Initial Catalog=app;User Id=sa;Password=Pass@word1!;TrustServerCertificate=True;MultipleActiveResultSets=True;Application Name=Repository Pattern Library"
      },
      "MySqlMain": {
        "Provider": "MySql",
        "UnitOfWork": true,
        "ConnectionString": "Server=server3;Port=3306;Database=app;User Id=root;Password=pass;"
      }
      "ClickHouseDW": {
        "Provider": "ClickHouse",
        "ConnectionString": "Host=server4;Port=8123;Database=dw;Username=default;Password="
      }
    }
  }
}

🧩 IRepository<TEntity> Metodi — DB Support Draft

Legenda: ✅ Supported · ⚠️ Limited/Workaround · ❌ Not available / impractical

🚀 Utilizzo

Un caso di utilizzo per copiare i dati di una tabella da 2 database diversi (MySql e SqlServer)

using System.ComponentModel.DataAnnotations.Schema;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Maurosoft.Net.RepositoryPattern.Interfaces;
using Maurosoft.Net.RepositoryPattern.Model;
using System.Data;
using Maurosoft.Net.RepositoryPattern;
using ZiggyCreatures.Caching.Fusion;

var host = Host.CreateDefaultBuilder(args)
    .ConfigureAppConfiguration(cfg =>
    {
        cfg.AddJsonFile("appsettings.json", optional: false, reloadOnChange: true);
        cfg.AddEnvironmentVariables();
    })
    .ConfigureServices((ctx, services) =>
    {
        services.AddRepositoryPattern(ctx.Configuration);
        services.AddKeyedScoped<IRepository<User>>("UserRepositoryMySql", (c, _) => new RepositoryPattern.Services.Repository<User>(c.GetRequiredService<IDbConnectionFactory>(), c.GetRequiredService<IFusionCache>(), "MySql"));
        services.AddKeyedScoped<IRepository<User>>("UserRepositorySqlServer", (c, _) => new RepositoryPattern.Services.Repository<User>(c.GetRequiredService<IDbConnectionFactory>(), c.GetRequiredService<IFusionCache>(), "SqlServer"));
    })
    .Build();

/*
- Sorgente: legge da MySql usando la SELECT (parametrizzata).
- Destinazione: il repository è attaccato a SqlServer → scrive su SQL Server.
- DatabaseField("UserName") definisce la/e colonne chiave di corrispondenza per il merge:
  - se UserName esiste già nel target → UPDATE della riga,
  - altrimenti → INSERT.
- Ritorno: rowAffected = numero di righe inserite/aggiornate nel target.
*/
using (var scoped = host.Services.CreateScope())
{
    var repo = scoped.ServiceProvider.GetRequiredKeyedService<IRepository<User>>("UserRepositorySqlServer");
    var uow = scoped.ServiceProvider.GetRequiredKeyedService<IUnitOfWork>("UnitOfWorkSqlServer");

    try
    {
      repo.Attach(uow);
      uow.Begin();

      // Merge degli utenti ... utilizzando il campo Username come chiave.
      var rowAffected = repo.CopyFrom(
          "MySql",                                       // endpoint sorgente (MySQL)
          "SELECT * FROM Users Where UserId > @UserId",  // query sorgente
          new { UserId = 1 },                            // parametri query
          CommandType.Text,                              // tipo comando
          60,                                            // timeout esecuzione (sec.)
          [ new DatabaseField("UserName") ]              // chiavi di merge (se non specificata, viene utilizzata la chiave primaria)
      );

      uow.Commit();
      
      Console.WriteLine($"Rows Affected: {rowAffected}");
    }
    catch
    {
        uow.Rollback();
        throw;
    }
}

[Table("Users")]
public class User
{
    public int UserId { get; set; }
    public string FirstName { get; set; } = string.Empty;
    public string LastName { get; set; } = string.Empty;
    public string UserName { get; set; } = string.Empty;
    public string Email { get; set; } = string.Empty;
}

🛡 Requisiti

• .NET 9
• Uno o più database supportati in esecuzione

📌 Roadmap

• Supporto SQL Server
• Supporto MySQL
• Supporto ClickHouse
• Supporto PostgreSQL
• Integrazione avanzata con caching