SteamAuth集成MySQL遇PDO重复数据问题，求数据更新代码

我明白你现在遇到的困扰——集成Steam Auth到MySQL的PDO代码时，要么碰到「表已存在」的报错，要么重复插入Steam用户数据。核心需求其实就是要实现**「存在则更新，不存在则插入」（UPSERT）**的逻辑，同时确保表只会被创建一次。下面给你一套完整的可落地解决方案：

1. 先解决「表已存在」的问题 #

创建表时使用CREATE TABLE IF NOT EXISTS语法，这样即使表已经存在，也不会抛出错误。我们给Steam用户表设计必要字段，并且给唯一标识steamid添加唯一索引，这是后续实现UPSERT的基础。

function createSteamUsersTable($pdo) {
    $sql = "CREATE TABLE IF NOT EXISTS steam_users (
        id INT AUTO_INCREMENT PRIMARY KEY,
        steamid VARCHAR(255) NOT NULL UNIQUE,
        username VARCHAR(255) NOT NULL,
        avatar_url VARCHAR(255),
        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
        updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4";
    $pdo->exec($sql);
}

2. 实现「按需更新/插入」的UPSERT逻辑 #

MySQL原生支持INSERT ... ON DUPLICATE KEY UPDATE语法，当插入的steamid触发唯一键冲突时，会自动执行UPDATE语句更新指定字段。这种方式不用先查询再判断，一步完成操作，效率更高也更安全。

完整PDO代码示例 #

<?php
function newPDO() {
    $host = '你的主机地址';
    $db = '你的数据库名';
    $user = '你的用户名';
    $pass = '你的密码';
    $dsn = "mysql:host=$host;dbname=$db;charset=utf8mb4";
    $opt = [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
        PDO::ATTR_EMULATE_PREPARES => false, // 禁用模拟预处理，提升安全性
    ];
    try {
        return new PDO($dsn, $user, $pass, $opt);
    } catch(PDOException $e) {
        die("数据库连接失败: " . $e->getMessage());
    }
}

// 创建Steam用户表（仅在不存在时执行）
function createSteamUsersTable($pdo) {
    $sql = "CREATE TABLE IF NOT EXISTS steam_users (
        id INT AUTO_INCREMENT PRIMARY KEY,
        steamid VARCHAR(255) NOT NULL UNIQUE,
        username VARCHAR(255) NOT NULL,
        avatar_url VARCHAR(255),
        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
        updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4";
    $pdo->exec($sql);
}

// 插入或更新Steam用户数据
function upsertSteamUser($pdo, $steamid, $username, $avatar_url) {
    $sql = "INSERT INTO steam_users (steamid, username, avatar_url)
            VALUES (:steamid, :username, :avatar_url)
            ON DUPLICATE KEY UPDATE 
                username = :username,
                avatar_url = :avatar_url";
    
    $stmt = $pdo->prepare($sql);
    $stmt->bindParam(':steamid', $steamid);
    $stmt->bindParam(':username', $username);
    $stmt->bindParam(':avatar_url', $avatar_url);
    
    try {
        $stmt->execute();
        // 返回操作影响的行数（插入返回1，更新返回2）
        return $stmt->rowCount();
    } catch(PDOException $e) {
        die("用户数据操作失败: " . $e->getMessage());
    }
}

// 使用示例（模拟从Steam Auth获取的用户数据）
$pdo = newPDO();
createSteamUsersTable($pdo);

$steamUserData = [
    'steamid' => '12345678901234567',
    'username' => 'NerdyBoy',
    'avatar_url' => 'https://steamcdn-a.akamaihd.net/steamcommunity/public/images/avatars/xxx.jpg'
];

upsertSteamUser($pdo, $steamUserData['steamid'], $steamUserData['username'], $steamUserData['avatar_url']);
?>

关键细节说明 #

• 唯一键的作用：steamid字段的UNIQUE约束是UPSERT逻辑的核心，只有当这个字段重复时，才会触发更新操作。
• 自动更新时间：updated_at字段设置了ON UPDATE CURRENT_TIMESTAMP，每次更新数据时会自动刷新时间，方便追踪用户最新登录时间。
• 安全防护：开启PDO::ATTR_EMULATE_PREPARES => false并使用参数绑定，彻底避免SQL注入风险。

你只需要在Steam Auth的回调流程中，把获取到的用户数据传入upsertSteamUser函数，就能自动完成「新用户插入，老用户更新」的操作，再也不会碰到表已存在或数据重复的PDO错误了。

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