PHP：PDO数据获取与JSON编码集成实践

$stmt = $dbh->prepare("SELECT * FROM `products` WHERE `username` = '$userdetails' ORDER BY `uid` DESC");
$stmt->execute();

// 确保 $_SESSION['usr_name'] 正确访问
$userdetails = $_SESSION['usr_name']; 

// 使用命名占位符 :username
$stmt = $dbh->prepare("SELECT * FROM `products` WHERE `username` = :username ORDER BY `uid` DESC");

// 通过关联数组绑定参数
$stmt->execute([':username' => $userdetails]); 

// 假设 $stmt 已经执行并准备好获取结果
$fetch = $stmt->fetchAll(); // 获取所有匹配的产品

// 调试：检查 $fetch 的结构
// var_dump($fetch); 
// print_r($fetch);

// 如果只期望获取第一个产品的价格
if (!empty($fetch)) {
    $productPrice = $fetch[0]['price']; // 访问第一行数据的 'price' 键
} else {
    $productPrice = 0; // 或者其他默认值，表示未找到产品
}

// 或者，如果确定只获取一行，可以直接使用 fetch()
// $fetch = $stmt->fetch(PDO::FETCH_ASSOC); // 以关联数组形式获取一行
// if ($fetch) {
//     $productPrice = $fetch['price']; // 直接访问 'price' 键
// } else {
//     $productPrice = 0;
// }

// ... (之前的PDO安全获取数据代码) ...

// 假设我们已经通过 PDO 获取到 $productPrice 变量
// 例如：
// $userdetails = $_SESSION['usr_name'];
// $stmt = $dbh->prepare("SELECT * FROM `products` WHERE `username` = :username ORDER BY `uid` DESC LIMIT 1"); // 限制只获取一行
// $stmt->execute([':username' => $userdetails]);
// $productData = $stmt->fetch(PDO::FETCH_ASSOC); // 获取单行数据

// $productPrice = $productData ? $productData['price'] : 0; // 如果找到数据则取价格，否则为0

// 假设我们已经获取到 $productPrice
$productPrice = 12.99; // 示例值，实际应从数据库获取

$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, 'https://api.commerce.coinbase.com/charges');
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode(
    array (
        'name' => 'My-Business-Name',
        'description' => "Selected Product: ",
        'local_price' => 
            array (
                'amount' => $productPrice, // 正确地将变量值插入到数组中
                'currency' => 'GBP',
            ),
        'pricing_type' => 'fixed_price',
        'metadata' => 
            array (
                'customer_id' => 'uid_1',
                'customer_name' => 'Satoshi Nakamoto',
            )
    )
));
$result = curl_exec($ch);
curl_close($ch);
$response = json_decode($result, true);

<?php
session_start(); // 确保会话已启动

// 数据库连接示例 (请根据实际情况配置)
try {
    $dbh = new PDO('mysql:host=localhost;dbname=your_database', 'your_user', 'your_password');
    $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 设置错误模式为异常
    $dbh->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC); // 默认以关联数组获取
} catch (PDOException $e) {
    die("数据库连接失败: " . $e->getMessage());
}

$userdetails = $_SESSION['usr_name'] ?? 'default_user'; // 使用空合并运算符提供默认值

// 1. 安全地获取数据库数据：使用PDO预处理语句和参数绑定
$productPrice = 0; // 初始化价格变量
$productDescription = "未选择产品"; // 初始化描述变量

try {
    // 限制只获取一个产品，例如最新添加的或第一个匹配的
    $stmt = $dbh->prepare("SELECT `item`, `description`, `price` FROM `products` WHERE `username` = :username ORDER BY `uid` DESC LIMIT 1");
    $stmt->execute([':username' => $userdetails]);

    // 2. 理解PDO数据获取结果：使用 fetch() 获取单行数据
    $productData = $stmt->fetch(); // 默认 PDO::FETCH_ASSOC

    if ($productData) {
        $productPrice = $productData['price'];
        $productDescription = $productData['description'];
        // 调试：查看获取到的产品数据
        // var_dump($productData); 
    } else {
        echo "未找到匹配的产品数据。\n";
    }
} catch (PDOException $e) {
    echo "数据库查询错误: " . $e->getMessage() . "\n";
}

// 3. 将数据集成到JSON编码结构并进行API调用
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, 'https://api.commerce.coinbase.com/charges');
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json')); // 明确指定Content-Type

$postFields = array (
    'name' => 'My-Business-Name',
    'description' => "Selected Product: " . $productDescription, // 动态插入产品描述
    'local_price' => 
        array (
            'amount' => (string)$productPrice, // 确保金额是字符串类型，符合API要求
            'currency' => 'GBP',
        ),
    'pricing_type' => 'fixed_price',
    'metadata' => 
        array (
            'customer_id' => 'uid_1',
            'customer_name' => 'Satoshi Nakamoto',
        )
);

curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($postFields));

$result = curl_exec($ch);

if (curl_errno($ch)) {
    echo 'cURL 错误: ' . curl_error($ch) . "\n";
}

curl_close($ch);

$response = json_decode($result, true);

// 处理API响应
if ($response) {
    echo "API 响应:\n";
    print_r($response);
} else {
    echo "无法解析 API 响应 或 API 返回空值。\n";
    echo "原始响应: " . $result . "\n";
}

?>