本文介绍在 php 环境下从 sql server（mssql）安全、高效抽取数据并写入 mysql 的最佳实践，涵盖连接管理、预处理语句优化、批量写入策略及 on duplicate key update 的正确用法。
本文介绍在 php 环境下从 sql server（mssql）安全、高效抽取数据并写入 mysql 的最佳实践，涵盖连接管理、预处理语句优化、批量写入策略及 on duplicate key update 的正确用法。
在跨数据库迁移或实时同步场景中，将数据从 Microsoft SQL Server 同步至 MySQL 是常见需求。若采用逐行 INSERT ... ON DUPLICATE KEY UPDATE 并在循环内重复拼接 SQL 字符串（如 INSERT INTO t SET col=$row['col']），不仅存在严重的 SQL 注入风险，还会因频繁编译执行导致性能急剧下降。真正的最佳实践是：复用预处理语句（Prepared Statement） + 显式参数绑定 + 事务控制。
以下为推荐实现方案（使用 MySQLi 驱动，兼容 MySQL 5.6+）：
// 1. 建立 MSSQL 连接（SQLSRV 扩展）
$serverName = "your-mssql-server";
$connectionOptions = [
"Database" => "YourDB",
"Uid" => "username",
"PWD" => "password"
];
$conn_mssql = sqlsrv_connect($serverName, $connectionOptions);
if (!$conn_mssql) {
die("MSSQL 连接失败: " . print_r(sqlsrv_errors(), true));
}
// 2. 建立 MySQL 连接（MySQLi 面向对象模式）
$conn_mysql = new mysqli("localhost", "user", "pass", "database");
if ($conn_mysql->connect_error) {
die("MySQL 连接失败: " . $conn_mysql->connect_error);
}
// 3. 准备 MySQL 插入/更新语句（关键：只准备一次！）
$stmt = $conn_mysql->prepare("
INSERT INTO orders (id, ordernr)
VALUES (?, ?)
ON DUPLICATE KEY UPDATE ordernr = VALUES(ordernr)
");
$stmt->bind_param("is", $id, $ordernr); // "i"=integer, "s"=string
// 4. 执行 MSSQL 查询并逐行同步（内存友好，无需全量缓存）
$sql = "SELECT id, ordernr FROM orders WHERE status = 'completed'";
$result = sqlsrv_query($conn_mssql, $sql);
if (!$result) {
die("MSSQL 查询失败: " . print_r(sqlsrv_errors(), true));
}
// 5. 开启事务提升一致性与性能
$conn_mysql->begin_transaction();
try {
while ($row = sqlsrv_fetch_array($result, SQLSRV_FETCH_ASSOC)) {
$id = (int)$row['id'];
$ordernr = trim((string)$row['ordernr']);
$stmt->execute();
}
$conn_mysql->commit();
echo "同步完成：共处理 " . sqlsrv_num_rows($result) . " 行。\n";
} catch (Exception $e) {
$conn_mysql->rollback();
throw $e;
} finally {
$stmt->close();
sqlsrv_free_stmt($result);
sqlsrv_close($conn_mssql);
$conn_mysql->close();
}
✅ 关键优势说明：
MySQL8 CRM Schema Design Expert
下载
面向 CRM 系统的 MySQL 8 数据库模式设计。当用户需要为客户关系管理（CRM）系统设计、评审、优化或生成数据库模式时，应使用此项技能。
-
安全性：通过
bind_param()绑定变量，彻底规避 SQL 注入； - 性能：预处理语句仅编译一次，避免每次循环解析 SQL；
-
健壮性：
ON DUPLICATE KEY UPDATE ordernr = VALUES(ordernr)确保主键/唯一键冲突时精准更新，而非错误覆盖； - 可靠性：显式事务包裹，任一失败则全部回滚，保障数据一致性；
- 资源友好：不构造大数组，逐行流式处理，适用于百万级数据。
⚠️ 注意事项：
- MySQL 表必须定义
PRIMARY KEY或UNIQUE KEY（如id），否则ON DUPLICATE KEY UPDATE不生效； - 若需批量插入（如千行/批），可改用
INSERT ... VALUES (...), (...), (...) ON DUPLICATE KEY UPDATE拼接多值，但需严格控制批次大小（建议 ≤ 1000 行），避免 SQL 长度超限或锁表过久； - MSSQL 的
sqlsrv_fetch_array返回时间类型为DateTime对象，请用format('Y-m-d H:i:s')转换后再绑定； - 生产环境务必启用错误日志记录，禁用
display_errors，避免敏感信息泄露。
总结：不要拼接 SQL，不要逐条 query()，更不要一次性 INSERT INTO ... SELECT（跨 DB 不支持）。坚持「单次预处理 + 参数绑定 + 事务封装」，即可在安全、可控、可维护的前提下，完成高质量的异构数据库同步任务。
