Progetto Guidato — Creare un Forum con PHP e MySQL

CREATE TABLE categorie_forum ( id INT AUTO_INCREMENT PRIMARY KEY, nome VARCHAR(100) NOT NULL ); CREATE TABLE thread ( id INT AUTO_INCREMENT PRIMARY KEY, titolo VARCHAR(200) NOT NULL, categoria_id INT, autore_id INT, bloccato BOOLEAN DEFAULT FALSE, creato_il TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (categoria_id) REFERENCES categorie_forum(id), FOREIGN KEY (autore_id) REFERENCES utenti(id) ); CREATE TABLE risposte ( id INT AUTO_INCREMENT PRIMARY KEY, thread_id INT, autore_id INT, contenuto TEXT NOT NULL, nascosta BOOLEAN DEFAULT FALSE, creata_il TIMESTAMP DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (thread_id) REFERENCES thread(id) ); CREATE TABLE notifiche ( id INT AUTO_INCREMENT PRIMARY KEY, utente_id INT, messaggio VARCHAR(255), letta BOOLEAN DEFAULT FALSE, creata_il TIMESTAMP DEFAULT CURRENT_TIMESTAMP );

<?php $host = 'localhost'; $db = 'forum_volta'; $user = 'root'; $password = getenv('DB_PASSWORD'); try { $pdo = new PDO("mysql:host=$host;dbname=$db;charset=utf8mb4", $user, $password); $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { die("Connessione fallita: " . $e->getMessage()); } ?>

<?php require 'config.php'; echo "Connessione riuscita al database $db!"; ?>

<?php require 'config.php'; if ($_SERVER['REQUEST_METHOD'] === 'POST') { $titolo = $_POST['titolo'] ?? ''; $stmt = $pdo->prepare("INSERT INTO thread (titolo) VALUES (:titolo)"); $stmt->execute(['titolo' => $titolo]); header('Location: thread.php'); exit; } ?> <form method="post"> <input type="text" name="titolo" placeholder="Titolo del thread" required> <button type="submit">Crea thread</button> </form>

<?php require 'config.php'; $stmt = $pdo->query("SELECT id, titolo FROM thread ORDER BY creato_il DESC"); $threadList = $stmt->fetchAll(PDO::FETCH_ASSOC); ?> <h1>Discussioni</h1> <a href="nuovo_thread.php">+ Nuovo thread</a> <ul> <?php foreach ($threadList as $t): ?> <li><a href="visualizza.php?id=<?= $t['id'] ?>"><?= htmlspecialchars($t['titolo']) ?></a></li> <?php endforeach; ?> </ul>

<?php require 'config.php'; $id = (int) ($_GET['id'] ?? 0); $stmt = $pdo->prepare(" SELECT t.titolo, u.nome AS autore, c.nome AS categoria FROM thread t LEFT JOIN utenti u ON t.autore_id = u.id LEFT JOIN categorie_forum c ON t.categoria_id = c.id WHERE t.id = :id "); $stmt->execute(['id' => $id]); $thread = $stmt->fetch(PDO::FETCH_ASSOC); $stmtRisposte = $pdo->prepare(" SELECT r.contenuto, u.nome AS autore FROM risposte r LEFT JOIN utenti u ON r.autore_id = u.id WHERE r.thread_id = :id ORDER BY r.creata_il ASC "); $stmtRisposte->execute(['id' => $id]); $risposte = $stmtRisposte->fetchAll(PDO::FETCH_ASSOC); ?> <h1><?= htmlspecialchars($thread['titolo']) ?></h1> <p>Di <?= htmlspecialchars($thread['autore'] ?? 'Anonimo') ?> · <?= htmlspecialchars($thread['categoria'] ?? 'Senza categoria') ?></p> <?php foreach ($risposte as $r): ?> <p><strong><?= htmlspecialchars($r['autore'] ?? 'Anonimo') ?>:</strong> <?= nl2br(htmlspecialchars($r['contenuto'])) ?></p> <?php endforeach; ?>

<?php if ($_SERVER['REQUEST_METHOD'] === 'POST') { $contenuto = $_POST['contenuto'] ?? ''; $stmt = $pdo->prepare("INSERT INTO risposte (thread_id, contenuto) VALUES (:tid, :contenuto)"); $stmt->execute(['tid' => $id, 'contenuto' => $contenuto]); header("Location: visualizza.php?id=$id"); exit; } // ... il resto (recupero thread e risposte) resta come sopra ... ?> // ... markup del thread e delle risposte come sopra ... <form method="post"> <textarea name="contenuto" required></textarea> <button type="submit">Rispondi</button> </form>

<?php session_start(); require 'config.php'; if ($_SERVER['REQUEST_METHOD'] === 'POST') { $stmt = $pdo->prepare("SELECT * FROM utenti WHERE email = :email"); $stmt->execute(['email' => $_POST['email']]); $utente = $stmt->fetch(PDO::FETCH_ASSOC); if ($utente && password_verify($_POST['password'], $utente['password_hash'])) { $_SESSION['utente_id'] = $utente['id']; $_SESSION['ruolo'] = $utente['ruolo']; // 'admin', 'moderatore' o 'utente' header('Location: thread.php'); exit; } echo "Credenziali non valide"; } ?> <form method="post"> <input type="email" name="email" required> <input type="password" name="password" required> <button type="submit">Accedi</button> </form>

<?php session_start(); if (!isset($_SESSION['utente_id'])) { header('Location: login.php'); exit; } require 'config.php'; // nuovo_thread.php: aggiungiamo autore_id all'INSERT già visto al Passo 3 $stmt = $pdo->prepare("INSERT INTO thread (titolo, autore_id) VALUES (:titolo, :autore_id)"); $stmt->execute(['titolo' => $titolo, 'autore_id' => $_SESSION['utente_id']]); // visualizza.php: stessa aggiunta nell'INSERT delle risposte visto al Passo 4 $stmt = $pdo->prepare("INSERT INTO risposte (thread_id, contenuto, autore_id) VALUES (:tid, :contenuto, :autore_id)"); $stmt->execute(['tid' => $id, 'contenuto' => $contenuto, 'autore_id' => $_SESSION['utente_id']]); ?>

<?php session_start(); if (!isset($_SESSION['utente_id'])) { header('Location: login.php'); exit; } require 'config.php'; function puoModerare(string $ruolo): bool { return in_array($ruolo, ['admin', 'moderatore']); } if (!puoModerare($_SESSION['ruolo'])) { die("Permesso negato: solo admin o moderatori"); } if ($_SERVER['REQUEST_METHOD'] === 'POST') { if (isset($_POST['nascondi_risposta'])) { $stmt = $pdo->prepare("UPDATE risposte SET nascosta = TRUE WHERE id = :id"); $stmt->execute(['id' => $_POST['nascondi_risposta']]); } if (isset($_POST['blocca_thread'])) { $stmt = $pdo->prepare("UPDATE thread SET bloccato = TRUE WHERE id = :id"); $stmt->execute(['id' => $_POST['blocca_thread']]); } } ?>

<?php // query risposte del Passo 4, con l'aggiunta del filtro: $stmtRisposte = $pdo->prepare(" SELECT r.contenuto, u.nome AS autore FROM risposte r LEFT JOIN utenti u ON r.autore_id = u.id WHERE r.thread_id = :id AND r.nascosta = FALSE ORDER BY r.creata_il ASC "); ?>

<?php // subito dopo l'INSERT della risposta (Passo 5), aggiungiamo: $stmtThread = $pdo->prepare("SELECT autore_id, titolo FROM thread WHERE id = :id"); $stmtThread->execute(['id' => $id]); $threadInfo = $stmtThread->fetch(PDO::FETCH_ASSOC); if ($threadInfo['autore_id'] !== null) { $stmtNotifica = $pdo->prepare("INSERT INTO notifiche (utente_id, messaggio) VALUES (:uid, :msg)"); $stmtNotifica->execute([ 'uid' => $threadInfo['autore_id'], 'msg' => "Nuova risposta al tuo thread: {$threadInfo['titolo']}" ]); } ?>

<?php require 'config.php'; $stmt = $pdo->query(" SELECT t.titolo, COUNT(r.id) AS num_risposte FROM thread t LEFT JOIN risposte r ON t.id = r.thread_id GROUP BY t.titolo ORDER BY num_risposte DESC LIMIT 5 "); $popolari = $stmt->fetchAll(PDO::FETCH_ASSOC); ?>