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

如何在C中将表格数据高效导入数据库？

admin
行业动态
2025-01-26
2238

在C#中，将表格数据导入数据库通常涉及以下步骤：使用如DataTable或DataSet等数据结构来存储表格数据。通过ADO.NET建立与数据库的连接。使用SqlCommand或OleDbCommand等命令对象执行SQL语句，将数据插入到数据库表中。也可以使用SqlBulkCopy等批量操作类提高导入效率。

在C#中将表格数据导入数据库是一个常见的需求，特别是在数据处理和数据分析领域，以下是详细的步骤和代码示例，展示如何实现这一功能。

如何在C中将表格数据高效导入数据库？第1张

准备工作

确保你已经安装了以下工具和库：

.NET SDK

SQL Server（或其他支持的数据库）

Entity Framework Core（可选，但推荐用于ORM）

Dapper（一个轻量级的ORM）

创建数据库和表

假设我们有一个SQL Server数据库，名为TestDB，其中包含一个表Employees，结构如下：

Column Name	Data Type
Id	INT
Name	NVARCHAR
Age	INT
Department	NVARCHAR

你可以使用以下SQL脚本来创建这个数据库和表：

CREATE DATABASE TestDB;
GO
USE TestDB;
GO
CREATE TABLE Employees (
    Id INT PRIMARY KEY IDENTITY(1,1),
    Name NVARCHAR(50),
    Age INT,
    Department NVARCHAR(50)
);
GO

准备表格数据

假设你有一个CSV文件employees.csv如下：

Name,Age,Department
John Doe,30,HR
Jane Smith,25,Engineering
Emily Johnson,40,Marketing

C#代码实现

下面是一个使用Dapper库将CSV文件中的数据导入到SQL Server数据库中的完整C#代码示例。

安装Dapper

通过NuGet安装Dapper库：

dotnet add package Dapper

代码实现

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.Linq;
using Dapper;
class Program
{
    static void Main()
    {
        string connectionString = "Server=your_server;Database=TestDB;Integrated Security=True;";
        string csvFilePath = "employees.csv";
        // Step 1: Read CSV file and parse it into a list of dictionaries
        List<Dictionary<string, string>> records = ReadCsv(csvFilePath);
        // Step 2: Insert data into the database using Dapper
        using (var connection = new SqlConnection(connectionString))
        {
            connection.Open();
            foreach (var record in records)
            {
                string sql = "INSERT INTO Employees (Name, Age, Department) VALUES (@Name, @Age, @Department)";
                connection.Execute(sql, new { Name = record["Name"], Age = int.Parse(record["Age"]), Department = record["Department"] });
            }
        }
        Console.WriteLine("Data imported successfully!");
    }
    static List<Dictionary<string, string>> ReadCsv(string filePath)
    {
        List<Dictionary<string, string>> records = new List<Dictionary<string, string>>();
        string[] lines = File.ReadAllLines(filePath);
        string[] headers = lines[0].Split(',');
        foreach (var line in lines.Skip(1))
        {
            string[] values = line.Split(',');
            Dictionary<string, string> record = new Dictionary<string, string>();
            for (int i = 0; i < headers.Length; i++)
            {
                record[headers[i]] = values[i];
            }
            records.Add(record);
        }
        return records;
    }
}