C#에서 Excel 파일을 SQL Server로 가져오는 방법

주요 특징

IronXL을 사용한 Excel 데이터 읽기

IronXL로 Excel 파일의 데이터를 읽는 프로세스가 더 쉬워졌습니다. 다음 예제는 IronXL을 사용하여 Excel 파일의 데이터를 읽는 방법을 보여줍니다. 이 방법으로 데이터를 읽고 각 행이 Excel 시트의 행에 해당하는 사전 목록에 저장합니다.

using IronXL;
using System;
using System.Collections.Generic;

public class ExcelReader
{
    public static List<Dictionary<string, object>> ReadExcelFile(string filePath)
    {
        // Initialize a list to store data from Excel
        var data = new List<Dictionary<string, object>>();

        // Load the workbook from the file path provided
        WorkBook workbook = WorkBook.Load(filePath);

        // Access the first worksheet in the workbook
        WorkSheet sheet = workbook.WorkSheets[0];

        // Retrieve column headers from the first row
        var headers = new List<string>();
        foreach (var header in sheet.Rows[0].Columns)
        {
            headers.Add(header.ToString());
        }

        // Loop through each row starting from the second row
        for (int i = 1; i < sheet.Rows.Count; i++)
        {
            // Create a dictionary to store the row data associated with column headers
            var rowData = new Dictionary<string, object>();
            for (int j = 0; j < headers.Count; j++)
            {
                rowData[headers[j]] = sheet.Rows[i][j].Value;
            }
            data.Add(rowData);
        }

        return data;
    }
}

using IronXL;
using System;
using System.Collections.Generic;

public class ExcelReader
{
    public static List<Dictionary<string, object>> ReadExcelFile(string filePath)
    {
        // Initialize a list to store data from Excel
        var data = new List<Dictionary<string, object>>();

        // Load the workbook from the file path provided
        WorkBook workbook = WorkBook.Load(filePath);

        // Access the first worksheet in the workbook
        WorkSheet sheet = workbook.WorkSheets[0];

        // Retrieve column headers from the first row
        var headers = new List<string>();
        foreach (var header in sheet.Rows[0].Columns)
        {
            headers.Add(header.ToString());
        }

        // Loop through each row starting from the second row
        for (int i = 1; i < sheet.Rows.Count; i++)
        {
            // Create a dictionary to store the row data associated with column headers
            var rowData = new Dictionary<string, object>();
            for (int j = 0; j < headers.Count; j++)
            {
                rowData[headers[j]] = sheet.Rows[i][j].Value;
            }
            data.Add(rowData);
        }

        return data;
    }
}

SQL Server에 연결하기

SQL Server에 연결하기 위해 SqlConnection 클래스를 System.Data.SqlClient 네임스페이스에서 사용합니다. 일반적으로 데이터베이스 이름, 서버 이름, 인증 정보로 구성되는 올바른 연결 문자열을 가지고 있는지 확인하십시오. SQL Server 데이터베이스 연결 및 데이터 추가 방법은 다음 예제에서 다룹니다.

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;

public class SqlServerConnector
{
    private string connectionString;

    // Constructor accepts a connection string
    public SqlServerConnector(string connectionString)
    {
        this.connectionString = connectionString;
    }

    // Inserts data into the specified table
    public void InsertData(Dictionary<string, object> data, string tableName)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();

            // Construct an SQL INSERT command with parameterized values to prevent SQL injection
            var columns = string.Join(",", data.Keys);
            var parameters = string.Join(",", data.Keys.Select(key => "@" + key));
            string query = $"INSERT INTO {tableName} ({columns}) VALUES ({parameters})";

            using (SqlCommand command = new SqlCommand(query, connection))
            {
                // Add parameters to the command
                foreach (var kvp in data)
                {
                    command.Parameters.AddWithValue("@" + kvp.Key, kvp.Value ?? DBNull.Value);
                }

                // Execute the command
                command.ExecuteNonQuery();
            }
        }
    }
}

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;

public class SqlServerConnector
{
    private string connectionString;

    // Constructor accepts a connection string
    public SqlServerConnector(string connectionString)
    {
        this.connectionString = connectionString;
    }

    // Inserts data into the specified table
    public void InsertData(Dictionary<string, object> data, string tableName)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();

            // Construct an SQL INSERT command with parameterized values to prevent SQL injection
            var columns = string.Join(",", data.Keys);
            var parameters = string.Join(",", data.Keys.Select(key => "@" + key));
            string query = $"INSERT INTO {tableName} ({columns}) VALUES ({parameters})";

            using (SqlCommand command = new SqlCommand(query, connection))
            {
                // Add parameters to the command
                foreach (var kvp in data)
                {
                    command.Parameters.AddWithValue("@" + kvp.Key, kvp.Value ?? DBNull.Value);
                }

                // Execute the command
                command.ExecuteNonQuery();
            }
        }
    }
}

IronXL과 SQL Server 결합하기

Excel 파일을 읽고 SQL 데이터베이스에 데이터를 삽입하는 논리가 수립되면 이 기능을 통합하여 가져오기를 완료하십시오. 다음 애플리케이션은 Excel 파일에서 정보를 가져와 Microsoft SQL Server 데이터베이스에 추가합니다.

using System;
using System.Collections.Generic;

class Program
{
    static void Main(string[] args)
    {
        // Define the path to the Excel file, SQL connection string, and target table name
        string excelFilePath = "path_to_your_excel_file.xlsx";
        string connectionString = "your_sql_server_connection_string";
        string tableName = "your_table_name";

        // Read data from Excel
        List<Dictionary<string, object>> excelData = ExcelReader.ReadExcelFile(excelFilePath);

        // Create an instance of the SQL connector and insert data
        SqlServerConnector sqlConnector = new SqlServerConnector(connectionString);
        foreach (var row in excelData)
        {
            sqlConnector.InsertData(row, tableName);
        }

        Console.WriteLine("Data import completed successfully.");
    }
}

using System;
using System.Collections.Generic;

class Program
{
    static void Main(string[] args)
    {
        // Define the path to the Excel file, SQL connection string, and target table name
        string excelFilePath = "path_to_your_excel_file.xlsx";
        string connectionString = "your_sql_server_connection_string";
        string tableName = "your_table_name";

        // Read data from Excel
        List<Dictionary<string, object>> excelData = ExcelReader.ReadExcelFile(excelFilePath);

        // Create an instance of the SQL connector and insert data
        SqlServerConnector sqlConnector = new SqlServerConnector(connectionString);
        foreach (var row in excelData)
        {
            sqlConnector.InsertData(row, tableName);
        }

        Console.WriteLine("Data import completed successfully.");
    }
}

이 클래스는 주어진 Excel 파일에서 IronXL을 사용하여 데이터를 읽는 역할을 담당합니다. ReadExcelFile 기능은 Excel 통합문서를 로드하고, 첫 번째 워크시트를 열고, 데이터 워크시트의 행을 반복하여 데이터를 수집합니다. 테이블 처리 용이성을 위해 정보는 사전 목록에 저장됩니다.

이 클래스는 지정된 데이터베이스 테이블에 데이터를 삽입하며 SQL Server 데이터베이스와의 연결을 관리합니다. InsertData 메소드는 SQL 삽입을 방지하기 위해 매개변수화된 쿼리를 사용하며 사전의 키에 기반하여 SQL INSERT 쿼리를 동적으로 생성합니다, 이는 열 이름을 나타냅니다.

Excel 파일에서 SQL 테이블로 데이터를 읽기 위해 ExcelReader 클래스를 사용하고, SQL Server 테이블에 각 행을 삽입하기 위해 SqlServerConnector 클래스를 사용하여 Main 기능이 전체 프로세스를 관리합니다.

오류 처리 및 최적화는 견고하고 효율적인 가져오기 프로세스를 보장하는 데 중요합니다. 견고한 오류 처리를 구현하면 누락된 파일, 잘못된 데이터 형식, SQL 예외와 같은 잠재적인 문제를 관리할 수 있습니다. 오류 처리 도입의 예시는 다음과 같습니다.

try
{
    // Insert the importing logic here
}
catch (Exception ex)
{
    Console.WriteLine("An error occurred: " + ex.Message);
}

try
{
    // Insert the importing logic here
}
catch (Exception ex)
{
    Console.WriteLine("An error occurred: " + ex.Message);
}