// 利用可能なPDOドライバを確認
print_r(PDO::getAvailableDrivers());
// 出力例: Array ( [0] => mysql [1] => pgsql [2] => sqlite )

<?php
try {
    $dsn = 'mysql:host=localhost;dbname=myapp;charset=utf8mb4';
    $username = 'root';
    $password = 'secret';

    $pdo = new PDO($dsn, $username, $password);

    echo "接続成功";
} catch (PDOException $e) {
    echo "接続失敗: " . $e->getMessage();
    exit(1);
}

<?php
// ファイルベースのSQLite
$pdo = new PDO('sqlite:/path/to/database.db');

// メモリ上のSQLite（テスト用途に便利）
$pdo = new PDO('sqlite::memory:');

<?php
$dsn = 'pgsql:host=localhost;port=5432;dbname=myapp';
$pdo = new PDO($dsn, 'postgres', 'secret');

<?php
$dsn = 'mysql:host=localhost;dbname=myapp;charset=utf8mb4';

$options = [
    // エラー時に例外をスローする（必須）
    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
    // フェッチモードを連想配列に設定
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
    // PDOのエミュレーションを無効化（真のプリペアドステートメントを使用）
    PDO::ATTR_EMULATE_PREPARES   => false,
];

$pdo = new PDO($dsn, 'root', 'secret', $options);

<?php
// 全ユーザーを取得
$stmt = $pdo->query('SELECT id, name, email FROM users');

// 1行ずつ取得（連想配列）
while ($row = $stmt->fetch()) {
    echo $row['name'] . ' - ' . $row['email'] . "
";
}

// 全行を一括取得
$users = $stmt->fetchAll();

// 特定のカラムだけ取得
$names = $pdo->query('SELECT name FROM users')
              ->fetchAll(PDO::FETCH_COLUMN);

<?php
// テーブル作成
$pdo->exec('CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    email VARCHAR(255) NOT NULL UNIQUE,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
)');

// データ削除（影響行数を取得）
$deletedRows = $pdo->exec("DELETE FROM users WHERE active = 0");
echo "{$deletedRows}件を削除しました";

<?php
// NG: SQLインジェクションの脆弱性！
$name = $_GET['name'];
$stmt = $pdo->query("SELECT * FROM users WHERE name = '$name'");
// 攻撃者が name=' OR 1=1 -- を送ると全レコードが取得される

<?php
// SELECT: ユーザーの検索
$stmt = $pdo->prepare('SELECT * FROM users WHERE email = :email');
$stmt->execute([':email' => $_POST['email']]);
$user = $stmt->fetch();

// INSERT: 新規ユーザーの登録
$stmt = $pdo->prepare('INSERT INTO users (name, email) VALUES (:name, :email)');
$stmt->execute([
    ':name'  => $_POST['name'],
    ':email' => $_POST['email'],
]);

// 挿入されたレコードのIDを取得
$newId = $pdo->lastInsertId();
echo "登録成功 ID: {$newId}";

<?php
// ?の順番にパラメータをバインド
$stmt = $pdo->prepare('SELECT * FROM users WHERE age >= ? AND age <= ?');
$stmt->execute([20, 30]);
$users = $stmt->fetchAll();

<?php
$stmt = $pdo->prepare('SELECT * FROM users WHERE id = :id AND active = :active');

// bindValue: 値を直接バインド（型を明示指定）
$stmt->bindValue(':id', 42, PDO::PARAM_INT);
$stmt->bindValue(':active', true, PDO::PARAM_BOOL);
$stmt->execute();

// bindParam: 変数への参照をバインド（execute時点の変数値が使われる）
$id = 1;
$stmt = $pdo->prepare('SELECT * FROM users WHERE id = :id');
$stmt->bindParam(':id', $id, PDO::PARAM_INT);

$id = 42;  // execute時にはこの値が使われる
$stmt->execute();

<?php
// 一度prepareすれば何度でもexecuteできる
$stmt = $pdo->prepare('INSERT INTO logs (level, message) VALUES (:level, :message)');

$logs = [
    [':level' => 'INFO',  ':message' => 'ユーザーがログインしました'],
    [':level' => 'WARN',  ':message' => 'パスワード試行回数超過'],
    [':level' => 'ERROR', ':message' => 'データベース接続タイムアウト'],
];

foreach ($logs as $log) {
    $stmt->execute($log);
}
echo count($logs) . "件のログを登録しました";

<?php
try {
    // トランザクション開始
    $pdo->beginTransaction();

    // 送金元の残高を減らす
    $stmt = $pdo->prepare('UPDATE accounts SET balance = balance - :amount WHERE id = :id');
    $stmt->execute([':amount' => 10000, ':id' => 1]);

    // 送金先の残高を増やす
    $stmt = $pdo->prepare('UPDATE accounts SET balance = balance + :amount WHERE id = :id');
    $stmt->execute([':amount' => 10000, ':id' => 2]);

    // 送金履歴を記録
    $stmt = $pdo->prepare('INSERT INTO transfers (from_id, to_id, amount) VALUES (?, ?, ?)');
    $stmt->execute([1, 2, 10000]);

    // すべて成功したらコミット
    $pdo->commit();
    echo "送金が完了しました";

} catch (PDOException $e) {
    // エラー発生時はロールバック
    $pdo->rollBack();
    echo "送金に失敗しました: " . $e->getMessage();
}

<?php
function purchaseItem(PDO $pdo, int $userId, int $itemId, int $quantity): bool
{
    try {
        $pdo->beginTransaction();

        // 在庫数を確認（FOR UPDATEで行ロック）
        $stmt = $pdo->prepare(
            'SELECT stock FROM items WHERE id = :id FOR UPDATE'
        );
        $stmt->execute([':id' => $itemId]);
        $item = $stmt->fetch();

        if (!$item || $item['stock'] < $quantity) {
            $pdo->rollBack();
            return false;  // 在庫不足
        }

        // 在庫を減らす
        $stmt = $pdo->prepare(
            'UPDATE items SET stock = stock - :qty WHERE id = :id'
        );
        $stmt->execute([':qty' => $quantity, ':id' => $itemId]);

        // 注文レコードを作成
        $stmt = $pdo->prepare(
            'INSERT INTO orders (user_id, item_id, quantity) VALUES (?, ?, ?)'
        );
        $stmt->execute([$userId, $itemId, $quantity]);

        $pdo->commit();
        return true;

    } catch (PDOException $e) {
        $pdo->rollBack();
        throw $e;
    }
}

<?php
try {
    $pdo = new PDO($dsn, $user, $pass, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
    ]);

    $stmt = $pdo->prepare('INSERT INTO users (name, email) VALUES (?, ?)');
    $stmt->execute(['田中太郎', 'tanaka@example.com']);

} catch (PDOException $e) {
    // エラー情報を取得
    echo "エラーコード: " . $e->getCode() . "
";
    echo "エラーメッセージ: " . $e->getMessage() . "
";

    // SQLSTATE エラーコードで条件分岐
    if ($e->getCode() === '23000') {
        echo "このメールアドレスは既に登録されています";
    }
}

<?php
function getDbConnection(): PDO
{
    static $pdo = null;

    if ($pdo === null) {
        try {
            $pdo = new PDO(
                'mysql:host=localhost;dbname=myapp;charset=utf8mb4',
                'root',
                'secret',
                [
                    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
                    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                    PDO::ATTR_EMULATE_PREPARES   => false,
                ]
            );
        } catch (PDOException $e) {
            // 本番ではエラー詳細をユーザーに見せない
            error_log('DB接続エラー: ' . $e->getMessage());
            http_response_code(500);
            echo 'システムエラーが発生しました。しばらくしてからお試しください。';
            exit(1);
        }
    }

    return $pdo;
}

// 使用例
try {
    $pdo = getDbConnection();
    $users = $pdo->query('SELECT * FROM users')->fetchAll();
} catch (PDOException $e) {
    error_log('SQLエラー: ' . $e->getMessage());
    // ユーザーには汎用メッセージを表示
    echo 'データの取得に失敗しました';
}

<?php
class Database
{
    private static ?PDO $instance = null;

    public static function getInstance(): PDO
    {
        if (self::$instance === null) {
            $config = require __DIR__ . '/config/database.php';

            self::$instance = new PDO(
                $config['dsn'],
                $config['username'],
                $config['password'],
                [
                    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
                    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                    PDO::ATTR_EMULATE_PREPARES   => false,
                ]
            );
        }

        return self::$instance;
    }

    // クローンとシリアライズを禁止（シングルトン）
    private function __clone() {}
    public function __wakeup() { throw new \Exception('Cannot unserialize'); }
}

// 使い方
$pdo = Database::getInstance();
$users = $pdo->query('SELECT * FROM users')->fetchAll();