Subversion Repositories eFlore/Projets.eflore-projets

<?php
//declare(encoding='UTF-8');
/**
 * Exemple de lancement du script : :
 * /opt/lampp/bin/php cli.php cel -a chargerTous
 *
 * @category    php 5.2
 * @package             eFlore/Scripts
 * @author              Jean-Pascal MILCENT <jpm@tela-botanica.org>
 * @copyright   Copyright (c) 2011, 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$
 */
class Tapirlink extends EfloreScript {

        public function executer() {
                try {
                        $this->initialiserProjet('tapirlink');

                        // Lancement de l'action demandée
                        $cmd = $this->getParametre('a');
                        switch ($cmd) {
                                case 'chargerTous' :
                                        $this->chargerStructureSql();
                                        $this->chargerTapirlink();
                                        break;
                                case 'supprimerTous' :
                                        $this->supprimerTous();
                                        break;
                                default :
                                        throw new Exception("Erreur : la commande '$cmd' n'existe pas!");
                        }
                } catch (Exception $e) {
                        $this->traiterErreur($e->getMessage());
                }
        }

        protected function initialiserProjet($projet) {
                $bases = $this->getListeBases();
                parent::initialiserProjet($projet);
                $this->verifierPresenceBdd($bases);
        }

        private function getListeBases() {
                $requete = "SHOW DATABASES";
                $bases = $this->getBdd()->recupererTous($requete);
                return $bases;
        }

        private function verifierPresenceBdd($bases) {
                $bddNom = Config::get('bdd_nom');
                $existe = false;
                foreach ($bases as $base) {
                        if ($base['Database'] == $bddNom) {
                                $existe = true;
                                break;
                        }
                }
                if ($existe === false) {
                        $message = "Veuillez créer la base de données '$bddNom'.";
                        throw new Exception($message);
                }
        }

        private function chargerTapirlink() {
                $tablesCodes = array_keys(Config::get('tables'));
                foreach ($tablesCodes as $code) {
                        echo "Chargement de la table : $code\n";
                        $this->chargerFichierTsvDansTable($code);
                }
        }

        private function chargerFichierTsvDansTable($code) {
                $chemin = Config::get('chemins.'.$code);
                $table = Config::get('tables.'.$code);
                $requete = "LOAD DATA INFILE '$chemin' ".
                        "REPLACE INTO TABLE $table ".
                        'CHARACTER SET utf8 '.
                        'FIELDS '.
                        "       TERMINATED BY '\t' ".
                        "       ENCLOSED BY '' ".
                        "       ESCAPED BY '\\\' ".
                        'IGNORE 1 LINES';
                $this->getBdd()->requeter($requete);
        }

        private function supprimerTous() {
                $requete = "DROP TABLE IF EXISTS raw_occurrence_record ";
                $this->getBdd()->requeter($requete);
        }
}
?>