DataTable写入SQL Server遇参数重复及非空约束问题求助

咱们先拆解你遇到的两个核心问题，再一步步修正代码，彻底解决这些麻烦：

问题1：变量名'@Value1'已声明 #

你代码里的核心问题有两个：一是每次循环都重复添加同名参数，二是完全没必要写内层的j循环——你要插入的是每行的三个固定字段值，不是遍历所有列。另外，把数据库连接的打开/关闭放在循环里，不仅效率极低，还容易引发连接泄漏。

问题2：无法插入NULL到非空列 #

这个是因为你的取值逻辑错误（内层j循环导致取到了错误的列值或空值），再加上没对DataTable里的NULL值做兜底处理。

修正后的逐行插入代码示例 #

Task AddToDB = Task.Run(() => {
    // 用using管理连接，确保自动释放资源
    using (sqlConnection)
    {
        try
        {
            sqlConnection.Open();
            // 只定义一次SQL语句，避免重复赋值
            sqlCommand.CommandText = @"INSERT INTO TestTable VALUES (@Value1, @Value2, @Value3)";
            sqlCommand.Connection = sqlConnection;

            // 遍历DataTable的每一行
            for (int i = 0; i < DataTableView.Rows.Count; i++)
            {
                DataRow row = DataTableView.Rows[i];
                
                // 关键：每次处理新行前清空参数，避免重复声明
                sqlCommand.Parameters.Clear();

                // 给三个参数赋值，同时处理NULL情况
                // 注意：这里的row[0]/row[1]/row[2]要对应你DataTable里的列索引，根据实际调整！
                sqlCommand.Parameters.AddWithValue("@Value1", row[0] ?? DBNull.Value);
                sqlCommand.Parameters.AddWithValue("@Value2", row[1] ?? DBNull.Value);
                sqlCommand.Parameters.AddWithValue("@Value3", row[2] ?? DBNull.Value);

                // 执行插入
                sqlCommand.ExecuteNonQuery();
            }
        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.Message, "Error");
        }
        finally
        {
            if (sqlConnection.State == ConnectionState.Open)
            {
                sqlConnection.Close();
            }
        }
    }
});
return AddToDB;

关键修正点说明 #

• 删掉多余的内层j循环：你要插入的是每行的三个固定字段，直接取对应列的索引值即可，不需要遍历所有列。
• 循环内清空参数：sqlCommand.Parameters.Clear()必须放在每行处理前，彻底避免参数重复声明的问题。
• 处理NULL值：用row[0] ?? DBNull.Value把.NET的null转换成SQL能识别的DBNull.Value；如果业务不允许某个字段为空，还可以在这里设置默认值，比如：

  sqlCommand.Parameters.AddWithValue("@Value1", row[0] ?? "默认字符串");
  

• 连接只打开一次：把连接打开操作放在循环外，循环结束后再关闭，大幅提升插入效率。

进阶优化：用SqlBulkCopy批量插入 #

如果你的DataTable数据量较大，逐行插入效率会很低，推荐用SqlBulkCopy做批量写入，速度能提升几十倍：

Task AddToDB = Task.Run(() => {
    using (sqlConnection)
    {
        try
        {
            sqlConnection.Open();
            using (SqlBulkCopy bulkCopy = new SqlBulkCopy(sqlConnection))
            {
                bulkCopy.DestinationTableName = "TestTable";
                // 如果DataTable和数据库表的列名不一致，需要手动映射，示例：
                // bulkCopy.ColumnMappings.Add("DataTable列名1", "TestTable列名1");
                // bulkCopy.ColumnMappings.Add("DataTable列名2", "TestTable列名2");
                // bulkCopy.ColumnMappings.Add("DataTable列名3", "TestTable列名3");

                // 提前处理DataTable里的NULL值，替换成非空默认值
                foreach (DataRow row in DataTableView.Rows)
                {
                    for (int colIndex = 0; colIndex < DataTableView.Columns.Count; colIndex++)
                    {
                        if (row.IsNull(colIndex))
                        {
                            // 根据列类型设置默认值
                            if (DataTableView.Columns[colIndex].DataType == typeof(string))
                            {
                                row[colIndex] = string.Empty;
                            }
                            else if (DataTableView.Columns[colIndex].DataType == typeof(int))
                            {
                                row[colIndex] = 0;
                            }
                            // 其他数据类型同理处理
                        }
                    }
                }

                // 批量写入数据库
                bulkCopy.WriteToServer(DataTableView);
            }
        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.Message, "Error");
        }
    }
});
return AddToDB;

这个方法既解决了NULL插入的问题，又能高效处理大批量数据，非常实用。

内容的提问来源于stack exchange，提问作者Денис