2,22 → 2,25 |
// declare(encoding='UTF-8'); |
/** |
* Script de migration des Mots Clés de la version 1 de la base de données du CEL à la v2. |
* Utilisation : /opt/lampp/bin/php cli.php MigrationMotsCles |
* |
* @category php 5.2 |
* @package Cel/Scripts |
* @author Aurélien PERONNET <aurelien@tela-botanica.org> |
* @author Aurelien PERONNET <aurelien@tela-botanica.org> |
* @author Jean-Pascal MILCENT <jpm@tela-botanica.org> |
* @copyright Copyright (c) 2012, Tela Botanica (accueil@tela-botanica.org) |
* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL |
* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL |
* @version $Id$ |
* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL |
* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL |
* @version $Id$ |
*/ |
class MigrationMotsCles extends Cel { |
class MigrationMotsCles { |
|
const SEPARATEUR_MOT_CLE_TEXTE = ','; |
const truncate = true; //Doit on vider les tables de destination ? |
const dry_run = false; |
|
private $bdd = null; |
private $script = null; |
private $nouvellesTables = array('cel_mots_cles_obs', 'cel_mots_cles_images', 'cel_images_mots_cles', 'cel_obs_mots_cles'); |
public static $bdd_cel_migration; |
public static $bdd_utilisateurs; |
29,30 → 32,34 |
*/ |
private static $avancement = array(); |
|
/** |
* Méthode appelée avec une requête de type GET. |
*/ |
public function getElement($params) { |
if (!isset($this->config['database_cel']['database_migration']) || $this->config['database_cel']['database_migration'] == '') { |
public function __construct(Conteneur $conteneur) { |
$bddMigration = $conteneur->getParametre('database_cel.database_migration'); |
if ($bddMigration == null || $bddMigration == '') { |
echo 'Attention la variable de configuration database_migration dans la section database_cel, contenant la base de données d\'arrivée, doit être remplie '."\n"; |
exit; |
} |
|
if (!isset($this->config['database_ident']['database']) || $this->config['database_ident']['database'] == '') { |
$bddIdentification = $conteneur->getParametre('database_ident.database'); |
if ($bddIdentification == null || $bddIdentification == '') { |
echo 'Attention la variable de configuration database dans la section database_ident, contenant la base de données utilisateurs, doit être remplie '."\n"; |
exit; |
} |
|
self::$bdd_cel_migration = $this->config['database_cel']['database_migration']; |
self::$bdd_utilisateurs = $this->config['database_ident']['database']; |
self::$bdd_cel_migration = $conteneur->getParametre('database_cel.database_migration'); |
self::$bdd_utilisateurs = $conteneur->getParametre('database_ident.database'); |
$this->bdd = $conteneur->getBdd(); |
$this->script = $conteneur->getScript(); |
} |
|
/** |
* Méthode appelée pour executer le script. |
*/ |
public function executer($params) { |
echo "--MIGRATION DES MOTS CLES --------------------------------------\n"; |
if (self::truncate) { |
echo "-------------------------------------------------------------------\n"; |
echo " ETAPE 0. Vider les tables ... \n\n"; |
echo " ETAPE 0. Vider les tables ... \n"; |
echo "-------------------------------------------------------------------\n"; |
$this->viderTables(); |
echo "---------------------------------------------------------------- OK\n"; |
} |
|
echo "-------------------------------------------------------------------\n"; |
59,20 → 66,18 |
echo " ETAPE 1. Paramétrage ... \n"; |
echo "-------------------------------------------------------------------\n"; |
$this->getUtilisateurs(); |
echo "\n"."\n"."\n"; |
|
echo "-------------------------------------------------------------------\n"; |
echo " ETAPE 2. Migration des mots clés ... \n"; |
echo "-------------------------------------------------------------------\n"; |
$this->migrerTableMotsClesObs(); |
echo "\n---------------------------------------------------------------- OK\n"; |
$this->migrerTableMotsClesImages(); |
echo "\n"."\n"."\n"; |
|
echo "-------------------------------------------------------------------\n"; |
echo " ETAPE 3. Migration des liaisons mots clés ... \n"; |
echo "-------------------------------------------------------------------\n"; |
$this->migrerLiaisonsMotsClesObs(); |
$this->migrerLiaisonsMotsClesImages(); |
echo "\n"."\n"."\n"; |
|
echo "-------------------------------------------------------------------\n"; |
echo " ETAPE 4. Génération des index des mots clés ... \n"; |
80,7 → 85,6 |
$this->genererIndexTexteMotsClesObs(); |
$this->genererIndexTexteMotsClesImages(); |
$this->mettreANullMotsClesTxtVide(); |
echo "\n"."\n"."\n"; |
} |
|
private function viderTables() { |
87,18 → 91,18 |
foreach ($this->nouvellesTables as $nomTable) { |
echo 'Vider la table '.$nomTable.'...'; |
$requete = 'TRUNCATE TABLE '.self::$bdd_cel_migration.'.'.$nomTable; |
$resultat = $this->executerRequete($requete); |
$resultat = $this->bdd->executer($requete); |
echo "ok \n"; |
} |
} |
|
public function executerRequeteSimple($requete) { |
private function executerRequeteSimple($requete) { |
// Fonction de commodité pour afficher les requetes au lieu de les executer |
if (self::dry_run) { |
echo str_replace('),','),'."\n", $requete); |
return true; |
} else { |
return parent::executerRequeteSimple($requete); |
return $this->bdd->executer($requete); |
} |
|
} |
105,19 → 109,17 |
|
|
private function getUtilisateurs() { |
echo "\n-------------------------------------------------------------------\n"; |
echo "--SELECTION DES UTILISATEURS---------------------------------------\n\n"; |
echo "SELECTION DES UTILISATEURS\n"; |
|
$requete = 'SELECT U_ID as id, U_MAIL as mail, U_NAME as nom, U_SURNAME as prenom, U_PASSWD as pass '. |
'FROM '.self::$bdd_utilisateurs.'.annuaire_tela'; |
$tableau_utilisateurs = $this->executerRequete($requete); |
$tableau_utilisateurs = $this->bdd->requeter($requete); |
|
foreach( $tableau_utilisateurs as &$utilisateur) { |
$this->tableau_utilisateurs[$utilisateur['mail']] = $utilisateur; |
} |
|
echo sizeof($this->tableau_utilisateurs)." utilisateurs sélectionnés"; |
echo "\n-----------------------------------------------------------------OK\n"; |
echo count($this->tableau_utilisateurs)." utilisateurs sélectionnés \n"; |
} |
|
private function migrerTableMotsClesObs() { |
129,19 → 131,19 |
} |
|
private function migrerTableMotsCles($image_ou_obs) { |
echo "--MIGRATION DES MOTS CLES $image_ou_obs ---------------------------------\n"; |
echo "MIGRATION DES MOTS CLES $image_ou_obs\n"; |
$pas = 1; |
|
//limite des mots clés |
$requeteNbMotsCles = 'SELECT count(*) as nb FROM cel_mots_cles_'.$image_ou_obs; |
$resultatNbMotsCles = $this->executerRequete($requeteNbMotsCles); |
$nbMotsCles = (int) $resultatNbMotsCles[0]['nb']; |
$nbMotsCles = (int) $this->bdd->requeter($requeteNbMotsCles, Bdd::SQL_RETOUR_COLONNE); |
|
for ($i = 0; $i < $nbMotsCles; $i += $pas) { |
$requete = 'SELECT * '. |
'FROM cel_mots_cles_'.$image_ou_obs.' '. |
'ORDER BY cmc_niveau '. |
"LIMIT $i,$pas "; |
$arbres_mots_cles = $this->executerRequete($requete); |
$arbres_mots_cles = $this->bdd->requeter($requete); |
|
if (count($arbres_mots_cles) > 0) { |
$champ_parent = ($image_ou_obs == "obs") ? 'ce_mot_cle_obs_parent' : 'ce_mot_cle_image_parent'; |
161,53 → 163,25 |
if (!$migration) { |
echo "La migration des mots cles $image_ou_obs a échoué ! "."\n"; |
} else { |
$this->afficherAvancement("Migration des mots clés $image_ou_obs (par $pas)"); |
$this->script->afficherAvancement("Migration des mots clés $image_ou_obs (par $pas)"); |
} |
} |
} |
echo "\n"; |
} |
|
/** |
* Utiliser cette méthode dans une boucle pour afficher un message suivi du nombre de tour de boucle effectué. |
* Vous devrez vous même gérer le retour à la ligne à la sortie de la boucle. |
* |
* @param string le message d'information. |
* @param int le nombre de départ à afficher. |
* @return void le message est affiché dans la console. |
*/ |
protected function afficherAvancement($message, $depart = 0) { |
if (! isset(self::$avancement[$message])) { |
self::$avancement[$message] = $depart; |
echo "$message : "; |
|
$actuel =& self::$avancement[$message]; |
echo $actuel++; |
} else { |
$actuel =& self::$avancement[$message]; |
|
// Cas du passage de 99 (= 2 caractères) à 100 (= 3 caractères) |
$passage = 0; |
if (strlen((string) ($actuel - 1)) < strlen((string) ($actuel))) { |
$passage = 1; |
} |
|
echo str_repeat(chr(8), (strlen((string) $actuel) - $passage)); |
echo $actuel++; |
} |
} |
|
private function construireSousRequeteInsertionArbresMotsCles($prefixe, $ligne) { |
$id_proprietaire_mot_cle = $ligne[$prefixe.'id_proprietaire']; |
$id_proprietaire_mot_cle = $this->renvoyerIdPourMigration($id_proprietaire_mot_cle); |
|
$sous_requete = '('.$this->proteger($ligne[$prefixe.'id_mot_cle_utilisateur']).','. |
$this->proteger($id_proprietaire_mot_cle).','. |
$this->proteger($ligne[$prefixe.'mot_cle']).','. |
$this->proteger($ligne[$prefixe.'id_mot_cle_general']).','. |
$this->proteger($ligne[$prefixe.'bg']).','. |
$this->proteger($ligne[$prefixe.'bd']).','. |
$this->proteger($ligne[$prefixe.'niveau']).','. |
$this->proteger($ligne[$prefixe.'id_parent']). |
$sous_requete = '('.$this->bdd->proteger($ligne[$prefixe.'id_mot_cle_utilisateur']).','. |
$this->bdd->proteger($id_proprietaire_mot_cle).','. |
$this->bdd->proteger($ligne[$prefixe.'mot_cle']).','. |
$this->bdd->proteger($ligne[$prefixe.'id_mot_cle_general']).','. |
$this->bdd->proteger($ligne[$prefixe.'bg']).','. |
$this->bdd->proteger($ligne[$prefixe.'bd']).','. |
$this->bdd->proteger($ligne[$prefixe.'niveau']).','. |
$this->bdd->proteger($ligne[$prefixe.'id_parent']). |
')'; |
return $sous_requete; |
} |
229,9 → 203,9 |
return $retour; |
} |
|
public function mailValide($mail) { |
private function mailValide($mail) { |
// vérification bidon mais ça suffit pour ici |
return !(strpos('@',$mail) === false); |
return !(strpos($mail, '@') === false); |
} |
|
private function migrerLiaisonsMotsClesObs() { |
242,7 → 216,7 |
' AND mots_cles != "null" '. |
' AND mots_cles IS NOT NULL '. |
'ORDER BY identifiant '; |
$mots_cles_obs = $this->executerRequete($requete); |
$mots_cles_obs = $this->bdd->requeter($requete); |
|
$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_obs_mots_cles '. |
'(id_observation, id_mot_cle_obs, id_utilisateur) '. |
253,7 → 227,7 |
if (!$insertion) { |
echo 'La migration des mots cles obs a échoué ! '."\n"; |
} else { |
echo "Migration des mots cles obs : OK\n\n"; |
echo "Migration des mots cles obs : OK\n"; |
} |
} |
|
265,7 → 239,7 |
' AND ci_meta_mots_cles != "null" '. |
' AND ci_meta_mots_cles IS NOT NULL '. |
'ORDER BY ci_ce_utilisateur'; |
$mots_cles_images = $this->executerRequete($requete); |
$mots_cles_images = $this->bdd->requeter($requete); |
|
$requete = 'INSERT INTO '.self::$bdd_cel_migration.'.cel_images_mots_cles '. |
'(id_image, id_mot_cle_image, id_utilisateur) '. |
277,7 → 251,7 |
if (!$insertion) { |
echo 'La migration des mots cles images a échoué ! '."\n"; |
} else { |
echo "Migration des mots cles images : OK\n\n"; |
echo "Migration des mots cles images : OK\n"; |
} |
} |
|
286,9 → 260,9 |
foreach ($tableau_mots_cles as $element) { |
$mots_cles_ids = $this->parserMotsCles($element['mots_cles'], $separateur); |
foreach ($mots_cles_ids as $mot_cle_id) { |
$id = $this->proteger($element['id']); |
$id_mot_cle = $this->proteger($mot_cle_id); |
$id_utilisateur = $this->proteger($this->renvoyerIdPourMigration($element['id_utilisateur'])); |
$id = $this->bdd->proteger($element['id']); |
$id_mot_cle = $this->bdd->proteger($mot_cle_id); |
$id_utilisateur = $this->bdd->proteger($this->renvoyerIdPourMigration($element['id_utilisateur'])); |
$sous_requete[] = "($id, $id_mot_cle, $id_utilisateur)"; |
} |
} |
335,7 → 309,7 |
private function genererIndexTexteMotsClesObs() { |
$requete = 'SELECT DISTINCT id_observation, id_utilisateur '. |
'FROM '.self::$bdd_cel_migration.'.cel_obs_mots_cles '; |
$obs_a_mots_cles = $this->requeter($requete); |
$obs_a_mots_cles = $this->bdd->requeter($requete); |
|
foreach ($obs_a_mots_cles as $obs) { |
$mots_cles_texte = $this->obtenirMotsClesTexte($obs['id_observation'], $obs['id_utilisateur'], 'obs'); |
342,16 → 316,16 |
if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) { |
$mots_cles_texte_chaine = implode(',', $mots_cles_texte); |
$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine, $obs['id_observation'], $obs['id_utilisateur'], 'obs'); |
$this->afficherAvancement('Génération des index mots clés obs (par 1)'); |
$this->script->afficherAvancement('Génération des index mots clés obs (par 1)'); |
} |
} |
echo "\n-----------------------------------------------------------------OK\n"; |
echo "\n"; |
} |
|
private function genererIndexTexteMotsClesImages() { |
$requete = 'SELECT DISTINCT id_image, id_utilisateur '. |
'FROM '.self::$bdd_cel_migration.'.cel_images_mots_cles '; |
$images_a_mots_cles = $this->requeter($requete); |
$images_a_mots_cles = $this->bdd->requeter($requete); |
|
foreach ($images_a_mots_cles as $image) { |
$mots_cles_texte = $this->obtenirMotsClesTexte($image['id_image'], $image['id_utilisateur'], 'images'); |
359,10 → 333,10 |
if (is_array($mots_cles_texte) && count($mots_cles_texte) > 0) { |
$mots_cles_texte_chaine = implode(',', $mots_cles_texte); |
$mise_a_jour_index = $this->executerRequeteMiseAJourMotCleTexte($mots_cles_texte_chaine, $image['id_image'], $image['id_utilisateur'], 'images'); |
$this->afficherAvancement('Génération des index mots clés images (par 1)'); |
$this->script->afficherAvancement('Génération des index mots clés images (par 1)'); |
} |
} |
echo "\n-----------------------------------------------------------------OK\n"; |
echo "\n"; |
} |
|
private function obtenirMotsClesTexte($id_image_ou_obs, $id_utilisateur, $mode) { |
369,8 → 343,8 |
$bdd = self::$bdd_cel_migration; |
$champ_id_mot_cle = ($mode == 'obs') ? 'id_mot_cle_obs' : 'id_mot_cle_image'; |
$champ_id_obs_ou_img = ($mode == 'obs') ? 'id_observation' : 'id_image'; |
$id_image_ou_obs = $this->proteger($id_image_ou_obs); |
$id_utilisateur = $this->proteger($id_utilisateur); |
$id_image_ou_obs = $this->bdd->proteger($id_image_ou_obs); |
$id_utilisateur = $this->bdd->proteger($id_utilisateur); |
|
$requete = 'SELECT mot_cle '. |
"FROM $bdd.cel_mots_cles_$mode AS a ". |
378,7 → 352,7 |
" ON (a.$champ_id_mot_cle = b.$champ_id_mot_cle AND a.id_utilisateur = b.id_utilisateur) ". |
"WHERE b.$champ_id_obs_ou_img = $id_image_ou_obs ". |
" AND a.id_utilisateur = $id_utilisateur "; |
$resultats = $this->requeter($requete); |
$resultats = $this->bdd->requeter($requete); |
|
$mots_cles = array(); |
foreach ($resultats as $resultat) { |
392,16 → 366,16 |
$bdd = self::$bdd_cel_migration; |
$table = ($mode_image_ou_obs == 'obs') ? 'cel_obs' : 'cel_images'; |
$chp_id_obs_ou_img = ($mode_image_ou_obs == 'obs') ? 'id_observation' : 'id_image'; |
$id_image_ou_obs = $this->proteger($id_image_ou_obs); |
$mots_cles_texte = $this->proteger($mots_cles_texte_chaine); |
$ce_utilisateur = $this->proteger($id_utilisateur); |
$id_image_ou_obs = $this->bdd->proteger($id_image_ou_obs); |
$mots_cles_texte = $this->bdd->proteger($mots_cles_texte_chaine); |
$ce_utilisateur = $this->bdd->proteger($id_utilisateur); |
|
$requete = "UPDATE $bdd.$table ". |
"SET mots_cles_texte = $mots_cles_texte ". |
"WHERE $chp_id_obs_ou_img = $id_image_ou_obs ". |
" AND ce_utilisateur = $id_utilisateur "; |
" AND ce_utilisateur = $ce_utilisateur "; |
|
return $this->executer($requete); |
return $this->bdd->executer($requete); |
} |
|
private function mettreANullMotsClesTxtVide() { |
412,7 → 386,7 |
$requete = "UPDATE $bdd.$table ". |
'SET mots_cles_texte = NULL '. |
"WHERE mots_cles_texte = '' "; |
$this->executer($requete); |
$this->bdd->executer($requete); |
} |
} |
} |