调用SqlBulkCopy.WriteToServer写入DataTable无响应或超时，求解决方案

可能的原因及解决步骤 #

1. 连接字符串配置问题 #

• 必须添加TrustServerCertificate=true：Docker部署的SQL Server默认使用自签名证书，若未禁用SSL验证，会卡在SSL握手阶段导致无响应。
• 确认端口、地址、认证方式正确：检查Docker映射的端口是否为1433，SQL Server认证的账号密码是否有效，跨平台场景优先用SQL Server认证而非Windows认证。
• 手动管理连接：避免依赖SqlBulkCopy自动处理连接，手动创建并打开SqlConnection后传入构造函数，能更直观排查连接问题。

2. DataTable与目标表列不匹配 #

• 验证列名转换逻辑：DatabaseUtil.Convert和ConvertPropertyName不能出现列名与目标表不一致的情况（比如大小写、特殊字符处理错误），若数据库开启大小写敏感会直接匹配失败。
• 严格匹配数据类型：DataTable的列类型必须与目标表完全兼容，比如目标表是datetime，DataTable不能用datetimeoffset；目标列不允许空时，DataTable对应列不能有非DBNull.Value的空值。
• 确保列顺序一致：content.Items.Select(x => x.Data)的返回顺序必须和DataTable的列顺序完全对应，顺序错误会导致类型不匹配或插入到错误列，引发静默阻塞。

3. 数据库锁或约束阻塞 #

• 移除SqlBulkCopyOptions.TableLock选项：若目标表被其他查询占用锁，TableLock会导致长时间等待。
• 检查约束与触发器：
  • 外键约束：确保关联表数据存在，或临时禁用外键（ALTER TABLE [Table] NOCHECK CONSTRAINT ALL）测试。
  • 触发器：复杂触发器会大幅降低插入效率甚至引发阻塞，可临时禁用触发器（DISABLE TRIGGER ALL ON [Table]）验证。
• 查询数据库阻塞情况：在SQL Server执行以下语句查看是否有阻塞进程：

  SELECT 
      blocking_session_id, 
      session_id, 
      command, 
      wait_type, 
      wait_time
  FROM sys.dm_exec_requests
  WHERE blocking_session_id <> 0;
  

4. 隐藏异常与调试缺失 #

• 用try-catch包裹WriteToServer调用：很多情况下异常被静默吞掉，捕获并打印完整异常信息（包括InnerException）。
• 添加调试日志：确认DataTable是否正确填充（打印行数、列信息），连接是否成功打开，排查数据准备阶段的问题。

修改后的示例代码 #

try
{
    using var conn = new SqlConnection(ConnectionString);
    conn.Open();
    Log.Info("数据库连接已成功打开");

    using var bulkcopy = new SqlBulkCopy(conn, SqlBulkCopyOptions.Default, null)
    {
        DestinationTableName = $"[{databaseConfiguration.Schema}].[{DatabaseUtil.Convert(source.Name)}]",
        BulkCopyTimeout = 300, // 先设置非0超时，便于捕获超时异常
        BatchSize = 1000, // 适当调大批次大小提升效率
        NotifyAfter = 1000
    };

    bulkcopy.SqlRowsCopied += (_, e) => Log.Info($"已插入 {e.RowsCopied} 行数据");

    var dataTable = new DataTable(bulkcopy.DestinationTableName);
    foreach (var column in source.Columns)
    {
        var propertyName = DatabaseUtil.ConvertPropertyName(column.Name);
        bulkcopy.ColumnMappings.Add(propertyName, propertyName);
        
        // 明确添加列并打印调试信息
        var dataColumn = new DataColumn(propertyName, column.Type);
        dataTable.Columns.Add(dataColumn);
        Log.Info($"添加列：{propertyName}，类型：{column.Type.Name}");
    }

    foreach (var content in contents)
    {
        var values = content.Items.Select(x => x.Data).ToArray();
        var dataRow = dataTable.NewRow();
        dataRow.ItemArray = values;
        dataTable.Rows.Add(dataRow);
    }

    Log.Info($"待插入数据共 {dataTable.Rows.Count} 行");
    bulkcopy.WriteToServer(dataTable);
    Log.Info("批量插入完成");
}
catch (Exception ex)
{
    Log.Error($"批量插入失败：{ex.Message}", ex);
    throw;
}

内容的提问来源于stack exchange，提问作者bomberman2910