PHP脚本开发：DB2查询结果关联MySQL数据实现插入操作

嘿，我来帮你梳理这个跨数据库关联插入的PHP脚本实现思路，我之前做过类似的跨库同步需求，给你一套实用的方案：

1. 前置准备：确保扩展安装 #

首先得确认你的PHP环境已经装好对应数据库的扩展：

• DB2：需要ibm_db2扩展（可以通过php -m命令检查是否已加载）
• MySQL：推荐用PDO_MYSQL（兼容性更强）或者mysqli扩展

2. 核心实现步骤 #

2.1 建立双数据库连接 #

先同时连接DB2和MySQL，记得处理连接失败的异常情况：

// 连接DB2
$db2Conn = db2_connect(
    "DATABASE=你的DB2库名;HOSTNAME=DB2主机地址;PORT=50000;PROTOCOL=TCPIP;UID=DB2用户名;PWD=DB2密码",
    "", ""
);
if (!$db2Conn) {
    die("DB2连接失败: " . db2_conn_errormsg());
}

// 连接MySQL（PDO示例）
try {
    $mysqlConn = new PDO(
        'mysql:host=MySQL主机地址;dbname=你的MySQL库名;charset=utf8mb4',
        'MySQL用户名',
        'MySQL密码'
    );
    $mysqlConn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch(PDOException $e) {
    die("MySQL连接失败: " . $e->getMessage());
}

2.2 查询DB2目标数据集 #

先从DB2中取出需要的字段，重点包含用于关联的style字段：

// DB2查询语句，按需调整字段和过滤条件
$db2Query = "SELECT style, field_a, field_b, field_c FROM DB2源表 WHERE 你的过滤条件";
$stmtDb2 = db2_prepare($db2Conn, $db2Query);
db2_execute($stmtDb2);

2.3 关联MySQL SKU表并执行插入 #

针对每条DB2返回的数据，匹配MySQL的SKU表（关联条件db2.style = sku.groupI），获取对应ID后插入目标表：

// 遍历DB2结果集
while ($db2Row = db2_fetch_assoc($stmtDb2)) {
    $style = $db2Row['style'];
    $fieldA = $db2Row['field_a'];
    $fieldB = $db2Row['field_b'];

    // 查询MySQL SKU表，获取匹配的ID
    $skuQuery = "SELECT id, sku_code FROM sku表 WHERE groupI = :style";
    $stmtSku = $mysqlConn->prepare($skuQuery);
    $stmtSku->bindParam(':style', $style, PDO::PARAM_STR);
    $stmtSku->execute();
    $skuRow = $stmtSku->fetch(PDO::FETCH_ASSOC);

    // 找到匹配数据则执行插入
    if ($skuRow) {
        $skuId = $skuRow['id'];
        $insertQuery = "INSERT INTO MySQL目标表 (db2_field_a, db2_field_b, sku_id, create_time) 
                        VALUES (:fa, :fb, :sid, NOW())";
        $stmtInsert = $mysqlConn->prepare($insertQuery);
        $stmtInsert->bindParam(':fa', $fieldA);
        $stmtInsert->bindParam(':fb', $fieldB);
        $stmtInsert->bindParam(':sid', $skuId, PDO::PARAM_INT);
        $stmtInsert->execute();
        echo "成功插入一条匹配数据\n";
    } else {
        echo "未找到匹配SKU的style值: {$style}\n";
    }
}

2.4 关闭连接释放资源 #

操作完成后记得关闭数据库连接：

db2_close($db2Conn);
$mysqlConn = null; // PDO连接会在脚本结束自动关闭，手动关闭更稳妥

3. 性能优化建议 #

如果DB2返回的数据量很大，逐条查询MySQL会导致性能瓶颈，推荐用批量处理优化：

// 先批量获取所有DB2数据
$db2Data = [];
while ($row = db2_fetch_assoc($stmtDb2)) {
    $db2Data[] = $row;
}

// 提取所有style值，构造批量查询
$styles = array_column($db2Data, 'style');
$placeholders = implode(',', array_fill(0, count($styles), '?'));
$skuBatchQuery = "SELECT groupI, id FROM sku表 WHERE groupI IN ($placeholders)";
$stmtBatch = $mysqlConn->prepare($skuBatchQuery);
$stmtBatch->execute($styles);

// 把SKU数据转成键值对，方便快速匹配
$skuMap = [];
while ($skuRow = $stmtBatch->fetch(PDO::FETCH_ASSOC)) {
    $skuMap[$skuRow['groupI']] = $skuRow['id'];
}

// 批量插入目标表，开启事务保证原子性
$mysqlConn->beginTransaction();
try {
    $insertStmt = $mysqlConn->prepare("INSERT INTO MySQL目标表 (db2_field_a, db2_field_b, sku_id) VALUES (:fa, :fb, :sid)");
    foreach ($db2Data as $row) {
        if (isset($skuMap[$row['style']])) {
            $insertStmt->bindParam(':fa', $row['field_a']);
            $insertStmt->bindParam(':fb', $row['field_b']);
            $insertStmt->bindParam(':sid', $skuMap[$row['style']]);
            $insertStmt->execute();
        }
    }
    $mysqlConn->commit();
    echo "批量插入完成，共处理" . count($db2Data) . "条数据\n";
} catch(PDOException $e) {
    $mysqlConn->rollBack();
    die("批量插入失败: " . $e->getMessage());
}

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