PHP中判断MySQL表是否存在的高效方法

SELECT COUNT(*)
FROM information_schema.TABLES
WHERE TABLE_SCHEMA = 'your_database_name' AND TABLE_NAME = 'your_table_name';

<?php

// 假设您的数据库类（为演示目的，这里提供一个简化版，模拟常用功能）
class Database {
    private $pdo;
    private $dbName; // 存储当前连接的数据库名

    public function __construct($host, $db, $user, $pass) {
        $dsn = "mysql:host=$host;dbname=$db;charset=utf8mb4";
        $options = [
            PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION, // 启用异常模式
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,       // 默认关联数组返回
            PDO::ATTR_EMULATE_PREPARES   => false,                  // 禁用模拟预处理，使用真实预处理
        ];
        try {
            $this->pdo = new PDO($dsn, $user, $pass, $options);
            $this->dbName = $db; // 保存数据库名
        } catch (\PDOException $e) {
            throw new \PDOException("数据库连接失败: " . $e->getMessage(), (int)$e->getCode());
        }
    }

    /**
     * 执行SQL查询并返回PDOStatement对象
     * @param string $sql SQL语句
     * @param mixed ...$params 绑定参数
     * @return PDOStatement
     */
    public function query($sql, ...$params) {
        $stmt = $this->pdo->prepare($sql);
        $stmt->execute($params);
        return $stmt;
    }

    /**
     * 执行查询并返回第一行第一列的值（例如COUNT(*)）
     * @param string $sql SQL语句
     * @param mixed ...$params 绑定参数
     * @return mixed
     */
    public function fetchOne($sql, ...$params) {
        $stmt = $this->query($sql, ...$params);
        return $stmt->fetchColumn();
    }

    /**
     * 获取当前连接的数据库名称
     * @return string
     */
    public function getDbName() {
        return $this->dbName;
    }

    public function close() {
        $this->pdo = null;
    }
}

// 实例化数据库连接
try {
    $database = new Database('localhost', 'your_database_name', 'root', 'your_password');
} catch (Exception $e) {
    die($e->getMessage());
}


/**
 * 动态添加统计数据，如果表不存在则创建
 * @param Database $database 数据库连接实例
 * @param string $brow 浏览器信息
 * @param string $vers 版本信息
 * @param string $pag 页面标识，用于生成表名
 * @param string $lang 语言信息
 */
function addSts($database, $brow, $vers, $pag, $lang) {
    $tablename = "sts" . $pag; // 动态生成表名
    $databaseName = $database->getDbName(); // 获取当前连接的数据库名

    // 步骤1: 检查表是否存在
    $sqlCheckTable = "SELECT COUNT(*) FROM information_schema.TABLES WHERE TABLE_SCHEMA = ? AND TABLE_NAME = ?";
    $tableExists = $database->fetchOne($sqlCheckTable, $databaseName, $tablename);

    if ($tableExists > 0) {
        // 步骤2a: 如果表已存在，直接插入数据
        echo "表 '" . $tablename . "' 已存在。尝试插入数据。<br>";
        try {
            // 注意：如果id是AUTO_INCREMENT，INSERT时通常不指定id列，让数据库自动生成
            $stsinsert = $database->query(
                'INSERT INTO `' . $tablename . '` (browser, version, language, date) VALUES (?, ?, ?, CURRENT_TIMESTAMP())',
                $brow, $vers, $lang
            );
            if ($stsinsert->rowCount() > 0) {
                echo "数据插入成功。<br>";
            } else {
                echo "数据插入失败或未影响任何行。<br>";
            }
        } catch (Exception $e) {
            echo "插入数据时发生错误: " . $e->getMessage() . "<br>";
        }
    } else {
        // 步骤2b: 如果表不存在，则创建表
        echo "表 '" . $tablename . "' 不存在。尝试创建表。<br>";
        try {
            $pagecreation = $database->query(
                'CREATE TABLE `' . $tablename . '` (
                    `id` BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,
                    `browser` VARCHAR(20) NOT NULL,
                    `version` VARCHAR(10) NOT NULL,
                    `language` VARCHAR(5) NOT NULL,
                    `date` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
                    PRIMARY KEY (`id`)
                )'
            );
            if ($pagecreation) {
                echo "表 '" . $tablename . "' 创建成功。重新尝试插入数据。<br>";
                // 表创建成功后，立即再次调用本函数以插入数据
                addSts($database, $brow, $vers, $pag, $lang);
            } else {
                echo "表 '" . $tablename . "' 创建失败。<br>";
            }
        } catch (Exception $e) {
            echo "创建表时发生错误: " . $e->getMessage() . "<br>";
        }
    }
    // 注意：通常数据库连接在整个请求生命周期结束时关闭，
    // 如果函数会被多次调用，不应在每次调用后关闭。
    // 这里为了演示，暂时保留。
    // $database->close();
}

// 示例调用
echo "--- 第一次调用 (可能创建表) ---<br>";
addSts($database, 'Chrome', '100', 'homepage', 'en');
echo "<br>--- 第二次调用 (表已存在，直接插入) ---<br>";
addSts($database, 'Firefox', '90', 'homepage', 'zh');
echo "<br>--- 第三次调用 (新表，可能创建表) ---<br>";
addSts($database, 'Edge', '110', 'aboutus', 'fr');

$database->close(); // 在所有操作完成后关闭连接
?>