@@ -11,7 +11,7 @@ discard block |
||
| 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 |
||
| 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 |
||
| 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 | } |
@@ -57,8 +57,8 @@ discard block |
||
| 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 |
||
| 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 |
||
| 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 | } |
@@ -17,7 +17,7 @@ discard block |
||
| 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 |
||
| 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 |
||
| 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 | } |
@@ -17,7 +17,7 @@ discard block |
||
| 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 |
||
| 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 | } |
@@ -45,12 +45,12 @@ |
||
| 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 | } |
@@ -18,7 +18,7 @@ discard block |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 | } |
@@ -16,7 +16,7 @@ discard block |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 | } |
@@ -17,7 +17,7 @@ discard block |
||
| 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 |
||
| 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 | } |
@@ -51,5 +51,5 @@ |
||
| 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 | } |
@@ -326,14 +326,15 @@ |
||
| 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); |
@@ -38,7 +38,7 @@ discard block |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 | } |
@@ -17,7 +17,7 @@ discard block |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 |
||
| 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 | } |
@@ -21,7 +21,7 @@ |
||
| 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'); |
@@ -11,7 +11,7 @@ |
||
| 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'); |
@@ -11,7 +11,7 @@ |
||
| 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'); |