3. 使用PDO和预处理语句的批量执行
虽然PDO的 <code>execute()</code> 方法通常用于单条语句，但我们可以通过事务和循环来模拟高效的批量操作。
<?php
$data = [
['John', 'Doe', 28],
['Jane', 'Smith', 32]
];
try {
$pdo->beginTransaction(); // 开启事务是提升批量性能的关键
$stmt = $pdo->prepare("INSERT INTO Users (FirstName, LastName, Age) VALUES (?, ?, ?)");
foreach ($data as $row) {
$stmt->execute($row);
}
$pdo->commit(); // 提交事务
echo "使用PDO事务批量插入成功！";
} catch (Exception $e) {
$pdo->rollBack();
echo "批量插入失败: " . $e->getMessage();
}
?>三、性能优化策略
仅仅实现批量操作还不够，还需要从多个层面进行优化。
1. 使用事务（Transaction）
如上一个示例所示，将多个操作包裹在一个事务中，可以显著提升性能。因为数据库不需要为每一条INSERT都写入日志并立即提交，而是在事务提交时一次性处理。
<?php
sqlsrv_begin_transaction($conn);
// ... 执行多条sqlsrv_query ...
if(/* 所有操作成功 */) {
sqlsrv_commit($conn);
} else {
sqlsrv_rollback($conn);
}
?>2. 调整批处理大小
即使是批量操作，一次处理的数据量也并非越大越好。需要找到一个平衡点，避免单次请求过大导致内存溢出或超时，也避免请求次数过多。通常，每批1000到5000条记录是一个合理的范围。
<?php
$allData = /* 从文件或API获取的大量数据 */;
$batchSize = 1000;
$totalBatches = ceil(count($allData) / $batchSize);
for ($i = 0; $i < $totalBatches; $i++) {
$batchData = array_slice($allData, $i * $batchSize, $batchSize);
// 使用TVP或拼接SQL的方法插入$batchData
// 每批提交一个事务
}
?>3. 禁用索引和约束（针对特大初始数据加载）
在导入海量历史数据时，可以先删除目标表的非聚集索引和外键约束，待数据插入完成后再重建它们，这能极大加快插入速度。但这属于高危操作，必须在维护时段进行。
-- 导入前 ALTER INDEX ALL ON Users DISABLE; -- 或者直接删除非关键索引 DROP INDEX IX_Users_LastName ON Users; -- 执行批量插入... -- 导入后 ALTER INDEX ALL ON Users REBUILD; -- 或重新创建索引 CREATE INDEX IX_Users_LastName ON Users(LastName);
4. 使用BCP或Bulk Insert实用工具
对于极大规模的数据迁移，PHP可能不是最高效的工具。可以考虑使用SQL Server自带的命令行工具 <code>BCP</code> (Bulk Copy Program) 或 <code>BULK INSERT</code> T-SQL命令。你可以从PHP中调用这些外部命令。
<?php
// 1. 将数据写入一个CSV文件
$csvFile = 'data.csv';
// ... 将$data写入$csvFile ...
// 2. 使用exec调用BCP命令（需要配置好权限和路径）
$cmd = "bcp YourDatabase.dbo.Users in '$csvFile' -S localhost\SQLEXPRESS -U YourUsername -P YourPassword -c -t ',' -r '\n'";
exec($cmd, $output, $returnVar);
if($returnVar === 0) {
echo "BCP批量导入成功！";
}
?>5. 连接与查询超时设置
批量操作耗时可能较长，需要适当调整超时设置，避免连接意外中断。
$connectionOptions = array(
"Database" => "YourDatabase",
"Uid" => "YourUsername",
"PWD" => "YourPassword",
"LoginTimeout" => 30, // 连接超时（秒）
"ConnectionPooling" => false // 对于长时批量操作，考虑关闭连接池
);
$conn = sqlsrv_connect($serverName, $connectionOptions);
// 设置查询执行超时（秒）
$sql = "INSERT ...";
$stmt = sqlsrv_query($conn, $sql, array(), array("QueryTimeout" => 300));四、总结与最佳实践建议
优化PHP连接MSSQL的批量处理性能是一个系统工程，需要根据数据量、网络环境和业务需求选择合适的方法。
中小批量数据（< 10,000条）： 优先使用PDO预处理语句+事务的方式，代码简单且安全。
中大批量数据（10,000 - 1,000,000条）： 强烈推荐使用表值参数（TVP），它是性能与灵活性的最佳结合。
海量数据初始导入（> 1,000,000条）： 考虑使用BCP/BULK INSERT工具，或结合禁用索引的策略。
始终使用事务： 无论选择哪种方法，将批量操作包裹在事务中是保证性能和数据一致性的基础。
分批次处理： 设定合理的批处理大小，监控内存和脚本执行时间。
错误处理与日志记录： 完善的错误捕获和日志机制，对于排查批量操作中的问题至关重要。
通过综合运用上述方法与优化策略，你可以显著提升PHP应用程序与Microsoft SQL Server之间数据批量处理的效率，满足高性能企业应用的需求。