针对你提到的50万条记录迁移耗时过长、需要避免超时/内存问题的需求，咱们可以通过稳定分页循环+批量事务插入的思路来调整脚本，下面是具体的实现和优化要点：

核心思路 #

把原来的1000条批次改成500条（更稳妥，降低单次操作的内存占用和超时风险），用DB2的分页语法分批查询源数据，每批次用事务批量插入目标库，同时做好错误处理和资源释放，确保整个流程稳定高效。

完整优化脚本示例 #

# 加载IBM DB2 .NET驱动（路径根据你的安装目录调整）
Add-Type -Path "C:\Program Files\IBM\SQLLIB\bin\netf40\IBM.Data.DB2.dll"

# 源库和目标库的连接字符串（替换成你的实际配置）
$sourceConnStr = "Server=源DB地址:端口;Database=源库名;Uid=用户名;Pwd=密码;"
$targetConnStr = "Server=目标DB地址:端口;Database=目标库名;Uid=用户名;Pwd=密码;"

# 配置批次大小和起始偏移量
$batchSize = 500
$currentOffset = 0

try {
    # 初始化并打开数据库连接
    $sourceConn = New-Object IBM.Data.DB2.DB2Connection($sourceConnStr)
    $targetConn = New-Object IBM.Data.DB2.DB2Connection($targetConnStr)
    $sourceConn.Open()
    $targetConn.Open()

    Write-Host "开始批量迁移数据，批次大小：$batchSize"

    while ($true) {
        # 分页查询源数据——必须加ORDER BY保证分页稳定！
        $sourceQuery = @"
            SELECT col1, col2, col3  -- 替换成你的实际列
            FROM 源表名
            ORDER BY 主键列/唯一索引列  -- 用索引列排序，提升分页查询速度
            OFFSET $currentOffset ROWS
            FETCH NEXT $batchSize ROWS ONLY
"@
        $sourceCmd = New-Object IBM.Data.DB2.DB2Command($sourceQuery, $sourceConn)
        $dataReader = $sourceCmd.ExecuteReader()

        # 如果没有更多数据，退出循环
        if (-not $dataReader.HasRows) {
            $dataReader.Close()
            Write-Host "所有数据迁移完成！"
            break
        }

        # 准备批量插入的参数化命令（避免SQL注入，提升执行效率）
        $insertCmd = New-Object IBM.Data.DB2.DB2Command(@"
            INSERT INTO 目标表名 (col1, col2, col3)
            VALUES (@col1, @col2, @col3)
"@, $targetConn)
        # 按实际列类型添加参数（调整DB2Type和长度）
        $insertCmd.Parameters.Add("@col1", [IBM.Data.DB2.DB2Type]::VarChar, 100) | Out-Null
        $insertCmd.Parameters.Add("@col2", [IBM.Data.DB2.DB2Type]::Integer) | Out-Null
        $insertCmd.Parameters.Add("@col3", [IBM.Data.DB2.DB2Type]::Timestamp) | Out-Null

        # 开启事务，保证每批次数据的一致性
        $trans = $targetConn.BeginTransaction()
        $insertCmd.Transaction = $trans

        try {
            $processedCount = 0
            # 遍历当前批次的记录并插入
            while ($dataReader.Read()) {
                $insertCmd.Parameters["@col1"].Value = $dataReader["col1"]
                $insertCmd.Parameters["@col2"].Value = $dataReader["col2"]
                $insertCmd.Parameters["@col3"].Value = $dataReader["col3"]
                
                $insertCmd.ExecuteNonQuery()
                $processedCount++
            }

            # 提交事务
            $trans.Commit()
            Write-Host "已成功迁移第 $($currentOffset + 1) 至 $($currentOffset + $processedCount) 条记录"
        }
        catch {
            # 出错回滚事务，记录错误信息
            $trans.Rollback()
            Write-Error "批次迁移失败：$_"
            # 这里可以选择是否终止整个流程，注释掉下面的throw就会继续下一批次
            throw
        }
        finally {
            # 释放当前批次的资源，避免内存泄漏
            $dataReader.Close()
            $insertCmd.Dispose()
            $trans.Dispose()
        }

        # 更新偏移量，进入下一批次
        $currentOffset += $batchSize
    }
}
catch {
    Write-Error "迁移流程发生致命错误：$_"
}
finally {
    # 确保关闭所有数据库连接
    if ($sourceConn.State -eq 'Open') { $sourceConn.Close() }
    if ($targetConn.State -eq 'Open') { $targetConn.Close() }
    $sourceConn.Dispose()
    $targetConn.Dispose()
}

关键优化要点说明 #

1. 稳定分页的前提
   一定要在查询语句中加上ORDER BY，而且最好用主键或有索引的列排序。如果没有排序，DB2的OFFSET可能会返回重复或遗漏的记录，同时索引列排序能大幅提升分页查询的速度（避免每次都扫描全表）。

2. 事务控制的重要性
   每批次用一个事务，比单条插入的事务开销小很多，同时能保证批次内的数据要么全成功要么全回滚，不会出现部分插入的情况。

3. 参数化查询的优势
   不要直接拼接SQL字符串，参数化查询既避免了SQL注入风险，还能让DB2缓存执行计划，后续批次的插入速度会更快。

4. 资源释放
   每次循环后要及时关闭DataReader、释放Command和Transaction对象，避免PowerShell内存占用过高导致的性能问题。

5. 错误处理
   捕获每批次的异常并回滚事务，你可以根据需求选择是否终止整个流程（比如如果是关键数据，出错就终止；如果允许跳过错误批次，就注释掉throw语句）。

额外性能提升建议 #

• 调整批次大小：500是比较稳妥的数值，如果你的DB服务器性能较好，可以尝试调到800-1000；如果经常出现超时，就减小到200-300。
• 使用DB2BulkCopy：如果你的IBM.Data.DB2驱动支持（DB2 V10.5+），可以用IBM.Data.DB2.DB2BulkCopy类，它比逐条插入快得多，适合超大量数据的迁移。
• 优化源表索引：确保源查询的ORDER BY列有索引，这会让分页查询的速度提升数倍，尤其是数据量越大，效果越明显。
• 减少PowerShell额外操作：循环内尽量避免不必要的输出或计算，用Out-Null屏蔽不需要的返回值，减少PowerShell的性能开销。

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