Cómo leer datos de un archivo CSV y almacenarlos en la base de datos C#

¿Qué es un archivo CSV?

Un archivo CSV (Valores Separados por Comas) es un archivo de texto sin formato que contiene datos separados por comas. Es un formato popular para transferir datos debido a su simplicidad y compatibilidad con varias aplicaciones, como Excel.

El papel de SQL Server y las bases de datos

SQL Server es un sistema de gestión de bases de datos de Microsoft. Se utiliza para almacenar y gestionar datos de manera estructurada. En nuestro caso, almacenaremos los datos CSV en una tabla de SQL Server.

Prerrequisitos

1. Visual Studio: asegúrese de tener instalado Visual Studio.
2. SQL Server: debe tener SQL Server instalado y accesible.
3. Instalación de IronXL: Instale IronXL ejecutando el siguiente comando NuGet:

dotnet add package IronXL

Asegúrate de ejecutar estos comandos dentro del directorio del proyecto donde deseas instalar IronXL.

Creación de una tabla de SQL Server

Antes de importar datos, crea una tabla de destino en tu base de datos SQL Server. Esta tabla almacenará los datos del CSV.

CREATE TABLE YourTableName (
    Column1 DataType,
    Column2 DataType,
    ...
);

Reemplaza YourTableName, Column1, Column2 y DataType con tus detalles específicos.

Paso 1: Lectura del archivo CSV

Al comenzar la tarea de importar datos de un archivo CSV, el primer paso crucial es leer los datos dentro del mismo con precisión. Cada línea en un archivo CSV típicamente representa un registro de datos, y cada registro consta de uno o más campos, separados por comas.

Luego empleamos la biblioteca IronXL para manejar el archivo CSV. Para leer el archivo CSV usando IronXL, se utilizarán sus clases WorkBook y WorkSheet. La clase WorkBook representa una hoja de cálculo completa, que podría ser un archivo de Excel o, en nuestro caso, un archivo CSV. Cuando cargas la ruta del archivo CSV en un objeto WorkBook, IronXL trata el archivo CSV como una hoja de cálculo/tabla de datos.

using IronXL;
using System.Data;

public class CSVReader
{
    // Reads a CSV file and converts it to a DataTable
    public DataTable ReadCSV(string filePath)
    {
        WorkBook workbook = WorkBook.Load(filePath);
        WorkSheet sheet = workbook.DefaultWorkSheet;
        // Convert to DataTable for easier processing
        DataTable dataTable = sheet.ToDataTable(true); // Set to 'true' if your CSV has a header row
        return dataTable;
    }
}

using IronXL;
using System.Data;

public class CSVReader
{
    // Reads a CSV file and converts it to a DataTable
    public DataTable ReadCSV(string filePath)
    {
        WorkBook workbook = WorkBook.Load(filePath);
        WorkSheet sheet = workbook.DefaultWorkSheet;
        // Convert to DataTable for easier processing
        DataTable dataTable = sheet.ToDataTable(true); // Set to 'true' if your CSV has a header row
        return dataTable;
    }
}

Paso 2: Establecer una conexión a la base de datos

Establecer una conexión a tu base de datos SQL Server es un paso fundamental en el proceso de almacenar tus datos CSV. Este paso implica configurar un enlace de comunicación entre tu aplicación y el servidor de base de datos. Una conexión exitosa es crucial porque, sin ella, transferir datos a la base de datos sería imposible.

Este paso se centra en crear y abrir una conexión utilizando una cadena de conexión en C#. La cadena de conexión es un componente vital ya que contiene la información necesaria para establecer la conexión. Es como una llave que abre la puerta a tu base de datos.

using System.Data.SqlClient;

public class DatabaseConnector
{
    // Connection string to connect to the database
    private string connectionString = "your_connection_string_here";

    public SqlConnection ConnectToDatabase()
    {
        SqlConnection connection = new SqlConnection(connectionString);
        connection.Open();
        return connection;
    }
}

using System.Data.SqlClient;

public class DatabaseConnector
{
    // Connection string to connect to the database
    private string connectionString = "your_connection_string_here";

    public SqlConnection ConnectToDatabase()
    {
        SqlConnection connection = new SqlConnection(connectionString);
        connection.Open();
        return connection;
    }
}

La variable connectionString contiene todos los detalles necesarios para conectar a tu SQL Server. Típicamente incluye el nombre del servidor, el nombre de la base de datos, el ID de usuario y la contraseña. Un ejemplo de cadena de conexión es: Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;. Es esencial reemplazar estos marcadores de posición con los detalles de tu servidor real.

Paso 3: Almacenamiento de datos en la base de datos

Habiendo establecido una conexión con la base de datos SQL Server, el siguiente paso crítico es almacenar los datos CSV en la base de datos. Este paso involucra transferir los datos que has leído y procesado a tu tabla de SQL Server. Es una parte crucial del proceso de manejo de datos, ya que involucra la migración de datos reales de un archivo local a un servidor de base de datos.

En este paso, nos enfocaremos en cómo los datos CSV, ahora almacenados en un DataTable, se transfieren a la base de datos SQL Server. Usamos una combinación de características de C# y SQL Server para lograr esta tarea de manera eficiente.

using System;
using System.Data;
using System.Data.SqlClient;

public class DataImporter
{
    public void ImportData(DataTable dataTable)
    {
        using (SqlConnection connection = new DatabaseConnector().ConnectToDatabase())
        {
            // Check if the table exists and create it if it does not.
            string tableName = "CSVData"; // Use a valid SQL table name format
            string checkTable = $"IF NOT EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '{tableName}') BEGIN ";
            string createTable = "CREATE TABLE " + tableName + " (";
            for (int i = 0; i < dataTable.Columns.Count; i++)
            {
                createTable += $"[{dataTable.Columns[i].ColumnName}] NVARCHAR(MAX)";
                if (i < dataTable.Columns.Count - 1)
                    createTable += ", ";
            }
            createTable += ") END";
            SqlCommand createTableCommand = new SqlCommand(checkTable + createTable, connection);
            createTableCommand.ExecuteNonQuery();

            // Now we use SqlBulkCopy to import the data
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
            {
                bulkCopy.DestinationTableName = tableName;
                try
                {
                    bulkCopy.WriteToServer(dataTable);
                    Console.WriteLine("Data imported successfully!");
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
        }
    }
}

using System;
using System.Data;
using System.Data.SqlClient;

public class DataImporter
{
    public void ImportData(DataTable dataTable)
    {
        using (SqlConnection connection = new DatabaseConnector().ConnectToDatabase())
        {
            // Check if the table exists and create it if it does not.
            string tableName = "CSVData"; // Use a valid SQL table name format
            string checkTable = $"IF NOT EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '{tableName}') BEGIN ";
            string createTable = "CREATE TABLE " + tableName + " (";
            for (int i = 0; i < dataTable.Columns.Count; i++)
            {
                createTable += $"[{dataTable.Columns[i].ColumnName}] NVARCHAR(MAX)";
                if (i < dataTable.Columns.Count - 1)
                    createTable += ", ";
            }
            createTable += ") END";
            SqlCommand createTableCommand = new SqlCommand(checkTable + createTable, connection);
            createTableCommand.ExecuteNonQuery();

            // Now we use SqlBulkCopy to import the data
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
            {
                bulkCopy.DestinationTableName = tableName;
                try
                {
                    bulkCopy.WriteToServer(dataTable);
                    Console.WriteLine("Data imported successfully!");
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }
        }
    }
}

Comienza abriendo una conexión a la base de datos SQL Server utilizando la clase DatabaseConnector, asegurando un camino para las transacciones de datos. El método verifica la existencia de la tabla llamada "CSVData" dentro de la base de datos.

Si la tabla no se encuentra, procede a crearla. El esquema de la tabla se construye en base al esquema del DataTable pasado al método, con todas las columnas configuradas como NVARCHAR(MAX) para acomodar cualquier dato de texto. Este es un enfoque genérico y puede necesitar refinamiento para ajustar más de cerca los tipos de datos específicos.

Después de eso, se formula y ejecuta un comando SQL para verificar la existencia de la tabla o para crearla. Esto asegura que la operación de copiado en bloque subsiguiente tenga una tabla de destino lista para la inserción de datos. Con la tabla lista, se emplea la clase SqlBulkCopy para transferir datos desde el DataTable directamente a la tabla SQL Server. Esta operación está diseñada para transferencias de datos en bloque de alto rendimiento, lo que la hace adecuada para manejar grandes volúmenes de datos de manera eficiente.

Paso 4: Poniéndolo todo junto

Después de trabajar diligentemente en los pasos anteriores de leer datos CSV, establecer una conexión a la base de datos y prepararse para transferir los datos, llegamos a la etapa final y crucial: integrar estos componentes individuales en un proceso cohesivo.

Esta integración se realiza en el método Main de tu aplicación C#, donde todo se une, permitiendo la ejecución real de la importación de datos del archivo CSV a la base de datos SQL Server.

class Program
{
    static void Main(string[] args)
    {
        string filePath = "path_to_your_csv_file.csv";
        CSVReader reader = new CSVReader();
        DataTable dataTable = reader.ReadCSV(filePath);
        DataImporter importer = new DataImporter();
        importer.ImportData(dataTable);
        Console.WriteLine("Data imported successfully!");
    }
}

class Program
{
    static void Main(string[] args)
    {
        string filePath = "path_to_your_csv_file.csv";
        CSVReader reader = new CSVReader();
        DataTable dataTable = reader.ReadCSV(filePath);
        DataImporter importer = new DataImporter();
        importer.ImportData(dataTable);
        Console.WriteLine("Data imported successfully!");
    }
}

Reemplazar path_to_your_csv_file.csv con la ruta a tu archivo CSV.

Ejecución del proyecto

Una vez que ejecutes el proyecto, verás el siguiente resultado. Los mensajes de éxito representan que todas las operaciones se han ejecutado correctamente y los datos se han copiado a la base de datos.

Data imported successfully!

Ahora, puedes abrir SQL Server Management Studio (SSMS) y verificar la tabla en la base de datos. Verás los siguientes datos en la tabla.