Completed
Push — master ( 05da1d...9a9099 )
by cam
01:15
created
ecrire/inc/simplexml_to_array.php 2 patches
Indentation   +61 added lines, -61 removed lines patch added patch discarded remove patch
@@ -11,7 +11,7 @@  discard block
 block discarded – undo
11 11
 \***************************************************************************/
12 12
 
13 13
 if (!defined('_ECRIRE_INC_VERSION')) {
14
-	return;
14
+    return;
15 15
 }
16 16
 
17 17
 
@@ -23,12 +23,12 @@  discard block
 block discarded – undo
23 23
  * @return array
24 24
  */
25 25
 function inc_simplexml_to_array_dist($u, $utiliser_namespace = false) {
26
-	// decoder la chaine en SimpleXML si pas deja fait
27
-	if (is_string($u)) {
28
-		$u = simplexml_load_string($u);
29
-	}
26
+    // decoder la chaine en SimpleXML si pas deja fait
27
+    if (is_string($u)) {
28
+        $u = simplexml_load_string($u);
29
+    }
30 30
 
31
-	return array('root' => @xmlObjToArr($u, $utiliser_namespace));
31
+    return array('root' => @xmlObjToArr($u, $utiliser_namespace));
32 32
 }
33 33
 
34 34
 
@@ -43,66 +43,66 @@  discard block
 block discarded – undo
43 43
  **/
44 44
 function xmlObjToArr($obj, $utiliser_namespace = false) {
45 45
 
46
-	$tableau = array();
46
+    $tableau = array();
47 47
 
48
-	// Cette fonction getDocNamespaces() est longue sur de gros xml. On permet donc
49
-	// de l'activer ou pas suivant le contenu supposé du XML
50
-	if (is_object($obj)) {
51
-		if (is_array($utiliser_namespace)) {
52
-			$namespace = $utiliser_namespace;
53
-		} else {
54
-			if ($utiliser_namespace) {
55
-				$namespace = $obj->getDocNamespaces(true);
56
-			}
57
-			$namespace[null] = null;
58
-		}
48
+    // Cette fonction getDocNamespaces() est longue sur de gros xml. On permet donc
49
+    // de l'activer ou pas suivant le contenu supposé du XML
50
+    if (is_object($obj)) {
51
+        if (is_array($utiliser_namespace)) {
52
+            $namespace = $utiliser_namespace;
53
+        } else {
54
+            if ($utiliser_namespace) {
55
+                $namespace = $obj->getDocNamespaces(true);
56
+            }
57
+            $namespace[null] = null;
58
+        }
59 59
 
60
-		$name = strtolower((string)$obj->getName());
61
-		$text = trim((string)$obj);
62
-		if (strlen($text) <= 0) {
63
-			$text = null;
64
-		}
60
+        $name = strtolower((string)$obj->getName());
61
+        $text = trim((string)$obj);
62
+        if (strlen($text) <= 0) {
63
+            $text = null;
64
+        }
65 65
 
66
-		$children = array();
67
-		$attributes = array();
66
+        $children = array();
67
+        $attributes = array();
68 68
 
69
-		// get info for all namespaces
70
-		foreach ($namespace as $ns => $nsUrl) {
71
-			// attributes
72
-			$objAttributes = $obj->attributes($ns, true);
73
-			foreach ($objAttributes as $attributeName => $attributeValue) {
74
-				$attribName = strtolower(trim((string)$attributeName));
75
-				$attribVal = trim((string)$attributeValue);
76
-				if (!empty($ns)) {
77
-					$attribName = $ns . ':' . $attribName;
78
-				}
79
-				$attributes[$attribName] = $attribVal;
80
-			}
69
+        // get info for all namespaces
70
+        foreach ($namespace as $ns => $nsUrl) {
71
+            // attributes
72
+            $objAttributes = $obj->attributes($ns, true);
73
+            foreach ($objAttributes as $attributeName => $attributeValue) {
74
+                $attribName = strtolower(trim((string)$attributeName));
75
+                $attribVal = trim((string)$attributeValue);
76
+                if (!empty($ns)) {
77
+                    $attribName = $ns . ':' . $attribName;
78
+                }
79
+                $attributes[$attribName] = $attribVal;
80
+            }
81 81
 
82
-			// children
83
-			$objChildren = $obj->children($ns, true);
84
-			foreach ($objChildren as $childName => $child) {
85
-				$childName = strtolower((string)$childName);
86
-				if (!empty($ns)) {
87
-					$childName = $ns . ':' . $childName;
88
-				}
89
-				$children[$childName][] = xmlObjToArr($child, $namespace);
90
-			}
91
-		}
82
+            // children
83
+            $objChildren = $obj->children($ns, true);
84
+            foreach ($objChildren as $childName => $child) {
85
+                $childName = strtolower((string)$childName);
86
+                if (!empty($ns)) {
87
+                    $childName = $ns . ':' . $childName;
88
+                }
89
+                $children[$childName][] = xmlObjToArr($child, $namespace);
90
+            }
91
+        }
92 92
 
93
-		$tableau = array(
94
-			'name' => $name,
95
-		);
96
-		if ($text) {
97
-			$tableau['text'] = $text;
98
-		}
99
-		if ($attributes) {
100
-			$tableau['attributes'] = $attributes;
101
-		}
102
-		if ($children) {
103
-			$tableau['children'] = $children;
104
-		}
105
-	}
93
+        $tableau = array(
94
+            'name' => $name,
95
+        );
96
+        if ($text) {
97
+            $tableau['text'] = $text;
98
+        }
99
+        if ($attributes) {
100
+            $tableau['attributes'] = $attributes;
101
+        }
102
+        if ($children) {
103
+            $tableau['children'] = $children;
104
+        }
105
+    }
106 106
 
107
-	return $tableau;
107
+    return $tableau;
108 108
 }
Please login to merge, or discard this patch.
Spacing   +7 added lines, -7 removed lines patch added patch discarded remove patch
@@ -57,8 +57,8 @@  discard block
 block discarded – undo
57 57
 			$namespace[null] = null;
58 58
 		}
59 59
 
60
-		$name = strtolower((string)$obj->getName());
61
-		$text = trim((string)$obj);
60
+		$name = strtolower((string) $obj->getName());
61
+		$text = trim((string) $obj);
62 62
 		if (strlen($text) <= 0) {
63 63
 			$text = null;
64 64
 		}
@@ -71,10 +71,10 @@  discard block
 block discarded – undo
71 71
 			// attributes
72 72
 			$objAttributes = $obj->attributes($ns, true);
73 73
 			foreach ($objAttributes as $attributeName => $attributeValue) {
74
-				$attribName = strtolower(trim((string)$attributeName));
75
-				$attribVal = trim((string)$attributeValue);
74
+				$attribName = strtolower(trim((string) $attributeName));
75
+				$attribVal = trim((string) $attributeValue);
76 76
 				if (!empty($ns)) {
77
-					$attribName = $ns . ':' . $attribName;
77
+					$attribName = $ns.':'.$attribName;
78 78
 				}
79 79
 				$attributes[$attribName] = $attribVal;
80 80
 			}
@@ -82,9 +82,9 @@  discard block
 block discarded – undo
82 82
 			// children
83 83
 			$objChildren = $obj->children($ns, true);
84 84
 			foreach ($objChildren as $childName => $child) {
85
-				$childName = strtolower((string)$childName);
85
+				$childName = strtolower((string) $childName);
86 86
 				if (!empty($ns)) {
87
-					$childName = $ns . ':' . $childName;
87
+					$childName = $ns.':'.$childName;
88 88
 				}
89 89
 				$children[$childName][] = xmlObjToArr($child, $namespace);
90 90
 			}
Please login to merge, or discard this patch.
ecrire/inc/precharger_article.php 1 patch
Indentation   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -17,7 +17,7 @@  discard block
 block discarded – undo
17 17
  **/
18 18
 
19 19
 if (!defined('_ECRIRE_INC_VERSION')) {
20
-	return;
20
+    return;
21 21
 }
22 22
 
23 23
 include_spip('inc/precharger_objet');
@@ -39,7 +39,7 @@  discard block
 block discarded – undo
39 39
  *     Couples clés / valeurs des champs du formulaire à charger.
40 40
  **/
41 41
 function inc_precharger_article_dist($id_article, $id_rubrique = 0, $lier_trad = 0) {
42
-	return precharger_objet('article', $id_article, $id_rubrique, $lier_trad, 'titre');
42
+    return precharger_objet('article', $id_article, $id_rubrique, $lier_trad, 'titre');
43 43
 }
44 44
 
45 45
 
@@ -60,5 +60,5 @@  discard block
 block discarded – undo
60 60
  *     Couples clés / valeurs des champs du formulaire à charger
61 61
  **/
62 62
 function inc_precharger_traduction_article_dist($id_article, $id_rubrique = 0, $lier_trad = 0) {
63
-	return precharger_traduction_objet('article', $id_article, $id_rubrique, $lier_trad, 'titre');
63
+    return precharger_traduction_objet('article', $id_article, $id_rubrique, $lier_trad, 'titre');
64 64
 }
Please login to merge, or discard this patch.
ecrire/inc/lister_objets.php 2 patches
Indentation   +21 added lines, -21 removed lines patch added patch discarded remove patch
@@ -17,7 +17,7 @@  discard block
 block discarded – undo
17 17
  **/
18 18
 
19 19
 if (!defined('_ECRIRE_INC_VERSION')) {
20
-	return;
20
+    return;
21 21
 }
22 22
 
23 23
 
@@ -39,29 +39,29 @@  discard block
 block discarded – undo
39 39
  *     Code HTML de la liste
40 40
  */
41 41
 function inc_lister_objets_dist($vue, $contexte = array(), $force = false) {
42
-	$res = ""; // debug
43
-	if (!is_array($contexte)) {
44
-		return _L('$contexte doit etre un tableau dans inc/lister_objets');
45
-	}
42
+    $res = ""; // debug
43
+    if (!is_array($contexte)) {
44
+        return _L('$contexte doit etre un tableau dans inc/lister_objets');
45
+    }
46 46
 
47
-	$fond = "prive/objets/liste/$vue";
48
-	if (!find_in_path($fond . "." . _EXTENSION_SQUELETTES)) {
49
-		// traiter les cas particuliers
50
-		include_spip('base/connect_sql');
51
-		$vue = table_objet($vue);
52
-		$fond = "prive/objets/liste/$vue";
53
-		if (!find_in_path($fond . "." . _EXTENSION_SQUELETTES)) {
54
-			return _L("vue $vue introuvable pour lister les objets");
55
-		}
56
-	}
47
+    $fond = "prive/objets/liste/$vue";
48
+    if (!find_in_path($fond . "." . _EXTENSION_SQUELETTES)) {
49
+        // traiter les cas particuliers
50
+        include_spip('base/connect_sql');
51
+        $vue = table_objet($vue);
52
+        $fond = "prive/objets/liste/$vue";
53
+        if (!find_in_path($fond . "." . _EXTENSION_SQUELETTES)) {
54
+            return _L("vue $vue introuvable pour lister les objets");
55
+        }
56
+    }
57 57
 
58 58
 
59
-	$contexte['sinon'] = ($force ? $contexte['titre'] : '');
59
+    $contexte['sinon'] = ($force ? $contexte['titre'] : '');
60 60
 
61
-	$res = recuperer_fond($fond, $contexte, array('ajax' => true));
62
-	if (_request('var_liste')) {
63
-		echo var_export($contexte, true);
64
-	}
61
+    $res = recuperer_fond($fond, $contexte, array('ajax' => true));
62
+    if (_request('var_liste')) {
63
+        echo var_export($contexte, true);
64
+    }
65 65
 
66
-	return $res;
66
+    return $res;
67 67
 }
Please login to merge, or discard this patch.
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -45,12 +45,12 @@
 block discarded – undo
45 45
 	}
46 46
 
47 47
 	$fond = "prive/objets/liste/$vue";
48
-	if (!find_in_path($fond . "." . _EXTENSION_SQUELETTES)) {
48
+	if (!find_in_path($fond."."._EXTENSION_SQUELETTES)) {
49 49
 		// traiter les cas particuliers
50 50
 		include_spip('base/connect_sql');
51 51
 		$vue = table_objet($vue);
52 52
 		$fond = "prive/objets/liste/$vue";
53
-		if (!find_in_path($fond . "." . _EXTENSION_SQUELETTES)) {
53
+		if (!find_in_path($fond."."._EXTENSION_SQUELETTES)) {
54 54
 			return _L("vue $vue introuvable pour lister les objets");
55 55
 		}
56 56
 	}
Please login to merge, or discard this patch.
ecrire/base/connect_sql.php 2 patches
Spacing   +11 added lines, -12 removed lines patch added patch discarded remove patch
@@ -18,7 +18,7 @@  discard block
 block discarded – undo
18 18
 if (!defined('_ECRIRE_INC_VERSION')) {
19 19
 	return;
20 20
 }
21
-require_once _ROOT_RESTREINT . 'base/objets.php';
21
+require_once _ROOT_RESTREINT.'base/objets.php';
22 22
 
23 23
 
24 24
 /**
@@ -59,7 +59,7 @@  discard block
 block discarded – undo
59 59
 		$f = (!preg_match('/^[\w\.]*$/', $serveur))
60 60
 			? '' // nom de serveur mal ecrit
61 61
 			: ($serveur ?
62
-				(_DIR_CONNECT . $serveur . '.php') // serveur externe
62
+				(_DIR_CONNECT.$serveur.'.php') // serveur externe
63 63
 				: (_FILE_CONNECT ? _FILE_CONNECT // serveur principal ok
64 64
 					: ($install ? _FILE_CONNECT_TMP // init du serveur principal
65 65
 						: ''))); // installation pas faite
@@ -102,9 +102,9 @@  discard block
 block discarded – undo
102 102
 	// chargement de la version du jeu de fonctions
103 103
 	// si pas dans le fichier par defaut
104 104
 	$type = $GLOBALS['db_ok']['type'];
105
-	$jeu = 'spip_' . $type . '_functions_' . $version;
105
+	$jeu = 'spip_'.$type.'_functions_'.$version;
106 106
 	if (!isset($GLOBALS[$jeu])) {
107
-		if (!find_in_path($type . '_' . $version . '.php', 'req/', true)) {
107
+		if (!find_in_path($type.'_'.$version.'.php', 'req/', true)) {
108 108
 			spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS);
109 109
 
110 110
 			// ne plus reessayer
@@ -165,9 +165,9 @@  discard block
 block discarded – undo
165 165
 	$connexion = spip_connect($serveur);
166 166
 	$e = sql_errno($serveur);
167 167
 	$t = (isset($connexion['type']) ? $connexion['type'] : 'sql');
168
-	$m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim($connexion['last']);
169
-	$f = $t . $serveur;
170
-	spip_log($m, $f . '.' . _LOG_ERREUR);
168
+	$m = "Erreur $e de $t: ".sql_error($serveur)."\nin ".sql_error_backtrace()."\n".trim($connexion['last']);
169
+	$f = $t.$serveur;
170
+	spip_log($m, $f.'.'._LOG_ERREUR);
171 171
 }
172 172
 
173 173
 /**
@@ -249,7 +249,7 @@  discard block
 block discarded – undo
249 249
 	// si en cours d'installation ou si db=@test@ on ne pose rien
250 250
 	// car c'est un test de connexion
251 251
 	if (!defined('_ECRIRE_INSTALL') and $db !== "@test@") {
252
-		$f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
252
+		$f = _DIR_TMP.$type.'.'.substr(md5($host.$port.$db), 0, 8).'.out';
253 253
 	} elseif ($db == '@test@') {
254 254
 		$db = '';
255 255
 	}
@@ -289,7 +289,7 @@  discard block
 block discarded – undo
289 289
 	// En cas d'indisponibilite du serveur, eviter de le bombarder
290 290
 	if ($f) {
291 291
 		@touch($f);
292
-		spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
292
+		spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type.'.'._LOG_HS);
293 293
 	}
294 294
 }
295 295
 
@@ -379,8 +379,7 @@  discard block
 block discarded – undo
379 379
  * @return string Valeur échappée.
380 380
  **/
381 381
 function _q($a) {
382
-	return (is_numeric($a)) ? strval($a) :
383
-		(!is_array($a) ? ("'" . addslashes($a) . "'")
382
+	return (is_numeric($a)) ? strval($a) : (!is_array($a) ? ("'".addslashes($a)."'")
384 383
 			: join(",", array_map('_q', $a)));
385 384
 }
386 385
 
@@ -452,7 +451,7 @@  discard block
 block discarded – undo
452 451
 				break;
453 452
 			default:
454 453
 				$replace = range(1, count($textes));
455
-				$replace = '%' . implode('$s,%', $replace) . '$s';
454
+				$replace = '%'.implode('$s,%', $replace).'$s';
456 455
 				$replace = explode(',', $replace);
457 456
 				break;
458 457
 		}
Please login to merge, or discard this patch.
Indentation   +296 added lines, -296 removed lines patch added patch discarded remove patch
@@ -16,7 +16,7 @@  discard block
 block discarded – undo
16 16
  * @package SPIP\Core\SQL
17 17
  **/
18 18
 if (!defined('_ECRIRE_INC_VERSION')) {
19
-	return;
19
+    return;
20 20
 }
21 21
 require_once _ROOT_RESTREINT . 'base/objets.php';
22 22
 
@@ -42,118 +42,118 @@  discard block
 block discarded – undo
42 42
  **/
43 43
 function spip_connect($serveur = '', $version = '') {
44 44
 
45
-	$serveur = !is_string($serveur) ? '' : strtolower($serveur);
46
-	$index = $serveur ? $serveur : 0;
47
-	if (!$version) {
48
-		$version = $GLOBALS['spip_sql_version'];
49
-	}
50
-	if (isset($GLOBALS['connexions'][$index][$version])) {
51
-		return $GLOBALS['connexions'][$index];
52
-	}
53
-
54
-	include_spip('base/abstract_sql');
55
-	$install = (_request('exec') == 'install');
56
-
57
-	// Premiere connexion ?
58
-	if (!($old = isset($GLOBALS['connexions'][$index]))) {
59
-		$f = (!preg_match('/^[\w\.]*$/', $serveur))
60
-			? '' // nom de serveur mal ecrit
61
-			: ($serveur ?
62
-				(_DIR_CONNECT . $serveur . '.php') // serveur externe
63
-				: (_FILE_CONNECT ? _FILE_CONNECT // serveur principal ok
64
-					: ($install ? _FILE_CONNECT_TMP // init du serveur principal
65
-						: ''))); // installation pas faite
66
-
67
-		unset($GLOBALS['db_ok']);
68
-		unset($GLOBALS['spip_connect_version']);
69
-		if ($f) {
70
-			if (is_readable($f)) {
71
-				include($f);
72
-			} elseif ($serveur and !$install) {
73
-				// chercher une declaration de serveur dans le path
74
-				// qui pourra un jour servir a declarer des bases sqlite
75
-				// par des plugins. Et sert aussi aux boucles POUR.
76
-				find_in_path("$serveur.php", 'connect/', true);
77
-			}
78
-		}
79
-		if (!isset($GLOBALS['db_ok'])) {
80
-			// fera mieux la prochaine fois
81
-			if ($install) {
82
-				return false;
83
-			}
84
-			if ($f and is_readable($f)) {
85
-				spip_log("spip_connect: fichier de connexion '$f' OK.", _LOG_INFO_IMPORTANTE);
86
-			} else {
87
-				spip_log("spip_connect: fichier de connexion '$f' non trouve", _LOG_INFO_IMPORTANTE);
88
-			}
89
-			spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.", _LOG_HS);
90
-
91
-			// ne plus reessayer si ce n'est pas l'install
92
-			return $GLOBALS['connexions'][$index] = false;
93
-		}
94
-		$GLOBALS['connexions'][$index] = $GLOBALS['db_ok'];
95
-	}
96
-	// si la connexion a deja ete tentee mais a echoue, le dire!
97
-	if (!$GLOBALS['connexions'][$index]) {
98
-		return false;
99
-	}
100
-
101
-	// la connexion a reussi ou etait deja faite.
102
-	// chargement de la version du jeu de fonctions
103
-	// si pas dans le fichier par defaut
104
-	$type = $GLOBALS['db_ok']['type'];
105
-	$jeu = 'spip_' . $type . '_functions_' . $version;
106
-	if (!isset($GLOBALS[$jeu])) {
107
-		if (!find_in_path($type . '_' . $version . '.php', 'req/', true)) {
108
-			spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS);
109
-
110
-			// ne plus reessayer
111
-			return $GLOBALS['connexions'][$index][$version] = array();
112
-		}
113
-	}
114
-	$GLOBALS['connexions'][$index][$version] = $GLOBALS[$jeu];
115
-	if ($old) {
116
-		return $GLOBALS['connexions'][$index];
117
-	}
118
-
119
-	$GLOBALS['connexions'][$index]['spip_connect_version'] = isset($GLOBALS['spip_connect_version']) ? $GLOBALS['spip_connect_version'] : 0;
120
-
121
-	// initialisation de l'alphabet utilise dans les connexions SQL
122
-	// si l'installation l'a determine.
123
-	// Celui du serveur principal l'impose aux serveurs secondaires
124
-	// s'ils le connaissent
125
-
126
-	if (!$serveur) {
127
-		$charset = spip_connect_main($GLOBALS[$jeu], $GLOBALS['db_ok']['charset']);
128
-		if (!$charset) {
129
-			unset($GLOBALS['connexions'][$index]);
130
-			spip_log("spip_connect: absence de charset", _LOG_AVERTISSEMENT);
131
-
132
-			return false;
133
-		}
134
-	} else {
135
-		if ($GLOBALS['db_ok']['charset']) {
136
-			$charset = $GLOBALS['db_ok']['charset'];
137
-		}
138
-		// spip_meta n'existe pas toujours dans la base
139
-		// C'est le cas d'un dump sqlite par exemple 
140
-		elseif ($GLOBALS['connexions'][$index]['spip_connect_version']
141
-			and sql_showtable('spip_meta', true, $serveur)
142
-			and $r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'", '', '', '', '', $serveur)
143
-		) {
144
-			$charset = $r;
145
-		} else {
146
-			$charset = -1;
147
-		}
148
-	}
149
-	if ($charset != -1) {
150
-		$f = $GLOBALS[$jeu]['set_charset'];
151
-		if (function_exists($f)) {
152
-			$f($charset, $serveur);
153
-		}
154
-	}
155
-
156
-	return $GLOBALS['connexions'][$index];
45
+    $serveur = !is_string($serveur) ? '' : strtolower($serveur);
46
+    $index = $serveur ? $serveur : 0;
47
+    if (!$version) {
48
+        $version = $GLOBALS['spip_sql_version'];
49
+    }
50
+    if (isset($GLOBALS['connexions'][$index][$version])) {
51
+        return $GLOBALS['connexions'][$index];
52
+    }
53
+
54
+    include_spip('base/abstract_sql');
55
+    $install = (_request('exec') == 'install');
56
+
57
+    // Premiere connexion ?
58
+    if (!($old = isset($GLOBALS['connexions'][$index]))) {
59
+        $f = (!preg_match('/^[\w\.]*$/', $serveur))
60
+            ? '' // nom de serveur mal ecrit
61
+            : ($serveur ?
62
+                (_DIR_CONNECT . $serveur . '.php') // serveur externe
63
+                : (_FILE_CONNECT ? _FILE_CONNECT // serveur principal ok
64
+                    : ($install ? _FILE_CONNECT_TMP // init du serveur principal
65
+                        : ''))); // installation pas faite
66
+
67
+        unset($GLOBALS['db_ok']);
68
+        unset($GLOBALS['spip_connect_version']);
69
+        if ($f) {
70
+            if (is_readable($f)) {
71
+                include($f);
72
+            } elseif ($serveur and !$install) {
73
+                // chercher une declaration de serveur dans le path
74
+                // qui pourra un jour servir a declarer des bases sqlite
75
+                // par des plugins. Et sert aussi aux boucles POUR.
76
+                find_in_path("$serveur.php", 'connect/', true);
77
+            }
78
+        }
79
+        if (!isset($GLOBALS['db_ok'])) {
80
+            // fera mieux la prochaine fois
81
+            if ($install) {
82
+                return false;
83
+            }
84
+            if ($f and is_readable($f)) {
85
+                spip_log("spip_connect: fichier de connexion '$f' OK.", _LOG_INFO_IMPORTANTE);
86
+            } else {
87
+                spip_log("spip_connect: fichier de connexion '$f' non trouve", _LOG_INFO_IMPORTANTE);
88
+            }
89
+            spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.", _LOG_HS);
90
+
91
+            // ne plus reessayer si ce n'est pas l'install
92
+            return $GLOBALS['connexions'][$index] = false;
93
+        }
94
+        $GLOBALS['connexions'][$index] = $GLOBALS['db_ok'];
95
+    }
96
+    // si la connexion a deja ete tentee mais a echoue, le dire!
97
+    if (!$GLOBALS['connexions'][$index]) {
98
+        return false;
99
+    }
100
+
101
+    // la connexion a reussi ou etait deja faite.
102
+    // chargement de la version du jeu de fonctions
103
+    // si pas dans le fichier par defaut
104
+    $type = $GLOBALS['db_ok']['type'];
105
+    $jeu = 'spip_' . $type . '_functions_' . $version;
106
+    if (!isset($GLOBALS[$jeu])) {
107
+        if (!find_in_path($type . '_' . $version . '.php', 'req/', true)) {
108
+            spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS);
109
+
110
+            // ne plus reessayer
111
+            return $GLOBALS['connexions'][$index][$version] = array();
112
+        }
113
+    }
114
+    $GLOBALS['connexions'][$index][$version] = $GLOBALS[$jeu];
115
+    if ($old) {
116
+        return $GLOBALS['connexions'][$index];
117
+    }
118
+
119
+    $GLOBALS['connexions'][$index]['spip_connect_version'] = isset($GLOBALS['spip_connect_version']) ? $GLOBALS['spip_connect_version'] : 0;
120
+
121
+    // initialisation de l'alphabet utilise dans les connexions SQL
122
+    // si l'installation l'a determine.
123
+    // Celui du serveur principal l'impose aux serveurs secondaires
124
+    // s'ils le connaissent
125
+
126
+    if (!$serveur) {
127
+        $charset = spip_connect_main($GLOBALS[$jeu], $GLOBALS['db_ok']['charset']);
128
+        if (!$charset) {
129
+            unset($GLOBALS['connexions'][$index]);
130
+            spip_log("spip_connect: absence de charset", _LOG_AVERTISSEMENT);
131
+
132
+            return false;
133
+        }
134
+    } else {
135
+        if ($GLOBALS['db_ok']['charset']) {
136
+            $charset = $GLOBALS['db_ok']['charset'];
137
+        }
138
+        // spip_meta n'existe pas toujours dans la base
139
+        // C'est le cas d'un dump sqlite par exemple 
140
+        elseif ($GLOBALS['connexions'][$index]['spip_connect_version']
141
+            and sql_showtable('spip_meta', true, $serveur)
142
+            and $r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'", '', '', '', '', $serveur)
143
+        ) {
144
+            $charset = $r;
145
+        } else {
146
+            $charset = -1;
147
+        }
148
+    }
149
+    if ($charset != -1) {
150
+        $f = $GLOBALS[$jeu]['set_charset'];
151
+        if (function_exists($f)) {
152
+            $f($charset, $serveur);
153
+        }
154
+    }
155
+
156
+    return $GLOBALS['connexions'][$index];
157 157
 }
158 158
 
159 159
 /**
@@ -162,12 +162,12 @@  discard block
 block discarded – undo
162 162
  * @param string $serveur Nom du connecteur de bdd utilisé
163 163
  **/
164 164
 function spip_sql_erreur($serveur = '') {
165
-	$connexion = spip_connect($serveur);
166
-	$e = sql_errno($serveur);
167
-	$t = (isset($connexion['type']) ? $connexion['type'] : 'sql');
168
-	$m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim($connexion['last']);
169
-	$f = $t . $serveur;
170
-	spip_log($m, $f . '.' . _LOG_ERREUR);
165
+    $connexion = spip_connect($serveur);
166
+    $e = sql_errno($serveur);
167
+    $t = (isset($connexion['type']) ? $connexion['type'] : 'sql');
168
+    $m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim($connexion['last']);
169
+    $f = $t . $serveur;
170
+    spip_log($m, $f . '.' . _LOG_ERREUR);
171 171
 }
172 172
 
173 173
 /**
@@ -189,19 +189,19 @@  discard block
 block discarded – undo
189 189
  *     - array : description de la connexion, si l'instruction sql est indisponible pour cette connexion
190 190
  **/
191 191
 function spip_connect_sql($version, $ins = '', $serveur = '', $continue = false) {
192
-	$desc = spip_connect($serveur, $version);
193
-	if (function_exists($f = @$desc[$version][$ins])) {
194
-		return $f;
195
-	}
196
-	if ($continue) {
197
-		return $desc;
198
-	}
199
-	if ($ins) {
200
-		spip_log("Le serveur '$serveur' version $version n'a pas '$ins'", _LOG_ERREUR);
201
-	}
202
-	include_spip('inc/minipres');
203
-	echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), array('status' => 503));
204
-	exit;
192
+    $desc = spip_connect($serveur, $version);
193
+    if (function_exists($f = @$desc[$version][$ins])) {
194
+        return $f;
195
+    }
196
+    if ($continue) {
197
+        return $desc;
198
+    }
199
+    if ($ins) {
200
+        spip_log("Le serveur '$serveur' version $version n'a pas '$ins'", _LOG_ERREUR);
201
+    }
202
+    include_spip('inc/minipres');
203
+    echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), array('status' => 503));
204
+    exit;
205 205
 }
206 206
 
207 207
 /**
@@ -227,70 +227,70 @@  discard block
 block discarded – undo
227 227
  * @return array          Description de la connexion
228 228
  */
229 229
 function spip_connect_db(
230
-	$host,
231
-	$port,
232
-	$login,
233
-	$pass,
234
-	$db = '',
235
-	$type = 'mysql',
236
-	$prefixe = '',
237
-	$auth = '',
238
-	$charset = ''
230
+    $host,
231
+    $port,
232
+    $login,
233
+    $pass,
234
+    $db = '',
235
+    $type = 'mysql',
236
+    $prefixe = '',
237
+    $auth = '',
238
+    $charset = ''
239 239
 ) {
240
-	// temps avant nouvelle tentative de connexion
241
-	// suite a une connection echouee
242
-	if (!defined('_CONNECT_RETRY_DELAY')) {
243
-		define('_CONNECT_RETRY_DELAY', 30);
244
-	}
245
-
246
-	$f = "";
247
-	// un fichier de identifiant par combinaison (type,host,port,db)
248
-	// pour ne pas declarer tout indisponible d'un coup
249
-	// si en cours d'installation ou si db=@test@ on ne pose rien
250
-	// car c'est un test de connexion
251
-	if (!defined('_ECRIRE_INSTALL') and $db !== "@test@") {
252
-		$f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
253
-	} elseif ($db == '@test@') {
254
-		$db = '';
255
-	}
256
-
257
-	if ($f
258
-		and @file_exists($f)
259
-		and (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
260
-	) {
261
-		spip_log("Echec : $f recent. Pas de tentative de connexion", _LOG_HS);
262
-
263
-		return;
264
-	}
265
-
266
-	if (!$prefixe) {
267
-		$prefixe = isset($GLOBALS['table_prefix'])
268
-			? $GLOBALS['table_prefix'] : $db;
269
-	}
270
-	$h = charger_fonction($type, 'req', true);
271
-	if (!$h) {
272
-		spip_log("les requetes $type ne sont pas fournies", _LOG_HS);
273
-
274
-		return;
275
-	}
276
-	if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
277
-
278
-		if (!is_array($auth)) {
279
-			// compatibilite version 0.7 initiale
280
-			$g['ldap'] = $auth;
281
-			$auth = array('ldap' => $auth);
282
-		}
283
-		$g['authentification'] = $auth;
284
-		$g['type'] = $type;
285
-		$g['charset'] = $charset;
286
-
287
-		return $GLOBALS['db_ok'] = $g;
288
-	}
289
-	// En cas d'indisponibilite du serveur, eviter de le bombarder
290
-	if ($f) {
291
-		@touch($f);
292
-		spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
293
-	}
240
+    // temps avant nouvelle tentative de connexion
241
+    // suite a une connection echouee
242
+    if (!defined('_CONNECT_RETRY_DELAY')) {
243
+        define('_CONNECT_RETRY_DELAY', 30);
244
+    }
245
+
246
+    $f = "";
247
+    // un fichier de identifiant par combinaison (type,host,port,db)
248
+    // pour ne pas declarer tout indisponible d'un coup
249
+    // si en cours d'installation ou si db=@test@ on ne pose rien
250
+    // car c'est un test de connexion
251
+    if (!defined('_ECRIRE_INSTALL') and $db !== "@test@") {
252
+        $f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
253
+    } elseif ($db == '@test@') {
254
+        $db = '';
255
+    }
256
+
257
+    if ($f
258
+        and @file_exists($f)
259
+        and (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
260
+    ) {
261
+        spip_log("Echec : $f recent. Pas de tentative de connexion", _LOG_HS);
262
+
263
+        return;
264
+    }
265
+
266
+    if (!$prefixe) {
267
+        $prefixe = isset($GLOBALS['table_prefix'])
268
+            ? $GLOBALS['table_prefix'] : $db;
269
+    }
270
+    $h = charger_fonction($type, 'req', true);
271
+    if (!$h) {
272
+        spip_log("les requetes $type ne sont pas fournies", _LOG_HS);
273
+
274
+        return;
275
+    }
276
+    if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
277
+
278
+        if (!is_array($auth)) {
279
+            // compatibilite version 0.7 initiale
280
+            $g['ldap'] = $auth;
281
+            $auth = array('ldap' => $auth);
282
+        }
283
+        $g['authentification'] = $auth;
284
+        $g['type'] = $type;
285
+        $g['charset'] = $charset;
286
+
287
+        return $GLOBALS['db_ok'] = $g;
288
+    }
289
+    // En cas d'indisponibilite du serveur, eviter de le bombarder
290
+    if ($f) {
291
+        @touch($f);
292
+        spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
293
+    }
294 294
 }
295 295
 
296 296
 
@@ -322,31 +322,31 @@  discard block
 block discarded – undo
322 322
  *     - nom du charset sinon
323 323
  **/
324 324
 function spip_connect_main($connexion, $charset_sql_connexion = '') {
325
-	if ($GLOBALS['spip_connect_version'] < 0.1 and _DIR_RESTREINT) {
326
-		include_spip('inc/headers');
327
-		redirige_url_ecrire('upgrade', 'reinstall=oui');
328
-	}
329
-
330
-	if (!($f = $connexion['select'])) {
331
-		return false;
332
-	}
333
-	// si le charset est fourni, l'utiliser
334
-	if ($charset_sql_connexion) {
335
-		return $charset_sql_connexion;
336
-	}
337
-	// sinon on regarde la table spip_meta
338
-	// en cas d'erreur select retourne la requette (is_string=true donc)
339
-	if (!$r = $f('valeur', 'spip_meta', "nom='charset_sql_connexion'")
340
-		or is_string($r)
341
-	) {
342
-		return false;
343
-	}
344
-	if (!($f = $connexion['fetch'])) {
345
-		return false;
346
-	}
347
-	$r = $f($r);
348
-
349
-	return (isset($r['valeur']) && $r['valeur']) ? $r['valeur'] : -1;
325
+    if ($GLOBALS['spip_connect_version'] < 0.1 and _DIR_RESTREINT) {
326
+        include_spip('inc/headers');
327
+        redirige_url_ecrire('upgrade', 'reinstall=oui');
328
+    }
329
+
330
+    if (!($f = $connexion['select'])) {
331
+        return false;
332
+    }
333
+    // si le charset est fourni, l'utiliser
334
+    if ($charset_sql_connexion) {
335
+        return $charset_sql_connexion;
336
+    }
337
+    // sinon on regarde la table spip_meta
338
+    // en cas d'erreur select retourne la requette (is_string=true donc)
339
+    if (!$r = $f('valeur', 'spip_meta', "nom='charset_sql_connexion'")
340
+        or is_string($r)
341
+    ) {
342
+        return false;
343
+    }
344
+    if (!($f = $connexion['fetch'])) {
345
+        return false;
346
+    }
347
+    $r = $f($r);
348
+
349
+    return (isset($r['valeur']) && $r['valeur']) ? $r['valeur'] : -1;
350 350
 }
351 351
 
352 352
 /**
@@ -361,9 +361,9 @@  discard block
 block discarded – undo
361 361
  * @return array
362 362
  */
363 363
 function spip_connect_ldap($serveur = '') {
364
-	include_spip('auth/ldap');
364
+    include_spip('auth/ldap');
365 365
 
366
-	return auth_ldap_connect($serveur);
366
+    return auth_ldap_connect($serveur);
367 367
 }
368 368
 
369 369
 /**
@@ -379,9 +379,9 @@  discard block
 block discarded – undo
379 379
  * @return string Valeur échappée.
380 380
  **/
381 381
 function _q($a) {
382
-	return (is_numeric($a)) ? strval($a) :
383
-		(!is_array($a) ? ("'" . addslashes($a) . "'")
384
-			: join(",", array_map('_q', $a)));
382
+    return (is_numeric($a)) ? strval($a) :
383
+        (!is_array($a) ? ("'" . addslashes($a) . "'")
384
+            : join(",", array_map('_q', $a)));
385 385
 }
386 386
 
387 387
 /**
@@ -397,41 +397,41 @@  discard block
 block discarded – undo
397 397
  * @return array
398 398
  */
399 399
 function query_echappe_textes($query) {
400
-	static $codeEchappements = array("''" => "\x1@##@\x1", "\'" => "\x2@##@\x2", "\\\"" => "\x3@##@\x3");
401
-	$query = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
402
-	if (preg_match_all("/((['])[^']*(\\2))|(([\"])[^\"]*(\\5))/S", $query, $textes)) {
403
-		$textes = reset($textes); // indice 0 du match
404
-		switch (count($textes)) {
405
-			case 0:
406
-				$replace = array();
407
-				break;
408
-			case 1:
409
-				$replace = array('%1$s');
410
-				break;
411
-			case 2:
412
-				$replace = array('%1$s', '%2$s');
413
-				break;
414
-			case 3:
415
-				$replace = array('%1$s', '%2$s', '%3$s');
416
-				break;
417
-			case 4:
418
-				$replace = array('%1$s', '%2$s', '%3$s', '%4$s');
419
-				break;
420
-			case 5:
421
-				$replace = array('%1$s', '%2$s', '%3$s', '%4$s', '%5$s');
422
-				break;
423
-			default:
424
-				$replace = range(1, count($textes));
425
-				$replace = '%' . implode('$s,%', $replace) . '$s';
426
-				$replace = explode(',', $replace);
427
-				break;
428
-		}
429
-		$query = str_replace($textes, $replace, $query);
430
-	} else {
431
-		$textes = array();
432
-	}
433
-
434
-	return array($query, $textes);
400
+    static $codeEchappements = array("''" => "\x1@##@\x1", "\'" => "\x2@##@\x2", "\\\"" => "\x3@##@\x3");
401
+    $query = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
402
+    if (preg_match_all("/((['])[^']*(\\2))|(([\"])[^\"]*(\\5))/S", $query, $textes)) {
403
+        $textes = reset($textes); // indice 0 du match
404
+        switch (count($textes)) {
405
+            case 0:
406
+                $replace = array();
407
+                break;
408
+            case 1:
409
+                $replace = array('%1$s');
410
+                break;
411
+            case 2:
412
+                $replace = array('%1$s', '%2$s');
413
+                break;
414
+            case 3:
415
+                $replace = array('%1$s', '%2$s', '%3$s');
416
+                break;
417
+            case 4:
418
+                $replace = array('%1$s', '%2$s', '%3$s', '%4$s');
419
+                break;
420
+            case 5:
421
+                $replace = array('%1$s', '%2$s', '%3$s', '%4$s', '%5$s');
422
+                break;
423
+            default:
424
+                $replace = range(1, count($textes));
425
+                $replace = '%' . implode('$s,%', $replace) . '$s';
426
+                $replace = explode(',', $replace);
427
+                break;
428
+        }
429
+        $query = str_replace($textes, $replace, $query);
430
+    } else {
431
+        $textes = array();
432
+    }
433
+
434
+    return array($query, $textes);
435 435
 }
436 436
 
437 437
 /**
@@ -445,40 +445,40 @@  discard block
 block discarded – undo
445 445
  * @return string
446 446
  */
447 447
 function query_reinjecte_textes($query, $textes) {
448
-	static $codeEchappements = array("''" => "\x1@##@\x1", "\'" => "\x2@##@\x2", "\\\"" => "\x3@##@\x3");
449
-	# debug de la substitution
450
-	#if (($c1=substr_count($query,"%"))!=($c2=count($textes))){
451
-	#	spip_log("$c1 ::". $query,"tradquery"._LOG_ERREUR);
452
-	#	spip_log("$c2 ::". var_export($textes,1),"tradquery"._LOG_ERREUR);
453
-	#	spip_log("ini ::". $qi,"tradquery"._LOG_ERREUR);
454
-	#}
455
-	switch (count($textes)) {
456
-		case 0:
457
-			break;
458
-		case 1:
459
-			$query = sprintf($query, $textes[0]);
460
-			break;
461
-		case 2:
462
-			$query = sprintf($query, $textes[0], $textes[1]);
463
-			break;
464
-		case 3:
465
-			$query = sprintf($query, $textes[0], $textes[1], $textes[2]);
466
-			break;
467
-		case 4:
468
-			$query = sprintf($query, $textes[0], $textes[1], $textes[2], $textes[3]);
469
-			break;
470
-		case 5:
471
-			$query = sprintf($query, $textes[0], $textes[1], $textes[2], $textes[3], $textes[4]);
472
-			break;
473
-		default:
474
-			array_unshift($textes, $query);
475
-			$query = call_user_func_array('sprintf', $textes);
476
-			break;
477
-	}
478
-
479
-	$query = str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
480
-
481
-	return $query;
448
+    static $codeEchappements = array("''" => "\x1@##@\x1", "\'" => "\x2@##@\x2", "\\\"" => "\x3@##@\x3");
449
+    # debug de la substitution
450
+    #if (($c1=substr_count($query,"%"))!=($c2=count($textes))){
451
+    #	spip_log("$c1 ::". $query,"tradquery"._LOG_ERREUR);
452
+    #	spip_log("$c2 ::". var_export($textes,1),"tradquery"._LOG_ERREUR);
453
+    #	spip_log("ini ::". $qi,"tradquery"._LOG_ERREUR);
454
+    #}
455
+    switch (count($textes)) {
456
+        case 0:
457
+            break;
458
+        case 1:
459
+            $query = sprintf($query, $textes[0]);
460
+            break;
461
+        case 2:
462
+            $query = sprintf($query, $textes[0], $textes[1]);
463
+            break;
464
+        case 3:
465
+            $query = sprintf($query, $textes[0], $textes[1], $textes[2]);
466
+            break;
467
+        case 4:
468
+            $query = sprintf($query, $textes[0], $textes[1], $textes[2], $textes[3]);
469
+            break;
470
+        case 5:
471
+            $query = sprintf($query, $textes[0], $textes[1], $textes[2], $textes[3], $textes[4]);
472
+            break;
473
+        default:
474
+            array_unshift($textes, $query);
475
+            $query = call_user_func_array('sprintf', $textes);
476
+            break;
477
+    }
478
+
479
+    $query = str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
480
+
481
+    return $query;
482 482
 }
483 483
 
484 484
 
@@ -497,7 +497,7 @@  discard block
 block discarded – undo
497 497
  **/
498 498
 function spip_query($query, $serveur = '') {
499 499
 
500
-	$f = spip_connect_sql($GLOBALS['spip_sql_version'], 'query', $serveur, true);
500
+    $f = spip_connect_sql($GLOBALS['spip_sql_version'], 'query', $serveur, true);
501 501
 
502
-	return function_exists($f) ? $f($query, $serveur) : false;
502
+    return function_exists($f) ? $f($query, $serveur) : false;
503 503
 }
Please login to merge, or discard this patch.
ecrire/base/delete_all.php 2 patches
Indentation   +22 added lines, -22 removed lines patch added patch discarded remove patch
@@ -17,7 +17,7 @@  discard block
 block discarded – undo
17 17
  */
18 18
 
19 19
 if (!defined('_ECRIRE_INC_VERSION')) {
20
-	return;
20
+    return;
21 21
 }
22 22
 
23 23
 /**
@@ -29,27 +29,27 @@  discard block
 block discarded – undo
29 29
  * @param string $titre Inutilisé
30 30
  **/
31 31
 function base_delete_all_dist($titre) {
32
-	$delete = _request('delete');
33
-	$res = array();
34
-	if (is_array($delete)) {
35
-		foreach ($delete as $table) {
36
-			if (sql_drop_table($table)) {
37
-				$res[] = $table;
38
-			} else {
39
-				spip_log("SPIP n'a pas pu detruire $table.", _LOG_ERREUR);
40
-			}
41
-		}
32
+    $delete = _request('delete');
33
+    $res = array();
34
+    if (is_array($delete)) {
35
+        foreach ($delete as $table) {
36
+            if (sql_drop_table($table)) {
37
+                $res[] = $table;
38
+            } else {
39
+                spip_log("SPIP n'a pas pu detruire $table.", _LOG_ERREUR);
40
+            }
41
+        }
42 42
 
43
-		// un pipeline pour detruire les tables installees par les plugins
44
-		pipeline('delete_tables', '');
43
+        // un pipeline pour detruire les tables installees par les plugins
44
+        pipeline('delete_tables', '');
45 45
 
46
-		spip_unlink(_FILE_CONNECT);
47
-		spip_unlink(_FILE_CHMOD);
48
-		spip_unlink(_FILE_META);
49
-		spip_unlink(_ACCESS_FILE_NAME);
50
-		spip_unlink(_CACHE_RUBRIQUES);
51
-	}
52
-	$d = count($delete);
53
-	$r = count($res);
54
-	spip_log("Tables detruites: $r sur $d: " . join(', ', $res), _LOG_INFO_IMPORTANTE);
46
+        spip_unlink(_FILE_CONNECT);
47
+        spip_unlink(_FILE_CHMOD);
48
+        spip_unlink(_FILE_META);
49
+        spip_unlink(_ACCESS_FILE_NAME);
50
+        spip_unlink(_CACHE_RUBRIQUES);
51
+    }
52
+    $d = count($delete);
53
+    $r = count($res);
54
+    spip_log("Tables detruites: $r sur $d: " . join(', ', $res), _LOG_INFO_IMPORTANTE);
55 55
 }
Please login to merge, or discard this patch.
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -51,5 +51,5 @@
 block discarded – undo
51 51
 	}
52 52
 	$d = count($delete);
53 53
 	$r = count($res);
54
-	spip_log("Tables detruites: $r sur $d: " . join(', ', $res), _LOG_INFO_IMPORTANTE);
54
+	spip_log("Tables detruites: $r sur $d: ".join(', ', $res), _LOG_INFO_IMPORTANTE);
55 55
 }
Please login to merge, or discard this patch.
ecrire/base/dump.php 3 patches
Braces   +3 added lines, -2 removed lines patch added patch discarded remove patch
@@ -326,14 +326,15 @@
 block discarded – undo
326 326
 				$connecte = false;
327 327
 			}
328 328
 		}
329
-		if ($connecte)
330
-			# on ajoute les liaisons en premier
329
+		if ($connecte) {
330
+					# on ajoute les liaisons en premier
331 331
 			# si une restauration est interrompue,
332 332
 			# cela se verra mieux si il manque des objets
333 333
 			# que des liens
334 334
 		{
335 335
 			array_unshift($tables_for_dump, $link_table);
336 336
 		}
337
+		}
337 338
 	}
338 339
 
339 340
 	return array($tables_for_dump, $tables_for_link);
Please login to merge, or discard this patch.
Spacing   +35 added lines, -35 removed lines patch added patch discarded remove patch
@@ -38,7 +38,7 @@  discard block
 block discarded – undo
38 38
  * @return string
39 39
  **/
40 40
 function base_dump_meta_name($rub) {
41
-	return $meta = "status_dump_{$rub}_" . abs($GLOBALS['visiteur_session']['id_auteur']);
41
+	return $meta = "status_dump_{$rub}_".abs($GLOBALS['visiteur_session']['id_auteur']);
42 42
 }
43 43
 
44 44
 /**
@@ -84,7 +84,7 @@  discard block
 block discarded – undo
84 84
 	$connexion = $GLOBALS['connexions'][$serveur ? $serveur : 0];
85 85
 	$prefixe = $connexion['prefixe'];
86 86
 
87
-	$p = '/^' . $prefixe . '/';
87
+	$p = '/^'.$prefixe.'/';
88 88
 	$res = $tables;
89 89
 	foreach (sql_alltable(null, $serveur) as $t) {
90 90
 		if (preg_match($p, $t)) {
@@ -343,8 +343,8 @@  discard block
 block discarded – undo
343 343
 function base_vider_tables_destination_copie($tables, $exclure_tables = array(), $serveur = '') {
344 344
 	$trouver_table = charger_fonction('trouver_table', 'base');
345 345
 
346
-	spip_log('Vider ' . count($tables) . " tables sur serveur '$serveur' : " . join(', ', $tables),
347
-		'base.' . _LOG_INFO_IMPORTANTE);
346
+	spip_log('Vider '.count($tables)." tables sur serveur '$serveur' : ".join(', ', $tables),
347
+		'base.'._LOG_INFO_IMPORTANTE);
348 348
 	foreach ($tables as $table) {
349 349
 		if (!in_array($table, $exclure_tables)) {
350 350
 			// sur le serveur principal, il ne faut pas supprimer l'auteur loge !
@@ -381,14 +381,14 @@  discard block
 block discarded – undo
381 381
 function base_conserver_copieur($move = true, $serveur = '') {
382 382
 	// s'asurer qu'on a pas deja fait la manip !
383 383
 	if ($GLOBALS['visiteur_session']['id_auteur'] > 0 and sql_countsel("spip_auteurs", "id_auteur>0")) {
384
-		spip_log('Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
385
-			'dump.' . _LOG_INFO_IMPORTANTE);
384
+		spip_log('Conserver copieur dans id_auteur='.$GLOBALS['visiteur_session']['id_auteur']." pour le serveur '$serveur'",
385
+			'dump.'._LOG_INFO_IMPORTANTE);
386 386
 		sql_delete("spip_auteurs", "id_auteur<0", $serveur);
387 387
 		if ($move) {
388 388
 			sql_updateq('spip_auteurs', array('id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']),
389
-				"id_auteur=" . intval($GLOBALS['visiteur_session']['id_auteur']), array(), $serveur);
389
+				"id_auteur=".intval($GLOBALS['visiteur_session']['id_auteur']), array(), $serveur);
390 390
 		} else {
391
-			$row = sql_fetsel('*', 'spip_auteurs', 'id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'], '', '', '', '',
391
+			$row = sql_fetsel('*', 'spip_auteurs', 'id_auteur='.$GLOBALS['visiteur_session']['id_auteur'], '', '', '', '',
392 392
 				$serveur);
393 393
 			$row['id_auteur'] = -$GLOBALS['visiteur_session']['id_auteur'];
394 394
 			sql_insertq('spip_auteurs', $row, array(), $serveur);
@@ -411,15 +411,15 @@  discard block
 block discarded – undo
411 411
 	// rien a faire si ce n'est pas le serveur principal !
412 412
 	if ($serveur == '') {
413 413
 		if (sql_countsel("spip_auteurs", "id_auteur>0")) {
414
-			spip_log("Detruire copieur id_auteur<0 pour le serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
414
+			spip_log("Detruire copieur id_auteur<0 pour le serveur '$serveur'", 'dump.'._LOG_INFO_IMPORTANTE);
415 415
 			sql_delete("spip_auteurs", "id_auteur<0", $serveur);
416 416
 		} else {
417 417
 			spip_log("Restaurer copieur id_auteur<0 pour le serveur '$serveur' (aucun autre auteur en base)",
418
-				'dump.' . _LOG_INFO_IMPORTANTE);
418
+				'dump.'._LOG_INFO_IMPORTANTE);
419 419
 			sql_update('spip_auteurs', array('id_auteur' => '-id_auteur'), "id_auteur<0");
420 420
 		}
421 421
 	} else {
422
-		spip_log("Pas de destruction copieur sur serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
422
+		spip_log("Pas de destruction copieur sur serveur '$serveur'", 'dump.'._LOG_INFO_IMPORTANTE);
423 423
 	}
424 424
 }
425 425
 
@@ -453,19 +453,19 @@  discard block
 block discarded – undo
453 453
 			}
454 454
 		} else {
455 455
 			sql_drop_table($table, '', $serveur_dest);
456
-			spip_log("drop table '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
456
+			spip_log("drop table '$table' sur serveur '$serveur_dest'", 'dump.'._LOG_INFO_IMPORTANTE);
457 457
 		}
458 458
 		$desc_dest = false;
459 459
 	}
460 460
 	// si la table n'existe pas dans la destination, la creer a l'identique !
461 461
 	if (!$desc_dest) {
462
-		spip_log("creation '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
462
+		spip_log("creation '$table' sur serveur '$serveur_dest'", 'dump.'._LOG_INFO_IMPORTANTE);
463 463
 		include_spip('base/create');
464 464
 		creer_ou_upgrader_table($table, $desc, 'auto', $upgrade, $serveur_dest);
465 465
 		$desc_dest = sql_showtable($table, true, $serveur_dest);
466 466
 	}
467 467
 	if (!$desc_dest) {
468
-		spip_log("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1), 'dump.' . _LOG_ERREUR);
468
+		spip_log("Erreur creation '$table' sur serveur '$serveur_dest'".var_export($desc, 1), 'dump.'._LOG_ERREUR);
469 469
 	}
470 470
 
471 471
 	return $desc_dest;
@@ -524,16 +524,16 @@  discard block
 block discarded – undo
524 524
 	$racine_fonctions = (isset($options['racine_fonctions_dest']) ? $options['racine_fonctions_dest'] : 'base');
525 525
 	$data_pool = (isset($options['data_pool']) ? $options['data_pool'] : 50 * 1024);
526 526
 
527
-	spip_log("Copier " . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
528
-		'dump.' . _LOG_INFO_IMPORTANTE);
527
+	spip_log("Copier ".count($tables)." tables de '$serveur_source' vers '$serveur_dest'",
528
+		'dump.'._LOG_INFO_IMPORTANTE);
529 529
 
530 530
 	if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
531
-		spip_log("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
531
+		spip_log("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon", 'dump.'._LOG_INFO_IMPORTANTE);
532 532
 
533 533
 		return true; // echec mais on a fini, donc true
534 534
 	}
535 535
 	if (!$preparer_table_dest = charger_fonction('preparer_table_dest', $racine_fonctions, true)) {
536
-		spip_log("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
536
+		spip_log("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon", 'dump.'._LOG_INFO_IMPORTANTE);
537 537
 
538 538
 		return true; // echec mais on a fini, donc true
539 539
 	}
@@ -555,7 +555,7 @@  discard block
 block discarded – undo
555 555
 			true)
556 556
 		) {
557 557
 			spip_log("Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",
558
-				'dump.' . _LOG_INFO_IMPORTANTE);
558
+				'dump.'._LOG_INFO_IMPORTANTE);
559 559
 
560 560
 			return true; // echec mais on a fini, donc true
561 561
 		}
@@ -573,7 +573,7 @@  discard block
 block discarded – undo
573 573
 		$tables = array_diff($tables, array('spip_meta'));
574 574
 		$tables[] = 'spip_meta';
575 575
 	}
576
-	spip_log("Tables a copier :" . implode(", ", $tables), 'dump.' . _LOG_INFO);
576
+	spip_log("Tables a copier :".implode(", ", $tables), 'dump.'._LOG_INFO);
577 577
 
578 578
 	$trouver_table = charger_fonction('trouver_table', 'base');
579 579
 
@@ -627,7 +627,7 @@  discard block
 block discarded – undo
627 627
 						// mais si ca renvoie false c'est une erreur fatale => abandon
628 628
 						if ($inserer_copie($table, $rows, $desc_dest, $serveur_dest) === false) {
629 629
 							// forcer la sortie, charge a l'appelant de gerer l'echec
630
-							spip_log("Erreur fatale dans $inserer_copie table $table", "dump" . _LOG_ERREUR);
630
+							spip_log("Erreur fatale dans $inserer_copie table $table", "dump"._LOG_ERREUR);
631 631
 							$status['errors'][] = "Erreur fatale  lors de la copie de la table $table";
632 632
 							ecrire_fichier($status_file, serialize($status));
633 633
 
@@ -642,7 +642,7 @@  discard block
 block discarded – undo
642 642
 					if ($n == $status['tables_copiees'][$table]) {
643 643
 						break;
644 644
 					}
645
-					spip_log("recopie $table " . $status['tables_copiees'][$table], 'dump.' . _LOG_INFO_IMPORTANTE);
645
+					spip_log("recopie $table ".$status['tables_copiees'][$table], 'dump.'._LOG_INFO_IMPORTANTE);
646 646
 					if ($callback_progression) {
647 647
 						$callback_progression($status['tables_copiees'][$table], 0, $table);
648 648
 					}
@@ -653,43 +653,43 @@  discard block
 block discarded – undo
653 653
 				}
654 654
 				if ($drop_source) {
655 655
 					sql_drop_table($table, '', $serveur_source);
656
-					spip_log("drop $table sur serveur source '$serveur_source'", 'dump.' . _LOG_INFO_IMPORTANTE);
656
+					spip_log("drop $table sur serveur source '$serveur_source'", 'dump.'._LOG_INFO_IMPORTANTE);
657 657
 				}
658 658
 				$status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : "zero");
659 659
 				ecrire_fichier($status_file, serialize($status));
660
-				spip_log("tables_recopiees " . implode(',', array_keys($status['tables_copiees'])), 'dump.' . _LOG_INFO);
660
+				spip_log("tables_recopiees ".implode(',', array_keys($status['tables_copiees'])), 'dump.'._LOG_INFO);
661 661
 				if ($callback_progression) {
662 662
 					$callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
663 663
 				}
664 664
 			} else {
665 665
 				if ($status['tables_copiees'][$table] < 0) {
666
-					spip_log("Table $table deja copiee : " . $status['tables_copiees'][$table], "dump." . _LOG_INFO);
666
+					spip_log("Table $table deja copiee : ".$status['tables_copiees'][$table], "dump."._LOG_INFO);
667 667
 				}
668 668
 				if ($callback_progression) {
669 669
 					$callback_progression(0, $status['tables_copiees'][$table],
670
-						"$table" . ((is_numeric($status['tables_copiees'][$table]) and $status['tables_copiees'][$table] >= 0) ? "[Echec]" : ""));
670
+						"$table".((is_numeric($status['tables_copiees'][$table]) and $status['tables_copiees'][$table] >= 0) ? "[Echec]" : ""));
671 671
 				}
672 672
 			}
673 673
 		} else {
674 674
 			$status['errors'][] = "Impossible de lire la description de la table $table";
675 675
 			ecrire_fichier($status_file, serialize($status));
676
-			spip_log("Impossible de lire la description de la table $table", "dump." . _LOG_ERREUR);
676
+			spip_log("Impossible de lire la description de la table $table", "dump."._LOG_ERREUR);
677 677
 		}
678 678
 	}
679 679
 
680 680
 	// si le nombre de tables envoyees n'est pas egal au nombre de tables demandees
681 681
 	// abandonner
682 682
 	if (count($status['tables_copiees']) < count($tables)) {
683
-		spip_log("Nombre de tables copiees incorrect : " . count($status['tables_copiees']) . "/" . count($tables),
684
-			"dump." . _LOG_ERREUR);
685
-		$status['errors'][] = "Nombre de tables copiees incorrect : " . count($status['tables_copiees']) . "/" . count($tables);
683
+		spip_log("Nombre de tables copiees incorrect : ".count($status['tables_copiees'])."/".count($tables),
684
+			"dump."._LOG_ERREUR);
685
+		$status['errors'][] = "Nombre de tables copiees incorrect : ".count($status['tables_copiees'])."/".count($tables);
686 686
 		ecrire_fichier($status_file, serialize($status));
687 687
 	}
688 688
 
689 689
 	if ($detruire_copieur_si_besoin = charger_fonction('detruire_copieur_si_besoin', $racine_fonctions, true)) {
690 690
 		$detruire_copieur_si_besoin($serveur_dest);
691 691
 	} else {
692
-		spip_log("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.", 'dump.' . _LOG_INFO_IMPORTANTE);
692
+		spip_log("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.", 'dump.'._LOG_INFO_IMPORTANTE);
693 693
 	}
694 694
 
695 695
 	// OK, copie complete
@@ -713,8 +713,8 @@  discard block
 block discarded – undo
713 713
 	$r = sql_insertq_multi($table, $rows, $desc_dest, $serveur_dest);
714 714
 	$nb = sql_countsel($table, '', '', '', $serveur_dest);
715 715
 	if ($nb - $nb1 < count($rows)) {
716
-		spip_log("base_inserer_copie : " . ($nb - $nb1) . " insertions au lieu de " . count($rows) . ". On retente 1 par 1",
717
-			"dump" . _LOG_INFO_IMPORTANTE);
716
+		spip_log("base_inserer_copie : ".($nb - $nb1)." insertions au lieu de ".count($rows).". On retente 1 par 1",
717
+			"dump"._LOG_INFO_IMPORTANTE);
718 718
 		foreach ($rows as $row) {
719 719
 			// si l'enregistrement est deja en base, ca fera un echec ou un doublon
720 720
 			$r = sql_insertq($table, $row, $desc_dest, $serveur_dest);
@@ -723,8 +723,8 @@  discard block
 block discarded – undo
723 723
 		$r = 0;
724 724
 		$nb = sql_countsel($table, '', '', '', $serveur_dest);
725 725
 		if ($nb - $nb1 < count($rows)) {
726
-			spip_log("base_inserer_copie : " . ($nb - $nb1) . " insertions au lieu de " . count($rows) . " apres insertion 1 par 1",
727
-				"dump" . _LOG_ERREUR);
726
+			spip_log("base_inserer_copie : ".($nb - $nb1)." insertions au lieu de ".count($rows)." apres insertion 1 par 1",
727
+				"dump"._LOG_ERREUR);
728 728
 			$r = false;
729 729
 		}
730 730
 	}
Please login to merge, or discard this patch.
Indentation   +486 added lines, -486 removed lines patch added patch discarded remove patch
@@ -17,7 +17,7 @@  discard block
 block discarded – undo
17 17
  */
18 18
 
19 19
 if (!defined('_ECRIRE_INC_VERSION')) {
20
-	return;
20
+    return;
21 21
 }
22 22
 
23 23
 define('_VERSION_ARCHIVE', '1.3');
@@ -38,7 +38,7 @@  discard block
 block discarded – undo
38 38
  * @return string
39 39
  **/
40 40
 function base_dump_meta_name($rub) {
41
-	return $meta = "status_dump_{$rub}_" . abs($GLOBALS['visiteur_session']['id_auteur']);
41
+    return $meta = "status_dump_{$rub}_" . abs($GLOBALS['visiteur_session']['id_auteur']);
42 42
 }
43 43
 
44 44
 /**
@@ -53,15 +53,15 @@  discard block
 block discarded – undo
53 53
  * @return string
54 54
  **/
55 55
 function base_dump_dir($meta) {
56
-	include_spip('inc/documents');
57
-	// determine upload va aussi initialiser l'index "restreint"
58
-	$maindir = determine_upload();
59
-	if (!$GLOBALS['visiteur_session']['restreint']) {
60
-		$maindir = _DIR_DUMP;
61
-	}
62
-	$dir = sous_repertoire($maindir, $meta);
63
-
64
-	return $dir;
56
+    include_spip('inc/documents');
57
+    // determine upload va aussi initialiser l'index "restreint"
58
+    $maindir = determine_upload();
59
+    if (!$GLOBALS['visiteur_session']['restreint']) {
60
+        $maindir = _DIR_DUMP;
61
+    }
62
+    $dir = sous_repertoire($maindir, $meta);
63
+
64
+    return $dir;
65 65
 }
66 66
 
67 67
 /**
@@ -75,28 +75,28 @@  discard block
 block discarded – undo
75 75
  * @return array
76 76
  */
77 77
 function base_lister_toutes_tables(
78
-	$serveur = '',
79
-	$tables = array(),
80
-	$exclude = array(),
81
-	$affiche_vrai_prefixe = false
78
+    $serveur = '',
79
+    $tables = array(),
80
+    $exclude = array(),
81
+    $affiche_vrai_prefixe = false
82 82
 ) {
83
-	spip_connect($serveur);
84
-	$connexion = $GLOBALS['connexions'][$serveur ? $serveur : 0];
85
-	$prefixe = $connexion['prefixe'];
86
-
87
-	$p = '/^' . $prefixe . '/';
88
-	$res = $tables;
89
-	foreach (sql_alltable(null, $serveur) as $t) {
90
-		if (preg_match($p, $t)) {
91
-			$t1 = preg_replace($p, 'spip', $t);
92
-			if (!in_array($t1, $tables) and !in_array($t1, $exclude)) {
93
-				$res[] = ($affiche_vrai_prefixe ? $t : $t1);
94
-			}
95
-		}
96
-	}
97
-	sort($res);
98
-
99
-	return $res;
83
+    spip_connect($serveur);
84
+    $connexion = $GLOBALS['connexions'][$serveur ? $serveur : 0];
85
+    $prefixe = $connexion['prefixe'];
86
+
87
+    $p = '/^' . $prefixe . '/';
88
+    $res = $tables;
89
+    foreach (sql_alltable(null, $serveur) as $t) {
90
+        if (preg_match($p, $t)) {
91
+            $t1 = preg_replace($p, 'spip', $t);
92
+            if (!in_array($t1, $tables) and !in_array($t1, $exclude)) {
93
+                $res[] = ($affiche_vrai_prefixe ? $t : $t1);
94
+            }
95
+        }
96
+    }
97
+    sort($res);
98
+
99
+    return $res;
100 100
 }
101 101
 
102 102
 /**
@@ -106,11 +106,11 @@  discard block
 block discarded – undo
106 106
  * @return string
107 107
  */
108 108
 function base_prefixe_tables($serveur = '') {
109
-	spip_connect($serveur);
110
-	$connexion = $GLOBALS['connexions'][$serveur ? $serveur : 0];
111
-	$prefixe = $connexion['prefixe'];
109
+    spip_connect($serveur);
110
+    $connexion = $GLOBALS['connexions'][$serveur ? $serveur : 0];
111
+    $prefixe = $connexion['prefixe'];
112 112
 
113
-	return $prefixe;
113
+    return $prefixe;
114 114
 }
115 115
 
116 116
 
@@ -125,29 +125,29 @@  discard block
 block discarded – undo
125 125
  * @return array
126 126
  */
127 127
 function base_saisie_tables($name, $tables, $exclude = array(), $post = null, $serveur = '') {
128
-	include_spip('inc/filtres');
129
-	$res = array();
130
-	foreach ($tables as $k => $t) {
131
-		// par defaut tout est coche sauf les tables dans $exclude
132
-		if (is_null($post)) {
133
-			$check = (in_array($t, $exclude) ? false : true);
134
-		} // mais si on a poste une selection, la reprendre
135
-		else {
136
-			$check = in_array($t, $post);
137
-		}
138
-
139
-		$res[$k] = "<input type='checkbox' value='$t' name='$name"
140
-			. "[]' id='$name$k'"
141
-			. ($check ? " checked='checked'" : '')
142
-			. "/>\n"
143
-			. "<label for='$name$k'>$t</label>"
144
-			. " ("
145
-			. sinon(singulier_ou_pluriel(sql_countsel($t, '', '', '', $serveur), 'dump:une_donnee', 'dump:nb_donnees'),
146
-				_T('dump:aucune_donnee'))
147
-			. ")";
148
-	}
149
-
150
-	return $res;
128
+    include_spip('inc/filtres');
129
+    $res = array();
130
+    foreach ($tables as $k => $t) {
131
+        // par defaut tout est coche sauf les tables dans $exclude
132
+        if (is_null($post)) {
133
+            $check = (in_array($t, $exclude) ? false : true);
134
+        } // mais si on a poste une selection, la reprendre
135
+        else {
136
+            $check = in_array($t, $post);
137
+        }
138
+
139
+        $res[$k] = "<input type='checkbox' value='$t' name='$name"
140
+            . "[]' id='$name$k'"
141
+            . ($check ? " checked='checked'" : '')
142
+            . "/>\n"
143
+            . "<label for='$name$k'>$t</label>"
144
+            . " ("
145
+            . sinon(singulier_ou_pluriel(sql_countsel($t, '', '', '', $serveur), 'dump:une_donnee', 'dump:nb_donnees'),
146
+                _T('dump:aucune_donnee'))
147
+            . ")";
148
+    }
149
+
150
+    return $res;
151 151
 }
152 152
 
153 153
 
@@ -159,27 +159,27 @@  discard block
 block discarded – undo
159 159
  * @return array
160 160
  */
161 161
 function lister_tables_noexport() {
162
-	// par defaut tout est exporte sauf les tables ci-dessous
163
-	static $EXPORT_tables_noexport = null;
164
-	if (!is_null($EXPORT_tables_noexport)) {
165
-		return $EXPORT_tables_noexport;
166
-	}
167
-
168
-	$EXPORT_tables_noexport = array(
169
-		'spip_caches', // plugin invalideur
170
-		'spip_resultats', // resultats de recherche ... c'est un cache !
171
-		'spip_test', // c'est un test !
172
-		#'spip_referers',
173
-		#'spip_referers_articles',
174
-		#'spip_visites',
175
-		#'spip_visites_articles',
176
-		#'spip_versions',
177
-		#'spip_versions_fragments'
178
-	);
179
-
180
-	$EXPORT_tables_noexport = pipeline('lister_tables_noexport', $EXPORT_tables_noexport);
181
-
182
-	return $EXPORT_tables_noexport;
162
+    // par defaut tout est exporte sauf les tables ci-dessous
163
+    static $EXPORT_tables_noexport = null;
164
+    if (!is_null($EXPORT_tables_noexport)) {
165
+        return $EXPORT_tables_noexport;
166
+    }
167
+
168
+    $EXPORT_tables_noexport = array(
169
+        'spip_caches', // plugin invalideur
170
+        'spip_resultats', // resultats de recherche ... c'est un cache !
171
+        'spip_test', // c'est un test !
172
+        #'spip_referers',
173
+        #'spip_referers_articles',
174
+        #'spip_visites',
175
+        #'spip_visites_articles',
176
+        #'spip_versions',
177
+        #'spip_versions_fragments'
178
+    );
179
+
180
+    $EXPORT_tables_noexport = pipeline('lister_tables_noexport', $EXPORT_tables_noexport);
181
+
182
+    return $EXPORT_tables_noexport;
183 183
 }
184 184
 
185 185
 /**
@@ -190,25 +190,25 @@  discard block
 block discarded – undo
190 190
  * @return array
191 191
  */
192 192
 function lister_tables_noimport() {
193
-	static $IMPORT_tables_noimport = null;
194
-	if (!is_null($IMPORT_tables_noimport)) {
195
-		return $IMPORT_tables_noimport;
196
-	}
197
-
198
-	$IMPORT_tables_noimport = array();
199
-	// par defaut tout est importe sauf les tables ci-dessous
200
-	// possibiliter de definir cela tables via la meta
201
-	// compatibilite
202
-	if (isset($GLOBALS['meta']['IMPORT_tables_noimport'])) {
203
-		$IMPORT_tables_noimport = unserialize($GLOBALS['meta']['IMPORT_tables_noimport']);
204
-		if (!is_array($IMPORT_tables_noimport)) {
205
-			include_spip('inc/meta');
206
-			effacer_meta('IMPORT_tables_noimport');
207
-		}
208
-	}
209
-	$IMPORT_tables_noimport = pipeline('lister_tables_noimport', $IMPORT_tables_noimport);
210
-
211
-	return $IMPORT_tables_noimport;
193
+    static $IMPORT_tables_noimport = null;
194
+    if (!is_null($IMPORT_tables_noimport)) {
195
+        return $IMPORT_tables_noimport;
196
+    }
197
+
198
+    $IMPORT_tables_noimport = array();
199
+    // par defaut tout est importe sauf les tables ci-dessous
200
+    // possibiliter de definir cela tables via la meta
201
+    // compatibilite
202
+    if (isset($GLOBALS['meta']['IMPORT_tables_noimport'])) {
203
+        $IMPORT_tables_noimport = unserialize($GLOBALS['meta']['IMPORT_tables_noimport']);
204
+        if (!is_array($IMPORT_tables_noimport)) {
205
+            include_spip('inc/meta');
206
+            effacer_meta('IMPORT_tables_noimport');
207
+        }
208
+    }
209
+    $IMPORT_tables_noimport = pipeline('lister_tables_noimport', $IMPORT_tables_noimport);
210
+
211
+    return $IMPORT_tables_noimport;
212 212
 }
213 213
 
214 214
 
@@ -220,23 +220,23 @@  discard block
 block discarded – undo
220 220
  * @return array
221 221
  */
222 222
 function lister_tables_noerase() {
223
-	static $IMPORT_tables_noerase = null;
224
-	if (!is_null($IMPORT_tables_noerase)) {
225
-		return $IMPORT_tables_noerase;
226
-	}
227
-
228
-	$IMPORT_tables_noerase = array(
229
-		'spip_meta',
230
-		// par defaut on ne vide pas les stats, car elles ne figurent pas dans les dump
231
-		// et le cas echeant, un bouton dans l'admin permet de les vider a la main...
232
-		'spip_referers',
233
-		'spip_referers_articles',
234
-		'spip_visites',
235
-		'spip_visites_articles'
236
-	);
237
-	$IMPORT_tables_noerase = pipeline('lister_tables_noerase', $IMPORT_tables_noerase);
238
-
239
-	return $IMPORT_tables_noerase;
223
+    static $IMPORT_tables_noerase = null;
224
+    if (!is_null($IMPORT_tables_noerase)) {
225
+        return $IMPORT_tables_noerase;
226
+    }
227
+
228
+    $IMPORT_tables_noerase = array(
229
+        'spip_meta',
230
+        // par defaut on ne vide pas les stats, car elles ne figurent pas dans les dump
231
+        // et le cas echeant, un bouton dans l'admin permet de les vider a la main...
232
+        'spip_referers',
233
+        'spip_referers_articles',
234
+        'spip_visites',
235
+        'spip_visites_articles'
236
+    );
237
+    $IMPORT_tables_noerase = pipeline('lister_tables_noerase', $IMPORT_tables_noerase);
238
+
239
+    return $IMPORT_tables_noerase;
240 240
 }
241 241
 
242 242
 
@@ -250,83 +250,83 @@  discard block
 block discarded – undo
250 250
  * @return array
251 251
  */
252 252
 function base_liste_table_for_dump($exclude_tables = array()) {
253
-	$tables_for_dump = array();
254
-	$tables_pointees = array();
255
-	$tables = array();
256
-	$tables_principales = $GLOBALS['tables_principales'];
257
-	$tables_auxiliaires = $GLOBALS['tables_auxiliaires'];
258
-	$tables_jointures = $GLOBALS['tables_jointures'];
259
-
260
-	if (include_spip('base/objets')
261
-		and function_exists('lister_tables_objets_sql')
262
-	) {
263
-		$tables = lister_tables_objets_sql();
264
-		foreach ($tables as $t => $infos) {
265
-			if ($infos['principale'] and !isset($tables_principales[$t])) {
266
-				$tables_principales[$t] = true;
267
-			}
268
-			if (!$infos['principale'] and !isset($tables_auxiliaires[$t])) {
269
-				$tables_auxiliaires[$t] = true;
270
-			}
271
-			if (count($infos['tables_jointures'])) {
272
-				$tables_jointures[$t] = array_merge(isset($tables_jointures[$t]) ? $tables_jointures[$t] : array(),
273
-					$infos['tables_jointures']);
274
-			}
275
-		}
276
-	}
277
-
278
-	// on construit un index des tables de liens
279
-	// pour les ajouter SI les deux tables qu'ils connectent sont sauvegardees
280
-	$tables_for_link = array();
281
-	foreach ($tables_jointures as $table => $liste_relations) {
282
-		if (is_array($liste_relations)) {
283
-			$nom = $table;
284
-			if (!isset($tables_auxiliaires[$nom]) && !isset($tables_principales[$nom])) {
285
-				$nom = "spip_$table";
286
-			}
287
-			if (isset($tables_auxiliaires[$nom]) || isset($tables_principales[$nom])) {
288
-				foreach ($liste_relations as $link_table) {
289
-					if (isset($tables_auxiliaires[$link_table])/*||isset($tables_principales[$link_table])*/) {
290
-						$tables_for_link[$link_table][] = $nom;
291
-					} else {
292
-						if (isset($tables_auxiliaires["spip_$link_table"])/*||isset($tables_principales["spip_$link_table"])*/) {
293
-							$tables_for_link["spip_$link_table"][] = $nom;
294
-						}
295
-					}
296
-				}
297
-			}
298
-		}
299
-	}
300
-
301
-	$liste_tables = array_merge(array_keys($tables_principales), array_keys($tables_auxiliaires), array_keys($tables));
302
-	foreach ($liste_tables as $table) {
303
-		//		$name = preg_replace("{^spip_}","",$table);
304
-		if (!isset($tables_pointees[$table])
305
-			&& !in_array($table, $exclude_tables)
306
-			&& !isset($tables_for_link[$table])
307
-		) {
308
-			$tables_for_dump[] = $table;
309
-			$tables_pointees[$table] = 1;
310
-		}
311
-	}
312
-	foreach ($tables_for_link as $link_table => $liste) {
313
-		$connecte = true;
314
-		foreach ($liste as $connect_table) {
315
-			if (!in_array($connect_table, $tables_for_dump)) {
316
-				$connecte = false;
317
-			}
318
-		}
319
-		if ($connecte)
320
-			# on ajoute les liaisons en premier
321
-			# si une restauration est interrompue,
322
-			# cela se verra mieux si il manque des objets
323
-			# que des liens
324
-		{
325
-			array_unshift($tables_for_dump, $link_table);
326
-		}
327
-	}
328
-
329
-	return array($tables_for_dump, $tables_for_link);
253
+    $tables_for_dump = array();
254
+    $tables_pointees = array();
255
+    $tables = array();
256
+    $tables_principales = $GLOBALS['tables_principales'];
257
+    $tables_auxiliaires = $GLOBALS['tables_auxiliaires'];
258
+    $tables_jointures = $GLOBALS['tables_jointures'];
259
+
260
+    if (include_spip('base/objets')
261
+        and function_exists('lister_tables_objets_sql')
262
+    ) {
263
+        $tables = lister_tables_objets_sql();
264
+        foreach ($tables as $t => $infos) {
265
+            if ($infos['principale'] and !isset($tables_principales[$t])) {
266
+                $tables_principales[$t] = true;
267
+            }
268
+            if (!$infos['principale'] and !isset($tables_auxiliaires[$t])) {
269
+                $tables_auxiliaires[$t] = true;
270
+            }
271
+            if (count($infos['tables_jointures'])) {
272
+                $tables_jointures[$t] = array_merge(isset($tables_jointures[$t]) ? $tables_jointures[$t] : array(),
273
+                    $infos['tables_jointures']);
274
+            }
275
+        }
276
+    }
277
+
278
+    // on construit un index des tables de liens
279
+    // pour les ajouter SI les deux tables qu'ils connectent sont sauvegardees
280
+    $tables_for_link = array();
281
+    foreach ($tables_jointures as $table => $liste_relations) {
282
+        if (is_array($liste_relations)) {
283
+            $nom = $table;
284
+            if (!isset($tables_auxiliaires[$nom]) && !isset($tables_principales[$nom])) {
285
+                $nom = "spip_$table";
286
+            }
287
+            if (isset($tables_auxiliaires[$nom]) || isset($tables_principales[$nom])) {
288
+                foreach ($liste_relations as $link_table) {
289
+                    if (isset($tables_auxiliaires[$link_table])/*||isset($tables_principales[$link_table])*/) {
290
+                        $tables_for_link[$link_table][] = $nom;
291
+                    } else {
292
+                        if (isset($tables_auxiliaires["spip_$link_table"])/*||isset($tables_principales["spip_$link_table"])*/) {
293
+                            $tables_for_link["spip_$link_table"][] = $nom;
294
+                        }
295
+                    }
296
+                }
297
+            }
298
+        }
299
+    }
300
+
301
+    $liste_tables = array_merge(array_keys($tables_principales), array_keys($tables_auxiliaires), array_keys($tables));
302
+    foreach ($liste_tables as $table) {
303
+        //		$name = preg_replace("{^spip_}","",$table);
304
+        if (!isset($tables_pointees[$table])
305
+            && !in_array($table, $exclude_tables)
306
+            && !isset($tables_for_link[$table])
307
+        ) {
308
+            $tables_for_dump[] = $table;
309
+            $tables_pointees[$table] = 1;
310
+        }
311
+    }
312
+    foreach ($tables_for_link as $link_table => $liste) {
313
+        $connecte = true;
314
+        foreach ($liste as $connect_table) {
315
+            if (!in_array($connect_table, $tables_for_dump)) {
316
+                $connecte = false;
317
+            }
318
+        }
319
+        if ($connecte)
320
+            # on ajoute les liaisons en premier
321
+            # si une restauration est interrompue,
322
+            # cela se verra mieux si il manque des objets
323
+            # que des liens
324
+        {
325
+            array_unshift($tables_for_dump, $link_table);
326
+        }
327
+    }
328
+
329
+    return array($tables_for_dump, $tables_for_link);
330 330
 }
331 331
 
332 332
 /**
@@ -341,34 +341,34 @@  discard block
 block discarded – undo
341 341
  * @param string $serveur
342 342
  */
343 343
 function base_vider_tables_destination_copie($tables, $exclure_tables = array(), $serveur = '') {
344
-	$trouver_table = charger_fonction('trouver_table', 'base');
345
-
346
-	spip_log('Vider ' . count($tables) . " tables sur serveur '$serveur' : " . join(', ', $tables),
347
-		'base.' . _LOG_INFO_IMPORTANTE);
348
-	foreach ($tables as $table) {
349
-		if (!in_array($table, $exclure_tables)) {
350
-			// sur le serveur principal, il ne faut pas supprimer l'auteur loge !
351
-			if (($table != 'spip_auteurs') or $serveur != '') {
352
-				// regarder si il y a au moins un champ impt='non'
353
-				$desc = $trouver_table($table, $serveur);
354
-				if (isset($desc['field']['impt'])) {
355
-					sql_delete($table, "impt='oui'", $serveur);
356
-				} elseif ($desc) {
357
-					sql_delete($table, "", $serveur);
358
-				}
359
-			}
360
-		}
361
-	}
362
-
363
-	// sur le serveur principal, il ne faut pas supprimer l'auteur loge !
364
-	// Bidouille pour garder l'acces admin actuel pendant toute la restauration
365
-	if ($serveur == ''
366
-		and in_array('spip_auteurs', $tables)
367
-		and !in_array('spip_auteurs', $exclure_tables)
368
-	) {
369
-		base_conserver_copieur(true, $serveur);
370
-		sql_delete("spip_auteurs", "id_auteur>0", $serveur);
371
-	}
344
+    $trouver_table = charger_fonction('trouver_table', 'base');
345
+
346
+    spip_log('Vider ' . count($tables) . " tables sur serveur '$serveur' : " . join(', ', $tables),
347
+        'base.' . _LOG_INFO_IMPORTANTE);
348
+    foreach ($tables as $table) {
349
+        if (!in_array($table, $exclure_tables)) {
350
+            // sur le serveur principal, il ne faut pas supprimer l'auteur loge !
351
+            if (($table != 'spip_auteurs') or $serveur != '') {
352
+                // regarder si il y a au moins un champ impt='non'
353
+                $desc = $trouver_table($table, $serveur);
354
+                if (isset($desc['field']['impt'])) {
355
+                    sql_delete($table, "impt='oui'", $serveur);
356
+                } elseif ($desc) {
357
+                    sql_delete($table, "", $serveur);
358
+                }
359
+            }
360
+        }
361
+    }
362
+
363
+    // sur le serveur principal, il ne faut pas supprimer l'auteur loge !
364
+    // Bidouille pour garder l'acces admin actuel pendant toute la restauration
365
+    if ($serveur == ''
366
+        and in_array('spip_auteurs', $tables)
367
+        and !in_array('spip_auteurs', $exclure_tables)
368
+    ) {
369
+        base_conserver_copieur(true, $serveur);
370
+        sql_delete("spip_auteurs", "id_auteur>0", $serveur);
371
+    }
372 372
 }
373 373
 
374 374
 /**
@@ -379,21 +379,21 @@  discard block
 block discarded – undo
379 379
  * @return void
380 380
  */
381 381
 function base_conserver_copieur($move = true, $serveur = '') {
382
-	// s'asurer qu'on a pas deja fait la manip !
383
-	if ($GLOBALS['visiteur_session']['id_auteur'] > 0 and sql_countsel("spip_auteurs", "id_auteur>0")) {
384
-		spip_log('Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
385
-			'dump.' . _LOG_INFO_IMPORTANTE);
386
-		sql_delete("spip_auteurs", "id_auteur<0", $serveur);
387
-		if ($move) {
388
-			sql_updateq('spip_auteurs', array('id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']),
389
-				"id_auteur=" . intval($GLOBALS['visiteur_session']['id_auteur']), array(), $serveur);
390
-		} else {
391
-			$row = sql_fetsel('*', 'spip_auteurs', 'id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'], '', '', '', '',
392
-				$serveur);
393
-			$row['id_auteur'] = -$GLOBALS['visiteur_session']['id_auteur'];
394
-			sql_insertq('spip_auteurs', $row, array(), $serveur);
395
-		}
396
-	}
382
+    // s'asurer qu'on a pas deja fait la manip !
383
+    if ($GLOBALS['visiteur_session']['id_auteur'] > 0 and sql_countsel("spip_auteurs", "id_auteur>0")) {
384
+        spip_log('Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
385
+            'dump.' . _LOG_INFO_IMPORTANTE);
386
+        sql_delete("spip_auteurs", "id_auteur<0", $serveur);
387
+        if ($move) {
388
+            sql_updateq('spip_auteurs', array('id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']),
389
+                "id_auteur=" . intval($GLOBALS['visiteur_session']['id_auteur']), array(), $serveur);
390
+        } else {
391
+            $row = sql_fetsel('*', 'spip_auteurs', 'id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'], '', '', '', '',
392
+                $serveur);
393
+            $row['id_auteur'] = -$GLOBALS['visiteur_session']['id_auteur'];
394
+            sql_insertq('spip_auteurs', $row, array(), $serveur);
395
+        }
396
+    }
397 397
 }
398 398
 
399 399
 /**
@@ -408,19 +408,19 @@  discard block
 block discarded – undo
408 408
  * @param string $serveur
409 409
  */
410 410
 function base_detruire_copieur_si_besoin($serveur = '') {
411
-	// rien a faire si ce n'est pas le serveur principal !
412
-	if ($serveur == '') {
413
-		if (sql_countsel("spip_auteurs", "id_auteur>0")) {
414
-			spip_log("Detruire copieur id_auteur<0 pour le serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
415
-			sql_delete("spip_auteurs", "id_auteur<0", $serveur);
416
-		} else {
417
-			spip_log("Restaurer copieur id_auteur<0 pour le serveur '$serveur' (aucun autre auteur en base)",
418
-				'dump.' . _LOG_INFO_IMPORTANTE);
419
-			sql_update('spip_auteurs', array('id_auteur' => '-id_auteur'), "id_auteur<0");
420
-		}
421
-	} else {
422
-		spip_log("Pas de destruction copieur sur serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
423
-	}
411
+    // rien a faire si ce n'est pas le serveur principal !
412
+    if ($serveur == '') {
413
+        if (sql_countsel("spip_auteurs", "id_auteur>0")) {
414
+            spip_log("Detruire copieur id_auteur<0 pour le serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
415
+            sql_delete("spip_auteurs", "id_auteur<0", $serveur);
416
+        } else {
417
+            spip_log("Restaurer copieur id_auteur<0 pour le serveur '$serveur' (aucun autre auteur en base)",
418
+                'dump.' . _LOG_INFO_IMPORTANTE);
419
+            sql_update('spip_auteurs', array('id_auteur' => '-id_auteur'), "id_auteur<0");
420
+        }
421
+    } else {
422
+        spip_log("Pas de destruction copieur sur serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
423
+    }
424 424
 }
425 425
 
426 426
 /**
@@ -435,40 +435,40 @@  discard block
 block discarded – undo
435 435
  * @return array
436 436
  */
437 437
 function base_preparer_table_dest($table, $desc, $serveur_dest, $init = false) {
438
-	$upgrade = false;
439
-	// si la table existe et qu'on est a l'init, la dropper
440
-	if ($desc_dest = sql_showtable($table, true, $serveur_dest) and $init) {
441
-		if ($serveur_dest == '' and in_array($table, array('spip_meta', 'spip_auteurs'))) {
442
-			// ne pas dropper auteurs et meta sur le serveur principal
443
-			// faire un simple upgrade a la place
444
-			// pour ajouter les champs manquants
445
-			$upgrade = true;
446
-			// coherence avec le drop sur les autres tables
447
-			base_vider_tables_destination_copie(array($table), array(), $serveur_dest);
448
-			if ($table == 'spip_meta') {
449
-				// virer les version base qui vont venir avec l'import
450
-				sql_delete($table, "nom like '%_base_version'", $serveur_dest);
451
-				// hum casse la base si pas version_installee a l'import ...
452
-				sql_delete($table, "nom='version_installee'", $serveur_dest);
453
-			}
454
-		} else {
455
-			sql_drop_table($table, '', $serveur_dest);
456
-			spip_log("drop table '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
457
-		}
458
-		$desc_dest = false;
459
-	}
460
-	// si la table n'existe pas dans la destination, la creer a l'identique !
461
-	if (!$desc_dest) {
462
-		spip_log("creation '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
463
-		include_spip('base/create');
464
-		creer_ou_upgrader_table($table, $desc, 'auto', $upgrade, $serveur_dest);
465
-		$desc_dest = sql_showtable($table, true, $serveur_dest);
466
-	}
467
-	if (!$desc_dest) {
468
-		spip_log("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1), 'dump.' . _LOG_ERREUR);
469
-	}
470
-
471
-	return $desc_dest;
438
+    $upgrade = false;
439
+    // si la table existe et qu'on est a l'init, la dropper
440
+    if ($desc_dest = sql_showtable($table, true, $serveur_dest) and $init) {
441
+        if ($serveur_dest == '' and in_array($table, array('spip_meta', 'spip_auteurs'))) {
442
+            // ne pas dropper auteurs et meta sur le serveur principal
443
+            // faire un simple upgrade a la place
444
+            // pour ajouter les champs manquants
445
+            $upgrade = true;
446
+            // coherence avec le drop sur les autres tables
447
+            base_vider_tables_destination_copie(array($table), array(), $serveur_dest);
448
+            if ($table == 'spip_meta') {
449
+                // virer les version base qui vont venir avec l'import
450
+                sql_delete($table, "nom like '%_base_version'", $serveur_dest);
451
+                // hum casse la base si pas version_installee a l'import ...
452
+                sql_delete($table, "nom='version_installee'", $serveur_dest);
453
+            }
454
+        } else {
455
+            sql_drop_table($table, '', $serveur_dest);
456
+            spip_log("drop table '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
457
+        }
458
+        $desc_dest = false;
459
+    }
460
+    // si la table n'existe pas dans la destination, la creer a l'identique !
461
+    if (!$desc_dest) {
462
+        spip_log("creation '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
463
+        include_spip('base/create');
464
+        creer_ou_upgrader_table($table, $desc, 'auto', $upgrade, $serveur_dest);
465
+        $desc_dest = sql_showtable($table, true, $serveur_dest);
466
+    }
467
+    if (!$desc_dest) {
468
+        spip_log("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1), 'dump.' . _LOG_ERREUR);
469
+    }
470
+
471
+    return $desc_dest;
472 472
 }
473 473
 
474 474
 /**
@@ -514,186 +514,186 @@  discard block
 block discarded – undo
514 514
  */
515 515
 function base_copier_tables($status_file, $tables, $serveur_source, $serveur_dest, $options = array()) {
516 516
 
517
-	$callback_progression = isset($options['callback_progression']) ? $options['callback_progression'] : '';
518
-	$max_time = isset($options['max_time']) ? $options['max_time'] : 0;
519
-	$drop_source = isset($options['drop_source']) ? $options['drop_source'] : false;
520
-	$no_erase_dest = isset($options['no_erase_dest']) ? $options['no_erase_dest'] : array();
521
-	$where = isset($options['where']) ? $options['where'] : array();
522
-	$fonction_base_inserer = isset($options['fonction_base_inserer']) ? $options['fonction_base_inserer'] : 'inserer_copie';
523
-	$desc_tables_dest = isset($options['desc_tables_dest']) ? $options['desc_tables_dest'] : array();
524
-	$racine_fonctions = (isset($options['racine_fonctions_dest']) ? $options['racine_fonctions_dest'] : 'base');
525
-	$data_pool = (isset($options['data_pool']) ? $options['data_pool'] : 50 * 1024);
526
-
527
-	spip_log("Copier " . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
528
-		'dump.' . _LOG_INFO_IMPORTANTE);
529
-
530
-	if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
531
-		spip_log("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
532
-
533
-		return true; // echec mais on a fini, donc true
534
-	}
535
-	if (!$preparer_table_dest = charger_fonction('preparer_table_dest', $racine_fonctions, true)) {
536
-		spip_log("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
537
-
538
-		return true; // echec mais on a fini, donc true
539
-	}
540
-
541
-	if (!lire_fichier($status_file, $status)
542
-		or !$status = unserialize($status)
543
-	) {
544
-		$status = array();
545
-	}
546
-	$status['etape'] = 'basecopie';
547
-
548
-	// puis relister les tables a importer
549
-	// et les vider si besoin, au moment du premier passage ici
550
-	$initialisation_copie = (!isset($status["dump_status_copie"])) ? 0 : $status["dump_status_copie"];
551
-
552
-	// si init pas encore faite, vider les tables du serveur destination
553
-	if (!$initialisation_copie) {
554
-		if (!$vider_tables_destination_copie = charger_fonction('vider_tables_destination_copie', $racine_fonctions,
555
-			true)
556
-		) {
557
-			spip_log("Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",
558
-				'dump.' . _LOG_INFO_IMPORTANTE);
559
-
560
-			return true; // echec mais on a fini, donc true
561
-		}
562
-		$vider_tables_destination_copie($tables, $no_erase_dest, $serveur_dest);
563
-		$status["dump_status_copie"] = 'ok';
564
-		ecrire_fichier($status_file, serialize($status));
565
-	}
566
-
567
-	// les tables auteurs et meta doivent etre copiees en dernier !
568
-	if (in_array('spip_auteurs', $tables)) {
569
-		$tables = array_diff($tables, array('spip_auteurs'));
570
-		$tables[] = 'spip_auteurs';
571
-	}
572
-	if (in_array('spip_meta', $tables)) {
573
-		$tables = array_diff($tables, array('spip_meta'));
574
-		$tables[] = 'spip_meta';
575
-	}
576
-	spip_log("Tables a copier :" . implode(", ", $tables), 'dump.' . _LOG_INFO);
577
-
578
-	$trouver_table = charger_fonction('trouver_table', 'base');
579
-
580
-	foreach ($tables as $table) {
581
-		// si table commence par spip_ c'est une table SPIP, renommer le prefixe si besoin
582
-		// sinon chercher la vraie table
583
-		$desc_source = false;
584
-		if (strncmp($table, "spip_", 5) == 0) {
585
-			$desc_source = $trouver_table(preg_replace(",^spip_,", "", $table), $serveur_source, true);
586
-		}
587
-		if (!$desc_source or !isset($desc_source['exist']) or !$desc_source['exist']) {
588
-			$desc_source = $trouver_table($table, $serveur_source, false);
589
-		}
590
-
591
-		// verifier que la table est presente dans la base source
592
-		if ($desc_source) {
593
-			// $status['tables_copiees'][$table] contient l'avancement
594
-			// de la copie pour la $table : 0 a N et -N quand elle est finie (-1 si vide et finie...)
595
-			if (!isset($status['tables_copiees'][$table])) {
596
-				$status['tables_copiees'][$table] = 0;
597
-			}
598
-
599
-			if (is_numeric($status['tables_copiees'][$table])
600
-				and $status['tables_copiees'][$table] >= 0
601
-				and $desc_dest = $preparer_table_dest(
602
-					$table,
603
-					isset($desc_tables_dest[$table]) ? $desc_tables_dest[$table] : $desc_source,
604
-					$serveur_dest,
605
-					$status['tables_copiees'][$table] == 0)
606
-			) {
607
-				if ($callback_progression) {
608
-					$callback_progression($status['tables_copiees'][$table], 0, $table);
609
-				}
610
-				while (true) {
611
-					$n = intval($status['tables_copiees'][$table]);
612
-					// on copie par lot de 400
613
-					$res = sql_select('*', $table, isset($where[$table]) ? $where[$table] : '', '', '', "$n,400", '',
614
-						$serveur_source);
615
-					while ($row = sql_fetch($res, $serveur_source)) {
616
-						$rows = array($row);
617
-						// lire un groupe de donnees si demande en option
618
-						// (permet un envoi par lot vers la destination)
619
-						if ($data_pool > 0) {
620
-							$s = strlen(serialize($row));
621
-							while ($s < $data_pool and $row = sql_fetch($res, $serveur_source)) {
622
-								$s += strlen(serialize($row));
623
-								$rows[] = $row;
624
-							}
625
-						}
626
-						// si l'enregistrement est deja en base, ca fera un echec ou un doublon
627
-						// mais si ca renvoie false c'est une erreur fatale => abandon
628
-						if ($inserer_copie($table, $rows, $desc_dest, $serveur_dest) === false) {
629
-							// forcer la sortie, charge a l'appelant de gerer l'echec
630
-							spip_log("Erreur fatale dans $inserer_copie table $table", "dump" . _LOG_ERREUR);
631
-							$status['errors'][] = "Erreur fatale  lors de la copie de la table $table";
632
-							ecrire_fichier($status_file, serialize($status));
633
-
634
-							// copie finie
635
-							return true;
636
-						}
637
-						$status['tables_copiees'][$table] += count($rows);
638
-						if ($max_time and time() > $max_time) {
639
-							break;
640
-						}
641
-					}
642
-					if ($n == $status['tables_copiees'][$table]) {
643
-						break;
644
-					}
645
-					spip_log("recopie $table " . $status['tables_copiees'][$table], 'dump.' . _LOG_INFO_IMPORTANTE);
646
-					if ($callback_progression) {
647
-						$callback_progression($status['tables_copiees'][$table], 0, $table);
648
-					}
649
-					ecrire_fichier($status_file, serialize($status));
650
-					if ($max_time and time() > $max_time) {
651
-						return false;
652
-					} // on a pas fini, mais le temps imparti est ecoule
653
-				}
654
-				if ($drop_source) {
655
-					sql_drop_table($table, '', $serveur_source);
656
-					spip_log("drop $table sur serveur source '$serveur_source'", 'dump.' . _LOG_INFO_IMPORTANTE);
657
-				}
658
-				$status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : "zero");
659
-				ecrire_fichier($status_file, serialize($status));
660
-				spip_log("tables_recopiees " . implode(',', array_keys($status['tables_copiees'])), 'dump.' . _LOG_INFO);
661
-				if ($callback_progression) {
662
-					$callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
663
-				}
664
-			} else {
665
-				if ($status['tables_copiees'][$table] < 0) {
666
-					spip_log("Table $table deja copiee : " . $status['tables_copiees'][$table], "dump." . _LOG_INFO);
667
-				}
668
-				if ($callback_progression) {
669
-					$callback_progression(0, $status['tables_copiees'][$table],
670
-						"$table" . ((is_numeric($status['tables_copiees'][$table]) and $status['tables_copiees'][$table] >= 0) ? "[Echec]" : ""));
671
-				}
672
-			}
673
-		} else {
674
-			$status['errors'][] = "Impossible de lire la description de la table $table";
675
-			ecrire_fichier($status_file, serialize($status));
676
-			spip_log("Impossible de lire la description de la table $table", "dump." . _LOG_ERREUR);
677
-		}
678
-	}
679
-
680
-	// si le nombre de tables envoyees n'est pas egal au nombre de tables demandees
681
-	// abandonner
682
-	if (count($status['tables_copiees']) < count($tables)) {
683
-		spip_log("Nombre de tables copiees incorrect : " . count($status['tables_copiees']) . "/" . count($tables),
684
-			"dump." . _LOG_ERREUR);
685
-		$status['errors'][] = "Nombre de tables copiees incorrect : " . count($status['tables_copiees']) . "/" . count($tables);
686
-		ecrire_fichier($status_file, serialize($status));
687
-	}
688
-
689
-	if ($detruire_copieur_si_besoin = charger_fonction('detruire_copieur_si_besoin', $racine_fonctions, true)) {
690
-		$detruire_copieur_si_besoin($serveur_dest);
691
-	} else {
692
-		spip_log("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.", 'dump.' . _LOG_INFO_IMPORTANTE);
693
-	}
694
-
695
-	// OK, copie complete
696
-	return true;
517
+    $callback_progression = isset($options['callback_progression']) ? $options['callback_progression'] : '';
518
+    $max_time = isset($options['max_time']) ? $options['max_time'] : 0;
519
+    $drop_source = isset($options['drop_source']) ? $options['drop_source'] : false;
520
+    $no_erase_dest = isset($options['no_erase_dest']) ? $options['no_erase_dest'] : array();
521
+    $where = isset($options['where']) ? $options['where'] : array();
522
+    $fonction_base_inserer = isset($options['fonction_base_inserer']) ? $options['fonction_base_inserer'] : 'inserer_copie';
523
+    $desc_tables_dest = isset($options['desc_tables_dest']) ? $options['desc_tables_dest'] : array();
524
+    $racine_fonctions = (isset($options['racine_fonctions_dest']) ? $options['racine_fonctions_dest'] : 'base');
525
+    $data_pool = (isset($options['data_pool']) ? $options['data_pool'] : 50 * 1024);
526
+
527
+    spip_log("Copier " . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
528
+        'dump.' . _LOG_INFO_IMPORTANTE);
529
+
530
+    if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
531
+        spip_log("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
532
+
533
+        return true; // echec mais on a fini, donc true
534
+    }
535
+    if (!$preparer_table_dest = charger_fonction('preparer_table_dest', $racine_fonctions, true)) {
536
+        spip_log("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
537
+
538
+        return true; // echec mais on a fini, donc true
539
+    }
540
+
541
+    if (!lire_fichier($status_file, $status)
542
+        or !$status = unserialize($status)
543
+    ) {
544
+        $status = array();
545
+    }
546
+    $status['etape'] = 'basecopie';
547
+
548
+    // puis relister les tables a importer
549
+    // et les vider si besoin, au moment du premier passage ici
550
+    $initialisation_copie = (!isset($status["dump_status_copie"])) ? 0 : $status["dump_status_copie"];
551
+
552
+    // si init pas encore faite, vider les tables du serveur destination
553
+    if (!$initialisation_copie) {
554
+        if (!$vider_tables_destination_copie = charger_fonction('vider_tables_destination_copie', $racine_fonctions,
555
+            true)
556
+        ) {
557
+            spip_log("Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",
558
+                'dump.' . _LOG_INFO_IMPORTANTE);
559
+
560
+            return true; // echec mais on a fini, donc true
561
+        }
562
+        $vider_tables_destination_copie($tables, $no_erase_dest, $serveur_dest);
563
+        $status["dump_status_copie"] = 'ok';
564
+        ecrire_fichier($status_file, serialize($status));
565
+    }
566
+
567
+    // les tables auteurs et meta doivent etre copiees en dernier !
568
+    if (in_array('spip_auteurs', $tables)) {
569
+        $tables = array_diff($tables, array('spip_auteurs'));
570
+        $tables[] = 'spip_auteurs';
571
+    }
572
+    if (in_array('spip_meta', $tables)) {
573
+        $tables = array_diff($tables, array('spip_meta'));
574
+        $tables[] = 'spip_meta';
575
+    }
576
+    spip_log("Tables a copier :" . implode(", ", $tables), 'dump.' . _LOG_INFO);
577
+
578
+    $trouver_table = charger_fonction('trouver_table', 'base');
579
+
580
+    foreach ($tables as $table) {
581
+        // si table commence par spip_ c'est une table SPIP, renommer le prefixe si besoin
582
+        // sinon chercher la vraie table
583
+        $desc_source = false;
584
+        if (strncmp($table, "spip_", 5) == 0) {
585
+            $desc_source = $trouver_table(preg_replace(",^spip_,", "", $table), $serveur_source, true);
586
+        }
587
+        if (!$desc_source or !isset($desc_source['exist']) or !$desc_source['exist']) {
588
+            $desc_source = $trouver_table($table, $serveur_source, false);
589
+        }
590
+
591
+        // verifier que la table est presente dans la base source
592
+        if ($desc_source) {
593
+            // $status['tables_copiees'][$table] contient l'avancement
594
+            // de la copie pour la $table : 0 a N et -N quand elle est finie (-1 si vide et finie...)
595
+            if (!isset($status['tables_copiees'][$table])) {
596
+                $status['tables_copiees'][$table] = 0;
597
+            }
598
+
599
+            if (is_numeric($status['tables_copiees'][$table])
600
+                and $status['tables_copiees'][$table] >= 0
601
+                and $desc_dest = $preparer_table_dest(
602
+                    $table,
603
+                    isset($desc_tables_dest[$table]) ? $desc_tables_dest[$table] : $desc_source,
604
+                    $serveur_dest,
605
+                    $status['tables_copiees'][$table] == 0)
606
+            ) {
607
+                if ($callback_progression) {
608
+                    $callback_progression($status['tables_copiees'][$table], 0, $table);
609
+                }
610
+                while (true) {
611
+                    $n = intval($status['tables_copiees'][$table]);
612
+                    // on copie par lot de 400
613
+                    $res = sql_select('*', $table, isset($where[$table]) ? $where[$table] : '', '', '', "$n,400", '',
614
+                        $serveur_source);
615
+                    while ($row = sql_fetch($res, $serveur_source)) {
616
+                        $rows = array($row);
617
+                        // lire un groupe de donnees si demande en option
618
+                        // (permet un envoi par lot vers la destination)
619
+                        if ($data_pool > 0) {
620
+                            $s = strlen(serialize($row));
621
+                            while ($s < $data_pool and $row = sql_fetch($res, $serveur_source)) {
622
+                                $s += strlen(serialize($row));
623
+                                $rows[] = $row;
624
+                            }
625
+                        }
626
+                        // si l'enregistrement est deja en base, ca fera un echec ou un doublon
627
+                        // mais si ca renvoie false c'est une erreur fatale => abandon
628
+                        if ($inserer_copie($table, $rows, $desc_dest, $serveur_dest) === false) {
629
+                            // forcer la sortie, charge a l'appelant de gerer l'echec
630
+                            spip_log("Erreur fatale dans $inserer_copie table $table", "dump" . _LOG_ERREUR);
631
+                            $status['errors'][] = "Erreur fatale  lors de la copie de la table $table";
632
+                            ecrire_fichier($status_file, serialize($status));
633
+
634
+                            // copie finie
635
+                            return true;
636
+                        }
637
+                        $status['tables_copiees'][$table] += count($rows);
638
+                        if ($max_time and time() > $max_time) {
639
+                            break;
640
+                        }
641
+                    }
642
+                    if ($n == $status['tables_copiees'][$table]) {
643
+                        break;
644
+                    }
645
+                    spip_log("recopie $table " . $status['tables_copiees'][$table], 'dump.' . _LOG_INFO_IMPORTANTE);
646
+                    if ($callback_progression) {
647
+                        $callback_progression($status['tables_copiees'][$table], 0, $table);
648
+                    }
649
+                    ecrire_fichier($status_file, serialize($status));
650
+                    if ($max_time and time() > $max_time) {
651
+                        return false;
652
+                    } // on a pas fini, mais le temps imparti est ecoule
653
+                }
654
+                if ($drop_source) {
655
+                    sql_drop_table($table, '', $serveur_source);
656
+                    spip_log("drop $table sur serveur source '$serveur_source'", 'dump.' . _LOG_INFO_IMPORTANTE);
657
+                }
658
+                $status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : "zero");
659
+                ecrire_fichier($status_file, serialize($status));
660
+                spip_log("tables_recopiees " . implode(',', array_keys($status['tables_copiees'])), 'dump.' . _LOG_INFO);
661
+                if ($callback_progression) {
662
+                    $callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
663
+                }
664
+            } else {
665
+                if ($status['tables_copiees'][$table] < 0) {
666
+                    spip_log("Table $table deja copiee : " . $status['tables_copiees'][$table], "dump." . _LOG_INFO);
667
+                }
668
+                if ($callback_progression) {
669
+                    $callback_progression(0, $status['tables_copiees'][$table],
670
+                        "$table" . ((is_numeric($status['tables_copiees'][$table]) and $status['tables_copiees'][$table] >= 0) ? "[Echec]" : ""));
671
+                }
672
+            }
673
+        } else {
674
+            $status['errors'][] = "Impossible de lire la description de la table $table";
675
+            ecrire_fichier($status_file, serialize($status));
676
+            spip_log("Impossible de lire la description de la table $table", "dump." . _LOG_ERREUR);
677
+        }
678
+    }
679
+
680
+    // si le nombre de tables envoyees n'est pas egal au nombre de tables demandees
681
+    // abandonner
682
+    if (count($status['tables_copiees']) < count($tables)) {
683
+        spip_log("Nombre de tables copiees incorrect : " . count($status['tables_copiees']) . "/" . count($tables),
684
+            "dump." . _LOG_ERREUR);
685
+        $status['errors'][] = "Nombre de tables copiees incorrect : " . count($status['tables_copiees']) . "/" . count($tables);
686
+        ecrire_fichier($status_file, serialize($status));
687
+    }
688
+
689
+    if ($detruire_copieur_si_besoin = charger_fonction('detruire_copieur_si_besoin', $racine_fonctions, true)) {
690
+        $detruire_copieur_si_besoin($serveur_dest);
691
+    } else {
692
+        spip_log("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.", 'dump.' . _LOG_INFO_IMPORTANTE);
693
+    }
694
+
695
+    // OK, copie complete
696
+    return true;
697 697
 }
698 698
 
699 699
 /**
@@ -707,27 +707,27 @@  discard block
 block discarded – undo
707 707
  */
708 708
 function base_inserer_copie($table, $rows, $desc_dest, $serveur_dest) {
709 709
 
710
-	// verifier le nombre d'insertion
711
-	$nb1 = sql_countsel($table, '', '', '', $serveur_dest);
712
-	// si l'enregistrement est deja en base, ca fera un echec ou un doublon
713
-	$r = sql_insertq_multi($table, $rows, $desc_dest, $serveur_dest);
714
-	$nb = sql_countsel($table, '', '', '', $serveur_dest);
715
-	if ($nb - $nb1 < count($rows)) {
716
-		spip_log("base_inserer_copie : " . ($nb - $nb1) . " insertions au lieu de " . count($rows) . ". On retente 1 par 1",
717
-			"dump" . _LOG_INFO_IMPORTANTE);
718
-		foreach ($rows as $row) {
719
-			// si l'enregistrement est deja en base, ca fera un echec ou un doublon
720
-			$r = sql_insertq($table, $row, $desc_dest, $serveur_dest);
721
-		}
722
-		// on reverifie le total
723
-		$r = 0;
724
-		$nb = sql_countsel($table, '', '', '', $serveur_dest);
725
-		if ($nb - $nb1 < count($rows)) {
726
-			spip_log("base_inserer_copie : " . ($nb - $nb1) . " insertions au lieu de " . count($rows) . " apres insertion 1 par 1",
727
-				"dump" . _LOG_ERREUR);
728
-			$r = false;
729
-		}
730
-	}
731
-
732
-	return $r;
710
+    // verifier le nombre d'insertion
711
+    $nb1 = sql_countsel($table, '', '', '', $serveur_dest);
712
+    // si l'enregistrement est deja en base, ca fera un echec ou un doublon
713
+    $r = sql_insertq_multi($table, $rows, $desc_dest, $serveur_dest);
714
+    $nb = sql_countsel($table, '', '', '', $serveur_dest);
715
+    if ($nb - $nb1 < count($rows)) {
716
+        spip_log("base_inserer_copie : " . ($nb - $nb1) . " insertions au lieu de " . count($rows) . ". On retente 1 par 1",
717
+            "dump" . _LOG_INFO_IMPORTANTE);
718
+        foreach ($rows as $row) {
719
+            // si l'enregistrement est deja en base, ca fera un echec ou un doublon
720
+            $r = sql_insertq($table, $row, $desc_dest, $serveur_dest);
721
+        }
722
+        // on reverifie le total
723
+        $r = 0;
724
+        $nb = sql_countsel($table, '', '', '', $serveur_dest);
725
+        if ($nb - $nb1 < count($rows)) {
726
+            spip_log("base_inserer_copie : " . ($nb - $nb1) . " insertions au lieu de " . count($rows) . " apres insertion 1 par 1",
727
+                "dump" . _LOG_ERREUR);
728
+            $r = false;
729
+        }
730
+    }
731
+
732
+    return $r;
733 733
 }
Please login to merge, or discard this patch.
ecrire/base/serial.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -21,7 +21,7 @@
 block discarded – undo
21 21
  **/
22 22
 
23 23
 if (!defined('_ECRIRE_INC_VERSION')) {
24
-	return;
24
+    return;
25 25
 }
26 26
 
27 27
 include_spip('base/objets');
Please login to merge, or discard this patch.
prive/objets/liste/auteurs_associer_fonctions.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -11,7 +11,7 @@
 block discarded – undo
11 11
 \***************************************************************************/
12 12
 
13 13
 if (!defined('_ECRIRE_INC_VERSION')) {
14
-	return;
14
+    return;
15 15
 }
16 16
 
17 17
 include_spip('prive/objets/liste/auteurs_fonctions');
Please login to merge, or discard this patch.
prive/objets/liste/visiteurs_fonctions.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -11,7 +11,7 @@
 block discarded – undo
11 11
 \***************************************************************************/
12 12
 
13 13
 if (!defined('_ECRIRE_INC_VERSION')) {
14
-	return;
14
+    return;
15 15
 }
16 16
 
17 17
 include_spip('prive/objets/liste/auteurs_fonctions');
Please login to merge, or discard this patch.