SQL 如何在SQL Server中以最快的方式批量插入大量数据（C#客户端）

在本文中，我们将介绍如何使用C#客户端以最快的方式批量插入大量数据到SQL Server中。在处理大量数据时，效率很重要，因此我们将探讨几种方法，并比较它们的性能。

阅读更多：SQL 教程

方法一：使用SqlBulkCopy类

SqlBulkCopy类是一个高效的方式来处理大量数据的插入。它将数据从一个数据源（如DataTable对象）复制到目标数据表中。下面是一个示例代码，演示如何使用SqlBulkCopy类插入数据：

string connectionString = "Data Source=SERVER_NAME;Initial Catalog=DATABASE_NAME;User ID=USERNAME;Password=PASSWORD";
string tableName = "TABLE_NAME";

DataTable dataTable = new DataTable();
// 将数据添加到dataTable对象中

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection))
    {
        bulkCopy.DestinationTableName = tableName;
        // 设置其他属性，如BatchSize和BulkCopyTimeout

        try
        {
            bulkCopy.WriteToServer(dataTable);
        }
        catch (Exception ex)
        {
            // 处理异常
        }
    }
}

使用SqlBulkCopy类可以显著提高插入大量数据的性能。

方法二：使用Stored Procedure（存储过程）

存储过程是SQL Server中的一种可重用的代码块，可以接受参数并执行一系列的SQL语句。如果我们将大量数据插入的逻辑封装在一个存储过程中，可以提高插入速度。下面是一个示例存储过程，演示如何使用存储过程批量插入数据：

CREATE PROCEDURE InsertData
   @Data TABLE_TYPE READONLY
AS
BEGIN
   INSERT INTO TABLE_NAME (Column1, Column2, Column3)
   SELECT Column1, Column2, Column3
   FROM @Data
END

在C#客户端中执行存储过程的示例代码如下所示：

string connectionString = "Data Source=SERVER_NAME;Initial Catalog=DATABASE_NAME;User ID=USERNAME;Password=PASSWORD";

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    using (SqlCommand command = new SqlCommand("InsertData", connection))
    {
        command.CommandType = CommandType.StoredProcedure;
        // 添加存储过程参数，设置参数值

        try
        {
            command.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            // 处理异常
        }
    }
}

使用存储过程可以减少与数据库的交互次数，提高插入大量数据的性能。

方法三：使用BULK INSERT语句

SQL Server提供了BULK INSERT语句，用于快速将数据从文本文件导入数据库表中。如果我们将大量数据保存在文本文件中，并使用BULK INSERT语句将其导入数据库中，可以提高插入速度。下面是一个示例代码，演示如何使用BULK INSERT语句插入数据：

BULK INSERT TABLE_NAME
FROM 'C:\data.txt'
WITH
(
    FIELDTERMINATOR = ',',
    ROWTERMINATOR = '\n'
)

在C#客户端中可以使用SqlCommand对象执行BULK INSERT语句，示例代码如下所示：

string connectionString = "Data Source=SERVER_NAME;Initial Catalog=DATABASE_NAME;User ID=USERNAME;Password=PASSWORD";

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    using (SqlCommand command = new SqlCommand("BULK INSERT TABLE_NAME FROM 'C:\\data.txt' WITH (FIELDTERMINATOR = ',', ROWTERMINATOR = '\n')", connection))
    {
        try
        {
            command.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            // 处理异常
        }
    }
}

使用BULK INSERT语句可以快速导入大量数据到SQL Server中。

方法四：使用Table-Valued Parameters（表值参数）

表值参数是一种将数据以表的形式传递给存储过程或函数的方法。它可以提高插入大量数据的性能。下面是一个示例代码，演示如何使用表值参数插入数据：

首先，需要在SQL Server中创建一个用户自定义表类型：

CREATE TYPE dbo.CustomTableType AS TABLE
(
    Column1 INT,
    Column2 VARCHAR(50),
    Column3 DECIMAL(10,2)
)

然后，在存储过程参数中使用该表类型：

CREATE PROCEDURE InsertData
   @Data dbo.CustomTableType READONLY
AS
BEGIN
   INSERT INTO TABLE_NAME (Column1, Column2, Column3)
   SELECT Column1, Column2, Column3
   FROM @Data
END

在C#客户端中执行存储过程的示例代码如下所示：

string connectionString = "Data Source=SERVER_NAME;Initial Catalog=DATABASE_NAME;User ID=USERNAME;Password=PASSWORD";

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();

    using (SqlCommand command = new SqlCommand("InsertData", connection))
    {
        command.CommandType = CommandType.StoredProcedure;

        SqlParameter parameter = command.Parameters.AddWithValue("@Data", dataTable);
        parameter.SqlDbType = SqlDbType.Structured;
        parameter.TypeName = "dbo.CustomTableType";

        try
        {
            command.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            // 处理异常
        }
    }
}

使用表值参数可以减少与数据库的交互次数，提高插入大量数据的性能。

总结

本文介绍了在SQL Server中以最快的方式批量插入大量数据的方法。通过使用SqlBulkCopy类、存储过程、BULK INSERT语句和表值参数，我们可以提高插入大量数据的效率。根据具体需求选择适合的方法，并根据实际情况调整代码，可以进一步优化性能。在处理大量数据时，及时的性能优化非常重要，可以显著提升应用程序的响应速度。