PHP PDO：封装高效数据获取函数以提升代码复用性

<?php
// 假设 $db 已经是一个有效的PDO连接实例，例如：
// $db = new PDO('mysql:host=localhost;dbname=your_db;charset=utf8', 'username', 'password');
// $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 设置错误模式为抛出异常

$query = $db->prepare("SELECT * FROM texts WHERE id = :id");

// 第一次查询
$query->execute([ 'id' => 1 ]);
$fetchquery = $query->fetch(PDO::FETCH_ASSOC);
echo $fetchquery['text']; // 假设输出: Hello.

// 第二次查询
$query->execute([ 'id' => 2 ]);
$fetchquery = $query->fetch(PDO::FETCH_ASSOC);
echo $fetchquery['text']; // 假设输出: Welcome to my

// ...如果需要查询更多ID，则需要重复上述三行代码
?>

<?php

/**
 * 根据ID从texts表获取指定文本内容
 *
 * @param int $id 要查询的文本ID
 * @return string|null 返回查询到的文本内容，如果未找到则返回null
 */
function getTextById(int $id): ?string {
    // 假设 $GLOBALS['db'] 已经是一个有效的PDO连接实例。
    // 在生产环境中，更推荐通过参数传递或依赖注入管理数据库连接。
    global $db; 

    // 检查 $db 是否已初始化且为PDO实例
    if (!isset($db) || !($db instanceof PDO)) {
        // 可以在这里抛出更具体的异常或返回错误，例如：
        // throw new Exception("Database connection is not initialized.");
        error_log("PDO connection \$db is not available or not a PDO instance.");
        return null;
    }

    try {
        // 预处理SQL查询，只选择需要的字段以提高效率
        $query = $db->prepare("SELECT text FROM texts WHERE id = :id");

        // 绑定参数并执行查询
        $query->execute([ 'id' => $id ]);

        // 获取结果，使用PDO::FETCH_ASSOC以关联数组形式返回
        $result = $query->fetch(PDO::FETCH_ASSOC);

        // 返回文本内容，如果结果为空则返回null
        return $result['text'] ?? null;
    } catch (PDOException $e) {
        // 捕获PDO异常，记录错误信息，避免敏感信息泄露
        error_log("Database error in getTextById: " . $e->getMessage());
        return null; // 或者重新抛出异常让上层处理
    }
}

// 示例用法：
// 在调用函数之前，请确保 $db 变量已被正确初始化为PDO连接实例。
// 例如：
// try {
//     $db = new PDO('mysql:host=localhost;dbname=testdb;charset=utf8', 'user', 'password');
//     $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
//     $db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
// } catch (PDOException $e) {
//     die("数据库连接失败: " . $e->getMessage());
// }

echo getTextById(1) . "\n"; // 输出: Hello.
echo getTextById(2) . "\n"; // 输出: Welcome to my
echo getTextById(3) . "\n"; // 输出: website.

// 如果查询不存在的ID
echo "ID 99 的文本: " . (getTextById(99) ?? "未找到") . "\n"; // 输出: ID 99 的文本: 未找到

?>