CSV 파일에서 데이터를 읽어 데이터베이스에 저장하는 방법 (C#)

기초 이해하기

IronXL 소개

IronXL은 .NET 애플리케이션을 위해 맞춤 제작된 Excel 라이브러리로, 개발자가 Microsoft Office Interop 없이 Excel 파일을 읽고, 생성하고, 편집할 수 있도록 특별히 설계되었습니다. 이 라이브러리는 .NET Core, .NET Standard, .NET Framework 등 다양한 .NET 버전과 플랫폼뿐만 아니라 Windows, Linux, macOS와 같은 다양한 운영 체제를 지원하는 점에서 두드러집니다. 데이터 가져오기에 강력한 라이브러리로, 특히 CSV 파일 처리를 위한 것입니다.

How to Read and Store Data From CSV Files in C#

1. Visual Studio에서 C# 콘솔 프로그램을 만듭니다.
2. NuGet 패키지 관리자를 사용하여 CSV 라이브러리를 설치합니다.
3. 프로그램 내에서 라이브러리를 사용하여 CSV 파일을 로드합니다.
4. 데이터베이스와 연결을 생성합니다.
5. 라이브러리를 사용하여 CSV 파일의 내용을 읽습니다.
6. SqlBulkCopy 메서드를 사용하여 그 내용을 데이터베이스에 복사하십시오.

다음은 예제 코드 스니펫입니다:

using System;
using System.Data;
using System.Data.SqlClient;
using System.Globalization;
using System.IO;
using CsvHelper;

namespace CsvReader
{
    class Program
    {
        static void Main(string[] args)
        {
            string csvPath = @"path\to\your\csv\file.csv";

            using (var reader = new StreamReader(csvPath))
            using (var csv = new CsvReader(reader, CultureInfo.InvariantCulture))
            {
                // Mapping the CSV data to the corresponding model
                var records = csv.GetRecords<YourModel>();

                using (var sqlBulkCopy = new SqlBulkCopy("your_connection_string"))
                {
                    sqlBulkCopy.DestinationTableName = "YourTableName";
                    sqlBulkCopy.WriteToServer(records.AsDataReader());
                }

                Console.WriteLine("Data imported successfully!");
            }
        }
    }

    // Define your model that maps to the CSV columns
    public class YourModel
    {
        // Define properties here representing the CSV columns
    }
}

using System;
using System.Data;
using System.Data.SqlClient;
using System.Globalization;
using System.IO;
using CsvHelper;

namespace CsvReader
{
    class Program
    {
        static void Main(string[] args)
        {
            string csvPath = @"path\to\your\csv\file.csv";

            using (var reader = new StreamReader(csvPath))
            using (var csv = new CsvReader(reader, CultureInfo.InvariantCulture))
            {
                // Mapping the CSV data to the corresponding model
                var records = csv.GetRecords<YourModel>();

                using (var sqlBulkCopy = new SqlBulkCopy("your_connection_string"))
                {
                    sqlBulkCopy.DestinationTableName = "YourTableName";
                    sqlBulkCopy.WriteToServer(records.AsDataReader());
                }

                Console.WriteLine("Data imported successfully!");
            }
        }
    }

    // Define your model that maps to the CSV columns
    public class YourModel
    {
        // Define properties here representing the CSV columns
    }
}

"path\to\your\csv\file.csv"를 CSV 파일의 실제 경로로, YourModel를 당신의 CSV 데이터를 나타내는 모델로, "your_connection_string"를 데이터베이스 연결 문자열로, 그리고 "YourTableName"를 데이터베이스 테이블 이름으로 교체하세요.

환경 설정

dotnet add package IronXL

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

CSV 데이터 가져오기 단계별 가이드

1. 먼저, 가져오고자 하는 데이터가 포함된 CSV 파일이 있는지 확인하세요.
2. Visual Studio에서 새로운 C# 콘솔 애플리케이션 프로젝트를 만드세요.

3. CSV 파일을 읽기 위해 CsvHelper NuGet 패키지를 설치하세요. Visual Studio의 NuGet 패키지 관리자 콘솔을 열고 다음 명령어를 실행하여 수행할 수 있습니다:

   Install-Package CsvHelper

   Install-Package CsvHelper

   SHELL

4. C# 코드 파일 상단에 필요한 using 문을 추가합니다:

   using System;
   using System.IO;
   using System.Globalization;
   using CsvHelper;
   using System.Data.SqlClient;

   using System;
   using System.IO;
   using System.Globalization;
   using CsvHelper;
   using System.Data.SqlClient;

   $vbLabelText   $csharpLabel

5. 코드에서 CSV 파일의 경로를 지정하세요. 예를 들어:

   string csvFilePath = @"C:\path\to\your\csv\file.csv";

   string csvFilePath = @"C:\path\to\your\csv\file.csv";

   $vbLabelText   $csharpLabel

   C:\path\to\your\csv\file.csv를 CSV 파일의 실제 경로로 교체해야 합니다.

6. CSV 파일을 읽기 위해 StreamReader 클래스의 새 인스턴스를 생성하십시오:

   using (var reader = new StreamReader(csvFilePath))
   {
       // code goes here
   }

   using (var reader = new StreamReader(csvFilePath))
   {
       // code goes here
   }

   $vbLabelText   $csharpLabel

7. CsvReader 클래스의 새 인스턴스를 생성하고, StreamReader 객체를 전달하십시오:

   using (var reader = new StreamReader(csvFilePath))
   using (var csv = new CsvReader(reader, CultureInfo.InvariantCulture))
   {
       // code goes here
   }

   using (var reader = new StreamReader(csvFilePath))
   using (var csv = new CsvReader(reader, CultureInfo.InvariantCulture))
   {
       // code goes here
   }

   $vbLabelText   $csharpLabel

8. 필요에 따라 CsvReader 객체를 설정하십시오. 예를 들어:

   csv.Configuration.HasHeaderRecord = true;

   csv.Configuration.HasHeaderRecord = true;

   $vbLabelText   $csharpLabel

9. CsvReader 객체의 GetRecords<t>() 메서드를 사용하여 CSV 데이터를 객체의 모음으로 읽어 들이세요. <t>를 CSV 파일의 각 레코드를 나타내는 객체 유형으로 교체하세요. 예를 들어:

   var records = csv.GetRecords<YourModel>();

   var records = csv.GetRecords<YourModel>();

   $vbLabelText   $csharpLabel

   YourModel를 당신의 모델 클래스의 실제 이름으로 교체해야 합니다.

10. 레코드에 대해 반복하여 필요한 처리 또는 유효성 검사를 수행하세요.

    foreach (var record in records)
    {
        // Process each record as needed
    }

    foreach (var record in records)
    {
        // Process each record as needed
    }

    $vbLabelText   $csharpLabel
11. 선택적으로, ADO.NET 또는 Entity Framework와 같은 ORM 도구를 사용하여 SQL Server 데이터베이스에 대한 연결을 설정하세요.
12. 선택한 데이터베이스 액세스 매커니즘을 사용하여 각 레코드를 데이터베이스에 삽입하세요. 예를 들어 ADO.NET을 사용하는 경우, 데이터를 효율적으로 대량 삽입하기 위해 SqlBulkCopy 클래스를 활용할 수 있습니다.
13. 가져오기 프로세스 중에 발생할 수 있는 예외를 처리하고 적절한 오류 메시지나 로깅을 제공하세요.
14. 애플리케이션을 실행하여 데이터가 데이터베이스에 성공적으로 가져왔는지 확인함으로써 테스트하세요.

그게 다예요! 이제 C#을 사용하여 SQL Server 데이터베이스에 CSV 데이터를 성공적으로 가져왔습니다.

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;
    }
}

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;
    }
}

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);
                }
            }
        }
    }
}

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!");
    }
}

Data imported successfully!

결론

이 튜토리얼은 C#을 사용하여 CSV 파일에서 데이터를 읽고 SQL 서버 데이터베이스에 저장하는 프로세스를 안내했습니다. 이 단계들을 따르고 IronXL 라이브러리를 사용함으로써 C# 응용 프로그램에서 CSV 데이터를 효율적으로 관리할 수 있습니다.

IronXL은 구매 전에 기능을 경험할 수 있도록 무료 체험판을 제공합니다. 이 완전한 기능의 체험판은 잠재 사용자가 생산 환경에서 워터마크 없이 제품을 테스트하고 평가할 수 있도록 합니다. 체험판 기간이 끝난 후, 프로젝트에 IronXL을 계속 사용하기로 결정하면 제품의 라이선스가 $799부터 시작됩니다.