<?php
/**
 * Database configuration for mcifa.com
 * Aurora MySQL cluster with read/write endpoints
 */
require_once '/home/banners/public_html/bway/db/mysql_bootstrap.php';

define('DB_WRITE_HOST', 'amazonaurora.cluster-cemzxojvmybt.us-east-1.rds.amazonaws.com');
define('DB_READ_HOST', 'amazonaurora.cluster-ro-cemzxojvmybt.us-east-1.rds.amazonaws.com');
define('DB_USER', 'admin');
define('DB_PASS', 'xxatN6Lb8Kbwb9MiU1At');

// Datasource to database name mapping
$dsn_map = [
    'mcifawb'  => 'banners_mcifa',
    'mcifawb2' => 'banners_mcifa',
];

// Singleton PDO connections
$_pdo_connections = [];

function getDbConnection($datasource = 'mcifawb', $write = false) {
    global $dsn_map, $_pdo_connections;

    $dbName = $dsn_map[$datasource] ?? 'banners_mcifa';
    $host = $write ? DB_WRITE_HOST : DB_READ_HOST;
    $key = $host . '/' . $dbName;

    if (!isset($_pdo_connections[$key])) {
        $_pdo_connections[$key] = new PDO(
            "mysql:host={$host};dbname={$dbName};charset=utf8mb4",
            DB_USER,
            DB_PASS,
            mysqlPdoOptions([
                PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                PDO::ATTR_EMULATE_PREPARES   => false,
                PDO::ATTR_CASE               => PDO::CASE_LOWER,
            ])
        );
    }

    return $_pdo_connections[$key];
}

function getWriteDb($datasource = 'mcifawb') {
    return getDbConnection($datasource, true);
}

function getReadDb($datasource = 'mcifawb') {
    return getDbConnection($datasource, false);
}