CoreDatabase 2025.5.15

SqlParameterExtensions

Una clase estática de extensiones para facilitar la creación y adición de parámetros SQL (SqlParameter) a una colección de parámetros (IDataParameterCollection) de forma fluida y legible en aplicaciones .NET que usan ADO.NET.

🚀 Características principales

• Sobrecargas convenientes para Add que permiten agregar parámetros SQL con distintos niveles de detalle: solo nombre y valor, tipo SQL, tamaño, precisión y dirección.
• Soporte para rangos con AddRange, que agrega múltiples parámetros a la vez.
• Binding automático de objetos con BindFrom<T> que convierte propiedades públicas en parámetros SQL.

📦 Métodos disponibles

Add(string parameterName, object value)

Agrega un parámetro con nombre y valor.

Add(string parameterName, SqlDbType sqlDbType, object value)

Agrega un parámetro con tipo de dato SQL.

Add(string parameterName, SqlDbType sqlDbType, int size, object value)

Agrega un parámetro con tamaño especificado.

Add(string parameterName, SqlDbType sqlDbType, byte precision, byte scale, object value)

Agrega un parámetro con precisión y escala (ideal para decimales).

Add(string parameterName, SqlDbType sqlDbType, int size, object value, ParameterDirection direction)

Agrega un parámetro con dirección (input, output, etc.).

AddRange(IEnumerable<IDataParameter> parameters)

Agrega una colección de parámetros a la colección actual.

BindFrom<T>(T item)

Convierte las propiedades públicas de un objeto en parámetros y los agrega a la colección. Solo se incluyen propiedades primitivas.

Interfaz IMSSqlRepository

La interfaz IMSSqlRepository define el contrato para el repositorio que permite interactuar con una base de datos SQL Server. Sus responsabilidades incluyen la gestión de conexiones, ejecución de comandos y consultas, manejo de transacciones y operaciones bulk.

Propiedades principales

• string ConnectionString
  Cadena de conexión actual utilizada para conectar con la base de datos.

• ConnectionState ConnectionState
  Estado actual de la conexión (abierta, cerrada, etc.).

Gestión de conexión y transacciones

• void ConnectionClose()
  Cierra la conexión si está abierta y no hay transacciones activas.

• void BeginTransaction()
  Inicia una transacción en la conexión actual.

• void CommitTransaction()
  Confirma la transacción activa y cierra la conexión.

• void RollbackTransaction()
  Revierte la transacción activa y cierra la conexión.

Consultas y ejecución

• DataTable GetTableFromQuery(string query, Action<IDataParameterCollection> parameter = null)
  Ejecuta una consulta SQL y devuelve un DataTable con los resultados.

• DataTable GetTableFromStoredProcedure(string procedimientoAlmacenado, Action<IDataParameterCollection> parameter = null)
  Ejecuta un procedimiento almacenado y devuelve un DataTable.

• T GetItemFromQuery<T>(string query, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Ejecuta una consulta y transforma la primera fila a un objeto del tipo T.

• T GetItemFromStoredProcedure<T>(string procedimientoAlmacenado, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Igual que el anterior, pero con procedimiento almacenado.

• ICollection<Dictionary<string, object>> GetDictionaryFromQuery(string query, Action<IDataParameterCollection> parameter = null)
  Obtiene resultados de consulta como una colección de diccionarios con nombre/valor.

• ICollection<Dictionary<string, object>> GetDictionaryFromStoredProcedure(string procedimientoAlmacenado, Action<IDataParameterCollection> parameter = null)
  Igual que el anterior, pero para procedimientos almacenados.

• ICollection<T> GetItemsFromStoredProcedure<T>(string procedimientoAlmacenado, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Obtiene una colección de objetos tipo T a partir de un procedimiento almacenado.

• ICollection<T> GetItemsFromQuery<T>(string query, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Obtiene una colección de objetos tipo T a partir de una consulta SQL.

Ejecución de comandos

• void ExecuteNonQuery(string command, Action<IDataParameterCollection> parameter = null)
  Ejecuta comandos SQL que no retornan datos (INSERT, UPDATE, DELETE, etc.).

• void ExecuteInsert<T>(string tableName, T entity) where T : class, new()
  Inserta un único objeto en la tabla especificada usando reflexión.

• void ExecuteInsert<T>(string tableName, ICollection<T> collection) where T : class, new()
  Inserta una colección de objetos en la tabla especificada.

• void ExecuteStoredProcedureCommand(string procedimientoAlmacenado, Action<IDataParameterCollection> parameter = null)
  Ejecuta un procedimiento almacenado que no devuelve resultados.

Operaciones Bulk Copy

• void ExecuteBulkCopyToTable(DataTable source, string destinationTable)
  Borra la tabla destino, la crea según la estructura de la tabla fuente y realiza la inserción masiva.

• void ExecuteBulkCopy(DataTable source, string destinationTable)
  Inserción masiva desde un DataTable.

• void ExecuteBulkCopy(IDataReader source, string destinationTable)
  Inserción masiva desde un IDataReader.

Otros métodos útiles

• DateTime GetCurrentDateTime()
  Obtiene la fecha y hora actual del servidor SQL.

• Métodos para crear parámetros SQL para consultas y procedimientos almacenados (AddParameter).

• Métodos para configurar la conexión (SetDatabaseLogon).

Métodos Asíncronos de IMSSqlRepository

La interfaz también define métodos asíncronos para mejorar el rendimiento y escalabilidad de las operaciones de base de datos.

Métodos asíncronos principales

• Task<T> GetItemFromQueryAsync<T>(string query, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Ejecuta una consulta SQL asíncrona y transforma la primera fila en un objeto T.

• Task<T> GetItemFromStoredProcedureAsync<T>(string procedimientoAlmacenado) where T : new()
  Ejecuta un procedimiento almacenado de forma asíncrona y devuelve un objeto T por defecto.

• Task<T> GetItemFromStoredProcedureAsync<T>(string procedimientoAlmacenado, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Ejecuta un procedimiento almacenado de forma asíncrona y mapea la primera fila a un objeto T.

• Task<DataTable> GetTableFromQueryAsync(string query, Action<IDataParameterCollection> parameter = null)
  Ejecuta una consulta asíncrona y devuelve un DataTable con los resultados.

• Task<DataTable> GetTableFromStoredProcedureAsync(string procedimientoAlmacenado, Action<IDataParameterCollection> parameter = null)
  Ejecuta un procedimiento almacenado de forma asíncrona y devuelve un DataTable.

• Task<ICollection<Dictionary<string, object>>> GetDictionaryFromQueryAsync(string query, Action<IDataParameterCollection> parameter = null)
  Ejecuta una consulta asíncrona y devuelve una colección de diccionarios.

• Task<ICollection<Dictionary<string, object>>> GetDictionaryFromStoredProcedureAsync(string procedimientoAlmacenado, Action<IDataParameterCollection> parameter = null)
  Igual que el anterior, pero para procedimientos almacenados.

• Task<ICollection<T>> GetItemsFromQueryAsync<T>(string query, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Obtiene una colección de objetos T de una consulta asíncrona.

• Task<ICollection<T>> GetItemsFromStoredProcedureAsync<T>(string storedProcedure) where T : new()
  Obtiene una colección de objetos T de un procedimiento almacenado asíncrono.

• Task<ICollection<T>> GetItemsFromStoredProcedureAsync<T>(string storedProcedure, Func<IDataReader, T> expression, Action<IDataParameterCollection> parameter = null)
  Igual que el anterior, pero con mapeo personalizado.

Comandos asíncronos

• Task<int> ExecuteStoredProcedureCommandAsync(string storedProcedure, Action<IDataParameterCollection> parameter = null)
  Ejecuta un procedimiento almacenado asíncrono que devuelve el número de filas afectadas.

• Task ExecuteNonQueryAsync(string command, Action<IDataParameterCollection> parameter = null)
  Ejecuta un comando SQL que no retorna datos de forma asíncrona.

• Task ExecuteBulkCopyToTableAsync(DataTable sourceTable, string destinationTable)
  Realiza una inserción masiva asíncrona creando la tabla destino.

• Task ExecuteBulkCopyAsync(DataTable source, string destinationTable)
  Inserción masiva asíncrona desde un DataTable.

• Task ExecuteBulkCopyAsync(IDataReader source, string destinationTable)
  Inserción masiva asíncrona desde un IDataReader.

• Task ExecuteInsertAsync<T>(string tableName, T entity)
  Inserta un objeto de forma asíncrona en la tabla especificada.

• Task ExecuteInsertAsync<T>(string tableName, ICollection<T> collection)
  Inserta una colección de objetos de forma asíncrona.

• Task<DateTime> GetCurrentDateTimeAsync()
  Obtiene la fecha y hora actual del servidor SQL de forma asíncrona.

Métodos para manejo de tablas en IMSSqlRepository

Además de los métodos para manipulación de datos, la interfaz incluye operaciones para gestionar tablas directamente:

• void DropTable(string tableName)
  Elimina la tabla especificada de la base de datos.

• void CreateTable(DataTable sourceTable, string destinationTable)
  Crea una tabla en la base de datos a partir de la estructura de un DataTable.

• void CreateTable(IDataReader reader, string destinationTable)
  Crea una tabla en la base de datos basándose en la estructura del IDataReader.

Interfaz IServiceProviderKeyed

Esta interfaz proporciona un mecanismo para obtener servicios basados en una clave específica:

public interface IServiceProviderKeyed
{
    TService GetKeyedService<TService, TKeyed>(TKeyed key);
}

public void ConfigureServices(IServiceCollection services)
{
    services.AddMicrosoftSQL(provider =>
    {
        // Aquí configuras la instancia concreta de IMSSqlRepository
        IMSSqlRepository repo = new MSSqlRepository();
        repo.SetDatabaseLogon("Server=myServer;Database=myDB;User Id=myUser;Password=myPassword;");
        return repo;
    }, ServiceLifetime.Scoped);
}