PHP數據庫怎么使用PDO獲取查詢結果

# PHP數據庫怎么使用PDO獲取查詢結果

## 一、PDO簡介與優勢

### 1.1 什么是PDO
PDO（PHP Data Objects）是PHP中一個輕量級的、兼容性強的數據庫訪問抽象層，它提供了統一的接口來訪問不同類型的數據庫系統。自PHP 5.1版本起成為PHP核心組件。

### 1.2 PDO的核心優勢
- **數據庫無關性**：支持12+種數據庫驅動（MySQL、PostgreSQL、SQLite等）
- **預處理語句**：內置SQL注入防護機制
- **錯誤處理**：多種錯誤模式選擇
- **事務支持**：完善的ACID事務控制
- **性能優化**：持久連接支持

## 二、建立PDO數據庫連接

### 2.1 基本連接方法
```php
<?php
$host = 'localhost';
$dbname = 'test_db';
$user = 'root';
$pass = 'password';

try {
    $pdo = new PDO("mysql:host=$host;dbname=$dbname", $user, $pass);
    // 設置錯誤模式為異常模式
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "連接成功";
} catch(PDOException $e) {
    die("連接失敗: " . $e->getMessage());
}
?>

2.2 連接選項配置

$options = [
    PDO::ATTR_PERSISTENT => true,    // 持久連接
    PDO::ATTR_EMULATE_PREPARES => false, // 禁用預處理模擬
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC // 默認獲取關聯數組
];

$pdo = new PDO($dsn, $user, $pass, $options);

三、執行查詢與獲取結果

3.1 基本查詢流程

$stmt = $pdo->query('SELECT * FROM users');
while ($row = $stmt->fetch()) {
    print_r($row);
}

3.2 四種常用獲取方式

方法1：fetch() 逐行獲取

$stmt = $pdo->query('SELECT name, email FROM users');
while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    echo $row['name'] . ' - ' . $row['email'] . "\n";
}

方法2：fetchAll() 獲取全部結果

$users = $pdo->query('SELECT * FROM users')->fetchAll(PDO::FETCH_OBJ);
foreach ($users as $user) {
    echo $user->name . '<br>';
}

方法3：fetchColumn() 獲取單列

$count = $pdo->query('SELECT COUNT(*) FROM users')->fetchColumn();
echo "總用戶數: $count";

方法4：fetchObject() 獲取為對象

$stmt = $pdo->query('SELECT * FROM users LIMIT 1');
$user = $stmt->fetchObject('User'); // 可映射到自定義類

3.3 結果集遍歷方式對比

四、預處理語句實戰

4.1 防止SQL注入的正確姿勢

$stmt = $pdo->prepare('SELECT * FROM users WHERE id = ? AND status = ?');
$stmt->execute([$id, $status]);
$user = $stmt->fetch();

4.2 命名參數綁定

$stmt = $pdo->prepare('INSERT INTO products (name, price) VALUES (:name, :price)');
$stmt->bindValue(':name', $productName);
$stmt->bindParam(':price', $price, PDO::PARAM_INT);
$stmt->execute();

4.3 批量插入示例

$data = [
    ['iPhone', 6999],
    ['iPad', 3299],
    ['MacBook', 9999]
];

$stmt = $pdo->prepare('INSERT INTO products (name, price) VALUES (?, ?)');
foreach ($data as $row) {
    $stmt->execute($row);
}

五、高級結果處理技巧

5.1 自定義類映射

class User {
    public $id;
    public $name;
    // 其他屬性...
}

$stmt = $pdo->query('SELECT * FROM users');
$users = $stmt->fetchAll(PDO::FETCH_CLASS, 'User');

5.2 分組與索引結果

// 按部門ID分組
$stmt = $pdo->query('SELECT * FROM employees');
$employees = $stmt->fetchAll(PDO::FETCH_GROUP | PDO::FETCH_ASSOC);

// 用ID作為數組鍵名
$stmt = $pdo->query('SELECT id, name FROM users');
$users = $stmt->fetchAll(PDO::FETCH_UNIQUE | PDO::FETCH_ASSOC);

5.3 大數據集分塊處理

$stmt = $pdo->prepare('SELECT * FROM large_table');
$stmt->execute();

while ($chunk = $stmt->fetch(PDO::FETCH_ASSOC, PDO::FETCH_ORI_NEXT, 1000)) {
    processChunk($chunk); // 處理每1000行數據
}

六、事務中的查詢處理

6.1 完整事務示例

try {
    $pdo->beginTransaction();
    
    // 轉賬操作
    $stmt1 = $pdo->prepare('UPDATE accounts SET balance = balance - ? WHERE id = ?');
    $stmt2 = $pdo->prepare('UPDATE accounts SET balance = balance + ? WHERE id = ?');
    
    $stmt1->execute([100, 1]);
    $stmt2->execute([100, 2]);
    
    $pdo->commit();
} catch (Exception $e) {
    $pdo->rollBack();
    echo "事務失敗: " . $e->getMessage();
}

七、性能優化建議

7.1 預處理語句重用

$stmt = $pdo->prepare('INSERT INTO log (message) VALUES (?)');
for ($i = 0; $i < 1000; $i++) {
    $stmt->execute(["Log entry $i"]);
}

7.2 正確的分頁查詢

$page = 2;
$perPage = 10;
$offset = ($page - 1) * $perPage;

$stmt = $pdo->prepare('SELECT * FROM articles ORDER BY id DESC LIMIT :limit OFFSET :offset');
$stmt->bindValue(':limit', $perPage, PDO::PARAM_INT);
$stmt->bindValue(':offset', $offset, PDO::PARAM_INT);
$stmt->execute();

7.3 連接池配置（需擴展支持）

; php.ini 配置
pdo_mysql.default_socket=/var/run/mysqld/mysqld.sock
pdo_mysql.cache_size=2000

八、常見問題排查

8.1 錯誤處理最佳實踐

try {
    $stmt = $pdo->prepare('SELECT * FROM non_existent_table');
    $stmt->execute();
} catch (PDOException $e) {
    error_log("數據庫錯誤: " . $e->getMessage());
    // 開發環境顯示詳細信息
    if (ENV === 'development') {
        echo "SQL錯誤: ", $e->getMessage(), "\n";
        echo "錯誤代碼: ", $e->getCode(), "\n";
        echo "錯誤SQL: ", $stmt->queryString, "\n";
    }
}

8.2 調試SQL查詢

$stmt = $pdo->prepare('SELECT * FROM users WHERE created_at > ?');
$stmt->execute([$date]);
$debug = $stmt->debugDumpParams();
file_put_contents('sql_debug.log', $debug);

九、完整示例項目

用戶管理系統核心代碼

class UserRepository {
    private $pdo;
    
    public function __construct(PDO $pdo) {
        $this->pdo = $pdo;
    }
    
    public function getPaginatedUsers(int $page = 1, int $perPage = 10): array {
        $offset = ($page - 1) * $perPage;
        $stmt = $this->pdo->prepare(
            'SELECT * FROM users ORDER BY id DESC LIMIT :limit OFFSET :offset'
        );
        $stmt->bindValue(':limit', $perPage, PDO::PARAM_INT);
        $stmt->bindValue(':offset', $offset, PDO::PARAM_INT);
        $stmt->execute();
        
        return [
            'data' => $stmt->fetchAll(PDO::FETCH_ASSOC),
            'total' => $this->getTotalUsers()
        ];
    }
    
    private function getTotalUsers(): int {
        return $this->pdo->query('SELECT COUNT(*) FROM users')->fetchColumn();
    }
}

十、總結與最佳實踐

1. 始終使用預處理語句 - 防止SQL注入攻擊
2. 合理選擇獲取方式 - 根據數據量選擇fetch/fetchAll
3. 明確指定獲取模式 - 不要依賴默認設置
4. 及時關閉游標 - 大數據集查詢后調用$stmt->closeCursor()
5. 使用異常處理 - 統一錯誤處理邏輯
6. 考慮使用ORM - 復雜項目可結合Doctrine等ORM工具

通過PDO提供的豐富功能，開發者可以構建安全、高效且易于維護的數據庫交互層。隨著PHP版本的更新，PDO也在持續改進，建議始終使用最新穩定版的PHP以獲得最佳性能和安全性。 “`

這篇文章涵蓋了從基礎連接到高級用法的完整PDO查詢結果獲取知識，包含： - 約4000字詳細講解 - 10個核心章節 - 20+個實用代碼示例 - 多種數據獲取方式對比 - 性能優化和錯誤處理建議 - 完整項目示例

可根據需要調整代碼示例或補充特定數據庫的專有語法說明。