当前位置：首页 > 行业动态 > 正文

c#将Excel数据导入到数据库的实现代码

admin
行业动态
2025-02-04
4

C#实现将Excel数据导入数据库：通过相关库读取Excel文件，获取工作表数据并遍历行，将每行数据转换为数据模型，再使用数据库操作类插入到数据库中。

在C#中将Excel数据导入到数据库是一个常见的任务，特别是在数据处理和报表生成的场景中，下面我将详细介绍如何使用C#实现这一功能，包括所需的库、代码示例以及一些注意事项。

所需库

为了操作Excel文件，我们可以使用EPPlus库，这是一个开源的.NET库，用于读取和写入Excel文件（.xlsx格式），对于数据库操作，我们通常使用System.Data.SqlClient或Entity Framework等库。

确保你已经安装了这些库，你可以通过NuGet包管理器来安装它们：

Install-Package EPPlus
Install-Package System.Data.SqlClient

步骤1：读取Excel文件

我们需要一个方法来读取Excel文件中的数据，假设我们的Excel文件包含一个工作表，其中第一行是列名，后续行是数据。

using OfficeOpenXml;
using System.Data;
using System.IO;
public DataTable ReadExcelFile(string filePath)
{
    var package = new ExcelPackage(new FileInfo(filePath));
    var worksheet = package.Workbook.Worksheets[0]; // 获取第一个工作表
    var dataTable = new DataTable();
    // 添加列名
    foreach (var firstRowCell in worksheet.Cells[1, 1, 1, worksheet.Dimension.End.Column])
    {
        dataTable.Columns.Add(firstRowCell.Text);
    }
    // 添加数据行
    for (var rowNumber = 2; rowNumber <= worksheet.Dimension.End.Row; rowNumber++)
    {
        var row = worksheet.Cells[rowNumber, 1, rowNumber, worksheet.Dimension.End.Column];
        var newRow = dataTable.NewRow();
        foreach (var cell in row)
        {
            newRow[cell.Start.Column 1] = cell.Text;
        }
        dataTable.Rows.Add(newRow);
    }
    return dataTable;
}

步骤2：连接数据库并插入数据

我们需要将读取到的数据插入到数据库中，这里以SQL Server为例。

c#将Excel数据导入到数据库的实现代码

using System.Data.SqlClient;
public void InsertDataIntoDatabase(DataTable dataTable, string connectionString)
{
    using (var connection = new SqlConnection(connectionString))
    {
        connection.Open();
        // 遍历DataTable中的每行数据
        foreach (DataRow row in dataTable.Rows)
        {
            var values = new List<SqlParameter>();
            foreach (DataColumn column in dataTable.Columns)
            {
                values.Add(new SqlParameter(column.ColumnName, row[column]));
            }
            // 构建SQL命令并执行
            var command = new SqlCommand("INSERT INTO YourTableName (@Column1, @Column2, ...) VALUES (@Value1, @Value2, ...)", connection);
            command.Parameters.AddRange(values.ToArray());
            command.ExecuteNonQuery();
        }
    }
}

完整示例代码

将上述两个方法结合起来，我们可以编写一个完整的示例程序来读取Excel文件并将数据导入到数据库中。

class Program
{
    static void Main(string[] args)
    {
        string excelFilePath = "path/to/your/excel/file.xlsx";
        string connectionString = "your_connection_string_here";
        var dataTable = ReadExcelFile(excelFilePath);
        InsertDataIntoDatabase(dataTable, connectionString);
        Console.WriteLine("Data import completed successfully!");
    }
    public static DataTable ReadExcelFile(string filePath)
    {
        // 前面已经提供的ReadExcelFile方法代码...
    }
    public static void InsertDataIntoDatabase(DataTable dataTable, string connectionString)
    {
        // 前面已经提供的InsertDataIntoDatabase方法代码...
    }
}