5. PDO 데이터베이스 연동

<?php
// [보안에 극도로 취약한 레거시 쿼리 작성법]
$userEmail = $_POST['email']; // 입력값: "hacker@evil.com' OR '1'='1"

// 실제 완성되는 SQL: SELECT * FROM users WHERE email = 'hacker@evil.com' OR '1'='1';
// 이 조건식은 무조건 참('1'='1')이 되어 해커는 비밀번호 검증 없이 사이트 전체 유저 목록을 털어갈 수 있습니다.
$sql = "SELECT * FROM users WHERE email = '{$userEmail}'";
?>

<?php
declare(strict_types=1);

// 데이터베이스 접속 정보 설정
$host = '127.0.0.1';
$db   = 'my_project_db';
$user = 'db_user';
$pass = 'secret_password_123';
$charset = 'utf8mb4';

// DSN (Data Source Name) 규격 설정
$dsn = "mysql:host={$host};dbname={$db};charset={$charset}";

// PDO 작동 옵션 배열 설정
$options = [
    // 1. 에러 발생 시 예외(PDOException)를 던지도록 강제 설정
    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
    // 2. 조회 결과 데이터를 기본적으로 연관 배열('column_name' => value) 구조로 매핑해 반환
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
    // 3. 데이터베이스 드라이버 레벨에서 PreparedStatement 모방(Emulation)을 끄고 순정 prepared 기능을 가동
    PDO::ATTR_EMULATE_PREPARES   => false,
];

try {
    // PDO 인스턴스 생성 및 연결 시도
    $pdo = new PDO($dsn, $user, $pass, $options);
    echo "데이터베이스 서버 연결 성공!<br>";
} catch (PDOException $e) {
    // 연결 예외가 발생했을 때 화면에 에러 코드가 그대로 노출되는 것을 막고 안전한 로그를 기록
    error_log($e->getMessage());
    die("서버 에러가 발생했습니다. 잠시 후 다시 시도해주세요.");
}
?>

<?php
// 1. 쿼리 뼈대 사전 선언 (Placeholder :title, :content 사용)
$sql = "INSERT INTO posts (title, content, created_at) VALUES (:title, :content, NOW())";

$stmt = $pdo->prepare($sql); // 쿼리 준비

// 2. 바인딩할 파라미터 값 정의
$title = "PHP 웹개발 실무 가이드";
$content = "PDO와 Prepared Statement를 사용하면 데이터베이스를 매우 안전하게 다룰 수 있습니다.";

// 3. 파라미터 바인딩 및 최종 실행
$stmt->execute([
    'title'   => $title,
    'content' => $content
]);

// 방금 삽입된 레코드의 Auto Increment 기본키 ID 조회
$newId = $pdo->lastInsertId();
echo "성공적으로 {$newId}번 글이 추가되었습니다.<br>";
?>

<?php
// [단건 조회]
$postId = 5;
$sql = "SELECT * FROM posts WHERE id = :id";
$stmt = $pdo->prepare($sql);

$stmt->execute(['id' => $postId]);
$post = $stmt->fetch(); // 단 한 건의 레코드만 가져옵니다.

if ($post) {
    echo "제목: " . htmlspecialchars($post['title']) . "<br>";
} else {
    echo "존재하지 않는 게시글입니다.<br>";
}

// [다건 전체 조회]
$sqlAll = "SELECT * FROM posts ORDER BY id DESC";
$stmtAll = $pdo->prepare($sqlAll);
$stmtAll->execute();

$posts = $stmtAll->fetchAll(); // 전체 매칭 레코드를 배열 구조로 가져옵니다.

foreach ($posts as $row) {
    echo " - [" . $row['id'] . "] " . htmlspecialchars($row['title']) . "<br>";
}
?>

<?php
$sql = "UPDATE posts SET title = :title WHERE id = :id";
$stmt = $pdo->prepare($sql);

$stmt->execute([
    'title' => '수정된 PHP 웹개발 실무 가이드',
    'id'    => 5
]);

// 영향받은 데이터베이스 행(Row)의 개수 확인
$affectedRows = $stmt->rowCount();
echo "총 {$affectedRows}개의 레코드가 성공적으로 수정되었습니다.<br>";
?>

<?php
$sql = "DELETE FROM posts WHERE id = :id";
$stmt = $pdo->prepare($sql);

$stmt->execute(['id' => 5]);

$affectedRows = $stmt->rowCount();
echo "총 {$affectedRows}개의 레코드가 데이터베이스에서 영구 삭제되었습니다.<br>";
?>