DS.Foundation.Data 8.4.2

DS.Foundation.Data

Acceso a datos común para aplicaciones DS:

• DatabaseAccessPointOptions, que describe una conexión (motor, cadena de conexión y esquema).

• DatabaseAccessPointFactory, que arma esa conexión desde un DataStoreOptions.

• FluentMigratorUpdater, que ejecuta migraciones de FluentMigrator.

• Administradores de bases de datos para SQL Server, PostgreSQL y MySQL.

• Clases base de entidades para Dapper y NHibernate.

• Target framework: netstandard2.0.

• Dependencias: DS.Foundation, FluentMigrator 6.2 (runners de SQL Server, PostgreSQL y MySQL), Npgsql, MySqlConnector.

Instalación

<PackageReference Include="DS.Foundation.Data" Version="8.4.1" />

Registro

El paquete no registra servicios en DI. Las clases se crean directamente con un DatabaseAccessPointOptions. Para registrar NHibernate use el paquete DS.Foundation.NHibernate.

Configuración

DatabaseAccessPointOptions

Cadenas generadas por DatabaseAccessPointFactory.CreateFrom(DataStoreOptions)

Solo para DataStoreOptions.Type == Database; con otro tipo devuelve null. Usa Host, Port, Path (nombre de la base), Security.Username y Security.Password.

El motor por defecto de la fábrica es MySQL (new DatabaseAccessPointFactory()).

Los valores con ;, = o comillas (por ejemplo, una contraseña) se entrecomillan según el formato de cadenas de conexión de ADO.NET, así que no rompen la cadena.

En SQL Server, TrustServerCertificate=True acepta el certificado del servidor sin validarlo. Es el valor por defecto por compatibilidad; en producción, con un certificado de confianza, desactivarlo:

var factory = new DatabaseAccessPointFactory(DbEngine.SqlServer) { TrustServerCertificate = false };

Uso

Ejecutar migraciones

using DS.Foundation.Configuration;
using DS.Foundation.Configuration.Options;
using DS.Foundation.Data.FluentMigrator;

var dap = new DatabaseAccessPointOptions
{
    Engine = DbEngine.PostgreSQL,
    ConnectionString = connectionString,
    Schema = "public",
};

new FluentMigratorUpdater(dap)
    .ScanIn(typeof(MiPrimeraMigracion).Assembly)
    .Run();              // todas las migraciones pendientes

new FluentMigratorUpdater(dap)
    .ScanIn(typeof(MiPrimeraMigracion).Assembly)
    .Run("datos-demo");  // solo las migraciones con [Tags("datos-demo")]

• Motores soportados por FluentMigratorUpdater: SQL Server, PostgreSQL, MySQL y MariaDB (con el runner de MySQL 8).
• La tabla de versiones es __fm_migration_history (CustomVersionTableMetaData). Para usar otra, herede de CustomVersionTableMetaData y pásela con SetVersionTableMetaDataType(typeof(MiTabla)).
• ScanInAllAssemblies() busca en los ensamblados cargados las clases que implementan IFluentMigratorRepository.
• Run es sincrónico y escribe el log de FluentMigrator en la consola.

Crear la conexión desde DataStoreOptions

var dap = new DatabaseAccessPointFactory(DbEngine.SqlServer).CreateFrom(dataStoreOptions);

Administrar bases (pruebas y herramientas)

var manager = new PostgresDbManager(dap);
List<string> tablas = manager.ListTables();   // esquema public
manager.Execute("UPDATE ...");                // sentencia sin parámetros
manager.Reset();                               // DROP DATABASE + CREATE DATABASE de la base de la cadena

Reset() en PostgreSQL y SQL Server se conecta a la base de mantenimiento (postgres o master), así que el usuario necesita acceso a ella y permiso para crear bases. Falla si otras sesiones están usando la base.

Entidades

• AgnosticEntity<T>: identidad por Id; == y Equals comparan Id.
• AuditableEntity<T>: agrega Deleted, AudWhen (ticks UTC), AudWho y AudWhat.
• DapperGuidEntity: Id Guid generado al construir. DapperAuditableEntity agrega IsDeleted y UpdateDateTime (hora local).
• NHibernateEntity<T>: igualdad compatible con entidades transitorias de NHibernate.

Errores frecuentes

Qué no hacer

• No pasar datos de usuario a Execute, MultipleNonQueryOptimizer.Add ni a los nombres de base: el SQL se envía tal cual, sin parámetros.
• No usar Reset() contra bases productivas: elimina y recrea la base de datos.
• No guardar ConnectionString ni Security.Password en appsettings.json versionado.
• No usar MultipleNonQueryOptimizer con sentencias de más de 4096 caracteres: lanza una excepción.

Cambios

Ver CHANGELOG.md.