求助：基于C#的SQL Server跨库全表动态数据迁移代码问题

看了你的代码，这里面有几个关键逻辑错误导致迁移失败，我帮你逐一梳理并修正：

原代码的主要问题： #

• 覆盖了源表名的Reader：循环里你把reader重新赋值为执行TRUNCATE后的结果，但TRUNCATE语句不返回任何数据，后续SqlBulkCopy用这个空Reader根本读不到数据，还直接打断了原来遍历源表名的循环流程。
• 连接管理混乱：目标连接在循环里反复打开关闭，没有确保连接状态的正确性，很容易引发连接占用、重复打开的报错。
• 表名未做安全处理：直接拼接表名到SQL语句中，如果表名包含空格、特殊字符或关键字，会直接触发SQL语法错误。
• 资源未正确释放：没有使用using语句管理连接、命令、Reader等实现IDisposable的对象，容易造成数据库连接泄漏、资源占用过高的问题。

修正后的代码： #

// 用using自动管理所有可释放资源，无需手动调用Close
using (SqlConnection sourceConn = new SqlConnection(@"Data Source = Stack; Initial Catalog = SSIS2; Trusted_Connection=yes;"))
using (SqlConnection destConn = new SqlConnection(@"Data Source = Stack; Initial Catalog = SSIS1; Trusted_Connection=yes;"))
{
    sourceConn.Open();
    destConn.Open();

    // 获取源数据库所有表名的命令
    using (SqlCommand getTablesCmd = new SqlCommand("SELECT NAME FROM sys.TABLES", sourceConn))
    using (SqlDataReader tableReader = getTablesCmd.ExecuteReader())
    {
        while (tableReader.Read())
        {
            string tableName = tableReader["name"].ToString();
            // 给表名包裹方括号，避免特殊字符或关键字引发语法错误
            string safeTableName = $"[{tableName}]";

            // 第一步：清空目标表数据
            using (SqlCommand truncateCmd = new SqlCommand($"TRUNCATE TABLE {safeTableName}", destConn))
            {
                truncateCmd.ExecuteNonQuery();
            }

            // 第二步：读取源表的全部数据
            using (SqlCommand getTableDataCmd = new SqlCommand($"SELECT * FROM {safeTableName}", sourceConn))
            using (SqlDataReader dataReader = getTableDataCmd.ExecuteReader())
            {
                // 第三步：批量写入目标表
                using (SqlBulkCopy bulkCopy = new SqlBulkCopy(destConn))
                {
                    bulkCopy.DestinationTableName = safeTableName;
                    // 自动映射同名列（需确保源表和目标表结构一致）
                    bulkCopy.ColumnMappings.Add(new SqlBulkCopyColumnMapping());
                    bulkCopy.WriteToServer(dataReader);
                }
            }
        }
    }
}

额外说明： #

• 结构一致性要求：这段代码默认源表和目标表的结构完全匹配（列名、数据类型、顺序一致），如果结构不同，你需要手动配置ColumnMappings来指定源列和目标列的对应关系。
• 性能优化：如果单表数据量极大，可以调整SqlBulkCopy的BatchSize属性，控制每次批量写入的数据量，避免内存占用过高。
• 错误处理：建议添加try-catch块捕获迁移过程中的异常（比如目标表不存在、权限不足、数据类型不匹配等），方便快速定位问题。

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