<?php

require "config.php";

function db_connect(): PDO
{
    static $pdo = null;
    if ($pdo !== null) {
        return $pdo;
    }

    try {
        $pdo = new PDO(CONFIG_DB_DSN, CONFIG_DB_USER, CONFIG_DB_PASSWORD);
    } catch (PDOException $e) {
        exit("Errore connessione database: " . $e->getMessage());
    }

    return $pdo;
}

function db_query(string $query, array $params = []): array
{
    $pdo = db_connect();

    try {
        $stmt = $pdo->prepare($query);
        $stmt->execute($params);
        return $stmt->fetchAll();
    } catch (PDOException $e) {
        exit("Errore connessione database: " . $e->getMessage());
    }
}

?>