PDO报错：绑定变量数量与令牌数量不匹配问题排查

问题原因 #

1. 占位符与绑定参数数量不匹配
   UPDATE语句里定义了8个?占位符，但execute()只传入了1个参数（json_encode($itms)），两者数量完全不匹配，这是触发错误的直接原因。

2. SQL语法错误
   SET子句最后一个字段position.satellites =?,后面多了一个逗号，会导致MySQL解析SQL时出错。

3. 逻辑混乱
   前面循环生成了多条数据的字符串格式，但后面却用单条UPDATE语句，两者逻辑不匹配——要么是更新单条记录，要么是批量更新多条，当前写法完全矛盾。

解决方案 #

根据需求分两种情况处理：

情况1：更新单条记录（根据ident_same_update） #

如果$json["result"]里只有一条数据，或仅需更新对应ident_same_update的单条记录，修改代码如下：

$bdd = new PDO('mysql:host=localhost;dbname=message_receiver', 'root', '', array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION));

// 取目标单条数据（示例取第一条，可根据实际调整）
$data = $json["result"][0] ?? [];

try {
    $requete = $bdd->prepare("
        UPDATE php_message_listener
        SET 
            `server.timestamp` = ?,
            `position.longitude` = ?,
            `position.latitude` = ?,
            `timestamp` = ?,
            `position.altitude` = ?,
            `position.direction` = ?,
            `position.speed` = ?,
            `position.satellites` = ?
        WHERE ident = ?
    ");
    // 传入8个字段值 + 1个ident参数，共9个参数
    $requete->execute([
        floatval($data['server.timestamp'] ?? 0),
        floatval($data['position.longitude'] ?? 0),
        floatval($data['position.latitude'] ?? 0),
        floatval($data['timestamp'] ?? 0),
        floatval($data['position.altitude'] ?? 0),
        floatval($data['position.direction'] ?? 0),
        floatval($data['position.speed'] ?? 0),
        intval($data['position.satellites'] ?? 0),
        $ident_same_update
    ]);
} catch(Exception $e) {
    die('Erreur : '.$e->getMessage());
}

注意：字段名含.时需用反引号`包裹，避免MySQL解析为「表.字段」格式；同时将ident改为参数绑定，规避SQL注入风险。

情况2：批量更新多条记录 #

若需批量更新多条对应不同ident的记录，MySQL需使用UPDATE ... JOIN语法，示例如下：

$bdd = new PDO('mysql:host=localhost;dbname=message_receiver', 'root', '', array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION));

$params = [];
$timestampCases = [];
$longitudeCases = [];
// 其他字段同理，需为每个字段创建CASE语句

foreach ($json["result"] as $item) {
    $ident = $item['ident'] ?? $ident_same_update;
    // 为每个字段构建CASE WHEN逻辑
    $timestampCases[] = "WHEN ident = ? THEN ?";
    $params[] = $ident;
    $params[] = floatval($item['server.timestamp'] ?? 0);
    
    $longitudeCases[] = "WHEN ident = ? THEN ?";
    $params[] = $ident;
    $params[] = floatval($item['position.longitude'] ?? 0);
    
    // 继续添加latitude、timestamp等其他字段的CASE逻辑
}

// 收集所有要更新的ident，用于WHERE条件
$identList = array_unique(array_slice($params, 0, count($params), 2));

try {
    $requete = $bdd->prepare("
        UPDATE php_message_listener
        SET 
            `server.timestamp` = CASE " . implode(' ', $timestampCases) . " END,
            `position.longitude` = CASE " . implode(' ', $longitudeCases) . " END
            // 继续添加其他字段的SET语句
        WHERE ident IN (" . rtrim(str_repeat('?,', count($identList)), ',') . ")
    ");
    // 合并字段参数与ident参数
    $requete->execute(array_merge($params, $identList));
} catch(Exception $e) {
    die('Erreur : '.$e->getMessage());
}

这种方式需为每个要更新的字段编写CASE WHEN逻辑，确保每条记录匹配对应值。

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