nis2-agile/scripts/migrate-a4.php

<?php
/**
 * NIS2 Agile - Runner migrazioni A4 (modello relazionale: organigramma RACI, skill,
 * scadenziario, ...). Applica i file SQL di A4 usando la STESSA connessione PDO
 * dell'app (config/database.php), cosi da colpire il DB realmente servito da
 * php-fpm, NON il DB secondario del container.
 *
 * USO (sull'host, con la connessione dell'app):
 *   docker exec nis2-app php /var/www/nis2-agile/scripts/migrate-a4.php
 *
 * Idempotente: le migrazioni usano CREATE TABLE IF NOT EXISTS.
 * Sola lettura/additivo su tabelle esistenti: NON modifica nessuna tabella
 * preesistente. Stesso pattern di scripts/migrate-isms.php.
 */

require_once __DIR__ . '/../application/config/config.php';
require_once __DIR__ . '/../application/config/database.php';

$files = [
    __DIR__ . '/../docs/sql/041_org_roles.sql',   // Fase 4.1 — organigramma
    __DIR__ . '/../docs/sql/042_competences.sql', // Fase 4.2 — competenze
    // Le fasi 4.3-4.5 aggiungeranno qui i rispettivi file (043, ...).
];

$pdo = Database::getInstance();
$totalStmts = 0;

foreach ($files as $file) {
    if (!is_readable($file)) {
        fwrite(STDERR, "[migrate-a4] File non leggibile: $file\n");
        exit(1);
    }
    $sql = (string) file_get_contents($file);

    // Rimuove i commenti "--" (riga intera E in coda): un commento puo contenere
    // ';' e spezzerebbe lo split. Le migrazioni non usano '--' dentro valori.
    $lines = preg_split('/\r?\n/', $sql);
    $clean = [];
    foreach ($lines as $l) {
        $pos = strpos($l, '--');
        if ($pos !== false) {
            $l = substr($l, 0, $pos);
        }
        if (trim($l) === '') {
            continue;
        }
        $clean[] = $l;
    }
    $sql = implode("\n", $clean);

    // Split semplice su ';' (nessun DELIMITER / stored procedure in questi file).
    $statements = array_filter(array_map('trim', explode(';', $sql)), fn($s) => $s !== '');

    echo "== " . basename($file) . " (" . count($statements) . " statement) ==\n";
    foreach ($statements as $stmt) {
        try {
            $pdo->exec($stmt);
            $totalStmts++;
        } catch (PDOException $e) {
            $head = substr(preg_replace('/\s+/', ' ', $stmt), 0, 80);
            fwrite(STDERR, "[ERRORE] su \"$head...\": " . $e->getMessage() . "\n");
            exit(1);
        }
    }
}

echo "\n[OK] Eseguiti $totalStmts statement.\n";

// Verifica rapida: tabella org_roles (4.1) e le 4 tabelle competenze (4.2).
$cols = $pdo->query("SHOW COLUMNS FROM org_roles")->fetchAll(PDO::FETCH_COLUMN, 0);
$expected = ['id','organization_id','role_name','parent_role_id','holder_user_id','is_governance_body','description','sort_order','created_by','created_at','updated_at'];
$missing = array_diff($expected, $cols);
if ($missing) {
    fwrite(STDERR, "[ATTENZIONE] org_roles colonne mancanti: " . implode(', ', $missing) . "\n");
    exit(1);
}
echo "[OK] org_roles pronta (A4 Fase 4.1).\n";

foreach (['skills','role_skills','user_skills','skill_course_map'] as $t) {
    $c = $pdo->query("SHOW COLUMNS FROM `$t`")->fetchAll(PDO::FETCH_COLUMN, 0);
    if (!$c) {
        fwrite(STDERR, "[ATTENZIONE] tabella mancante: $t\n");
        exit(1);
    }
    echo "[OK] $t pronta (" . count($c) . " colonne).\n";
}
echo "[OK] Competenze pronte (A4 Fase 4.2).\n";