Subversion Repositories eFlore/Projets.eflore-projets

Rev

Rev 53 | Rev 105 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
11 jpm 1 
<?php
2 
/** Exemple lancement:
22 jpm 3 
 * /opt/lampp/bin/php -d memory_limit=3500M ~/web/eflore-projets/scripts/cli.php nvjfl
28 jpm 4 
 * 		-a chargerTous
11 jpm 5 
 * Options :
28 jpm 6 
 * -t : Permet de tester le script sur un jeux réduit de données (indiquer le nombre de lignes).
11 jpm 7 
*/
79 jpm 8 
class Nvjfl extends EfloreScript {
11 jpm 9 
 
22 jpm 10 
	private $nomsIndex = array();
11 
	private $numeroIndex = 1;
12 
 
11 jpm 13 
	protected $parametres_autorises = array(
24 jpm 14 
		'-t' => array(false, true, 'Permet de tester le script sur un jeux réduit de données (indiquer le nombre de lignes).'));
11 jpm 15 
 
16 
	public function executer() {
17 
		// Lancement de l'action demandée
22 jpm 18 
		try {
79 jpm 19 
			$this->initialiserProjet('nvjfl');
24 jpm 20 
 
22 jpm 21 
			$cmd = $this->getParametre('a');
22 
		    switch ($cmd) {
24 jpm 23 
		    	case 'chargerTous' :
44 jpm 24 
		    		$this->chargerStructureSql();
24 jpm 25 
		    		$this->chargerNvjfl();
26 
		    		$this->chargerBiblio();
27 
		    		$this->chargerBiblioLien();
27 jpm 28 
		    		$this->chargerOntologies();
24 jpm 29 
		    		break;
53 jpm 30 
	    		case 'chargerStructure' :
31 
	    			$this->chargerStructureSql();
32 
	    			break;
24 jpm 33 
				case 'chargerNvjfl' :
34 
					$this->chargerNvjfl();
22 jpm 35 
					break;
24 jpm 36 
				case 'chargerBiblio' :
37 
					$this->chargerBiblio();
38 
					break;
39 
				case 'chargerBiblioLien' :
40 
					$this->chargerBiblioLien();
41 
					break;
27 jpm 42 
				case 'chargerOntologies' :
43 
					$this->chargerOntologies();
44 
					break;
22 jpm 45 
				default :
79 jpm 46 
					throw new Exception("Erreur : la commande '$cmd' n'existe pas!");
22 jpm 47 
			}
48 
		} catch (Exception $e) {
49 
			$this->traiterErreur($e->getMessage());
11 jpm 50 
		}
51 
    }
24 jpm 52 
 
22 jpm 53 
    /**
24 jpm 54 
     * Charge le fichier en créant un id pour chaque nom vernaculaire.
22 jpm 55 
     */
24 jpm 56 
	private function chargerNvjfl() {
57 
		//Debug::printr(Config::get('fichiers'));
58 
		$fichierOuvert = $this->ouvrirFichier(Config::get('chemins.nvjfl'));
22 jpm 59 
		$donnees = $this->analyserFichier($fichierOuvert);
60 
		fclose($fichierOuvert);
61 
		foreach ($donnees as $donnee) {
24 jpm 62 
			$requete = 'INSERT INTO '.Config::get('tables.nvjfl').' VALUES ('.implode(', ', $donnee).')';
79 jpm 63 
			$this->getBdd()->requeter($requete);
11 jpm 64 
 
22 jpm 65 
			$this->afficherAvancement("Insertion des noms vernaculaires dans la base de données");
79 jpm 66 
			if ($this->stopperLaBoucle($this->getParametre('t'))) {
22 jpm 67 
				break;
68 
			}
69 
		}
70 
		echo "\n";
71 
	}
72 
 
73 
	private function analyserFichier($fichierOuvert) {
74 
		$donnees = array();
75 
		$entetesCsv = fgets($fichierOuvert);
76 
		while ($ligneCsv = fgets($fichierOuvert)) {
77 
			$champs = explode("\t", trim($ligneCsv));
24 jpm 78 
			if (count($champs) > 0) {
79 
				$nomVernaculaire = $champs[2];
80 
				$indexCourrant = $this->getIndexNomVernaculaire($nomVernaculaire);
81 
				$champs = array_merge(array($indexCourrant), $champs);
82 
				$donnees[] = $this->protegerValeursDesChamps($champs);
83 
			}
22 jpm 84 
			$this->afficherAvancement("Analyse du fichier des noms vernaculaires");
85 
			if ($this->stopperLaBoucle()) {
86 
				break;
87 
			}
88 
		}
89 
		echo "\n";
90 
		return $donnees;
91 
	}
92 
 
93 
	private function getIndexNomVernaculaire($nomVernaculaire) {
94 
		$indexCourrant = null;
95 
		if (array_key_exists($nomVernaculaire, $this->nomsIndex) == false) {
96 
			$this->nomsIndex[$nomVernaculaire] = $this->numeroIndex++;
97 
		}
98 
		$indexCourrant = $this->nomsIndex[$nomVernaculaire];
99 
		return $indexCourrant;
100 
	}
101 
 
102 
	private function ouvrirFichier($chemin) {
103 
		$fichierOuvert = false;
104 
		if ($chemin) {
105 
			if (file_exists($chemin) === true) {
106 
				$fichierOuvert = fopen($chemin, 'r');
107 
				if ($fichierOuvert == false) {
108 
					throw new Exception("Le fichier $chemin n'a pas pu être ouvert.");
11 jpm 109 
				}
110 
			} else {
22 jpm 111 
				throw new Exception("Le fichier $chemin est introuvable.");
11 jpm 112 
			}
22 jpm 113 
		} else {
114 
			throw new Exception("Aucun chemin de fichier n'a été fourni.");
11 jpm 115 
		}
22 jpm 116 
		return $fichierOuvert;
11 jpm 117 
	}
22 jpm 118 
 
119 
	private function protegerValeursDesChamps($champs) {
120 
		$champsProteges = array();
121 
		for ($i = 0; $i < 9; $i++) {
122 
			$valeur = isset($champs[$i]) ? $champs[$i] : '';
79 jpm 123 
			$champsProteges[] = $this->getBdd()->proteger($valeur);
22 jpm 124 
		}
125 
		return $champsProteges;
126 
	}
24 jpm 127 
 
128 
	private function chargerBiblio() {
129 
		$cheminsNvjflBiblio = Config::get('chemins.nvjflBiblio');
130 
		$tableNvjflBiblio = Config::get('tables.nvjflBiblio');
131 
		$requete = "LOAD DATA INFILE '$cheminsNvjflBiblio' ".
132 
			"REPLACE INTO TABLE $tableNvjflBiblio ".
133 
			'CHARACTER SET utf8 '.
134 
			'FIELDS '.
135 
			"	TERMINATED BY '\t' ".
136 
			"	ENCLOSED BY '' ".
137 
			"	ESCAPED BY '\\\' ".
138 
			'IGNORE 1 LINES';
79 jpm 139 
		$this->getBdd()->requeter($requete);
24 jpm 140 
	}
141 
 
142 
	private function chargerBiblioLien() {
143 
		$cheminNvjflLienBiblio = Config::get('chemins.nvjflLienBiblio');
144 
		$tableNvjflLienBiblio = Config::get('tables.nvjflLienBiblio');
145 
		$requete = "LOAD DATA INFILE '$cheminNvjflLienBiblio' ".
146 
			"REPLACE INTO TABLE $tableNvjflLienBiblio ".
147 
			'CHARACTER SET utf8 '.
148 
			'FIELDS '.
149 
			"	TERMINATED BY '\t' ".
150 
			"	ENCLOSED BY '' ".
151 
			"	ESCAPED BY '\\\' ".
152 
			'IGNORE 1 LINES';
79 jpm 153 
		$this->getBdd()->requeter($requete);
24 jpm 154 
	}
27 jpm 155 
 
156 
	private function chargerOntologies() {
157 
		$cheminOntologies = Config::get('chemins.ontologies');
158 
		$tableOntologies = Config::get('tables.ontologies');
159 
		$requete = "LOAD DATA INFILE '$cheminOntologies' ".
160 
				"REPLACE INTO TABLE $tableOntologies ".
161 
				'CHARACTER SET utf8 '.
162 
				'FIELDS '.
163 
				"	TERMINATED BY '\t' ".
164 
				"	ENCLOSED BY '' ".
165 
				"	ESCAPED BY '\\\' ".
166 
				'IGNORE 1 LINES';
79 jpm 167 
		$this->getBdd()->requeter($requete);
27 jpm 168 
	}
11 jpm 169 
}
170 
?>