95 lines
3.2 KiB
PHP
95 lines
3.2 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
// Import Script für tippspiel2027
|
||
|
|
// Dieses Skript verbindet sich mit einer alten Datenbank (wo der Live-Dump importiert wurde)
|
||
|
|
// und kopiert die relevanten Daten in die neue tippspiel2027 Datenbank.
|
||
|
|
// Tote Features wie "Spieler Ligen" und "grünes Trikot" werden ignoriert.
|
||
|
|
|
||
|
|
$host = getenv('DB_HOST') ?: '127.0.0.1';
|
||
|
|
$user = getenv('DB_USER') ?: 'root';
|
||
|
|
$pass = getenv('DB_PASS') ?: '';
|
||
|
|
$oldDbName = getenv('DB_OLD_NAME') ?: 'tippspiel_legacy';
|
||
|
|
$newDbName = getenv('DB_NEW_NAME') ?: 'tippspiel2027';
|
||
|
|
|
||
|
|
try {
|
||
|
|
$pdo = new PDO("mysql:host=$host;charset=utf8mb4", $user, $pass);
|
||
|
|
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
|
||
|
|
|
||
|
|
echo "Erstelle neue Datenbank $newDbName falls nicht vorhanden...\n";
|
||
|
|
$pdo->exec("CREATE DATABASE IF NOT EXISTS `$newDbName` DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci");
|
||
|
|
|
||
|
|
// Neues Schema laden
|
||
|
|
$pdo->exec("USE `$newDbName`");
|
||
|
|
$schema = file_get_contents(__DIR__ . '/schema.sql');
|
||
|
|
if ($schema) {
|
||
|
|
$pdo->exec($schema);
|
||
|
|
echo "Neues Schema erfolgreich in $newDbName angelegt.\n";
|
||
|
|
} else {
|
||
|
|
die("Fehler: schema.sql nicht gefunden.\n");
|
||
|
|
}
|
||
|
|
|
||
|
|
echo "Starte Import von $oldDbName nach $newDbName...\n";
|
||
|
|
|
||
|
|
$tablesToMigrate = [
|
||
|
|
'users',
|
||
|
|
'settings',
|
||
|
|
'seasons',
|
||
|
|
'rounds',
|
||
|
|
'games',
|
||
|
|
'tipps',
|
||
|
|
'payments',
|
||
|
|
'quotas',
|
||
|
|
'roundmails',
|
||
|
|
'manual_payouts'
|
||
|
|
];
|
||
|
|
|
||
|
|
foreach ($tablesToMigrate as $table) {
|
||
|
|
echo "Migriere Tabelle: $table...\n";
|
||
|
|
|
||
|
|
// Prüfen, ob Tabelle in der alten DB existiert
|
||
|
|
$tableExists = $pdo->query("SELECT 1 FROM information_schema.tables WHERE table_schema = '$oldDbName' AND table_name = '$table'")->fetchColumn();
|
||
|
|
if (!$tableExists) {
|
||
|
|
echo " Überspringe $table, existiert in $oldDbName nicht.\n";
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Leeren der neuen Tabelle
|
||
|
|
$pdo->exec("TRUNCATE TABLE `$newDbName`.`$table`");
|
||
|
|
|
||
|
|
// Alle Daten aus alter DB holen
|
||
|
|
$rows = $pdo->query("SELECT * FROM `$oldDbName`.`$table`")->fetchAll(PDO::FETCH_ASSOC);
|
||
|
|
if (count($rows) === 0) {
|
||
|
|
echo " Keine Daten in $table.\n";
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Holen der Spalten der NEUEN Tabelle (um Legacy Felder zu ignorieren)
|
||
|
|
$newColsStmt = $pdo->query("DESCRIBE `$newDbName`.`$table`");
|
||
|
|
$newCols = $newColsStmt->fetchAll(PDO::FETCH_COLUMN);
|
||
|
|
|
||
|
|
$inserted = 0;
|
||
|
|
foreach ($rows as $row) {
|
||
|
|
$filteredRow = [];
|
||
|
|
foreach ($newCols as $col) {
|
||
|
|
if (array_key_exists($col, $row)) {
|
||
|
|
$filteredRow[$col] = $row[$col];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!empty($filteredRow)) {
|
||
|
|
$cols = '`' . implode('`, `', array_keys($filteredRow)) . '`';
|
||
|
|
$vals = implode(', ', array_fill(0, count($filteredRow), '?'));
|
||
|
|
$stmt = $pdo->prepare("INSERT INTO `$newDbName`.`$table` ($cols) VALUES ($vals)");
|
||
|
|
$stmt->execute(array_values($filteredRow));
|
||
|
|
$inserted++;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
echo " $inserted Einträge migriert.\n";
|
||
|
|
}
|
||
|
|
|
||
|
|
echo "Import erfolgreich abgeschlossen!\n";
|
||
|
|
|
||
|
|
} catch (PDOException $e) {
|
||
|
|
die("Datenbankfehler: " . $e->getMessage() . "\n");
|
||
|
|
}
|