PDO数据查询的封装与重用：构建高效的数据库操作函数

// 假设 $db 是一个已连接的PDO对象
$query = $db->prepare("select * from texts where id = :id");

// 获取 id 为 1 的文本
$query->execute([ 'id' => 1 ]);
$fetchquery = $query->fetch(PDO::FETCH_ASSOC);
echo $fetchquery['text']; // 输出: Hello.

// 获取 id 为 2 的文本
$query->execute([ 'id' => 2 ]);
$fetchquery = $query->fetch(PDO::FETCH_ASSOC);
echo $fetchquery['text']; // 输出: Welcome to my

// 获取 id 为 3 的文本
$query->execute([ 'id' => 3 ]);
$fetchquery = $query->fetch(PDO::FETCH_ASSOC);
echo $fetchquery['text']; // 输出: website.

/**
 * 根据ID从texts表获取单条文本内容
 *
 * @param int $id 要查询的文本ID
 * @return string|null 返回对应的文本内容，如果未找到则返回null
 */
function getTextById(int $id): ?string {
    // 假设 $GLOBALS['db'] 存储了PDO连接对象
    // 更好的实践是作为参数传入，详见下文
    global $db; 

    // 准备SQL查询语句
    // 仅选择需要的列，提高效率
    $query = $db->prepare("SELECT text FROM texts WHERE id = :id");

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

    // 获取结果
    $result = $query->fetch(PDO::FETCH_ASSOC);

    // 返回文本内容，如果结果为空则返回null
    return $result['text'] ?? null; 
}

// 假设 $db 已经被初始化并连接到数据库
// 例如：$db = new PDO('mysql:host=localhost;dbname=testdb', 'user', 'password');

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

/**
 * 根据ID从texts表获取单条文本内容 (推荐方式：PDO对象作为参数)
 *
 * @param PDO $db PDO数据库连接对象
 * @param int $id 要查询的文本ID
 * @return string|null 返回对应的文本内容，如果未找到则返回null
 */
function getTextByIdImproved(PDO $db, int $id): ?string {
    $query = $db->prepare("SELECT text FROM texts WHERE id = :id");
    $query->execute(['id' => $id]);
    $result = $query->fetch(PDO::FETCH_ASSOC);
    return $result['text'] ?? null;
}

// 使用示例
// echo getTextByIdImproved($db, 1);

function getTextByIdWithErrors(PDO $db, int $id): ?string {
    try {
        $query = $db->prepare("SELECT text FROM texts WHERE id = :id");
        $query->execute(['id' => $id]);
        $result = $query->fetch(PDO::FETCH_ASSOC);
        return $result['text'] ?? null;
    } catch (PDOException $e) {
        // 记录错误或抛出自定义异常
        error_log("数据库查询错误: " . $e->getMessage());
        // 根据应用需求，可以选择返回null、抛出更高级的异常或显示友好错误信息
        return null; 
    }
}

/**
 * 通用单行单列查询函数
 *
 * @param PDO $db PDO数据库连接对象
 * @param string $tableName 表名
 * @param string $columnName 要查询的列名
 * @param string $idColumnName ID列名 (默认为 'id')
 * @param mixed $idValue ID值
 * @return mixed|null 返回查询到的值，如果未找到则返回null
 */
function fetchSingleValue(PDO $db, string $tableName, string $columnName, string $idColumnName, $idValue) {
    try {
        $sql = "SELECT " . $columnName . " FROM " . $tableName . " WHERE " . $idColumnName . " = :idValue";
        $query = $db->prepare($sql);
        $query->execute([':idValue' => $idValue]);
        $result = $query->fetch(PDO::FETCH_ASSOC);
        return $result[$columnName] ?? null;
    } catch (PDOException $e) {
        error_log("通用查询错误: " . $e->getMessage());
        return null;
    }
}

// 使用示例：
// echo fetchSingleValue($db, 'texts', 'text', 'id', 1);
// echo fetchSingleValue($db, 'users', 'username', 'user_id', 5);