Belajar Backend Development: Koneksi Database MySQL dengan PDO

TL;DR (Ringkasan Eksekutif)

• Standar Modern: PDO adalah antarmuka wajib di PHP 8.x untuk berinteraksi dengan basis data.
• Anti SQL-Injection: Mengamankan data Anda secara otomatis menggunakan Native Prepared Statements.
• Multi-Database: Beralih antara MySQL, PostgreSQL, SQLite, dll., hanya dengan mengganti variabel DSN.
• Skala Enterprise: Mendukung transaksi berantai (ACID) via beginTransaction() dan koneksi persisten untuk optimasi memori.

Glosarium Mikro (Definisi Istilah Teknis)

DSN (Data Source Name)

Format teks yang menyimpan instruksi arah (alamat host, nama database, driver, dan port) agar program tahu lokasi server basis data Anda.

ACID (Atomicity, Consistency, Isolation, Durability)

Empat pilar properti sakral dalam transaksi basis data tingkat Enterprise. Intinya: Jika satu proses pengisian data gagal, seluruh rangkaian proses sebelumnya harus digagalkan (Rollback) agar tidak ada data yang tercatat setengah-setengah.

<?php
$host = '127.0.0.1';
$db   = 'infokoding_pgdb';
$user = 'postgres';
$pass = 'rahasia123';
$port = '5432';

// 1. Cukup ubah awalan driver dari 'mysql:' menjadi 'pgsql:' di parameter DSN
$dsn = "pgsql:host=$host;port=$port;dbname=$db";

$options = [
    PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
];

try {
    $pdo = new PDO($dsn, $user, $pass, $options);
    echo "Tautan ke PostgreSQL berhasil dilakukan secara mulus!";
} catch (\PDOException $e) {
    die("Error Koneksi PGSQL: " . $e->getMessage());
}
?>

DB_HOST=127.0.0.1
DB_NAME=infokoding_db
DB_USER=root
DB_PASS=SandiSuperRahasia!123

<?php
// Mengambil kredensial dari environment system (.env)
$host = $_ENV['DB_HOST'] ?? '127.0.0.1';
$db   = $_ENV['DB_NAME'];
$user = $_ENV['DB_USER'];
$pass = $_ENV['DB_PASS'];
$charset = 'utf8mb4';

$dsn = "mysql:host=$host;dbname=$db;charset=$charset";
$options = [
    PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION, // Melemparkan exception jika gagal
    PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,       // Menarik data dalam bentuk array asosiatif
    PDO::ATTR_EMULATE_PREPARES   => false,                  // Mengamankan dari tipe SQL injection tingkat lanjut
    PDO::ATTR_PERSISTENT         => true                    // [Opsional] Menyalakan sesi persisten
];

try {
    $pdo = new PDO($dsn, $user, $pass, $options);
    echo "Penghubung database berhasil diinisiasi secara aman!";
} catch (\PDOException $e) {
    // PENTING: Jangan mengekspos variabel $e->getMessage() di production!
    throw new \PDOException($e->getMessage(), (int)$e->getCode());
}
?>

$options = [
    PDO::ATTR_ERRMODE                      => PDO::ERRMODE_EXCEPTION,
    PDO::MYSQL_ATTR_SSL_KEY                => '/path/to/client-key.pem',
    PDO::MYSQL_ATTR_SSL_CERT               => '/path/to/client-cert.pem',
    PDO::MYSQL_ATTR_SSL_CA                 => '/path/to/ca-cert.pem',
    PDO::MYSQL_ATTR_SSL_VERIFY_SERVER_CERT => false // Disarankan set 'true' jika CA valid
];

// 1. Siapkan kueri dengan Named Parameters (:status, :limit)
$sql = "SELECT id, nama, email FROM users WHERE status = :status ORDER BY created_at DESC LIMIT :limit";
$stmt = $pdo->prepare($sql);

// 2. Eksekusi kueri dengan memetakan array asosiatif (binding data)
// Nilai PDO::PARAM_INT / STR bisa dikonfigurasi otomatis di background
$stmt->execute([
    ':status' => 'aktif',
    ':limit'  => 10
]);

// 3. Ambil seluruh baris hasil kueri
$users = $stmt->fetchAll();

foreach ($users as $row) {
    echo $row['nama'] . " - " . $row['email'] . "<br>";
}

try {
    // 1. Kunci database dan mulai sesi transaksi
    $pdo->beginTransaction();

    // 2. Eksekusi Kueri A (Memotong saldo rekening pengirim)
    $stmt1 = $pdo->prepare("UPDATE rekening SET saldo = saldo - 50000 WHERE user_id = :sender");
    $stmt1->execute([':sender' => 12]);

    // 3. Eksekusi Kueri B (Menambah saldo rekening penerima)
    $stmt2 = $pdo->prepare("UPDATE rekening SET saldo = saldo + 50000 WHERE user_id = :receiver");
    $stmt2->execute([':receiver' => 45]);

    // 4. Jika kedua kueri berhasil tanpa melempar Exception, simpan permanen
    $pdo->commit();
    echo "Transfer uang berhasil diproses secara atomik!";

} catch (\PDOException $e) {
    // 5. Jika terjadi error sistem di tengah jalan, batalkan (rollback) Kueri A yang terlanjur berjalan!
    $pdo->rollBack();
    echo "Transfer gagal diproses. Saldo uang telah dikembalikan utuh. Error: " . $e->getMessage();
}

// 1. Hancurkan statement terlebih dahulu jika ada
$stmt = null;

// 2. Hancurkan variabel koneksi induk PDO
$pdo = null; 

• [PDOException 2002] Connection refused: Apa penyebabnya dan bagaimana cara mengatasinya?
  Masalah ini terjadi karena server basis data MySQL Anda mati, atau penulisan IP/Port host salah. Solusinya, periksa status service MySQL (misalnya dengan systemctl status mysql) dan pastikan baris variabel DB_HOST beserta DB_PORT di file konfigurasi .env ditulis dengan benar.
• [PDOException 1045] Access denied for user: Mengapa otentikasi saya ditolak?
  Otentikasi ditolak karena Username atau Password basis data yang Anda masukkan tidak cocok. Periksa kembali kecocokan antara variabel DB_USER dan DB_PASS, serta pastikan tidak ada karakter spasi siluman yang tak sengaja tertulis di bagian belakang isi file .env Anda.
• [PDOException 1049] Unknown database: Apa yang harus saya lakukan jika menemui error ini?
  Error ini menandakan bahwa kredensial akses berhasil menembus server, tetapi nama tabel/database tidak ditemukan. Solusinya, Anda wajib menciptakan database tersebut terlebih dahulu menggunakan phpMyAdmin atau menjalankan instruksi eksekusi SQL mentah CREATE DATABASE nama_db; sebelum skrip aplikasi PHP dijalankan.

<?php
/**
 * PHP PDO Master Boilerplate (Production Ready)
 * Menggunakan Arsitektur Kelas Singleton
 * 
 * @author Rusmawan Abdullah Sani
 * @link   https://github.com/admininfokoding/php-docker-boilerplate
 */
class Database {
    // Properti penyimpan memori instansi koneksi tunggal
    private static $instance = null;
    
    // Properti wadah antarmuka PDO yang sesungguhnya
    private $pdo;

    // Konstruktor dilarang (private) untuk mencegah pemanggilan "new Database()" dari luar kelas!
    private function __construct() {
        $host    = '127.0.0.1';
        $db      = 'nama_database_anda';
        $user    = 'root';
        $pass    = 'password_super_rahasia';
        $port    = '3306';
        $charset = 'utf8mb4';

        // Merangkai DSN (Data Source Name)
        $dsn = "mysql:host=$host;port=$port;dbname=$db;charset=$charset";
        
        // Parameter Keamanan & Ketangguhan Standar Master
        $options = [
            PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION, // Menyalakan interupsi peringatan bahaya (Exception)
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,       // Menarik data dalam format Array Kolom (mudah dibaca)
            PDO::ATTR_EMULATE_PREPARES   => false,                  // Menolak kueri pura-pura (Memblokir total SQL Injection tingkat atas)
            PDO::ATTR_PERSISTENT         => true,                   // Memperbolehkan sesi koneksi berkelanjutan untuk server lalu-lintas padat
        ];

        try {
            // Memicu koneksi pertama
            $this->pdo = new PDO($dsn, $user, $pass, $options);
        } catch (\PDOException $e) {
            // Pada level Production (server nyata yang dipakai pelanggan), error dilarang tampil di layar!
            // Error wajib dikirim diam-diam ke log server agar peretas tak bisa melihatnya.
            error_log("GAGAL KONEK DB: " . $e->getMessage());
            
            // Melempar pesan error sederhana untuk konsumsi mata pengguna
            throw new \PDOException("Terjadi masalah sistem saat menghubungi brankas data. Mohon kembali nanti.", (int)$e->getCode());
        }
    }

    /**
     * Memanggil Fungsi Pintu Akses Instansi Tunggal (Singleton)
     */
    public static function getInstance() {
        // Jika antarmuka belum pernah dibuat di memori, buat sekarang (Lazy Loading)
        if (self::$instance === null) {
            self::$instance = new self();
        }
        return self::$instance;
    }

    /**
     * Mengembalikan objek PDO bersih yang sudah terhubung siap pakai
     */
    public function getConnection() {
        return $this->pdo;
    }
}

/* =========================================
   CARA PENGGUNAAN DI DALAM SKRIP PROYEK ANDA
   ========================================= */

// 1. Meminta koneksi (meskipun dipanggil berkali-kali, sistem tetap membatasi hanya 1 koneksi MySQL!)
// $db = Database::getInstance()->getConnection();

// 2. Tinggal tarik data Anda secara aman:
// $stmt = $db->query("SELECT * FROM tabel_pengguna");
// $pengguna = $stmt->fetchAll();
// print_r($pengguna);