@@ -80,9 +80,9 @@ discard block |
||
| 80 | 80 | // de connexion, et tout risque d'ambiguite |
| 81 | 81 | if (!isset($nom_cache_desc_sql[$serveur][$objets_sql])) { |
| 82 | 82 | $nom_cache_desc_sql[$serveur][$objets_sql] = |
| 83 | - _DIR_CACHE . 'sql_desc_' |
|
| 83 | + _DIR_CACHE.'sql_desc_' |
|
| 84 | 84 | . ($serveur ? "{$serveur}_" : "") |
| 85 | - . substr(md5($connexion['db'] . ":" . $connexion['prefixe'] . ":$objets_sql"), 0, 8) |
|
| 85 | + . substr(md5($connexion['db'].":".$connexion['prefixe'].":$objets_sql"), 0, 8) |
|
| 86 | 86 | . '.txt'; |
| 87 | 87 | // nouveau nom de cache = nouvelle version en memoire |
| 88 | 88 | unset($connexion['tables']); |
@@ -110,7 +110,7 @@ discard block |
||
| 110 | 110 | if ($connexion['spip_connect_version']) { |
| 111 | 111 | if ($table_spip and isset($GLOBALS['table_des_tables'][$nom])) { |
| 112 | 112 | $nom = $GLOBALS['table_des_tables'][$nom]; |
| 113 | - $nom_sql = 'spip_' . $nom; |
|
| 113 | + $nom_sql = 'spip_'.$nom; |
|
| 114 | 114 | } |
| 115 | 115 | } |
| 116 | 116 | |
@@ -136,11 +136,11 @@ discard block |
||
| 136 | 136 | // meme si pas d'abreviation declaree, trouver la table spip_$nom |
| 137 | 137 | // si c'est une table principale, |
| 138 | 138 | // puisqu'on le fait aussi pour les tables auxiliaires |
| 139 | - elseif ($nom_sql == $nom and isset($GLOBALS['tables_principales']['spip_' . $nom])) { |
|
| 140 | - $nom_sql = 'spip_' . $nom; |
|
| 139 | + elseif ($nom_sql == $nom and isset($GLOBALS['tables_principales']['spip_'.$nom])) { |
|
| 140 | + $nom_sql = 'spip_'.$nom; |
|
| 141 | 141 | $fdesc = &$GLOBALS['tables_principales'][$nom_sql]; |
| 142 | 142 | } elseif (isset($GLOBALS['tables_auxiliaires'][$n = $nom]) |
| 143 | - or isset($GLOBALS['tables_auxiliaires'][$n = 'spip_' . $nom]) |
|
| 143 | + or isset($GLOBALS['tables_auxiliaires'][$n = 'spip_'.$nom]) |
|
| 144 | 144 | ) { |
| 145 | 145 | $nom_sql = $n; |
| 146 | 146 | $fdesc = &$GLOBALS['tables_auxiliaires'][$n]; |
@@ -152,7 +152,7 @@ discard block |
||
| 152 | 152 | $desc = sql_showtable($nom_sql, $table_spip, $serveur); |
| 153 | 153 | if (!$desc or !$desc['field']) { |
| 154 | 154 | if (!$fdesc) { |
| 155 | - spip_log("trouver_table: table inconnue '$serveur' '$nom'", 'base' . _LOG_INFO_IMPORTANTE); |
|
| 155 | + spip_log("trouver_table: table inconnue '$serveur' '$nom'", 'base'._LOG_INFO_IMPORTANTE); |
|
| 156 | 156 | |
| 157 | 157 | return null; |
| 158 | 158 | } |
@@ -164,7 +164,7 @@ discard block |
||
| 164 | 164 | $desc['exist'] = true; |
| 165 | 165 | // gerer le cas des cles vides (echec de l'analyse sur une vue par exemple) |
| 166 | 166 | // pour recuperer la declaration de lister_tables_objets_sql() si il y en a une |
| 167 | - if (! $desc['key']) { |
|
| 167 | + if (!$desc['key']) { |
|
| 168 | 168 | spip_log("trouver_table: table sans cle '$serveur' '$nom'", 'base'); |
| 169 | 169 | unset($desc['key']); |
| 170 | 170 | } |
@@ -178,10 +178,10 @@ discard block |
||
| 178 | 178 | // $desc est prioritaire pour la description de la table |
| 179 | 179 | $desc = array_merge(lister_tables_objets_sql($nom_sql, $desc), $desc); |
| 180 | 180 | // s'assurer qu'on a toujours un 'key' |
| 181 | - if (!isset($desc['key']) && !empty($fdesc['key'])){ |
|
| 181 | + if (!isset($desc['key']) && !empty($fdesc['key'])) { |
|
| 182 | 182 | $desc['key'] = $fdesc['key']; |
| 183 | 183 | } |
| 184 | - if (! isset($desc['key'])) { |
|
| 184 | + if (!isset($desc['key'])) { |
|
| 185 | 185 | $desc['key'] = array(); |
| 186 | 186 | } |
| 187 | 187 | |
@@ -52,7 +52,7 @@ discard block |
||
| 52 | 52 | |
| 53 | 53 | $l = ""; |
| 54 | 54 | if ($primary = id_table_objet($objet) |
| 55 | - and $trouver_table($l = $table_sql . "_liens") |
|
| 55 | + and $trouver_table($l = $table_sql."_liens") |
|
| 56 | 56 | and !preg_match(',[^\w],', $primary) |
| 57 | 57 | and !preg_match(',[^\w],', $l) |
| 58 | 58 | ) { |
@@ -211,7 +211,7 @@ discard block |
||
| 211 | 211 | * @return int |
| 212 | 212 | */ |
| 213 | 213 | function objet_optimiser_liens($objets_source, $objets_lies) { |
| 214 | - spip_log("objet_optimiser_liens : ".json_encode($objets_source) . ', ' . json_encode($objets_lies), 'genie'._LOG_DEBUG); |
|
| 214 | + spip_log("objet_optimiser_liens : ".json_encode($objets_source).', '.json_encode($objets_lies), 'genie'._LOG_DEBUG); |
|
| 215 | 215 | return objet_traiter_liaisons('lien_optimise', $objets_source, $objets_lies); |
| 216 | 216 | } |
| 217 | 217 | |
@@ -401,7 +401,7 @@ discard block |
||
| 401 | 401 | $where = lien_where($primary, '*', $objet, $id_objet); |
| 402 | 402 | $rang = intval(sql_getfetsel('max(rang_lien)', $table_lien, $where)); |
| 403 | 403 | // si aucun lien n'a de rang, on en introduit pas, on garde zero |
| 404 | - if ($rang>0) { |
|
| 404 | + if ($rang > 0) { |
|
| 405 | 405 | $rang = intval($rang) + 1; |
| 406 | 406 | } |
| 407 | 407 | } |
@@ -436,7 +436,7 @@ discard block |
||
| 436 | 436 | |
| 437 | 437 | if (lien_triables($table_lien) and isset($insertions['rang_lien']) and intval($insertions['rang_lien'])) { |
| 438 | 438 | // on decale les liens de rang_lien>=la valeur inseree pour faire la place |
| 439 | - $w = lien_where($primary, '*', $objet, $id_objet, array('rang_lien>='.intval($insertions['rang_lien']),"$primary!=".intval($id))); |
|
| 439 | + $w = lien_where($primary, '*', $objet, $id_objet, array('rang_lien>='.intval($insertions['rang_lien']), "$primary!=".intval($id))); |
|
| 440 | 440 | sql_update($table_lien, array('rang_lien'=>'rang_lien+1'), $w); |
| 441 | 441 | } |
| 442 | 442 | |
@@ -459,7 +459,7 @@ discard block |
||
| 459 | 459 | } |
| 460 | 460 | } |
| 461 | 461 | // si on a fait des insertions, on reordonne les liens concernes |
| 462 | - if ($ins>0) { |
|
| 462 | + if ($ins > 0) { |
|
| 463 | 463 | lien_ordonner($objet_source, $primary, $table_lien, $id, $objets); |
| 464 | 464 | } |
| 465 | 465 | |
@@ -489,10 +489,10 @@ discard block |
||
| 489 | 489 | $objet = (($objet == '*') ? $objet : objet_type($objet)); # securite |
| 490 | 490 | |
| 491 | 491 | $where = lien_where($primary, '*', $objet, $id_objet); |
| 492 | - $liens = sql_allfetsel("$primary, id_objet, objet, rang_lien", $table_lien, $where, $primary,"rang_lien"); |
|
| 492 | + $liens = sql_allfetsel("$primary, id_objet, objet, rang_lien", $table_lien, $where, $primary, "rang_lien"); |
|
| 493 | 493 | |
| 494 | 494 | $rangs = array_column($liens, 'rang_lien'); |
| 495 | - if (count($rangs) and (max($rangs)>0 or min($rangs)<0)) { |
|
| 495 | + if (count($rangs) and (max($rangs) > 0 or min($rangs) < 0)) { |
|
| 496 | 496 | $rang = 1; |
| 497 | 497 | foreach ($liens as $lien) { |
| 498 | 498 | $where = lien_where($primary, $lien[$primary], $objet, $id_objet, array('rang_lien!='.intval($rang))); |
@@ -556,7 +556,7 @@ discard block |
||
| 556 | 556 | |
| 557 | 557 | if ($id_source !== '*') { |
| 558 | 558 | $where[] = (is_array($id_source) ? sql_in(addslashes($primary), array_map('intval', $id_source), |
| 559 | - $not) : addslashes($primary) . ($not ? "<>" : "=") . intval($id_source)); |
|
| 559 | + $not) : addslashes($primary).($not ? "<>" : "=").intval($id_source)); |
|
| 560 | 560 | } elseif ($not) { |
| 561 | 561 | $where[] = "0=1"; |
| 562 | 562 | } // idiot mais quand meme |
@@ -568,11 +568,11 @@ discard block |
||
| 568 | 568 | } |
| 569 | 569 | |
| 570 | 570 | if ($objet !== '*') { |
| 571 | - $where[] = "objet=" . sql_quote($objet); |
|
| 571 | + $where[] = "objet=".sql_quote($objet); |
|
| 572 | 572 | } |
| 573 | 573 | if ($id_objet !== '*') { |
| 574 | 574 | $where[] = (is_array($id_objet) ? sql_in('id_objet', array_map('intval', $id_objet), |
| 575 | - $not) : "id_objet" . ($not ? "<>" : "=") . intval($id_objet)); |
|
| 575 | + $not) : "id_objet".($not ? "<>" : "=").intval($id_objet)); |
|
| 576 | 576 | } elseif ($not) { |
| 577 | 577 | $where[] = "0=1"; |
| 578 | 578 | } // idiot mais quand meme |
@@ -735,19 +735,19 @@ discard block |
||
| 735 | 735 | // il faut les eliminier en repetant la condition dans le where L.objet='xxx' |
| 736 | 736 | "$table_lien AS L |
| 737 | 737 | LEFT JOIN $spip_table_objet AS O |
| 738 | - ON (O.$id_table_objet=L.id_objet AND L.objet=" . sql_quote($type) . ")", |
|
| 739 | - "L.objet=" . sql_quote($type) . " AND O.$id_table_objet IS NULL"); |
|
| 738 | + ON (O.$id_table_objet=L.id_objet AND L.objet=".sql_quote($type).")", |
|
| 739 | + "L.objet=".sql_quote($type)." AND O.$id_table_objet IS NULL"); |
|
| 740 | 740 | // sur une cle primaire composee, pas d'autres solutions que de virer un a un |
| 741 | 741 | while ($row = sql_fetch($res)) { |
| 742 | 742 | if ($primary === 'id_document' and in_array($type, ['site', 'rubrique']) and !intval($row['id_objet'])) { |
| 743 | 743 | continue; // gaffe, c'est le logo du site ou des rubriques! |
| 744 | 744 | } |
| 745 | 745 | $e = sql_delete($table_lien, |
| 746 | - array("$primary=" . $row['id'], "id_objet=" . $row['id_objet'], "objet=" . sql_quote($type))); |
|
| 746 | + array("$primary=".$row['id'], "id_objet=".$row['id_objet'], "objet=".sql_quote($type))); |
|
| 747 | 747 | if ($e != false) { |
| 748 | 748 | $dels += $e; |
| 749 | 749 | spip_log( |
| 750 | - "lien_optimise: Entree " . $row['id'] . "/" . $row['id_objet'] . "/$type supprimee dans la table $table_lien", |
|
| 750 | + "lien_optimise: Entree ".$row['id']."/".$row['id_objet']."/$type supprimee dans la table $table_lien", |
|
| 751 | 751 | 'genie'._LOG_INFO_IMPORTANTE |
| 752 | 752 | ); |
| 753 | 753 | } |
@@ -848,7 +848,7 @@ discard block |
||
| 848 | 848 | if (lien_triables($table_lien) and isset($qualif['rang_lien'])) { |
| 849 | 849 | if (intval($qualif['rang_lien'])) { |
| 850 | 850 | // on decale les liens de rang_lien>=la valeur inseree pour faire la place |
| 851 | - $w = lien_where($primary, '*', $objet, $id_objet, array('rang_lien>='.intval($qualif['rang_lien']),"$primary!=".intval($id))); |
|
| 851 | + $w = lien_where($primary, '*', $objet, $id_objet, array('rang_lien>='.intval($qualif['rang_lien']), "$primary!=".intval($id))); |
|
| 852 | 852 | sql_update($table_lien, array('rang_lien'=>'rang_lien+1'), $w); |
| 853 | 853 | } |
| 854 | 854 | // tous les liens de même rôle recoivent le rang indiqué aussi |
@@ -939,7 +939,7 @@ discard block |
||
| 939 | 939 | */ |
| 940 | 940 | function lien_propage_date_modif($objet, $ids) { |
| 941 | 941 | static $done = array(); |
| 942 | - $hash = md5($objet . serialize($ids)); |
|
| 942 | + $hash = md5($objet.serialize($ids)); |
|
| 943 | 943 | |
| 944 | 944 | // sql_updateq, peut être un rien lent. |
| 945 | 945 | // On évite de l'appeler 2 fois sur les mêmes choses |
@@ -954,7 +954,7 @@ discard block |
||
| 954 | 954 | and isset($desc['field']['date_modif']) |
| 955 | 955 | ) { |
| 956 | 956 | $primary = id_table_objet($objet); |
| 957 | - $where = (is_array($ids) ? sql_in($primary, array_map('intval', $ids)) : "$primary=" . intval($ids)); |
|
| 957 | + $where = (is_array($ids) ? sql_in($primary, array_map('intval', $ids)) : "$primary=".intval($ids)); |
|
| 958 | 958 | sql_updateq($table, array('date_modif' => date('Y-m-d H:i:s')), $where); |
| 959 | 959 | } |
| 960 | 960 | |
@@ -70,7 +70,7 @@ discard block |
||
| 70 | 70 | $md5args = md5($arguments); |
| 71 | 71 | |
| 72 | 72 | // si pas de date programee, des que possible |
| 73 | - $duplicate_where = 'status=' . intval(_JQ_SCHEDULED) . ' AND '; |
|
| 73 | + $duplicate_where = 'status='.intval(_JQ_SCHEDULED).' AND '; |
|
| 74 | 74 | if (!$time) { |
| 75 | 75 | $time = time(); |
| 76 | 76 | $duplicate_where = ""; // ne pas dupliquer si deja le meme job en cours d'execution |
@@ -94,9 +94,8 @@ discard block |
||
| 94 | 94 | and |
| 95 | 95 | $id_job = sql_getfetsel('id_job', 'spip_jobs', |
| 96 | 96 | $duplicate_where = |
| 97 | - $duplicate_where . 'fonction=' . sql_quote($function) |
|
| 98 | - . (($no_duplicate === 'function_only') ? '' : |
|
| 99 | - ' AND md5args=' . sql_quote($md5args) . ' AND inclure=' . sql_quote($file))) |
|
| 97 | + $duplicate_where.'fonction='.sql_quote($function) |
|
| 98 | + . (($no_duplicate === 'function_only') ? '' : ' AND md5args='.sql_quote($md5args).' AND inclure='.sql_quote($file))) |
|
| 100 | 99 | ) { |
| 101 | 100 | return $id_job; |
| 102 | 101 | } |
@@ -108,9 +107,9 @@ discard block |
||
| 108 | 107 | if ( |
| 109 | 108 | $no_duplicate |
| 110 | 109 | and |
| 111 | - $id_prev = sql_getfetsel('id_job', 'spip_jobs', "id_job<" . intval($id_job) . " AND $duplicate_where") |
|
| 110 | + $id_prev = sql_getfetsel('id_job', 'spip_jobs', "id_job<".intval($id_job)." AND $duplicate_where") |
|
| 112 | 111 | ) { |
| 113 | - sql_delete('spip_jobs', 'id_job=' . intval($id_job)); |
|
| 112 | + sql_delete('spip_jobs', 'id_job='.intval($id_job)); |
|
| 114 | 113 | |
| 115 | 114 | return $id_prev; |
| 116 | 115 | } |
@@ -122,9 +121,9 @@ discard block |
||
| 122 | 121 | // ie cas d'un char non acceptables sur certains type de champs |
| 123 | 122 | // qui coupe la valeur |
| 124 | 123 | if (defined('_JQ_INSERT_CHECK_ARGS') and $id_job) { |
| 125 | - $args = sql_getfetsel('args', 'spip_jobs', 'id_job=' . intval($id_job)); |
|
| 124 | + $args = sql_getfetsel('args', 'spip_jobs', 'id_job='.intval($id_job)); |
|
| 126 | 125 | if ($args !== $arguments) { |
| 127 | - spip_log('arguments job errones / longueur ' . strlen($args) . " vs " . strlen($arguments) . ' / valeur : ' . var_export($arguments, |
|
| 126 | + spip_log('arguments job errones / longueur '.strlen($args)." vs ".strlen($arguments).' / valeur : '.var_export($arguments, |
|
| 128 | 127 | true), 'queue'); |
| 129 | 128 | } |
| 130 | 129 | } |
@@ -152,7 +151,7 @@ discard block |
||
| 152 | 151 | function queue_purger() { |
| 153 | 152 | include_spip('base/abstract_sql'); |
| 154 | 153 | sql_delete('spip_jobs'); |
| 155 | - sql_delete("spip_jobs_liens", "id_job NOT IN (" . sql_get_select("id_job", "spip_jobs") . ")"); |
|
| 154 | + sql_delete("spip_jobs_liens", "id_job NOT IN (".sql_get_select("id_job", "spip_jobs").")"); |
|
| 156 | 155 | include_spip('inc/genie'); |
| 157 | 156 | genie_queue_watch_dist(); |
| 158 | 157 | } |
@@ -167,8 +166,8 @@ discard block |
||
| 167 | 166 | function queue_remove_job($id_job) { |
| 168 | 167 | include_spip('base/abstract_sql'); |
| 169 | 168 | |
| 170 | - if ($row = sql_fetsel('fonction,inclure,date', 'spip_jobs', 'id_job=' . intval($id_job)) |
|
| 171 | - and $res = sql_delete('spip_jobs', 'id_job=' . intval($id_job)) |
|
| 169 | + if ($row = sql_fetsel('fonction,inclure,date', 'spip_jobs', 'id_job='.intval($id_job)) |
|
| 170 | + and $res = sql_delete('spip_jobs', 'id_job='.intval($id_job)) |
|
| 172 | 171 | ) { |
| 173 | 172 | queue_unlink_job($id_job); |
| 174 | 173 | // est-ce une tache cron qu'il faut relancer ? |
@@ -217,7 +216,7 @@ discard block |
||
| 217 | 216 | * resultat du sql_delete |
| 218 | 217 | */ |
| 219 | 218 | function queue_unlink_job($id_job) { |
| 220 | - return sql_delete("spip_jobs_liens", "id_job=" . intval($id_job)); |
|
| 219 | + return sql_delete("spip_jobs_liens", "id_job=".intval($id_job)); |
|
| 221 | 220 | } |
| 222 | 221 | |
| 223 | 222 | /** |
@@ -233,7 +232,7 @@ discard block |
||
| 233 | 232 | // deserialiser les arguments |
| 234 | 233 | $args = unserialize($row['args']); |
| 235 | 234 | if ($args === false) { |
| 236 | - spip_log('arguments job errones ' . var_export($row, true), 'queue'); |
|
| 235 | + spip_log('arguments job errones '.var_export($row, true), 'queue'); |
|
| 237 | 236 | $args = array(); |
| 238 | 237 | } |
| 239 | 238 | |
@@ -250,12 +249,12 @@ discard block |
||
| 250 | 249 | } |
| 251 | 250 | |
| 252 | 251 | if (!function_exists($fonction)) { |
| 253 | - spip_log("fonction $fonction ($inclure) inexistante " . var_export($row, true), 'queue'); |
|
| 252 | + spip_log("fonction $fonction ($inclure) inexistante ".var_export($row, true), 'queue'); |
|
| 254 | 253 | |
| 255 | 254 | return false; |
| 256 | 255 | } |
| 257 | 256 | |
| 258 | - spip_log("queue [" . $row['id_job'] . "]: $fonction() start", 'queue'); |
|
| 257 | + spip_log("queue [".$row['id_job']."]: $fonction() start", 'queue'); |
|
| 259 | 258 | switch (count($args)) { |
| 260 | 259 | case 0: |
| 261 | 260 | $res = $fonction(); |
@@ -295,7 +294,7 @@ discard block |
||
| 295 | 294 | # plus lent mais completement generique |
| 296 | 295 | $res = call_user_func_array($fonction, $args); |
| 297 | 296 | } |
| 298 | - spip_log("queue [" . $row['id_job'] . "]: $fonction() end", 'queue'); |
|
| 297 | + spip_log("queue [".$row['id_job']."]: $fonction() end", 'queue'); |
|
| 299 | 298 | |
| 300 | 299 | return $res; |
| 301 | 300 | |
@@ -327,14 +326,14 @@ discard block |
||
| 327 | 326 | function queue_schedule($force_jobs = null) { |
| 328 | 327 | $time = time(); |
| 329 | 328 | if (defined('_DEBUG_BLOCK_QUEUE')) { |
| 330 | - spip_log("_DEBUG_BLOCK_QUEUE : schedule stop", 'jq' . _LOG_DEBUG); |
|
| 329 | + spip_log("_DEBUG_BLOCK_QUEUE : schedule stop", 'jq'._LOG_DEBUG); |
|
| 331 | 330 | |
| 332 | 331 | return; |
| 333 | 332 | } |
| 334 | 333 | |
| 335 | 334 | // rien a faire si le prochain job est encore dans le futur |
| 336 | 335 | if (queue_sleep_time_to_next_job() > 0 and (!$force_jobs or !count($force_jobs))) { |
| 337 | - spip_log("queue_sleep_time_to_next_job", 'jq' . _LOG_DEBUG); |
|
| 336 | + spip_log("queue_sleep_time_to_next_job", 'jq'._LOG_DEBUG); |
|
| 338 | 337 | |
| 339 | 338 | return; |
| 340 | 339 | } |
@@ -355,7 +354,7 @@ discard block |
||
| 355 | 354 | } |
| 356 | 355 | $end_time = $time + _JQ_MAX_JOBS_TIME_TO_EXECUTE; |
| 357 | 356 | |
| 358 | - spip_log("JQ schedule $time / $end_time", 'jq' . _LOG_DEBUG); |
|
| 357 | + spip_log("JQ schedule $time / $end_time", 'jq'._LOG_DEBUG); |
|
| 359 | 358 | |
| 360 | 359 | if (!defined('_JQ_MAX_JOBS_EXECUTE')) { |
| 361 | 360 | define('_JQ_MAX_JOBS_EXECUTE', 200); |
@@ -369,19 +368,19 @@ discard block |
||
| 369 | 368 | // lorsqu'un job cron n'a pas fini, sa priorite est descendue |
| 370 | 369 | // pour qu'il ne bloque pas les autres jobs en attente |
| 371 | 370 | if (is_array($force_jobs) and count($force_jobs)) { |
| 372 | - $cond = "status=" . intval(_JQ_SCHEDULED) . " AND " . sql_in("id_job", $force_jobs); |
|
| 371 | + $cond = "status=".intval(_JQ_SCHEDULED)." AND ".sql_in("id_job", $force_jobs); |
|
| 373 | 372 | } else { |
| 374 | 373 | $now = date('Y-m-d H:i:s', $time); |
| 375 | - $cond = "status=" . intval(_JQ_SCHEDULED) . " AND date<=" . sql_quote($now); |
|
| 374 | + $cond = "status=".intval(_JQ_SCHEDULED)." AND date<=".sql_quote($now); |
|
| 376 | 375 | } |
| 377 | 376 | |
| 378 | 377 | register_shutdown_function('queue_error_handler'); // recuperer les erreurs auant que possible |
| 379 | - $res = sql_allfetsel('*', 'spip_jobs', $cond, '', 'priorite DESC,date', '0,' . (_JQ_MAX_JOBS_EXECUTE + 1)); |
|
| 378 | + $res = sql_allfetsel('*', 'spip_jobs', $cond, '', 'priorite DESC,date', '0,'.(_JQ_MAX_JOBS_EXECUTE + 1)); |
|
| 380 | 379 | do { |
| 381 | 380 | if ($row = array_shift($res)) { |
| 382 | 381 | $nbj++; |
| 383 | 382 | // il faut un verrou, a base de sql_delete |
| 384 | - if (sql_delete('spip_jobs', "id_job=" . intval($row['id_job']) . " AND status=" . intval(_JQ_SCHEDULED))) { |
|
| 383 | + if (sql_delete('spip_jobs', "id_job=".intval($row['id_job'])." AND status=".intval(_JQ_SCHEDULED))) { |
|
| 385 | 384 | #spip_log("JQ schedule job ".$nbj." OK",'jq'); |
| 386 | 385 | // on reinsert dans la base aussitot avec un status=_JQ_PENDING |
| 387 | 386 | $row['status'] = _JQ_PENDING; |
@@ -396,13 +395,13 @@ discard block |
||
| 396 | 395 | queue_close_job($row, $time, $result); |
| 397 | 396 | } |
| 398 | 397 | } |
| 399 | - spip_log("JQ schedule job end time " . $time, 'jq' . _LOG_DEBUG); |
|
| 398 | + spip_log("JQ schedule job end time ".$time, 'jq'._LOG_DEBUG); |
|
| 400 | 399 | } while ($nbj < _JQ_MAX_JOBS_EXECUTE and $row and $time < $end_time); |
| 401 | - spip_log("JQ schedule end time " . time(), 'jq' . _LOG_DEBUG); |
|
| 400 | + spip_log("JQ schedule end time ".time(), 'jq'._LOG_DEBUG); |
|
| 402 | 401 | |
| 403 | 402 | if ($row = array_shift($res)) { |
| 404 | 403 | queue_update_next_job_time(0); // on sait qu'il y a encore des jobs a lancer ASAP |
| 405 | - spip_log("JQ encore !", 'jq' . _LOG_DEBUG); |
|
| 404 | + spip_log("JQ encore !", 'jq'._LOG_DEBUG); |
|
| 406 | 405 | } else { |
| 407 | 406 | queue_update_next_job_time(); |
| 408 | 407 | } |
@@ -438,9 +437,9 @@ discard block |
||
| 438 | 437 | } |
| 439 | 438 | } |
| 440 | 439 | // purger ses liens eventuels avec des objets |
| 441 | - sql_delete("spip_jobs_liens", "id_job=" . intval($row['id_job'])); |
|
| 440 | + sql_delete("spip_jobs_liens", "id_job=".intval($row['id_job'])); |
|
| 442 | 441 | // supprimer le job fini |
| 443 | - sql_delete('spip_jobs', 'id_job=' . intval($row['id_job'])); |
|
| 442 | + sql_delete('spip_jobs', 'id_job='.intval($row['id_job'])); |
|
| 444 | 443 | } |
| 445 | 444 | |
| 446 | 445 | /** |
@@ -511,17 +510,17 @@ discard block |
||
| 511 | 510 | // traiter les jobs morts au combat (_JQ_PENDING depuis plus de 180s) |
| 512 | 511 | // pour cause de timeout ou autre erreur fatale |
| 513 | 512 | $res = sql_allfetsel("*", "spip_jobs", |
| 514 | - "status=" . intval(_JQ_PENDING) . " AND date<" . sql_quote(date('Y-m-d H:i:s', $time - 180))); |
|
| 513 | + "status=".intval(_JQ_PENDING)." AND date<".sql_quote(date('Y-m-d H:i:s', $time - 180))); |
|
| 515 | 514 | if (is_array($res)) { |
| 516 | 515 | foreach ($res as $row) { |
| 517 | 516 | queue_close_job($row, $time); |
| 518 | - spip_log ("queue_close_job car _JQ_PENDING depuis +180s : ".print_r($row,1), "job_mort"._LOG_ERREUR); |
|
| 517 | + spip_log("queue_close_job car _JQ_PENDING depuis +180s : ".print_r($row, 1), "job_mort"._LOG_ERREUR); |
|
| 519 | 518 | } |
| 520 | 519 | } |
| 521 | 520 | |
| 522 | 521 | // chercher la date du prochain job si pas connu |
| 523 | 522 | if (is_null($next) or is_null(queue_sleep_time_to_next_job())) { |
| 524 | - $date = sql_getfetsel('date', 'spip_jobs', "status=" . intval(_JQ_SCHEDULED), '', 'date', '0,1'); |
|
| 523 | + $date = sql_getfetsel('date', 'spip_jobs', "status=".intval(_JQ_SCHEDULED), '', 'date', '0,1'); |
|
| 525 | 524 | $next = strtotime($date); |
| 526 | 525 | } |
| 527 | 526 | if (!is_null($next_time)) { |
@@ -533,7 +532,7 @@ discard block |
||
| 533 | 532 | if ($next) { |
| 534 | 533 | if (is_null($nb_jobs_scheduled)) { |
| 535 | 534 | $nb_jobs_scheduled = sql_countsel('spip_jobs', |
| 536 | - "status=" . intval(_JQ_SCHEDULED) . " AND date<" . sql_quote(date('Y-m-d H:i:s', $time))); |
|
| 535 | + "status=".intval(_JQ_SCHEDULED)." AND date<".sql_quote(date('Y-m-d H:i:s', $time))); |
|
| 537 | 536 | } elseif ($next <= $time) { |
| 538 | 537 | $nb_jobs_scheduled++; |
| 539 | 538 | } |
@@ -601,7 +600,7 @@ discard block |
||
| 601 | 600 | } |
| 602 | 601 | |
| 603 | 602 | // ne pas relancer si on vient de lancer dans la meme seconde par un hit concurent |
| 604 | - if (file_exists($lock = _DIR_TMP . "cron.lock") and !(@filemtime($lock) < $_SERVER['REQUEST_TIME'])) { |
|
| 603 | + if (file_exists($lock = _DIR_TMP."cron.lock") and !(@filemtime($lock) < $_SERVER['REQUEST_TIME'])) { |
|
| 605 | 604 | return $texte; |
| 606 | 605 | } |
| 607 | 606 | |
@@ -672,20 +671,20 @@ discard block |
||
| 672 | 671 | $scheme = ''; |
| 673 | 672 | $port = 80; |
| 674 | 673 | } |
| 675 | - $fp = @fsockopen($scheme . $parts['host'], |
|
| 674 | + $fp = @fsockopen($scheme.$parts['host'], |
|
| 676 | 675 | isset($parts['port']) ? $parts['port'] : $port, |
| 677 | 676 | $errno, $errstr, 1); |
| 678 | 677 | |
| 679 | 678 | if ($fp) { |
| 680 | 679 | $host_sent = $parts['host']; |
| 681 | 680 | if (isset($parts['port']) and $parts['port'] !== $port) { |
| 682 | - $host_sent .= ':' . $parts['port']; |
|
| 681 | + $host_sent .= ':'.$parts['port']; |
|
| 683 | 682 | } |
| 684 | 683 | $timeout = 200; // ms |
| 685 | 684 | stream_set_timeout($fp, 0, $timeout * 1000); |
| 686 | - $query = $parts['path'] . ($parts['query'] ? "?" . $parts['query'] : ""); |
|
| 687 | - $out = "GET " . $query . " HTTP/1.1\r\n"; |
|
| 688 | - $out .= "Host: " . $host_sent . "\r\n"; |
|
| 685 | + $query = $parts['path'].($parts['query'] ? "?".$parts['query'] : ""); |
|
| 686 | + $out = "GET ".$query." HTTP/1.1\r\n"; |
|
| 687 | + $out .= "Host: ".$host_sent."\r\n"; |
|
| 689 | 688 | $out .= "Connection: Close\r\n\r\n"; |
| 690 | 689 | fwrite($fp, $out); |
| 691 | 690 | spip_timer('read'); |
@@ -26,11 +26,10 @@ discard block |
||
| 26 | 26 | $postaff = decompiler_($struct->postaff, $fmt, $prof); |
| 27 | 27 | |
| 28 | 28 | $type = $struct->sql_serveur ? "$struct->sql_serveur:" : ''; |
| 29 | - $type .= ($struct->type_requete ? $struct->type_requete : |
|
| 30 | - $struct->table_optionnelle); |
|
| 29 | + $type .= ($struct->type_requete ? $struct->type_requete : $struct->table_optionnelle); |
|
| 31 | 30 | |
| 32 | 31 | if ($struct->jointures_explicites) { |
| 33 | - $type .= " " . $struct->jointures_explicites; |
|
| 32 | + $type .= " ".$struct->jointures_explicites; |
|
| 34 | 33 | } |
| 35 | 34 | if ($struct->table_optionnelle) { |
| 36 | 35 | $type .= "?"; |
@@ -39,11 +38,11 @@ discard block |
||
| 39 | 38 | |
| 40 | 39 | $crit = $struct->param; |
| 41 | 40 | if ($crit and !is_array($crit[0])) { |
| 42 | - $type = strtolower($type) . array_shift($crit); |
|
| 41 | + $type = strtolower($type).array_shift($crit); |
|
| 43 | 42 | } |
| 44 | 43 | $crit = decompiler_criteres($struct, $fmt, $prof); |
| 45 | 44 | |
| 46 | - $f = 'format_boucle_' . $fmt; |
|
| 45 | + $f = 'format_boucle_'.$fmt; |
|
| 47 | 46 | |
| 48 | 47 | return $f($preaff, $avant, $nom, $type, $crit, $milieu, $apres, $altern, $postaff, $prof); |
| 49 | 48 | } |
@@ -56,21 +55,20 @@ discard block |
||
| 56 | 55 | $res[] = decompiler_($v, $fmt, $prof); |
| 57 | 56 | } |
| 58 | 57 | } |
| 59 | - $file = is_string($struct->texte) ? $struct->texte : |
|
| 60 | - decompiler_($struct->texte, $fmt, $prof); |
|
| 61 | - $f = 'format_inclure_' . $fmt; |
|
| 58 | + $file = is_string($struct->texte) ? $struct->texte : decompiler_($struct->texte, $fmt, $prof); |
|
| 59 | + $f = 'format_inclure_'.$fmt; |
|
| 62 | 60 | |
| 63 | 61 | return $f($file, $res, $prof); |
| 64 | 62 | } |
| 65 | 63 | |
| 66 | 64 | function decompiler_texte($struct, $fmt = '', $prof = 0) { |
| 67 | - $f = 'format_texte_' . $fmt; |
|
| 65 | + $f = 'format_texte_'.$fmt; |
|
| 68 | 66 | |
| 69 | 67 | return strlen($struct->texte) ? $f($struct->texte, $prof) : ''; |
| 70 | 68 | } |
| 71 | 69 | |
| 72 | 70 | function decompiler_polyglotte($struct, $fmt = '', $prof = 0) { |
| 73 | - $f = 'format_polyglotte_' . $fmt; |
|
| 71 | + $f = 'format_polyglotte_'.$fmt; |
|
| 74 | 72 | |
| 75 | 73 | return $f($struct->traductions, $prof); |
| 76 | 74 | } |
@@ -83,7 +81,7 @@ discard block |
||
| 83 | 81 | |
| 84 | 82 | $filtres = decompiler_liste($struct->param, $fmt, $prof); |
| 85 | 83 | |
| 86 | - $f = 'format_idiome_' . $fmt; |
|
| 84 | + $f = 'format_idiome_'.$fmt; |
|
| 87 | 85 | |
| 88 | 86 | return $f($struct->nom_champ, $struct->module, $args, $filtres, $prof); |
| 89 | 87 | } |
@@ -98,7 +96,7 @@ discard block |
||
| 98 | 96 | } |
| 99 | 97 | $filtres = decompiler_liste($p, $fmt, $prof); |
| 100 | 98 | } |
| 101 | - $f = 'format_champ_' . $fmt; |
|
| 99 | + $f = 'format_champ_'.$fmt; |
|
| 102 | 100 | |
| 103 | 101 | return $f($struct->nom_champ, $struct->nom_boucle, $struct->etoile, $avant, $apres, $args, $filtres, $prof); |
| 104 | 102 | } |
@@ -107,7 +105,7 @@ discard block |
||
| 107 | 105 | if (!is_array($sources)) { |
| 108 | 106 | return ''; |
| 109 | 107 | } |
| 110 | - $f = 'format_liste_' . $fmt; |
|
| 108 | + $f = 'format_liste_'.$fmt; |
|
| 111 | 109 | $res = ''; |
| 112 | 110 | foreach ($sources as $arg) { |
| 113 | 111 | if (!is_array($arg)) { |
@@ -123,7 +121,7 @@ discard block |
||
| 123 | 121 | and (strlen($v[0]->apres) == 1) |
| 124 | 122 | and $v[0]->apres == $v[0]->avant |
| 125 | 123 | ) { |
| 126 | - $args[] = $v[0]->avant . $v[0]->texte . $v[0]->apres; |
|
| 124 | + $args[] = $v[0]->avant.$v[0]->texte.$v[0]->apres; |
|
| 127 | 125 | } else { |
| 128 | 126 | $args[] = decompiler_($v, $fmt, 0 - $prof); |
| 129 | 127 | } |
@@ -146,7 +144,7 @@ discard block |
||
| 146 | 144 | return ''; |
| 147 | 145 | } |
| 148 | 146 | $res = ''; |
| 149 | - $f = 'format_critere_' . $fmt; |
|
| 147 | + $f = 'format_critere_'.$fmt; |
|
| 150 | 148 | foreach ($sources as $crit) { |
| 151 | 149 | if (!is_array($crit)) { |
| 152 | 150 | continue; |
@@ -158,12 +156,12 @@ discard block |
||
| 158 | 156 | and $v[0]->type == 'texte' |
| 159 | 157 | and $v[0]->apres |
| 160 | 158 | ) { |
| 161 | - $args[] = array(array('texte', ($v[0]->apres . $v[0]->texte . $v[0]->apres))); |
|
| 159 | + $args[] = array(array('texte', ($v[0]->apres.$v[0]->texte.$v[0]->apres))); |
|
| 162 | 160 | } else { |
| 163 | 161 | $res2 = array(); |
| 164 | 162 | foreach ($v as $k => $p) { |
| 165 | 163 | if (isset($p->type) |
| 166 | - and function_exists($d = 'decompiler_' . $p->type) |
|
| 164 | + and function_exists($d = 'decompiler_'.$p->type) |
|
| 167 | 165 | ) { |
| 168 | 166 | $r = $d($p, $fmt, (0 - $prof), @$v[$k + 1]); |
| 169 | 167 | $res2[] = array($p->type, $r); |
@@ -191,7 +189,7 @@ discard block |
||
| 191 | 189 | if (!isset($p->type)) { |
| 192 | 190 | continue; |
| 193 | 191 | } #?????? |
| 194 | - $d = 'decompiler_' . $p->type; |
|
| 192 | + $d = 'decompiler_'.$p->type; |
|
| 195 | 193 | $next = isset($liste[$k + 1]) ? $liste[$k + 1] : false; |
| 196 | 194 | // Forcer le champ etendu si son source (pas les reecritures) |
| 197 | 195 | // contenait des args et s'il est suivi d'espaces, |
@@ -216,16 +214,16 @@ discard block |
||
| 216 | 214 | $contenu[] = array($d($p, $fmt, $prof2), $p->type); |
| 217 | 215 | |
| 218 | 216 | } |
| 219 | - $f = 'format_suite_' . $fmt; |
|
| 217 | + $f = 'format_suite_'.$fmt; |
|
| 220 | 218 | |
| 221 | 219 | return $f($contenu); |
| 222 | 220 | } |
| 223 | 221 | |
| 224 | 222 | function public_decompiler($liste, $fmt = '', $prof = 0, $quoi = '') { |
| 225 | - if (!include_spip('public/format_' . $fmt)) { |
|
| 223 | + if (!include_spip('public/format_'.$fmt)) { |
|
| 226 | 224 | return "'$fmt'?"; |
| 227 | 225 | } |
| 228 | - $f = 'decompiler_' . $quoi; |
|
| 226 | + $f = 'decompiler_'.$quoi; |
|
| 229 | 227 | |
| 230 | 228 | return $f($liste, $fmt, $prof); |
| 231 | 229 | } |
@@ -26,7 +26,7 @@ |
||
| 26 | 26 | // On reexecute pour deboucher sur le include public. |
| 27 | 27 | // autrement on insiste |
| 28 | 28 | if (is_array($var_auth)) { |
| 29 | - $var_auth = '../?' . $_SERVER['QUERY_STRING']; |
|
| 29 | + $var_auth = '../?'.$_SERVER['QUERY_STRING']; |
|
| 30 | 30 | spip_setcookie('spip_session', $_COOKIE['spip_session'], [ |
| 31 | 31 | 'expires' => time() + 3600 * 24 * 14 |
| 32 | 32 | ]); |
@@ -82,19 +82,19 @@ discard block |
||
| 82 | 82 | spip_log("supprimer sessions auteur $id_auteur", "session"); |
| 83 | 83 | if ($toutes or $id_auteur !== $GLOBALS['visiteur_session']['id_auteur']) { |
| 84 | 84 | if ($dir = opendir(_DIR_SESSIONS)) { |
| 85 | - $t = $_SERVER['REQUEST_TIME'] - (4*_RENOUVELLE_ALEA); // 48h par defaut |
|
| 86 | - $t_short = $_SERVER['REQUEST_TIME'] - max(_RENOUVELLE_ALEA/4,3*3600); // 3h par defaut |
|
| 85 | + $t = $_SERVER['REQUEST_TIME'] - (4 * _RENOUVELLE_ALEA); // 48h par defaut |
|
| 86 | + $t_short = $_SERVER['REQUEST_TIME'] - max(_RENOUVELLE_ALEA / 4, 3 * 3600); // 3h par defaut |
|
| 87 | 87 | $t = time() - (4 * _RENOUVELLE_ALEA); |
| 88 | 88 | while (($f = readdir($dir)) !== false) { |
| 89 | 89 | $nb_files++; |
| 90 | 90 | if (preg_match(",^[^\d-]*(-?\d+)_\w{32}\.php[3]?$,", $f, $regs)) { |
| 91 | - $f = _DIR_SESSIONS . $f; |
|
| 91 | + $f = _DIR_SESSIONS.$f; |
|
| 92 | 92 | if (($actives and $regs[1] == $id_auteur) or ($t > filemtime($f))) { |
| 93 | 93 | spip_unlink($f); |
| 94 | 94 | } |
| 95 | 95 | // si il y a trop de sessions ouvertes, on purge les sessions anonymes de plus de 3H |
| 96 | 96 | // cf http://core.spip.org/issues/3276 |
| 97 | - elseif ($nb_files>$nb_max_files and !intval($regs[1]) and ($t_short > filemtime($f))) { |
|
| 97 | + elseif ($nb_files > $nb_max_files and !intval($regs[1]) and ($t_short > filemtime($f))) { |
|
| 98 | 98 | spip_unlink($f); |
| 99 | 99 | } |
| 100 | 100 | } |
@@ -170,9 +170,9 @@ discard block |
||
| 170 | 170 | } |
| 171 | 171 | |
| 172 | 172 | if (!isset($_COOKIE['spip_session']) |
| 173 | - or !preg_match(',^' . $id_auteur . '_,', $_COOKIE['spip_session']) |
|
| 173 | + or !preg_match(',^'.$id_auteur.'_,', $_COOKIE['spip_session']) |
|
| 174 | 174 | ) { |
| 175 | - $_COOKIE['spip_session'] = $id_auteur . '_' . md5(uniqid(rand(), true)); |
|
| 175 | + $_COOKIE['spip_session'] = $id_auteur.'_'.md5(uniqid(rand(), true)); |
|
| 176 | 176 | } |
| 177 | 177 | |
| 178 | 178 | // Maintenant on sait qu'on a des choses à écrire |
@@ -203,7 +203,7 @@ discard block |
||
| 203 | 203 | } else { |
| 204 | 204 | $fichier_session = fichier_session('alea_ephemere'); |
| 205 | 205 | if (!ecrire_fichier_session($fichier_session, $auteur)) { |
| 206 | - spip_log('Echec ecriture fichier session ' . $fichier_session, "session" . _LOG_HS); |
|
| 206 | + spip_log('Echec ecriture fichier session '.$fichier_session, "session"._LOG_HS); |
|
| 207 | 207 | include_spip('inc/minipres'); |
| 208 | 208 | echo minipres(); |
| 209 | 209 | exit; |
@@ -216,7 +216,7 @@ discard block |
||
| 216 | 216 | // poser le cookie de session SPIP |
| 217 | 217 | include_spip('inc/cookie'); |
| 218 | 218 | $duree = definir_duree_cookie_session($auteur); |
| 219 | - spip_setcookie( 'spip_session', $_COOKIE['spip_session'], [ |
|
| 219 | + spip_setcookie('spip_session', $_COOKIE['spip_session'], [ |
|
| 220 | 220 | 'expires' => time() + $duree |
| 221 | 221 | ]); |
| 222 | 222 | spip_log("ajoute session $fichier_session cookie $duree", "session"); |
@@ -225,8 +225,8 @@ discard block |
||
| 225 | 225 | if (!function_exists('autoriser')) { |
| 226 | 226 | include_spip('inc/autoriser'); |
| 227 | 227 | } |
| 228 | - if (autoriser('ecrire','','',$auteur) and _DUREE_COOKIE_ADMIN) { |
|
| 229 | - spip_setcookie('spip_admin', '@' . ($auteur['email'] ?: $auteur['login']), [ |
|
| 228 | + if (autoriser('ecrire', '', '', $auteur) and _DUREE_COOKIE_ADMIN) { |
|
| 229 | + spip_setcookie('spip_admin', '@'.($auteur['email'] ?: $auteur['login']), [ |
|
| 230 | 230 | 'expires' => time() + max(_DUREE_COOKIE_ADMIN, $duree) |
| 231 | 231 | ]); |
| 232 | 232 | } // sinon le supprimer ... |
@@ -267,7 +267,7 @@ discard block |
||
| 267 | 267 | $coef = 20; |
| 268 | 268 | } |
| 269 | 269 | } |
| 270 | - return (int)(_RENOUVELLE_ALEA * $coef); |
|
| 270 | + return (int) (_RENOUVELLE_ALEA * $coef); |
|
| 271 | 271 | } |
| 272 | 272 | |
| 273 | 273 | /** |
@@ -315,7 +315,7 @@ discard block |
||
| 315 | 315 | |
| 316 | 316 | // Renouveler la session avec l'alea courant |
| 317 | 317 | include($fichier_session); |
| 318 | - spip_log('renouvelle session ' . $GLOBALS['visiteur_session']['id_auteur'], "session"); |
|
| 318 | + spip_log('renouvelle session '.$GLOBALS['visiteur_session']['id_auteur'], "session"); |
|
| 319 | 319 | spip_unlink($fichier_session); |
| 320 | 320 | ajouter_session($GLOBALS['visiteur_session']); |
| 321 | 321 | } |
@@ -347,7 +347,7 @@ discard block |
||
| 347 | 347 | } |
| 348 | 348 | } else { |
| 349 | 349 | if ($change) { |
| 350 | - spip_log("rejoue session $fichier_session " . $_COOKIE['spip_session'], "session"); |
|
| 350 | + spip_log("rejoue session $fichier_session ".$_COOKIE['spip_session'], "session"); |
|
| 351 | 351 | if ($fichier_session) { |
| 352 | 352 | spip_unlink($fichier_session); |
| 353 | 353 | } |
@@ -563,7 +563,7 @@ discard block |
||
| 563 | 563 | } |
| 564 | 564 | |
| 565 | 565 | // liste des sessions |
| 566 | - $sessions = preg_files(_DIR_SESSIONS, '/' . $id_auteur . '_.*\.php$'); |
|
| 566 | + $sessions = preg_files(_DIR_SESSIONS, '/'.$id_auteur.'_.*\.php$'); |
|
| 567 | 567 | |
| 568 | 568 | // si on en a plus que la limite, supprimer les plus vieilles |
| 569 | 569 | // si ce ne sont pas des sessions anonymes car elles sont alors chacune differentes |
@@ -642,12 +642,12 @@ discard block |
||
| 642 | 642 | $auteur = preparer_ecriture_session($auteur); |
| 643 | 643 | |
| 644 | 644 | // enregistrer les autres donnees du visiteur |
| 645 | - $texte = "<" . "?php\n"; |
|
| 645 | + $texte = "<"."?php\n"; |
|
| 646 | 646 | foreach ($auteur as $var => $val) { |
| 647 | - $texte .= '$GLOBALS[\'visiteur_session\'][' . var_export($var, true) . '] = ' |
|
| 648 | - . var_export($val, true) . ";\n"; |
|
| 647 | + $texte .= '$GLOBALS[\'visiteur_session\']['.var_export($var, true).'] = ' |
|
| 648 | + . var_export($val, true).";\n"; |
|
| 649 | 649 | } |
| 650 | - $texte .= "?" . ">\n"; |
|
| 650 | + $texte .= "?".">\n"; |
|
| 651 | 651 | |
| 652 | 652 | return ecrire_fichier($fichier, $texte); |
| 653 | 653 | } |
@@ -677,7 +677,7 @@ discard block |
||
| 677 | 677 | $repertoire = sous_repertoire(_DIR_SESSIONS, '', false, $tantpis); |
| 678 | 678 | $c = $_COOKIE['spip_session']; |
| 679 | 679 | |
| 680 | - return $repertoire . intval($c) . '_' . md5($c . ' ' . $GLOBALS['meta'][$alea]) . '.php'; |
|
| 680 | + return $repertoire.intval($c).'_'.md5($c.' '.$GLOBALS['meta'][$alea]).'.php'; |
|
| 681 | 681 | } |
| 682 | 682 | } |
| 683 | 683 | |
@@ -695,7 +695,7 @@ discard block |
||
| 695 | 695 | * @return string |
| 696 | 696 | */ |
| 697 | 697 | function rejouer_session() { |
| 698 | - return '<img src="' . generer_url_action('cookie', 'change_session=oui', true) . '" width="0" height="0" alt="" />'; |
|
| 698 | + return '<img src="'.generer_url_action('cookie', 'change_session=oui', true).'" width="0" height="0" alt="" />'; |
|
| 699 | 699 | } |
| 700 | 700 | |
| 701 | 701 | |
@@ -710,7 +710,7 @@ discard block |
||
| 710 | 710 | return $res; |
| 711 | 711 | } |
| 712 | 712 | |
| 713 | - return $res = md5($GLOBALS['ip'] . (isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : '')); |
|
| 713 | + return $res = md5($GLOBALS['ip'].(isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : '')); |
|
| 714 | 714 | } |
| 715 | 715 | |
| 716 | 716 | |
@@ -74,7 +74,7 @@ discard block |
||
| 74 | 74 | } |
| 75 | 75 | } |
| 76 | 76 | |
| 77 | - $name = preg_replace('/^spip_/', $GLOBALS['cookie_prefix'] . '_', $name); |
|
| 77 | + $name = preg_replace('/^spip_/', $GLOBALS['cookie_prefix'].'_', $name); |
|
| 78 | 78 | |
| 79 | 79 | // expires |
| 80 | 80 | if (!isset($options['expires'])) { |
@@ -157,7 +157,7 @@ discard block |
||
| 157 | 157 | } |
| 158 | 158 | foreach ($_COOKIE as $name => $value) { |
| 159 | 159 | if (substr($name, 0, $prefix_long) == $cookie_prefix) { |
| 160 | - $spipname = preg_replace('/^' . $cookie_prefix . '_/', 'spip_', $name); |
|
| 160 | + $spipname = preg_replace('/^'.$cookie_prefix.'_/', 'spip_', $name); |
|
| 161 | 161 | $_COOKIE[$spipname] = $value; |
| 162 | 162 | $GLOBALS[$spipname] = $value; |
| 163 | 163 | } |
@@ -79,9 +79,9 @@ discard block |
||
| 79 | 79 | // chercher la classe d'iterateur |
| 80 | 80 | // IterateurXXX |
| 81 | 81 | // definie dans le fichier iterateurs/xxx.php |
| 82 | - $class = "Iterateur" . $iterateur; |
|
| 82 | + $class = "Iterateur".$iterateur; |
|
| 83 | 83 | if (!class_exists($class)) { |
| 84 | - if (!include_spip("iterateur/" . strtolower($iterateur)) |
|
| 84 | + if (!include_spip("iterateur/".strtolower($iterateur)) |
|
| 85 | 85 | or !class_exists($class) |
| 86 | 86 | ) { |
| 87 | 87 | die("Iterateur $iterateur non trouvé"); |
@@ -208,7 +208,7 @@ discard block |
||
| 208 | 208 | return $this->iter->$nom(); |
| 209 | 209 | } catch (Exception $e) { |
| 210 | 210 | // #GETCHILDREN sur un fichier de DirectoryIterator ... |
| 211 | - spip_log("Methode $nom en echec sur " . get_class($this->iter)); |
|
| 211 | + spip_log("Methode $nom en echec sur ".get_class($this->iter)); |
|
| 212 | 212 | spip_log("Cela peut être normal : retour d'une ligne de resultat ne pouvant pas calculer cette methode"); |
| 213 | 213 | |
| 214 | 214 | return ''; |
@@ -290,8 +290,8 @@ discard block |
||
| 290 | 290 | |
| 291 | 291 | // Creer la fonction de filtrage sur $this |
| 292 | 292 | if ($this->filtre) { |
| 293 | - $filtres = 'return (' . join(') AND (', $this->filtre) . ');'; |
|
| 294 | - $this->func_filtre = function () use ($filtres) { |
|
| 293 | + $filtres = 'return ('.join(') AND (', $this->filtre).');'; |
|
| 294 | + $this->func_filtre = function() use ($filtres) { |
|
| 295 | 295 | return eval($filtres); |
| 296 | 296 | }; |
| 297 | 297 | } |
@@ -313,28 +313,28 @@ discard block |
||
| 313 | 313 | # if (!in_array($cle, array('cle', 'valeur'))) |
| 314 | 314 | # return; |
| 315 | 315 | |
| 316 | - $a = '$this->get_select(\'' . $cle . '\')'; |
|
| 316 | + $a = '$this->get_select(\''.$cle.'\')'; |
|
| 317 | 317 | |
| 318 | 318 | $filtre = ''; |
| 319 | 319 | |
| 320 | 320 | if ($op == 'REGEXP') { |
| 321 | - $filtre = 'filtrer("match", ' . $a . ', ' . str_replace('\"', '"', $valeur) . ')'; |
|
| 321 | + $filtre = 'filtrer("match", '.$a.', '.str_replace('\"', '"', $valeur).')'; |
|
| 322 | 322 | $op = ''; |
| 323 | 323 | } else { |
| 324 | 324 | if ($op == 'LIKE') { |
| 325 | 325 | $valeur = str_replace(array('\"', '_', '%'), array('"', '.', '.*'), preg_quote($valeur)); |
| 326 | - $filtre = 'filtrer("match", ' . $a . ', ' . $valeur . ')'; |
|
| 326 | + $filtre = 'filtrer("match", '.$a.', '.$valeur.')'; |
|
| 327 | 327 | $op = ''; |
| 328 | 328 | } else { |
| 329 | 329 | if ($op == '=') { |
| 330 | 330 | $op = '=='; |
| 331 | 331 | } else { |
| 332 | 332 | if ($op == 'IN') { |
| 333 | - $filtre = 'in_array(' . $a . ', array' . $valeur . ')'; |
|
| 333 | + $filtre = 'in_array('.$a.', array'.$valeur.')'; |
|
| 334 | 334 | $op = ''; |
| 335 | 335 | } else { |
| 336 | 336 | if (!in_array($op, array('<', '<=', '>', '>='))) { |
| 337 | - spip_log('operateur non reconnu ' . $op); // [todo] mettre une erreur de squelette |
|
| 337 | + spip_log('operateur non reconnu '.$op); // [todo] mettre une erreur de squelette |
|
| 338 | 338 | $op = ''; |
| 339 | 339 | } |
| 340 | 340 | } |
@@ -343,7 +343,7 @@ discard block |
||
| 343 | 343 | } |
| 344 | 344 | |
| 345 | 345 | if ($op) { |
| 346 | - $filtre = $a . $op . str_replace('\"', '"', $valeur); |
|
| 346 | + $filtre = $a.$op.str_replace('\"', '"', $valeur); |
|
| 347 | 347 | } |
| 348 | 348 | |
| 349 | 349 | if ($not) { |
@@ -65,7 +65,7 @@ discard block |
||
| 65 | 65 | if (!$link) { |
| 66 | 66 | $erreurs[] = pg_last_error(); |
| 67 | 67 | foreach ($erreurs as $e) { |
| 68 | - spip_log('Echec pg_connect. Erreur : ' . $e, 'pg.' . _LOG_HS); |
|
| 68 | + spip_log('Echec pg_connect. Erreur : '.$e, 'pg.'._LOG_HS); |
|
| 69 | 69 | } |
| 70 | 70 | |
| 71 | 71 | return false; |
@@ -82,8 +82,8 @@ discard block |
||
| 82 | 82 | ); |
| 83 | 83 | } |
| 84 | 84 | |
| 85 | - spip_log("Connexion vers $host, base $db, prefixe $prefixe " . ($link ? 'operationnelle' : 'impossible'), |
|
| 86 | - 'pg.' . _LOG_DEBUG); |
|
| 85 | + spip_log("Connexion vers $host, base $db, prefixe $prefixe ".($link ? 'operationnelle' : 'impossible'), |
|
| 86 | + 'pg.'._LOG_DEBUG); |
|
| 87 | 87 | |
| 88 | 88 | return !$link ? false : array( |
| 89 | 89 | 'db' => $db, |
@@ -172,7 +172,7 @@ discard block |
||
| 172 | 172 | } else { |
| 173 | 173 | $suite = ''; |
| 174 | 174 | } |
| 175 | - $query = preg_replace('/([,\s])spip_/', '\1' . $prefixe . '_', $query) . $suite; |
|
| 175 | + $query = preg_replace('/([,\s])spip_/', '\1'.$prefixe.'_', $query).$suite; |
|
| 176 | 176 | |
| 177 | 177 | // renvoyer la requete inerte si demandee |
| 178 | 178 | if (!$requeter) { |
@@ -242,7 +242,7 @@ discard block |
||
| 242 | 242 | // ou revoir l'api de sql_alter en creant un |
| 243 | 243 | // sql_alter_table($table,array($actions)); |
| 244 | 244 | if (!preg_match("/\s*((\s*IGNORE)?\s*TABLE\s*([^\s]*))\s*(.*)?/is", $query, $regs)) { |
| 245 | - spip_log("$query mal comprise", 'pg.' . _LOG_ERREUR); |
|
| 245 | + spip_log("$query mal comprise", 'pg.'._LOG_ERREUR); |
|
| 246 | 246 | |
| 247 | 247 | return false; |
| 248 | 248 | } |
@@ -255,7 +255,7 @@ discard block |
||
| 255 | 255 | $i = 0; |
| 256 | 256 | $ouverte = false; |
| 257 | 257 | while ($do = array_shift($todo)) { |
| 258 | - $todo2[$i] = isset($todo2[$i]) ? $todo2[$i] . "," . $do : $do; |
|
| 258 | + $todo2[$i] = isset($todo2[$i]) ? $todo2[$i].",".$do : $do; |
|
| 259 | 259 | $o = (false !== strpos($do, "(")); |
| 260 | 260 | $f = (false !== strpos($do, ")")); |
| 261 | 261 | if ($o and !$f) { |
@@ -268,24 +268,24 @@ discard block |
||
| 268 | 268 | } |
| 269 | 269 | } |
| 270 | 270 | $todo = $todo2; |
| 271 | - $query = $debut . ' ' . array_shift($todo); |
|
| 271 | + $query = $debut.' '.array_shift($todo); |
|
| 272 | 272 | |
| 273 | 273 | if (!preg_match('/^\s*(IGNORE\s*)?TABLE\s+(\w+)\s+(ADD|DROP|CHANGE|MODIFY|RENAME)\s*(.*)$/is', $query, $r)) { |
| 274 | - spip_log("$query incompris", 'pg.' . _LOG_ERREUR); |
|
| 274 | + spip_log("$query incompris", 'pg.'._LOG_ERREUR); |
|
| 275 | 275 | } else { |
| 276 | 276 | if ($r[1]) { |
| 277 | - spip_log("j'ignore IGNORE dans $query", 'pg.' . _LOG_AVERTISSEMENT); |
|
| 277 | + spip_log("j'ignore IGNORE dans $query", 'pg.'._LOG_AVERTISSEMENT); |
|
| 278 | 278 | } |
| 279 | - $f = 'spip_pg_alter_' . strtolower($r[3]); |
|
| 279 | + $f = 'spip_pg_alter_'.strtolower($r[3]); |
|
| 280 | 280 | if (function_exists($f)) { |
| 281 | 281 | $f($r[2], $r[4], $serveur, $requeter); |
| 282 | 282 | } else { |
| 283 | - spip_log("$query non prevu", 'pg.' . _LOG_ERREUR); |
|
| 283 | + spip_log("$query non prevu", 'pg.'._LOG_ERREUR); |
|
| 284 | 284 | } |
| 285 | 285 | } |
| 286 | 286 | // Alter a plusieurs args. Faudrait optimiser. |
| 287 | 287 | if ($todo) { |
| 288 | - spip_pg_alter("TABLE $table " . join(',', $todo)); |
|
| 288 | + spip_pg_alter("TABLE $table ".join(',', $todo)); |
|
| 289 | 289 | } |
| 290 | 290 | |
| 291 | 291 | } |
@@ -293,10 +293,10 @@ discard block |
||
| 293 | 293 | // https://code.spip.net/@spip_pg_alter_change |
| 294 | 294 | function spip_pg_alter_change($table, $arg, $serveur = '', $requeter = true) { |
| 295 | 295 | if (!preg_match('/^`?(\w+)`?\s+`?(\w+)`?\s+(.*?)\s*(DEFAULT .*?)?(NOT\s+NULL)?\s*(DEFAULT .*?)?$/i', $arg, $r)) { |
| 296 | - spip_log("alter change: $arg incompris", 'pg.' . _LOG_ERREUR); |
|
| 296 | + spip_log("alter change: $arg incompris", 'pg.'._LOG_ERREUR); |
|
| 297 | 297 | } else { |
| 298 | 298 | list(, $old, $new, $type, $default, $null, $def2) = $r; |
| 299 | - $actions = array("ALTER $old TYPE " . mysql2pg_type($type)); |
|
| 299 | + $actions = array("ALTER $old TYPE ".mysql2pg_type($type)); |
|
| 300 | 300 | if ($null) { |
| 301 | 301 | $actions[] = "ALTER $old SET NOT NULL"; |
| 302 | 302 | } else { |
@@ -309,7 +309,7 @@ discard block |
||
| 309 | 309 | $actions[] = "ALTER $old DROP DEFAULT"; |
| 310 | 310 | } |
| 311 | 311 | |
| 312 | - spip_pg_query("ALTER TABLE $table " . join(', ', $actions)); |
|
| 312 | + spip_pg_query("ALTER TABLE $table ".join(', ', $actions)); |
|
| 313 | 313 | |
| 314 | 314 | if ($old != $new) { |
| 315 | 315 | spip_pg_query("ALTER TABLE $table RENAME $old TO $new", $serveur); |
@@ -320,7 +320,7 @@ discard block |
||
| 320 | 320 | // https://code.spip.net/@spip_pg_alter_add |
| 321 | 321 | function spip_pg_alter_add($table, $arg, $serveur = '', $requeter = true) { |
| 322 | 322 | if (!preg_match('/^(COLUMN|INDEX|KEY|PRIMARY\s+KEY|)\s*(.*)$/', $arg, $r)) { |
| 323 | - spip_log("alter add $arg incompris", 'pg.' . _LOG_ERREUR); |
|
| 323 | + spip_log("alter add $arg incompris", 'pg.'._LOG_ERREUR); |
|
| 324 | 324 | |
| 325 | 325 | return null; |
| 326 | 326 | } |
@@ -330,13 +330,13 @@ discard block |
||
| 330 | 330 | $m[2] = $n[1]; |
| 331 | 331 | } |
| 332 | 332 | |
| 333 | - return spip_pg_query("ALTER TABLE $table ADD " . $m[1] . ' ' . mysql2pg_type($m[2]), $serveur, $requeter); |
|
| 333 | + return spip_pg_query("ALTER TABLE $table ADD ".$m[1].' '.mysql2pg_type($m[2]), $serveur, $requeter); |
|
| 334 | 334 | } elseif ($r[1][0] == 'P') { |
| 335 | 335 | // la primary peut etre sur plusieurs champs |
| 336 | 336 | $r[2] = trim(str_replace('`', '', $r[2])); |
| 337 | 337 | $m = ($r[2][0] == '(') ? substr($r[2], 1, -1) : $r[2]; |
| 338 | 338 | |
| 339 | - return spip_pg_query("ALTER TABLE $table ADD CONSTRAINT $table" . '_pkey PRIMARY KEY (' . $m . ')', $serveur, |
|
| 339 | + return spip_pg_query("ALTER TABLE $table ADD CONSTRAINT $table".'_pkey PRIMARY KEY ('.$m.')', $serveur, |
|
| 340 | 340 | $requeter); |
| 341 | 341 | } else { |
| 342 | 342 | preg_match('/([^\s,]*)\s*(.*)?/', $r[2], $m); |
@@ -353,7 +353,7 @@ discard block |
||
| 353 | 353 | $colonnes = substr($m[1], 1, -1); |
| 354 | 354 | if (false !== strpos(",", $colonnes)) { |
| 355 | 355 | spip_log("PG : Erreur, impossible de creer un index sur plusieurs colonnes" |
| 356 | - . " sans qu'il ait de nom ($table, ($colonnes))", 'pg.' . _LOG_ERREUR); |
|
| 356 | + . " sans qu'il ait de nom ($table, ($colonnes))", 'pg.'._LOG_ERREUR); |
|
| 357 | 357 | } else { |
| 358 | 358 | $nom_index = $colonnes; |
| 359 | 359 | } |
@@ -370,23 +370,23 @@ discard block |
||
| 370 | 370 | // https://code.spip.net/@spip_pg_alter_drop |
| 371 | 371 | function spip_pg_alter_drop($table, $arg, $serveur = '', $requeter = true) { |
| 372 | 372 | if (!preg_match('/^(COLUMN|INDEX|KEY|PRIMARY\s+KEY|)\s*`?(\w*)`?/', $arg, $r)) { |
| 373 | - spip_log("alter drop: $arg incompris", 'pg.' . _LOG_ERREUR); |
|
| 373 | + spip_log("alter drop: $arg incompris", 'pg.'._LOG_ERREUR); |
|
| 374 | 374 | } else { |
| 375 | 375 | if (!$r[1] or $r[1] == 'COLUMN') { |
| 376 | - return spip_pg_query("ALTER TABLE $table DROP " . $r[2], $serveur); |
|
| 376 | + return spip_pg_query("ALTER TABLE $table DROP ".$r[2], $serveur); |
|
| 377 | 377 | } elseif ($r[1][0] == 'P') { |
| 378 | - return spip_pg_query("ALTER TABLE $table DROP CONSTRAINT $table" . '_pkey', $serveur); |
|
| 378 | + return spip_pg_query("ALTER TABLE $table DROP CONSTRAINT $table".'_pkey', $serveur); |
|
| 379 | 379 | } else { |
| 380 | - return spip_pg_query("DROP INDEX " . $table . '_' . $r[2], $serveur); |
|
| 380 | + return spip_pg_query("DROP INDEX ".$table.'_'.$r[2], $serveur); |
|
| 381 | 381 | } |
| 382 | 382 | } |
| 383 | 383 | } |
| 384 | 384 | |
| 385 | 385 | function spip_pg_alter_modify($table, $arg, $serveur = '', $requeter = true) { |
| 386 | 386 | if (!preg_match('/^`?(\w+)`?\s+(.*)$/', $arg, $r)) { |
| 387 | - spip_log("alter modify: $arg incompris", 'pg.' . _LOG_ERREUR); |
|
| 387 | + spip_log("alter modify: $arg incompris", 'pg.'._LOG_ERREUR); |
|
| 388 | 388 | } else { |
| 389 | - return spip_pg_alter_change($table, $r[1] . ' ' . $arg, $serveur = '', $requeter = true); |
|
| 389 | + return spip_pg_alter_change($table, $r[1].' '.$arg, $serveur = '', $requeter = true); |
|
| 390 | 390 | } |
| 391 | 391 | } |
| 392 | 392 | |
@@ -402,7 +402,7 @@ discard block |
||
| 402 | 402 | } elseif (preg_match('/^(TO)\s*`?(\w*)`?/', $arg, $r)) { |
| 403 | 403 | $rename = $r[2]; |
| 404 | 404 | } else { |
| 405 | - spip_log("alter rename: $arg incompris", 'pg.' . _LOG_ERREUR); |
|
| 405 | + spip_log("alter rename: $arg incompris", 'pg.'._LOG_ERREUR); |
|
| 406 | 406 | } |
| 407 | 407 | |
| 408 | 408 | return $rename ? spip_pg_query("ALTER TABLE $table RENAME TO $rename") : false; |
@@ -422,8 +422,8 @@ discard block |
||
| 422 | 422 | */ |
| 423 | 423 | function spip_pg_create_index($nom, $table, $champs, $serveur = '', $requeter = true) { |
| 424 | 424 | if (!($nom or $table or $champs)) { |
| 425 | - spip_log("Champ manquant pour creer un index pg ($nom, $table, (" . @join(',', $champs) . "))", |
|
| 426 | - 'pg.' . _LOG_ERREUR); |
|
| 425 | + spip_log("Champ manquant pour creer un index pg ($nom, $table, (".@join(',', $champs)."))", |
|
| 426 | + 'pg.'._LOG_ERREUR); |
|
| 427 | 427 | |
| 428 | 428 | return false; |
| 429 | 429 | } |
@@ -433,7 +433,7 @@ discard block |
||
| 433 | 433 | |
| 434 | 434 | // PG ne differentie pas noms des index en fonction des tables |
| 435 | 435 | // il faut donc creer des noms uniques d'index pour une base pg |
| 436 | - $nom = $table . '_' . $nom; |
|
| 436 | + $nom = $table.'_'.$nom; |
|
| 437 | 437 | // enlever d'eventuelles parentheses deja presentes sur champs |
| 438 | 438 | if (!is_array($champs)) { |
| 439 | 439 | if ($champs[0] == "(") { |
@@ -441,7 +441,7 @@ discard block |
||
| 441 | 441 | } |
| 442 | 442 | $champs = array($champs); |
| 443 | 443 | } |
| 444 | - $query = "CREATE INDEX $nom ON $table (" . join(',', $champs) . ")"; |
|
| 444 | + $query = "CREATE INDEX $nom ON $table (".join(',', $champs).")"; |
|
| 445 | 445 | if (!$requeter) { |
| 446 | 446 | return $query; |
| 447 | 447 | } |
@@ -465,7 +465,7 @@ discard block |
||
| 465 | 465 | } else { |
| 466 | 466 | $suite = ''; |
| 467 | 467 | } |
| 468 | - $query = 'EXPLAIN ' . preg_replace('/([,\s])spip_/', '\1' . $prefixe . '_', $query) . $suite; |
|
| 468 | + $query = 'EXPLAIN '.preg_replace('/([,\s])spip_/', '\1'.$prefixe.'_', $query).$suite; |
|
| 469 | 469 | |
| 470 | 470 | if (!$requeter) { |
| 471 | 471 | return $query; |
@@ -560,14 +560,14 @@ discard block |
||
| 560 | 560 | } |
| 561 | 561 | } |
| 562 | 562 | $from = spip_pg_from($from, $prefixe); |
| 563 | - $query = "SELECT " . $select |
|
| 563 | + $query = "SELECT ".$select |
|
| 564 | 564 | . (!$from ? '' : "\nFROM $from") |
| 565 | - . (!$where ? '' : ("\nWHERE " . (!is_array($where) ? calculer_pg_where($where) : (join("\n\tAND ", |
|
| 565 | + . (!$where ? '' : ("\nWHERE ".(!is_array($where) ? calculer_pg_where($where) : (join("\n\tAND ", |
|
| 566 | 566 | array_map('calculer_pg_where', $where)))))) |
| 567 | 567 | . spip_pg_groupby($groupby, $from, $select) |
| 568 | 568 | . (!$having ? '' : "\nHAVING $having") |
| 569 | 569 | . ($orderby ? ("\nORDER BY $orderby") : '') |
| 570 | - . (!$limit ? '' : (" LIMIT $count" . (!$offset ? '' : " OFFSET $offset"))); |
|
| 570 | + . (!$limit ? '' : (" LIMIT $count".(!$offset ? '' : " OFFSET $offset"))); |
|
| 571 | 571 | |
| 572 | 572 | // renvoyer la requete inerte si demandee |
| 573 | 573 | if ($requeter === false) { |
@@ -576,7 +576,7 @@ discard block |
||
| 576 | 576 | |
| 577 | 577 | $r = spip_pg_trace_query($query, $serveur); |
| 578 | 578 | |
| 579 | - return $r ? $r : $query;; |
|
| 579 | + return $r ? $r : $query; ; |
|
| 580 | 580 | } |
| 581 | 581 | |
| 582 | 582 | // Le traitement des prefixes de table dans un Select se limite au FROM |
@@ -588,7 +588,7 @@ discard block |
||
| 588 | 588 | $from = spip_pg_select_as($from); |
| 589 | 589 | } |
| 590 | 590 | |
| 591 | - return !$prefixe ? $from : preg_replace('/(\b)spip_/', '\1' . $prefixe . '_', $from); |
|
| 591 | + return !$prefixe ? $from : preg_replace('/(\b)spip_/', '\1'.$prefixe.'_', $from); |
|
| 592 | 592 | } |
| 593 | 593 | |
| 594 | 594 | // https://code.spip.net/@spip_pg_orderby |
@@ -597,7 +597,7 @@ discard block |
||
| 597 | 597 | $arg = (is_array($order) ? $order : preg_split('/\s*,\s*/', $order)); |
| 598 | 598 | |
| 599 | 599 | foreach ($arg as $v) { |
| 600 | - if (preg_match('/(case\s+.*?else\s+0\s+end)\s*AS\s+' . $v . '/', $select, $m)) { |
|
| 600 | + if (preg_match('/(case\s+.*?else\s+0\s+end)\s*AS\s+'.$v.'/', $select, $m)) { |
|
| 601 | 601 | |
| 602 | 602 | $res[] = $m[1]; |
| 603 | 603 | } else { |
@@ -758,7 +758,7 @@ discard block |
||
| 758 | 758 | $n++; |
| 759 | 759 | $res .= "\nwhen $index=$v then $n"; |
| 760 | 760 | } |
| 761 | - $arg = $m[1] . "case $res else 0 end " |
|
| 761 | + $arg = $m[1]."case $res else 0 end " |
|
| 762 | 762 | . substr($arg, strlen($m[0])); |
| 763 | 763 | } |
| 764 | 764 | |
@@ -803,9 +803,9 @@ discard block |
||
| 803 | 803 | } |
| 804 | 804 | |
| 805 | 805 | if (strtoupper($join) === 'AND') { |
| 806 | - return $exp . join("\n\t$join ", array_map('calculer_pg_where', $v)); |
|
| 806 | + return $exp.join("\n\t$join ", array_map('calculer_pg_where', $v)); |
|
| 807 | 807 | } else { |
| 808 | - return $exp . join($join, $v); |
|
| 808 | + return $exp.join($join, $v); |
|
| 809 | 809 | } |
| 810 | 810 | } |
| 811 | 811 | |
@@ -816,7 +816,7 @@ discard block |
||
| 816 | 816 | if (substr($k, -1) == '@') { |
| 817 | 817 | // c'est une jointure qui se refere au from precedent |
| 818 | 818 | // pas de virgule |
| 819 | - $argsas .= ' ' . $v; |
|
| 819 | + $argsas .= ' '.$v; |
|
| 820 | 820 | } else { |
| 821 | 821 | $as = ''; |
| 822 | 822 | // spip_log("$k : $v", _LOG_DEBUG); |
@@ -826,7 +826,7 @@ discard block |
||
| 826 | 826 | } elseif ($v != $k) { |
| 827 | 827 | $p = strpos($v, " "); |
| 828 | 828 | if ($p) { |
| 829 | - $v = substr($v, 0, $p) . " AS $k" . substr($v, $p); |
|
| 829 | + $v = substr($v, 0, $p)." AS $k".substr($v, $p); |
|
| 830 | 830 | } else { |
| 831 | 831 | $as = " AS $k"; |
| 832 | 832 | } |
@@ -834,7 +834,7 @@ discard block |
||
| 834 | 834 | } |
| 835 | 835 | // spip_log("subs $k : $v avec $as", _LOG_DEBUG); |
| 836 | 836 | // if (strpos($v, 'JOIN') === false) $argsas .= ', '; |
| 837 | - $argsas .= ', ' . $v . $as; |
|
| 837 | + $argsas .= ', '.$v.$as; |
|
| 838 | 838 | } |
| 839 | 839 | } |
| 840 | 840 | |
@@ -867,7 +867,7 @@ discard block |
||
| 867 | 867 | $serveur = '', |
| 868 | 868 | $requeter = true |
| 869 | 869 | ) { |
| 870 | - $c = !$groupby ? '*' : ('DISTINCT ' . (is_string($groupby) ? $groupby : join(',', $groupby))); |
|
| 870 | + $c = !$groupby ? '*' : ('DISTINCT '.(is_string($groupby) ? $groupby : join(',', $groupby))); |
|
| 871 | 871 | $r = spip_pg_select("COUNT($c)", $from, $where, '', '', '', $having, $serveur, $requeter); |
| 872 | 872 | if (!$requeter) { |
| 873 | 873 | return $r; |
@@ -971,7 +971,7 @@ discard block |
||
| 971 | 971 | // recherche de champs 'timestamp' pour mise a jour auto de ceux-ci |
| 972 | 972 | $couples = spip_pg_ajouter_champs_timestamp($table, $couples, $desc, $serveur); |
| 973 | 973 | |
| 974 | - return spip_pg_insert($table, "(" . join(',', array_keys($couples)) . ")", "(" . join(',', $couples) . ")", $desc, |
|
| 974 | + return spip_pg_insert($table, "(".join(',', array_keys($couples)).")", "(".join(',', $couples).")", $desc, |
|
| 975 | 975 | $serveur, $requeter); |
| 976 | 976 | } |
| 977 | 977 | |
@@ -992,7 +992,7 @@ discard block |
||
| 992 | 992 | $c = isset($tab_couples[0]) ? $tab_couples[0] : array(); |
| 993 | 993 | $les_cles = spip_pg_ajouter_champs_timestamp($table, $c, $desc, $serveur); |
| 994 | 994 | |
| 995 | - $cles = "(" . join(',', array_keys($les_cles)) . ')'; |
|
| 995 | + $cles = "(".join(',', array_keys($les_cles)).')'; |
|
| 996 | 996 | $valeurs = array(); |
| 997 | 997 | foreach ($tab_couples as $couples) { |
| 998 | 998 | foreach ($couples as $champ => $val) { |
@@ -1001,7 +1001,7 @@ discard block |
||
| 1001 | 1001 | // recherche de champs 'timestamp' pour mise a jour auto de ceux-ci |
| 1002 | 1002 | $couples = spip_pg_ajouter_champs_timestamp($table, $couples, $desc, $serveur); |
| 1003 | 1003 | |
| 1004 | - $valeurs[] = '(' . join(',', $couples) . ')'; |
|
| 1004 | + $valeurs[] = '('.join(',', $couples).')'; |
|
| 1005 | 1005 | } |
| 1006 | 1006 | $valeurs = implode(', ', $valeurs); |
| 1007 | 1007 | |
@@ -1023,7 +1023,7 @@ discard block |
||
| 1023 | 1023 | |
| 1024 | 1024 | $set = array(); |
| 1025 | 1025 | foreach ($couples as $champ => $val) { |
| 1026 | - $set[] = $champ . '=' . $val; |
|
| 1026 | + $set[] = $champ.'='.$val; |
|
| 1027 | 1027 | } |
| 1028 | 1028 | |
| 1029 | 1029 | $query = calculer_pg_expression('UPDATE', $table, ',') |
@@ -1060,7 +1060,7 @@ discard block |
||
| 1060 | 1060 | // https://code.spip.net/@spip_pg_replace |
| 1061 | 1061 | function spip_pg_replace($table, $values, $desc, $serveur = '', $requeter = true) { |
| 1062 | 1062 | if (!$values) { |
| 1063 | - spip_log("replace vide $table", 'pg.' . _LOG_AVERTISSEMENT); |
|
| 1063 | + spip_log("replace vide $table", 'pg.'._LOG_AVERTISSEMENT); |
|
| 1064 | 1064 | |
| 1065 | 1065 | return 0; |
| 1066 | 1066 | } |
@@ -1092,7 +1092,7 @@ discard block |
||
| 1092 | 1092 | |
| 1093 | 1093 | $where = join(' AND ', $prims); |
| 1094 | 1094 | if (!$where) { |
| 1095 | - return spip_pg_insert($table, "(" . join(',', array_keys($values)) . ")", "(" . join(',', $values) . ")", $desc, |
|
| 1095 | + return spip_pg_insert($table, "(".join(',', array_keys($values)).")", "(".join(',', $values).")", $desc, |
|
| 1096 | 1096 | $serveur); |
| 1097 | 1097 | } |
| 1098 | 1098 | $couples = join(',', $noprims); |
@@ -1111,10 +1111,9 @@ discard block |
||
| 1111 | 1111 | $couples = pg_affected_rows($couples); |
| 1112 | 1112 | } |
| 1113 | 1113 | if (!$couples) { |
| 1114 | - $ret = !$seq ? '' : |
|
| 1115 | - (" RETURNING nextval('$seq') < $prim"); |
|
| 1116 | - $connexion['last'] = $q = "INSERT INTO $table (" . join(',', array_keys($values)) . ') VALUES (' . join(',', |
|
| 1117 | - $values) . ")$ret"; |
|
| 1114 | + $ret = !$seq ? '' : (" RETURNING nextval('$seq') < $prim"); |
|
| 1115 | + $connexion['last'] = $q = "INSERT INTO $table (".join(',', array_keys($values)).') VALUES ('.join(',', |
|
| 1116 | + $values).")$ret"; |
|
| 1118 | 1117 | $couples = spip_pg_query_simple($link, $q); |
| 1119 | 1118 | if (!$couples) { |
| 1120 | 1119 | return false; |
@@ -1162,7 +1161,7 @@ discard block |
||
| 1162 | 1161 | ) { |
| 1163 | 1162 | return ''; |
| 1164 | 1163 | } else { |
| 1165 | - return $raw ? $prim : $table . '_' . $prim . "_seq"; |
|
| 1164 | + return $raw ? $prim : $table.'_'.$prim."_seq"; |
|
| 1166 | 1165 | } |
| 1167 | 1166 | } |
| 1168 | 1167 | |
@@ -1180,22 +1179,22 @@ discard block |
||
| 1180 | 1179 | return spip_pg_frommysql($v); |
| 1181 | 1180 | } else { |
| 1182 | 1181 | if (strncmp($v, '0000', 4) == 0) { |
| 1183 | - $v = "0001" . substr($v, 4); |
|
| 1182 | + $v = "0001".substr($v, 4); |
|
| 1184 | 1183 | } |
| 1185 | 1184 | if (strpos($v, "-00-00") === 4) { |
| 1186 | - $v = substr($v, 0, 4) . "-01-01" . substr($v, 10); |
|
| 1185 | + $v = substr($v, 0, 4)."-01-01".substr($v, 10); |
|
| 1187 | 1186 | } |
| 1188 | 1187 | |
| 1189 | 1188 | return "timestamp '$v'"; |
| 1190 | 1189 | } |
| 1191 | 1190 | } elseif (!sql_test_int($t)) { |
| 1192 | - return ("'" . pg_escape_string($v) . "'"); |
|
| 1191 | + return ("'".pg_escape_string($v)."'"); |
|
| 1193 | 1192 | } elseif (is_numeric($v) or (strpos($v, 'CAST(') === 0)) { |
| 1194 | 1193 | return $v; |
| 1195 | 1194 | } elseif ($v[0] == '0' and $v[1] !== 'x' and ctype_xdigit(substr($v, 1))) { |
| 1196 | 1195 | return substr($v, 1); |
| 1197 | 1196 | } else { |
| 1198 | - spip_log("Warning: '$v' n'est pas de type $t", 'pg.' . _LOG_AVERTISSEMENT); |
|
| 1197 | + spip_log("Warning: '$v' n'est pas de type $t", 'pg.'._LOG_AVERTISSEMENT); |
|
| 1199 | 1198 | |
| 1200 | 1199 | return intval($v); |
| 1201 | 1200 | } |
@@ -1203,7 +1202,7 @@ discard block |
||
| 1203 | 1202 | |
| 1204 | 1203 | // https://code.spip.net/@spip_pg_hex |
| 1205 | 1204 | function spip_pg_hex($v) { |
| 1206 | - return "CAST(x'" . $v . "' as bigint)"; |
|
| 1205 | + return "CAST(x'".$v."' as bigint)"; |
|
| 1207 | 1206 | } |
| 1208 | 1207 | |
| 1209 | 1208 | function spip_pg_quote($v, $type = '') { |
@@ -1242,15 +1241,15 @@ discard block |
||
| 1242 | 1241 | return $not ? '0=0' : '0=1'; |
| 1243 | 1242 | } |
| 1244 | 1243 | if (strpos($valeurs, "CAST(x'") !== false) { |
| 1245 | - return "($val=" . join("OR $val=", explode(',', $valeurs)) . ')'; |
|
| 1244 | + return "($val=".join("OR $val=", explode(',', $valeurs)).')'; |
|
| 1246 | 1245 | } |
| 1247 | 1246 | $n = $i = 0; |
| 1248 | 1247 | $in_sql = ""; |
| 1249 | 1248 | while ($n = strpos($valeurs, ',', $n + 1)) { |
| 1250 | 1249 | if ((++$i) >= 255) { |
| 1251 | - $in_sql .= "($val $not IN (" . |
|
| 1252 | - substr($valeurs, 0, $n) . |
|
| 1253 | - "))\n" . |
|
| 1250 | + $in_sql .= "($val $not IN (". |
|
| 1251 | + substr($valeurs, 0, $n). |
|
| 1252 | + "))\n". |
|
| 1254 | 1253 | ($not ? "AND\t" : "OR\t"); |
| 1255 | 1254 | $valeurs = substr($valeurs, $n + 1); |
| 1256 | 1255 | $i = $n = 0; |
@@ -1267,7 +1266,7 @@ discard block |
||
| 1267 | 1266 | $s = $link ? pg_last_error($link) : pg_last_error(); |
| 1268 | 1267 | if ($s) { |
| 1269 | 1268 | $s = str_replace('ERROR', 'errcode: 1000 ', $s); |
| 1270 | - spip_log("$s - $query", 'pg.' . _LOG_ERREUR); |
|
| 1269 | + spip_log("$s - $query", 'pg.'._LOG_ERREUR); |
|
| 1271 | 1270 | } |
| 1272 | 1271 | |
| 1273 | 1272 | return $s; |
@@ -1318,7 +1317,7 @@ discard block |
||
| 1318 | 1317 | function spip_pg_showbase($match, $serveur = '', $requeter = true) { |
| 1319 | 1318 | $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0]; |
| 1320 | 1319 | $link = $connexion['link']; |
| 1321 | - $connexion['last'] = $q = "SELECT tablename FROM pg_tables WHERE tablename ILIKE " . _q($match); |
|
| 1320 | + $connexion['last'] = $q = "SELECT tablename FROM pg_tables WHERE tablename ILIKE "._q($match); |
|
| 1322 | 1321 | |
| 1323 | 1322 | return spip_pg_query_simple($link, $q); |
| 1324 | 1323 | } |
@@ -1327,7 +1326,7 @@ discard block |
||
| 1327 | 1326 | function spip_pg_showtable($nom_table, $serveur = '', $requeter = true) { |
| 1328 | 1327 | $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0]; |
| 1329 | 1328 | $link = $connexion['link']; |
| 1330 | - $connexion['last'] = $q = "SELECT column_name, column_default, data_type FROM information_schema.columns WHERE table_name ILIKE " . _q($nom_table); |
|
| 1329 | + $connexion['last'] = $q = "SELECT column_name, column_default, data_type FROM information_schema.columns WHERE table_name ILIKE "._q($nom_table); |
|
| 1331 | 1330 | |
| 1332 | 1331 | $res = spip_pg_query_simple($link, $q); |
| 1333 | 1332 | if (!$res) { |
@@ -1338,15 +1337,15 @@ discard block |
||
| 1338 | 1337 | // il faut en tenir compte dans le return |
| 1339 | 1338 | $fields = array(); |
| 1340 | 1339 | while ($field = pg_fetch_array($res, null, PGSQL_NUM)) { |
| 1341 | - $fields[$field[0]] = $field[2] . (!$field[1] ? '' : (" DEFAULT " . $field[1])); |
|
| 1340 | + $fields[$field[0]] = $field[2].(!$field[1] ? '' : (" DEFAULT ".$field[1])); |
|
| 1342 | 1341 | } |
| 1343 | - $connexion['last'] = $q = "SELECT indexdef FROM pg_indexes WHERE tablename ILIKE " . _q($nom_table); |
|
| 1342 | + $connexion['last'] = $q = "SELECT indexdef FROM pg_indexes WHERE tablename ILIKE "._q($nom_table); |
|
| 1344 | 1343 | $res = spip_pg_query_simple($link, $q); |
| 1345 | 1344 | $keys = array(); |
| 1346 | 1345 | while ($index = pg_fetch_array($res, null, PGSQL_NUM)) { |
| 1347 | 1346 | if (preg_match('/CREATE\s+(UNIQUE\s+)?INDEX\s([^\s]+).*\((.*)\)$/', $index[0], $r)) { |
| 1348 | - $nom = str_replace($nom_table . '_', '', $r[2]); |
|
| 1349 | - $keys[($r[1] ? "PRIMARY KEY" : ("KEY " . $nom))] = $r[3]; |
|
| 1347 | + $nom = str_replace($nom_table.'_', '', $r[2]); |
|
| 1348 | + $keys[($r[1] ? "PRIMARY KEY" : ("KEY ".$nom))] = $r[3]; |
|
| 1350 | 1349 | } |
| 1351 | 1350 | } |
| 1352 | 1351 | |
@@ -1379,16 +1378,16 @@ discard block |
||
| 1379 | 1378 | if (strpos($k, "KEY ") === 0) { |
| 1380 | 1379 | $n = str_replace('`', '', $k); |
| 1381 | 1380 | $v = str_replace('`', '"', $v); |
| 1382 | - $i = $nom . preg_replace("/KEY +/", '_', $n); |
|
| 1381 | + $i = $nom.preg_replace("/KEY +/", '_', $n); |
|
| 1383 | 1382 | if ($k != $n) { |
| 1384 | 1383 | $i = "\"$i\""; |
| 1385 | 1384 | } |
| 1386 | 1385 | $keys[] = "CREATE INDEX $i ON $nom ($v);"; |
| 1387 | 1386 | } elseif (strpos($k, "UNIQUE ") === 0) { |
| 1388 | 1387 | $k = preg_replace("/^UNIQUE +/", '', $k); |
| 1389 | - $prim .= "$s\n\t\tCONSTRAINT " . str_replace('`', '"', $k) . " UNIQUE ($v)"; |
|
| 1388 | + $prim .= "$s\n\t\tCONSTRAINT ".str_replace('`', '"', $k)." UNIQUE ($v)"; |
|
| 1390 | 1389 | } else { |
| 1391 | - $prim .= "$s\n\t\t" . str_replace('`', '"', $k) . " ($v)"; |
|
| 1390 | + $prim .= "$s\n\t\t".str_replace('`', '"', $k)." ($v)"; |
|
| 1392 | 1391 | } |
| 1393 | 1392 | if ($k == "PRIMARY KEY") { |
| 1394 | 1393 | $prim_name = $v; |
@@ -1399,17 +1398,17 @@ discard block |
||
| 1399 | 1398 | |
| 1400 | 1399 | $character_set = ""; |
| 1401 | 1400 | if (@$GLOBALS['meta']['charset_sql_base']) { |
| 1402 | - $character_set .= " CHARACTER SET " . $GLOBALS['meta']['charset_sql_base']; |
|
| 1401 | + $character_set .= " CHARACTER SET ".$GLOBALS['meta']['charset_sql_base']; |
|
| 1403 | 1402 | } |
| 1404 | 1403 | if (@$GLOBALS['meta']['charset_collation_sql_base']) { |
| 1405 | - $character_set .= " COLLATE " . $GLOBALS['meta']['charset_collation_sql_base']; |
|
| 1404 | + $character_set .= " COLLATE ".$GLOBALS['meta']['charset_collation_sql_base']; |
|
| 1406 | 1405 | } |
| 1407 | 1406 | |
| 1408 | 1407 | foreach ($champs as $k => $v) { |
| 1409 | 1408 | $k = str_replace('`', '"', $k); |
| 1410 | 1409 | if (preg_match(',([a-z]*\s*(\(\s*[0-9]*\s*\))?(\s*binary)?),i', $v, $defs)) { |
| 1411 | 1410 | if (preg_match(',(char|text),i', $defs[1]) and !preg_match(',binary,i', $defs[1])) { |
| 1412 | - $v = $defs[1] . $character_set . ' ' . substr($v, strlen($defs[1])); |
|
| 1411 | + $v = $defs[1].$character_set.' '.substr($v, strlen($defs[1])); |
|
| 1413 | 1412 | } |
| 1414 | 1413 | } |
| 1415 | 1414 | |
@@ -1424,7 +1423,7 @@ discard block |
||
| 1424 | 1423 | |
| 1425 | 1424 | // En l'absence de "if not exists" en PG, on neutralise les erreurs |
| 1426 | 1425 | |
| 1427 | - $q = "CREATE $temporary TABLE $nom ($query" . ($prim ? ",$prim" : '') . ")" . |
|
| 1426 | + $q = "CREATE $temporary TABLE $nom ($query".($prim ? ",$prim" : '').")". |
|
| 1428 | 1427 | ($character_set ? " DEFAULT $character_set" : "") |
| 1429 | 1428 | . "\n"; |
| 1430 | 1429 | |
@@ -1435,7 +1434,7 @@ discard block |
||
| 1435 | 1434 | $r = @pg_query($link, $q); |
| 1436 | 1435 | |
| 1437 | 1436 | if (!$r) { |
| 1438 | - spip_log("Impossible de creer cette table: $q", 'pg.' . _LOG_ERREUR); |
|
| 1437 | + spip_log("Impossible de creer cette table: $q", 'pg.'._LOG_ERREUR); |
|
| 1439 | 1438 | } else { |
| 1440 | 1439 | foreach ($keys as $index) { |
| 1441 | 1440 | pg_query($link, $index); |
@@ -1459,13 +1458,13 @@ discard block |
||
| 1459 | 1458 | // vue deja presente |
| 1460 | 1459 | if (sql_showtable($nom, false, $serveur)) { |
| 1461 | 1460 | if ($requeter) { |
| 1462 | - spip_log("Echec creation d'une vue sql ($nom) car celle-ci existe deja (serveur:$serveur)", 'pg.' . _LOG_ERREUR); |
|
| 1461 | + spip_log("Echec creation d'une vue sql ($nom) car celle-ci existe deja (serveur:$serveur)", 'pg.'._LOG_ERREUR); |
|
| 1463 | 1462 | } |
| 1464 | 1463 | |
| 1465 | 1464 | return false; |
| 1466 | 1465 | } |
| 1467 | 1466 | |
| 1468 | - $query = "CREATE VIEW $nom AS " . $query_select; |
|
| 1467 | + $query = "CREATE VIEW $nom AS ".$query_select; |
|
| 1469 | 1468 | |
| 1470 | 1469 | return spip_pg_query($query, $serveur, $requeter); |
| 1471 | 1470 | } |
@@ -1473,7 +1472,7 @@ discard block |
||
| 1473 | 1472 | |
| 1474 | 1473 | // https://code.spip.net/@spip_pg_set_connect_charset |
| 1475 | 1474 | function spip_pg_set_connect_charset($charset, $serveur = '', $requeter = true) { |
| 1476 | - spip_log("changement de charset sql a ecrire en PG", 'pg.' . _LOG_ERREUR); |
|
| 1475 | + spip_log("changement de charset sql a ecrire en PG", 'pg.'._LOG_ERREUR); |
|
| 1477 | 1476 | } |
| 1478 | 1477 | |
| 1479 | 1478 | |
@@ -1487,7 +1486,7 @@ discard block |
||
| 1487 | 1486 | **/ |
| 1488 | 1487 | // https://code.spip.net/@spip_sqlite_optimize |
| 1489 | 1488 | function spip_pg_optimize($table, $serveur = '', $requeter = true) { |
| 1490 | - return spip_pg_query("VACUUM " . $table, $serveur, $requeter); |
|
| 1489 | + return spip_pg_query("VACUUM ".$table, $serveur, $requeter); |
|
| 1491 | 1490 | } |
| 1492 | 1491 | |
| 1493 | 1492 | // Selectionner la sous-chaine dans $objet |