ecrire/base/dump.php ➔ base_copier_tables()

Complexity

Conditions	53
Paths	> 20000

Size

Total Lines	162
Code Lines	107

Duplication

Lines	18
Ratio	11.11 %

Importance

Changes	2
Bugs	1	Features	0

<?php
function base_copier_tables($status_file, $tables, $serveur_source, $serveur_dest, $options=array()){

	$callback_progression = isset($options['callback_progression'])?$options['callback_progression']:'';
	$max_time = isset($options['max_time'])?$options['max_time']:0;
	$drop_source = isset($options['drop_source'])?$options['drop_source']:false;
	$no_erase_dest = isset($options['no_erase_dest'])?$options['no_erase_dest']:array();
	$where = isset($options['where'])?$options['where']:array();
	$fonction_base_inserer = isset($options['fonction_base_inserer'])?$options['fonction_base_inserer']:'inserer_copie';
	$desc_tables_dest = isset($options['desc_tables_dest'])?$options['desc_tables_dest']:array();
	$racine_fonctions = (isset($options['racine_fonctions_dest'])?$options['racine_fonctions_dest']:'base');
	$data_pool = (isset($options['data_pool'])?$options['data_pool']:50*1024);

	spip_log( "Copier ".count($tables)." tables de '$serveur_source' vers '$serveur_dest'",'dump.'._LOG_INFO_IMPORTANTE);

	if (!$inserer_copie = charger_fonction($fonction_base_inserer,$racine_fonctions, true)) {

This code seems to be duplicated across your project.

		spip_log( "Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon",'dump.'._LOG_INFO_IMPORTANTE);
		return true; // echec mais on a fini, donc true
	}
	if (!$preparer_table_dest = charger_fonction('preparer_table_dest',$racine_fonctions, true)) {

This code seems to be duplicated across your project.

		spip_log( "Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon",'dump.'._LOG_INFO_IMPORTANTE);
		return true; // echec mais on a fini, donc true
	}

	if (!lire_fichier($status_file, $status)
		OR !$status = unserialize($status))
		$status = array();
	$status['etape'] = 'basecopie';

	// puis relister les tables a importer
	// et les vider si besoin, au moment du premier passage ici
	$initialisation_copie = (!isset($status["dump_status_copie"])) ? 0 : $status["dump_status_copie"];

	// si init pas encore faite, vider les tables du serveur destination
	if (!$initialisation_copie) {
		if (!$vider_tables_destination_copie = charger_fonction('vider_tables_destination_copie',$racine_fonctions, true)) {

This code seems to be duplicated across your project.

			spip_log( "Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",'dump.'._LOG_INFO_IMPORTANTE);
			return true; // echec mais on a fini, donc true
		}
		$vider_tables_destination_copie($tables, $no_erase_dest, $serveur_dest);
		$status["dump_status_copie"]='ok';
		ecrire_fichier($status_file,serialize($status));
	}

	// les tables auteurs et meta doivent etre copiees en dernier !
	if (in_array('spip_auteurs',$tables)){
		$tables = array_diff($tables,array('spip_auteurs'));
		$tables[] = 'spip_auteurs';
	}
	if (in_array('spip_meta',$tables)){
		$tables = array_diff($tables,array('spip_meta'));
		$tables[] = 'spip_meta';
	}
	spip_log( "Tables a copier :".implode(", ",$tables),'dump.'._LOG_INFO);

	$trouver_table = charger_fonction('trouver_table','base');

	foreach ($tables as $table){
		// si table commence par spip_ c'est une table SPIP, renommer le prefixe si besoin
		// sinon chercher la vraie table
		$desc_source = false;
		if (strncmp($table,"spip_",5)==0){
			$desc_source = $trouver_table(preg_replace(",^spip_,","",$table), $serveur_source, true);
		}
		if (!$desc_source OR !isset($desc_source['exist']) OR !$desc_source['exist'])
			$desc_source = $trouver_table($table, $serveur_source, false);

		// verifier que la table est presente dans la base source
		if ($desc_source){
			// $status['tables_copiees'][$table] contient l'avancement
			// de la copie pour la $table : 0 a N et -N quand elle est finie (-1 si vide et finie...)
			if (!isset($status['tables_copiees'][$table]))
				$status['tables_copiees'][$table] = 0;

			if (is_numeric($status['tables_copiees'][$table])
				AND $status['tables_copiees'][$table]>=0
				AND $desc_dest = $preparer_table_dest(
								$table,
								isset($desc_tables_dest[$table])?$desc_tables_dest[$table]:$desc_source,
								$serveur_dest,
								$status['tables_copiees'][$table] == 0)){
				if ($callback_progression)
					$callback_progression($status['tables_copiees'][$table],0,$table);
				while (true) {
					$n = intval($status['tables_copiees'][$table]);
					// on copie par lot de 400
					$res = sql_select('*',$table,isset($where[$table])?$where[$table]:'','','',"$n,400",'',$serveur_source);
					while ($row = sql_fetch($res,$serveur_source)){
						$rows = array($row);
						// lire un groupe de donnees si demande en option
						// (permet un envoi par lot vers la destination)
						if ($data_pool>0){
							$s = strlen(serialize($row));
							while ($s<$data_pool AND $row = sql_fetch($res,$serveur_source)){
								$s += strlen(serialize($row));
								$rows[]= $row;
							}
						}
						// si l'enregistrement est deja en base, ca fera un echec ou un doublon
						// mais si ca renvoie false c'est une erreur fatale => abandon
						if ($inserer_copie($table,$rows,$desc_dest,$serveur_dest)===false) {
							// forcer la sortie, charge a l'appelant de gerer l'echec
							spip_log("Erreur fatale dans $inserer_copie table $table","dump"._LOG_ERREUR);
							$status['errors'][] = "Erreur fatale  lors de la copie de la table $table";
							ecrire_fichier($status_file,serialize($status));
							// copie finie
							return true;
						}
						$status['tables_copiees'][$table]+=count($rows);
						if ($max_time AND time()>$max_time)
							break;
					}
					if ($n == $status['tables_copiees'][$table])
						break;
					spip_log( "recopie $table ".$status['tables_copiees'][$table],'dump.'._LOG_INFO_IMPORTANTE);
					if ($callback_progression)
						$callback_progression($status['tables_copiees'][$table],0,$table);
					ecrire_fichier($status_file,serialize($status));
					if ($max_time AND time()>$max_time)
						return false; // on a pas fini, mais le temps imparti est ecoule
				}
				if ($drop_source) {
					sql_drop_table($table,'',$serveur_source);
					spip_log( "drop $table sur serveur source '$serveur_source'",'dump.'._LOG_INFO_IMPORTANTE);
				}
				$status['tables_copiees'][$table]=($status['tables_copiees'][$table]?-$status['tables_copiees'][$table]:"zero");
				ecrire_fichier($status_file,serialize($status));
				spip_log( "tables_recopiees ".implode(',',$status['tables_copiees']),'dump.'._LOG_INFO);
				if ($callback_progression)
					$callback_progression($status['tables_copiees'][$table],$status['tables_copiees'][$table],$table);
			}
			else {
				if ($status['tables_copiees'][$table]<0)
					spip_log("Table $table deja copiee : ".$status['tables_copiees'][$table],"dump."._LOG_INFO);
				if ($callback_progression)
					$callback_progression(0,$status['tables_copiees'][$table],"$table".((is_numeric($status['tables_copiees'][$table]) AND $status['tables_copiees'][$table]>=0)?"[Echec]":""));
			}
		}
		else {
			$status['errors'][] = "Impossible de lire la description de la table $table";
			ecrire_fichier($status_file,serialize($status));
			spip_log("Impossible de lire la description de la table $table","dump."._LOG_ERREUR);
		}
	}

	// si le nombre de tables envoyees n'est pas egal au nombre de tables demandees
	// abandonner
	if (count($status['tables_copiees'])<count($tables)){
		spip_log("Nombre de tables copiees incorrect : ".count($status['tables_copiees'])."/".count($tables),"dump."._LOG_ERREUR);
		$status['errors'][] = "Nombre de tables copiees incorrect : ".count($status['tables_copiees'])."/".count($tables);
		ecrire_fichier($status_file,serialize($status));
	}

	if ($detruire_copieur_si_besoin = charger_fonction('detruire_copieur_si_besoin',$racine_fonctions, true)) {

This code seems to be duplicated across your project.

		$detruire_copieur_si_besoin($serveur_dest);
	}
	else {
		spip_log( "Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.",'dump.'._LOG_INFO_IMPORTANTE);
	}

	// OK, copie complete
	return true;
}