96 lines
3.2 KiB
PHP
96 lines
3.2 KiB
PHP
<?php
|
|
/**
|
|
* Script de migration pour la table x_regions
|
|
* Transfert les données de la base source (geosector) vers la base cible (geosector_app)
|
|
*/
|
|
|
|
require_once dirname(__DIR__) . '/config.php';
|
|
|
|
try {
|
|
// Création du tunnel SSH si nécessaire
|
|
createSshTunnel();
|
|
|
|
// Connexion aux bases de données
|
|
$sourceDb = getSourceConnection();
|
|
$targetDb = getTargetConnection();
|
|
|
|
// Récupération des régions depuis la base source
|
|
$stmt = $sourceDb->query("SELECT * FROM x_regions");
|
|
$regions = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
|
|
echo "Nombre de régions à migrer: " . count($regions) . PHP_EOL;
|
|
|
|
// Préparation de la requête d'insertion
|
|
$insertQuery = "INSERT INTO x_regions (
|
|
id,
|
|
fk_pays,
|
|
libelle,
|
|
libelle_long,
|
|
table_osm,
|
|
departements,
|
|
chk_active
|
|
) VALUES (
|
|
:id,
|
|
:fk_pays,
|
|
:libelle,
|
|
:libelle_long,
|
|
:table_osm,
|
|
:departements,
|
|
:chk_active
|
|
) ON DUPLICATE KEY UPDATE
|
|
fk_pays = VALUES(fk_pays),
|
|
libelle = VALUES(libelle),
|
|
libelle_long = VALUES(libelle_long),
|
|
table_osm = VALUES(table_osm),
|
|
departements = VALUES(departements),
|
|
chk_active = VALUES(chk_active)";
|
|
|
|
$insertStmt = $targetDb->prepare($insertQuery);
|
|
|
|
// Compteurs
|
|
$successCount = 0;
|
|
$errorCount = 0;
|
|
|
|
// Traitement de chaque région
|
|
foreach ($regions as $region) {
|
|
try {
|
|
// Mappage des champs entre les deux structures
|
|
$id = isset($region['rowid']) ? $region['rowid'] : $region['id'];
|
|
$chkActive = isset($region['active']) ? $region['active'] :
|
|
(isset($region['chk_active']) ? $region['chk_active'] : 1);
|
|
|
|
// Préparation des données pour l'insertion
|
|
$regionData = [
|
|
'id' => $id,
|
|
'fk_pays' => $region['fk_pays'],
|
|
'libelle' => $region['libelle'],
|
|
'libelle_long' => $region['libelle_long'],
|
|
'table_osm' => $region['table_osm'],
|
|
'departements' => $region['departements'],
|
|
'chk_active' => $chkActive
|
|
];
|
|
|
|
// Insertion dans la base cible
|
|
$insertStmt->execute($regionData);
|
|
$successCount++;
|
|
|
|
} catch (Exception $e) {
|
|
$errorCount++;
|
|
echo "Erreur lors de la migration de la région ID {$id}: " . $e->getMessage() . PHP_EOL;
|
|
}
|
|
}
|
|
|
|
echo "Migration terminée. Succès: $successCount, Erreurs: $errorCount" . PHP_EOL;
|
|
|
|
// Fermer le tunnel SSH
|
|
closeSshTunnel();
|
|
|
|
} catch (Exception $e) {
|
|
echo "Erreur critique: " . $e->getMessage() . PHP_EOL;
|
|
|
|
// Fermer le tunnel SSH en cas d'erreur
|
|
closeSshTunnel();
|
|
|
|
exit(1);
|
|
}
|