@@ -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 | // http://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 | // http://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 | // http://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 | // http://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 | // http://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 | // http://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 | // http://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 | // http://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 |
@@ -64,27 +64,27 @@ discard block |
||
| 64 | 64 | // determiner le dossier de la base : $addr ou _DIR_DB |
| 65 | 65 | $f = _DIR_DB; |
| 66 | 66 | if ($addr and strpos($addr, '/') !== false) { |
| 67 | - $f = rtrim($addr, '/') . '/'; |
|
| 67 | + $f = rtrim($addr, '/').'/'; |
|
| 68 | 68 | } |
| 69 | 69 | |
| 70 | 70 | // un nom de base demande et impossible d'obtenir la base, on s'en va : |
| 71 | 71 | // il faut que la base existe ou que le repertoire parent soit writable |
| 72 | - if ($db and !is_file($f .= $db . '.sqlite') and !is_writable(dirname($f))) { |
|
| 73 | - spip_log("base $f non trouvee ou droits en ecriture manquants", 'sqlite.' . _LOG_HS); |
|
| 72 | + if ($db and !is_file($f .= $db.'.sqlite') and !is_writable(dirname($f))) { |
|
| 73 | + spip_log("base $f non trouvee ou droits en ecriture manquants", 'sqlite.'._LOG_HS); |
|
| 74 | 74 | |
| 75 | 75 | return false; |
| 76 | 76 | } |
| 77 | 77 | |
| 78 | 78 | // charger les modules sqlite au besoin |
| 79 | 79 | if (!_sqlite_charger_version($sqlite_version)) { |
| 80 | - spip_log("Impossible de trouver/charger le module SQLite ($sqlite_version)!", 'sqlite.' . _LOG_HS); |
|
| 80 | + spip_log("Impossible de trouver/charger le module SQLite ($sqlite_version)!", 'sqlite.'._LOG_HS); |
|
| 81 | 81 | |
| 82 | 82 | return false; |
| 83 | 83 | } |
| 84 | 84 | |
| 85 | 85 | // chargement des constantes |
| 86 | 86 | // il ne faut pas definir les constantes avant d'avoir charge les modules sqlite |
| 87 | - $define = "spip_sqlite" . $sqlite_version . "_constantes"; |
|
| 87 | + $define = "spip_sqlite".$sqlite_version."_constantes"; |
|
| 88 | 88 | $define(); |
| 89 | 89 | |
| 90 | 90 | $ok = false; |
@@ -92,8 +92,8 @@ discard block |
||
| 92 | 92 | // si pas de db -> |
| 93 | 93 | // base temporaire tant qu'on ne connait pas son vrai nom |
| 94 | 94 | // pour tester la connexion |
| 95 | - $db = "_sqlite" . $sqlite_version . "_install"; |
|
| 96 | - $tmp = _DIR_DB . $db . ".sqlite"; |
|
| 95 | + $db = "_sqlite".$sqlite_version."_install"; |
|
| 96 | + $tmp = _DIR_DB.$db.".sqlite"; |
|
| 97 | 97 | $ok = $link = new \PDO("sqlite:$tmp"); |
| 98 | 98 | } else { |
| 99 | 99 | // Ouvrir (eventuellement creer la base) |
@@ -102,7 +102,7 @@ discard block |
||
| 102 | 102 | |
| 103 | 103 | if (!$ok) { |
| 104 | 104 | $e = _sqlite_last_error_from_link($link); |
| 105 | - spip_log("Impossible d'ouvrir la base SQLite($sqlite_version) $f : $e", 'sqlite.' . _LOG_HS); |
|
| 105 | + spip_log("Impossible d'ouvrir la base SQLite($sqlite_version) $f : $e", 'sqlite.'._LOG_HS); |
|
| 106 | 106 | |
| 107 | 107 | return false; |
| 108 | 108 | } |
@@ -188,7 +188,7 @@ discard block |
||
| 188 | 188 | $table = $regs[3]; |
| 189 | 189 | $suite = $regs[4]; |
| 190 | 190 | } else { |
| 191 | - spip_log("SQLite : Probleme de ALTER TABLE mal forme dans $query", 'sqlite.' . _LOG_ERREUR); |
|
| 191 | + spip_log("SQLite : Probleme de ALTER TABLE mal forme dans $query", 'sqlite.'._LOG_ERREUR); |
|
| 192 | 192 | |
| 193 | 193 | return false; |
| 194 | 194 | } |
@@ -205,7 +205,7 @@ discard block |
||
| 205 | 205 | $i = 0; |
| 206 | 206 | $ouverte = false; |
| 207 | 207 | while ($do = array_shift($todo)) { |
| 208 | - $todo2[$i] = isset($todo2[$i]) ? $todo2[$i] . "," . $do : $do; |
|
| 208 | + $todo2[$i] = isset($todo2[$i]) ? $todo2[$i].",".$do : $do; |
|
| 209 | 209 | $o = (false !== strpos($do, "(")); |
| 210 | 210 | $f = (false !== strpos($do, ")")); |
| 211 | 211 | if ($o and !$f) { |
@@ -229,7 +229,7 @@ discard block |
||
| 229 | 229 | . ')\s*([^\s]*)\s*(.*)?/i', $do, $matches) |
| 230 | 230 | ) { |
| 231 | 231 | spip_log("SQLite : Probleme de ALTER TABLE, utilisation non reconnue dans : $do \n(requete d'origine : $query)", |
| 232 | - 'sqlite.' . _LOG_ERREUR); |
|
| 232 | + 'sqlite.'._LOG_ERREUR); |
|
| 233 | 233 | |
| 234 | 234 | return false; |
| 235 | 235 | } |
@@ -316,10 +316,10 @@ discard block |
||
| 316 | 316 | |
| 317 | 317 | // pas geres en sqlite2 |
| 318 | 318 | case 'RENAME': |
| 319 | - $do = "RENAME TO" . substr($do, 6); |
|
| 319 | + $do = "RENAME TO".substr($do, 6); |
|
| 320 | 320 | case 'RENAME TO': |
| 321 | 321 | if (!spip_sqlite::executer_requete("$debut $do", $serveur)) { |
| 322 | - spip_log("SQLite : Erreur ALTER TABLE / RENAME : $query", 'sqlite.' . _LOG_ERREUR); |
|
| 322 | + spip_log("SQLite : Erreur ALTER TABLE / RENAME : $query", 'sqlite.'._LOG_ERREUR); |
|
| 323 | 323 | |
| 324 | 324 | return false; |
| 325 | 325 | } |
@@ -360,7 +360,7 @@ discard block |
||
| 360 | 360 | $colonnes = substr($colonne_origine, 1, -1); |
| 361 | 361 | if (false !== strpos(",", $colonnes)) { |
| 362 | 362 | spip_log("SQLite : Erreur, impossible de creer un index sur plusieurs colonnes" |
| 363 | - . " sans qu'il ait de nom ($table, ($colonnes))", 'sqlite.' . _LOG_ERREUR); |
|
| 363 | + . " sans qu'il ait de nom ($table, ($colonnes))", 'sqlite.'._LOG_ERREUR); |
|
| 364 | 364 | break; |
| 365 | 365 | } else { |
| 366 | 366 | $nom_index = $colonnes; |
@@ -375,12 +375,12 @@ discard block |
||
| 375 | 375 | |
| 376 | 376 | // pas geres en sqlite2 |
| 377 | 377 | case 'ADD COLUMN': |
| 378 | - $do = "ADD" . substr($do, 10); |
|
| 378 | + $do = "ADD".substr($do, 10); |
|
| 379 | 379 | case 'ADD': |
| 380 | 380 | default: |
| 381 | 381 | if (!preg_match(',primary\s+key,i', $do)) { |
| 382 | 382 | if (!spip_sqlite::executer_requete("$debut $do", $serveur)) { |
| 383 | - spip_log("SQLite : Erreur ALTER TABLE / ADD : $query", 'sqlite.' . _LOG_ERREUR); |
|
| 383 | + spip_log("SQLite : Erreur ALTER TABLE / ADD : $query", 'sqlite.'._LOG_ERREUR); |
|
| 384 | 384 | |
| 385 | 385 | return false; |
| 386 | 386 | } |
@@ -401,7 +401,7 @@ discard block |
||
| 401 | 401 | } |
| 402 | 402 | $opts['field'] = array($colonne_ajoutee => $def); |
| 403 | 403 | if (!_sqlite_modifier_table($table, array($colonne_ajoutee), $opts, $serveur)) { |
| 404 | - spip_log("SQLite : Erreur ALTER TABLE / ADD : $query", 'sqlite.' . _LOG_ERREUR); |
|
| 404 | + spip_log("SQLite : Erreur ALTER TABLE / ADD : $query", 'sqlite.'._LOG_ERREUR); |
|
| 405 | 405 | |
| 406 | 406 | return false; |
| 407 | 407 | } |
@@ -409,10 +409,10 @@ discard block |
||
| 409 | 409 | break; |
| 410 | 410 | } |
| 411 | 411 | // tout est bon, ouf ! |
| 412 | - spip_log("SQLite ($serveur) : Changements OK : $debut $do", 'sqlite.' . _LOG_INFO); |
|
| 412 | + spip_log("SQLite ($serveur) : Changements OK : $debut $do", 'sqlite.'._LOG_INFO); |
|
| 413 | 413 | } |
| 414 | 414 | |
| 415 | - spip_log("SQLite ($serveur) : fin ALTER TABLE OK !", 'sqlite.' . _LOG_INFO); |
|
| 415 | + spip_log("SQLite ($serveur) : fin ALTER TABLE OK !", 'sqlite.'._LOG_INFO); |
|
| 416 | 416 | |
| 417 | 417 | return true; |
| 418 | 418 | } |
@@ -481,9 +481,9 @@ discard block |
||
| 481 | 481 | * @return bool true si la base est créee. |
| 482 | 482 | **/ |
| 483 | 483 | function spip_sqlite_create_base($nom, $serveur = '', $option = true) { |
| 484 | - $f = $nom . '.sqlite'; |
|
| 484 | + $f = $nom.'.sqlite'; |
|
| 485 | 485 | if (strpos($nom, "/") === false) { |
| 486 | - $f = _DIR_DB . $f; |
|
| 486 | + $f = _DIR_DB.$f; |
|
| 487 | 487 | } |
| 488 | 488 | |
| 489 | 489 | $ok = new \PDO("sqlite:$f"); |
@@ -522,12 +522,12 @@ discard block |
||
| 522 | 522 | // vue deja presente |
| 523 | 523 | if (sql_showtable($nom, false, $serveur)) { |
| 524 | 524 | spip_log("Echec creation d'une vue sql ($nom) car celle-ci existe deja (serveur:$serveur)", |
| 525 | - 'sqlite.' . _LOG_ERREUR); |
|
| 525 | + 'sqlite.'._LOG_ERREUR); |
|
| 526 | 526 | |
| 527 | 527 | return false; |
| 528 | 528 | } |
| 529 | 529 | |
| 530 | - $query = "CREATE VIEW $nom AS " . $query_select; |
|
| 530 | + $query = "CREATE VIEW $nom AS ".$query_select; |
|
| 531 | 531 | |
| 532 | 532 | return spip_sqlite_query($query, $serveur, $requeter); |
| 533 | 533 | } |
@@ -552,15 +552,15 @@ discard block |
||
| 552 | 552 | */ |
| 553 | 553 | function spip_sqlite_create_index($nom, $table, $champs, $unique = '', $serveur = '', $requeter = true) { |
| 554 | 554 | if (!($nom or $table or $champs)) { |
| 555 | - spip_log("Champ manquant pour creer un index sqlite ($nom, $table, (" . join(',', $champs) . "))", |
|
| 556 | - 'sqlite.' . _LOG_ERREUR); |
|
| 555 | + spip_log("Champ manquant pour creer un index sqlite ($nom, $table, (".join(',', $champs)."))", |
|
| 556 | + 'sqlite.'._LOG_ERREUR); |
|
| 557 | 557 | |
| 558 | 558 | return false; |
| 559 | 559 | } |
| 560 | 560 | |
| 561 | 561 | // SQLite ne differentie pas noms des index en fonction des tables |
| 562 | 562 | // il faut donc creer des noms uniques d'index pour une base sqlite |
| 563 | - $nom = $table . '_' . $nom; |
|
| 563 | + $nom = $table.'_'.$nom; |
|
| 564 | 564 | // enlever d'eventuelles parentheses deja presentes sur champs |
| 565 | 565 | if (!is_array($champs)) { |
| 566 | 566 | if ($champs[0] == "(") { |
@@ -582,12 +582,12 @@ discard block |
||
| 582 | 582 | } else { |
| 583 | 583 | /* simuler le IF EXISTS - version 2 et sqlite < 3.3a */ |
| 584 | 584 | $a = spip_sqlite_showtable($table, $serveur); |
| 585 | - if (isset($a['key']['KEY ' . $nom])) { |
|
| 585 | + if (isset($a['key']['KEY '.$nom])) { |
|
| 586 | 586 | return true; |
| 587 | 587 | } |
| 588 | 588 | } |
| 589 | 589 | |
| 590 | - $query = "CREATE " . ($unique ? "UNIQUE " : "") . "INDEX$ifnotexists $nom ON $table (" . join(',', $champs) . ")"; |
|
| 590 | + $query = "CREATE ".($unique ? "UNIQUE " : "")."INDEX$ifnotexists $nom ON $table (".join(',', $champs).")"; |
|
| 591 | 591 | $res = spip_sqlite_query($query, $serveur, $requeter); |
| 592 | 592 | if (!$requeter) { |
| 593 | 593 | return $res; |
@@ -663,7 +663,7 @@ discard block |
||
| 663 | 663 | $serveur = '', |
| 664 | 664 | $requeter = true |
| 665 | 665 | ) { |
| 666 | - $c = !$groupby ? '*' : ('DISTINCT ' . (is_string($groupby) ? $groupby : join(',', $groupby))); |
|
| 666 | + $c = !$groupby ? '*' : ('DISTINCT '.(is_string($groupby) ? $groupby : join(',', $groupby))); |
|
| 667 | 667 | $r = spip_sqlite_select("COUNT($c)", $from, $where, '', '', '', |
| 668 | 668 | $having, $serveur, $requeter); |
| 669 | 669 | if ((is_resource($r) or is_object($r)) && $requeter) { // ressource : sqlite2, object : sqlite3 |
@@ -761,14 +761,14 @@ discard block |
||
| 761 | 761 | */ |
| 762 | 762 | function spip_sqlite_drop_index($nom, $table, $serveur = '', $requeter = true) { |
| 763 | 763 | if (!($nom or $table)) { |
| 764 | - spip_log("Champ manquant pour supprimer un index sqlite ($nom, $table)", 'sqlite.' . _LOG_ERREUR); |
|
| 764 | + spip_log("Champ manquant pour supprimer un index sqlite ($nom, $table)", 'sqlite.'._LOG_ERREUR); |
|
| 765 | 765 | |
| 766 | 766 | return false; |
| 767 | 767 | } |
| 768 | 768 | |
| 769 | 769 | // SQLite ne differentie pas noms des index en fonction des tables |
| 770 | 770 | // il faut donc creer des noms uniques d'index pour une base sqlite |
| 771 | - $index = $table . '_' . $nom; |
|
| 771 | + $index = $table.'_'.$nom; |
|
| 772 | 772 | $exist = " IF EXISTS"; |
| 773 | 773 | |
| 774 | 774 | $query = "DROP INDEX$exist $index"; |
@@ -800,7 +800,7 @@ discard block |
||
| 800 | 800 | if ($s) { |
| 801 | 801 | $trace = debug_backtrace(); |
| 802 | 802 | if ($trace[0]['function'] != "spip_sqlite_error") { |
| 803 | - spip_log("$s - $query - " . sql_error_backtrace(), 'sqlite.' . _LOG_ERREUR); |
|
| 803 | + spip_log("$s - $query - ".sql_error_backtrace(), 'sqlite.'._LOG_ERREUR); |
|
| 804 | 804 | } |
| 805 | 805 | } |
| 806 | 806 | |
@@ -847,14 +847,14 @@ discard block |
||
| 847 | 847 | $t = $link->errorInfo(); |
| 848 | 848 | $s = ltrim($t[0], '0'); // 00000 si pas d'erreur |
| 849 | 849 | if ($s) { |
| 850 | - $s .= ' / ' . $t[1]; |
|
| 850 | + $s .= ' / '.$t[1]; |
|
| 851 | 851 | } // ajoute l'erreur du moteur SQLite |
| 852 | 852 | } else { |
| 853 | 853 | $s = ": aucune ressource sqlite (link)"; |
| 854 | 854 | } |
| 855 | 855 | |
| 856 | 856 | if ($s) { |
| 857 | - spip_log("Erreur sqlite $s", 'sqlite.' . _LOG_ERREUR); |
|
| 857 | + spip_log("Erreur sqlite $s", 'sqlite.'._LOG_ERREUR); |
|
| 858 | 858 | } |
| 859 | 859 | |
| 860 | 860 | return $s ? $s : 0; |
@@ -878,7 +878,7 @@ discard block |
||
| 878 | 878 | } |
| 879 | 879 | |
| 880 | 880 | $query = spip_sqlite::traduire_requete($query, $serveur); |
| 881 | - $query = 'EXPLAIN ' . $query; |
|
| 881 | + $query = 'EXPLAIN '.$query; |
|
| 882 | 882 | if (!$requeter) { |
| 883 | 883 | return $query; |
| 884 | 884 | } |
@@ -1038,7 +1038,7 @@ discard block |
||
| 1038 | 1038 | **/ |
| 1039 | 1039 | function spip_sqlite_insert($table, $champs, $valeurs, $desc = array(), $serveur = '', $requeter = true) { |
| 1040 | 1040 | |
| 1041 | - $query = "INSERT INTO $table " . ($champs ? "$champs VALUES $valeurs" : "DEFAULT VALUES"); |
|
| 1041 | + $query = "INSERT INTO $table ".($champs ? "$champs VALUES $valeurs" : "DEFAULT VALUES"); |
|
| 1042 | 1042 | if ($r = spip_sqlite_query($query, $serveur, $requeter)) { |
| 1043 | 1043 | if (!$requeter) { |
| 1044 | 1044 | return $r; |
@@ -1094,8 +1094,8 @@ discard block |
||
| 1094 | 1094 | |
| 1095 | 1095 | $cles = $valeurs = ""; |
| 1096 | 1096 | if (count($couples)) { |
| 1097 | - $cles = "(" . join(',', array_keys($couples)) . ")"; |
|
| 1098 | - $valeurs = "(" . join(',', $couples) . ")"; |
|
| 1097 | + $cles = "(".join(',', array_keys($couples)).")"; |
|
| 1098 | + $valeurs = "(".join(',', $couples).")"; |
|
| 1099 | 1099 | } |
| 1100 | 1100 | |
| 1101 | 1101 | return spip_sqlite_insert($table, $cles, $valeurs, $desc, $serveur, $requeter); |
@@ -1155,11 +1155,11 @@ discard block |
||
| 1155 | 1155 | |
| 1156 | 1156 | $champs = $valeurs = ""; |
| 1157 | 1157 | if (count($couples)) { |
| 1158 | - $champs = "(" . join(',', array_keys($couples)) . ")"; |
|
| 1159 | - $valeurs = "(" . join(',', $couples) . ")"; |
|
| 1160 | - $query = $query_start . "$champs VALUES $valeurs"; |
|
| 1158 | + $champs = "(".join(',', array_keys($couples)).")"; |
|
| 1159 | + $valeurs = "(".join(',', $couples).")"; |
|
| 1160 | + $query = $query_start."$champs VALUES $valeurs"; |
|
| 1161 | 1161 | } else { |
| 1162 | - $query = $query_start . "DEFAULT VALUES"; |
|
| 1162 | + $query = $query_start."DEFAULT VALUES"; |
|
| 1163 | 1163 | } |
| 1164 | 1164 | |
| 1165 | 1165 | if ($requeter) { |
@@ -1291,7 +1291,7 @@ discard block |
||
| 1291 | 1291 | * @return string Texte de sélection pour la requête |
| 1292 | 1292 | */ |
| 1293 | 1293 | function spip_sqlite_multi($objet, $lang) { |
| 1294 | - $r = "EXTRAIRE_MULTI(" . $objet . ", '" . $lang . "') AS multi"; |
|
| 1294 | + $r = "EXTRAIRE_MULTI(".$objet.", '".$lang."') AS multi"; |
|
| 1295 | 1295 | |
| 1296 | 1296 | return $r; |
| 1297 | 1297 | } |
@@ -1362,7 +1362,7 @@ discard block |
||
| 1362 | 1362 | function spip_sqlite_date_proche($champ, $interval, $unite) { |
| 1363 | 1363 | $op = (($interval <= 0) ? '>' : '<'); |
| 1364 | 1364 | |
| 1365 | - return "($champ $op datetime('" . date("Y-m-d H:i:s") . "', '$interval $unite'))"; |
|
| 1365 | + return "($champ $op datetime('".date("Y-m-d H:i:s")."', '$interval $unite'))"; |
|
| 1366 | 1366 | } |
| 1367 | 1367 | |
| 1368 | 1368 | |
@@ -1392,7 +1392,7 @@ discard block |
||
| 1392 | 1392 | and (!isset($desc['key']['PRIMARY KEY']) or $desc['key']['PRIMARY KEY'] !== $c) |
| 1393 | 1393 | ) { |
| 1394 | 1394 | spip_sqlite_alter($q = "TABLE $table CHANGE $c $c $d DEFAULT ''", $serveur); |
| 1395 | - spip_log("ALTER $q", "repair" . _LOG_INFO_IMPORTANTE); |
|
| 1395 | + spip_log("ALTER $q", "repair"._LOG_INFO_IMPORTANTE); |
|
| 1396 | 1396 | } |
| 1397 | 1397 | if (preg_match(",^(INTEGER),i", $d) |
| 1398 | 1398 | and stripos($d, "NOT NULL") !== false |
@@ -1401,7 +1401,7 @@ discard block |
||
| 1401 | 1401 | and (!isset($desc['key']['PRIMARY KEY']) or $desc['key']['PRIMARY KEY'] !== $c) |
| 1402 | 1402 | ) { |
| 1403 | 1403 | spip_sqlite_alter($q = "TABLE $table CHANGE $c $c $d DEFAULT '0'", $serveur); |
| 1404 | - spip_log("ALTER $q", "repair" . _LOG_INFO_IMPORTANTE); |
|
| 1404 | + spip_log("ALTER $q", "repair"._LOG_INFO_IMPORTANTE); |
|
| 1405 | 1405 | } |
| 1406 | 1406 | if (preg_match(",^(datetime),i", $d) |
| 1407 | 1407 | and stripos($d, "NOT NULL") !== false |
@@ -1410,7 +1410,7 @@ discard block |
||
| 1410 | 1410 | and (!isset($desc['key']['PRIMARY KEY']) or $desc['key']['PRIMARY KEY'] !== $c) |
| 1411 | 1411 | ) { |
| 1412 | 1412 | spip_sqlite_alter($q = "TABLE $table CHANGE $c $c $d DEFAULT '0000-00-00 00:00:00'", $serveur); |
| 1413 | - spip_log("ALTER $q", "repair" . _LOG_INFO_IMPORTANTE); |
|
| 1413 | + spip_log("ALTER $q", "repair"._LOG_INFO_IMPORTANTE); |
|
| 1414 | 1414 | } |
| 1415 | 1415 | } |
| 1416 | 1416 | |
@@ -1461,8 +1461,8 @@ discard block |
||
| 1461 | 1461 | // recherche de champs 'timestamp' pour mise a jour auto de ceux-ci |
| 1462 | 1462 | $couples = _sqlite_ajouter_champs_timestamp($table, $couples, $desc, $serveur); |
| 1463 | 1463 | |
| 1464 | - return spip_sqlite_query("REPLACE INTO $table (" . join(',', array_keys($couples)) . ') VALUES (' . join(',', |
|
| 1465 | - $couples) . ')', $serveur); |
|
| 1464 | + return spip_sqlite_query("REPLACE INTO $table (".join(',', array_keys($couples)).') VALUES ('.join(',', |
|
| 1465 | + $couples).')', $serveur); |
|
| 1466 | 1466 | } |
| 1467 | 1467 | |
| 1468 | 1468 | |
@@ -1548,7 +1548,7 @@ discard block |
||
| 1548 | 1548 | . _sqlite_calculer_expression('WHERE', $where) |
| 1549 | 1549 | . _sqlite_calculer_expression('GROUP BY', $groupby, ',') |
| 1550 | 1550 | . _sqlite_calculer_expression('HAVING', $having) |
| 1551 | - . ($orderby ? ("\nORDER BY " . _sqlite_calculer_order($orderby)) : '') |
|
| 1551 | + . ($orderby ? ("\nORDER BY "._sqlite_calculer_order($orderby)) : '') |
|
| 1552 | 1552 | . ($limit ? "\nLIMIT $limit" : ''); |
| 1553 | 1553 | |
| 1554 | 1554 | // dans un select, on doit renvoyer la requête en cas d'erreur |
@@ -1585,10 +1585,10 @@ discard block |
||
| 1585 | 1585 | |
| 1586 | 1586 | // interdire la creation d'une nouvelle base, |
| 1587 | 1587 | // sauf si on est dans l'installation |
| 1588 | - if (!is_file($f = _DIR_DB . $db . '.sqlite') |
|
| 1588 | + if (!is_file($f = _DIR_DB.$db.'.sqlite') |
|
| 1589 | 1589 | && (!defined('_ECRIRE_INSTALL') || !_ECRIRE_INSTALL) |
| 1590 | 1590 | ) { |
| 1591 | - spip_log("Il est interdit de creer la base $db", 'sqlite.' . _LOG_HS); |
|
| 1591 | + spip_log("Il est interdit de creer la base $db", 'sqlite.'._LOG_HS); |
|
| 1592 | 1592 | |
| 1593 | 1593 | return false; |
| 1594 | 1594 | } |
@@ -1597,12 +1597,12 @@ discard block |
||
| 1597 | 1597 | // avec les identifiants connus |
| 1598 | 1598 | $index = $serveur ? $serveur : 0; |
| 1599 | 1599 | |
| 1600 | - if ($link = spip_connect_db('', '', '', '', '@selectdb@' . $db, $serveur, '', '')) { |
|
| 1600 | + if ($link = spip_connect_db('', '', '', '', '@selectdb@'.$db, $serveur, '', '')) { |
|
| 1601 | 1601 | if (($db == $link['db']) && $GLOBALS['connexions'][$index] = $link) { |
| 1602 | 1602 | return $db; |
| 1603 | 1603 | } |
| 1604 | 1604 | } else { |
| 1605 | - spip_log("Impossible de selectionner la base $db", 'sqlite.' . _LOG_HS); |
|
| 1605 | + spip_log("Impossible de selectionner la base $db", 'sqlite.'._LOG_HS); |
|
| 1606 | 1606 | |
| 1607 | 1607 | return false; |
| 1608 | 1608 | } |
@@ -1653,7 +1653,7 @@ discard block |
||
| 1653 | 1653 | $match = str_replace("[[POURCENT]]", "%", $match); |
| 1654 | 1654 | $match = "^$match$"; |
| 1655 | 1655 | |
| 1656 | - return spip_sqlite_query("SELECT name FROM sqlite_master WHERE type='table' AND tbl_name REGEXP " . _q($match), |
|
| 1656 | + return spip_sqlite_query("SELECT name FROM sqlite_master WHERE type='table' AND tbl_name REGEXP "._q($match), |
|
| 1657 | 1657 | $serveur, $requeter); |
| 1658 | 1658 | } |
| 1659 | 1659 | |
@@ -1741,7 +1741,7 @@ discard block |
||
| 1741 | 1741 | |
| 1742 | 1742 | # rustine pour DECIMAL(10,2) |
| 1743 | 1743 | if (false !== strpos($k, ')')) { |
| 1744 | - $fields[$k_precedent] .= ',' . $k . ' ' . $def; |
|
| 1744 | + $fields[$k_precedent] .= ','.$k.' '.$def; |
|
| 1745 | 1745 | continue; |
| 1746 | 1746 | } |
| 1747 | 1747 | |
@@ -1776,13 +1776,13 @@ discard block |
||
| 1776 | 1776 | . 'ORDER BY substr(type,2,1), name'; |
| 1777 | 1777 | $a = spip_sqlite_query($query, $serveur, $requeter); |
| 1778 | 1778 | while ($r = spip_sqlite_fetch($a, null, $serveur)) { |
| 1779 | - $key = str_replace($nom_table . '_', '', $r['name']); // enlever le nom de la table ajoute a l'index |
|
| 1779 | + $key = str_replace($nom_table.'_', '', $r['name']); // enlever le nom de la table ajoute a l'index |
|
| 1780 | 1780 | $keytype = "KEY"; |
| 1781 | 1781 | if (strpos($r['sql'], "UNIQUE INDEX") !== false) { |
| 1782 | 1782 | $keytype = "UNIQUE KEY"; |
| 1783 | 1783 | } |
| 1784 | 1784 | $colonnes = preg_replace(',.*\((.*)\).*,', '$1', $r['sql']); |
| 1785 | - $keys[$keytype . ' ' . $key] = $colonnes; |
|
| 1785 | + $keys[$keytype.' '.$key] = $colonnes; |
|
| 1786 | 1786 | } |
| 1787 | 1787 | } |
| 1788 | 1788 | |
@@ -1831,7 +1831,7 @@ discard block |
||
| 1831 | 1831 | |
| 1832 | 1832 | $set = array(); |
| 1833 | 1833 | foreach ($champs as $champ => $val) { |
| 1834 | - $set[] = $champ . "=$val"; |
|
| 1834 | + $set[] = $champ."=$val"; |
|
| 1835 | 1835 | } |
| 1836 | 1836 | if (!empty($set)) { |
| 1837 | 1837 | return spip_sqlite_query( |
@@ -1885,7 +1885,7 @@ discard block |
||
| 1885 | 1885 | |
| 1886 | 1886 | $set = array(); |
| 1887 | 1887 | foreach ($champs as $champ => $val) { |
| 1888 | - $set[] = $champ . '=' . _sqlite_calculer_cite($val, isset($fields[$champ]) ? $fields[$champ] : ''); |
|
| 1888 | + $set[] = $champ.'='._sqlite_calculer_cite($val, isset($fields[$champ]) ? $fields[$champ] : ''); |
|
| 1889 | 1889 | } |
| 1890 | 1890 | |
| 1891 | 1891 | return spip_sqlite_query( |
@@ -1911,7 +1911,7 @@ discard block |
||
| 1911 | 1911 | */ |
| 1912 | 1912 | function _sqlite_init() { |
| 1913 | 1913 | if (!defined('_DIR_DB')) { |
| 1914 | - define('_DIR_DB', _DIR_ETC . 'bases/'); |
|
| 1914 | + define('_DIR_DB', _DIR_ETC.'bases/'); |
|
| 1915 | 1915 | } |
| 1916 | 1916 | if (!defined('_SQLITE_CHMOD')) { |
| 1917 | 1917 | define('_SQLITE_CHMOD', _SPIP_CHMOD); |
@@ -2014,9 +2014,9 @@ discard block |
||
| 2014 | 2014 | } |
| 2015 | 2015 | |
| 2016 | 2016 | // echapper les ' en '' |
| 2017 | - spip_log("Pas de methode ->quote pour echapper", "sqlite." . _LOG_INFO_IMPORTANTE); |
|
| 2017 | + spip_log("Pas de methode ->quote pour echapper", "sqlite."._LOG_INFO_IMPORTANTE); |
|
| 2018 | 2018 | |
| 2019 | - return ("'" . str_replace("'", "''", $v) . "'"); |
|
| 2019 | + return ("'".str_replace("'", "''", $v)."'"); |
|
| 2020 | 2020 | } |
| 2021 | 2021 | |
| 2022 | 2022 | |
@@ -2039,12 +2039,12 @@ discard block |
||
| 2039 | 2039 | $exp = "\n$expression "; |
| 2040 | 2040 | |
| 2041 | 2041 | if (!is_array($v)) { |
| 2042 | - return $exp . $v; |
|
| 2042 | + return $exp.$v; |
|
| 2043 | 2043 | } else { |
| 2044 | 2044 | if (strtoupper($join) === 'AND') { |
| 2045 | - return $exp . join("\n\t$join ", array_map('_sqlite_calculer_where', $v)); |
|
| 2045 | + return $exp.join("\n\t$join ", array_map('_sqlite_calculer_where', $v)); |
|
| 2046 | 2046 | } else { |
| 2047 | - return $exp . join($join, $v); |
|
| 2047 | + return $exp.join($join, $v); |
|
| 2048 | 2048 | } |
| 2049 | 2049 | } |
| 2050 | 2050 | } |
@@ -2078,17 +2078,17 @@ discard block |
||
| 2078 | 2078 | if (substr($k, -1) == '@') { |
| 2079 | 2079 | // c'est une jointure qui se refere au from precedent |
| 2080 | 2080 | // pas de virgule |
| 2081 | - $res .= ' ' . $v; |
|
| 2081 | + $res .= ' '.$v; |
|
| 2082 | 2082 | } else { |
| 2083 | 2083 | if (!is_numeric($k)) { |
| 2084 | 2084 | $p = strpos($v, " "); |
| 2085 | 2085 | if ($p) { |
| 2086 | - $v = substr($v, 0, $p) . " AS '$k'" . substr($v, $p); |
|
| 2086 | + $v = substr($v, 0, $p)." AS '$k'".substr($v, $p); |
|
| 2087 | 2087 | } else { |
| 2088 | 2088 | $v .= " AS '$k'"; |
| 2089 | 2089 | } |
| 2090 | 2090 | } |
| 2091 | - $res .= ', ' . $v; |
|
| 2091 | + $res .= ', '.$v; |
|
| 2092 | 2092 | } |
| 2093 | 2093 | } |
| 2094 | 2094 | |
@@ -2226,13 +2226,13 @@ discard block |
||
| 2226 | 2226 | |
| 2227 | 2227 | $def_origine = sql_showtable($table_origine, false, $serveur); |
| 2228 | 2228 | if (!$def_origine or !isset($def_origine['field'])) { |
| 2229 | - spip_log("Alter table impossible sur $table_origine : table non trouvee", 'sqlite' . _LOG_ERREUR); |
|
| 2229 | + spip_log("Alter table impossible sur $table_origine : table non trouvee", 'sqlite'._LOG_ERREUR); |
|
| 2230 | 2230 | |
| 2231 | 2231 | return false; |
| 2232 | 2232 | } |
| 2233 | 2233 | |
| 2234 | 2234 | |
| 2235 | - $table_tmp = $table_origine . '_tmp'; |
|
| 2235 | + $table_tmp = $table_origine.'_tmp'; |
|
| 2236 | 2236 | |
| 2237 | 2237 | // 1) creer une table temporaire avec les modifications |
| 2238 | 2238 | // - DROP : suppression de la colonne |
@@ -2318,7 +2318,7 @@ discard block |
||
| 2318 | 2318 | } else { |
| 2319 | 2319 | // enlever KEY |
| 2320 | 2320 | $k = substr($k, 4); |
| 2321 | - $queries[] = "CREATE INDEX $table_destination" . "_$k ON $table_destination ($v)"; |
|
| 2321 | + $queries[] = "CREATE INDEX $table_destination"."_$k ON $table_destination ($v)"; |
|
| 2322 | 2322 | } |
| 2323 | 2323 | } |
| 2324 | 2324 | |
@@ -2329,7 +2329,7 @@ discard block |
||
| 2329 | 2329 | foreach ($queries as $q) { |
| 2330 | 2330 | if (!spip_sqlite::executer_requete($q, $serveur)) { |
| 2331 | 2331 | spip_log("SQLite : ALTER TABLE table :" |
| 2332 | - . " Erreur a l'execution de la requete : $q", 'sqlite.' . _LOG_ERREUR); |
|
| 2332 | + . " Erreur a l'execution de la requete : $q", 'sqlite.'._LOG_ERREUR); |
|
| 2333 | 2333 | spip_sqlite::annuler_transaction($serveur); |
| 2334 | 2334 | |
| 2335 | 2335 | return false; |
@@ -2418,26 +2418,26 @@ discard block |
||
| 2418 | 2418 | $enum = "(\s*\([^\)]*\))?"; |
| 2419 | 2419 | |
| 2420 | 2420 | $remplace = array( |
| 2421 | - '/enum' . $enum . '/is' => 'VARCHAR(255)', |
|
| 2421 | + '/enum'.$enum.'/is' => 'VARCHAR(255)', |
|
| 2422 | 2422 | '/COLLATE \w+_bin/is' => 'COLLATE BINARY', |
| 2423 | 2423 | '/COLLATE \w+_ci/is' => 'COLLATE NOCASE', |
| 2424 | 2424 | '/auto_increment/is' => '', |
| 2425 | 2425 | '/(timestamp .* )ON .*$/is' => '\\1', |
| 2426 | 2426 | '/character set \w+/is' => '', |
| 2427 | - '/((big|small|medium|tiny)?int(eger)?)' . $num . '\s*unsigned/is' => '\\1 UNSIGNED', |
|
| 2427 | + '/((big|small|medium|tiny)?int(eger)?)'.$num.'\s*unsigned/is' => '\\1 UNSIGNED', |
|
| 2428 | 2428 | '/(text\s+not\s+null(\s+collate\s+\w+)?)\s*$/is' => "\\1 DEFAULT ''", |
| 2429 | - '/((char|varchar)' . $num . '\s+not\s+null(\s+collate\s+\w+)?)\s*$/is' => "\\1 DEFAULT ''", |
|
| 2429 | + '/((char|varchar)'.$num.'\s+not\s+null(\s+collate\s+\w+)?)\s*$/is' => "\\1 DEFAULT ''", |
|
| 2430 | 2430 | '/(datetime\s+not\s+null)\s*$/is' => "\\1 DEFAULT '0000-00-00 00:00:00'", |
| 2431 | 2431 | '/(date\s+not\s+null)\s*$/is' => "\\1 DEFAULT '0000-00-00'", |
| 2432 | 2432 | ); |
| 2433 | 2433 | |
| 2434 | 2434 | // pour l'autoincrement, il faut des INTEGER NOT NULL PRIMARY KEY |
| 2435 | 2435 | $remplace_autocinc = array( |
| 2436 | - '/(big|small|medium|tiny)?int(eger)?' . $num . '/is' => 'INTEGER' |
|
| 2436 | + '/(big|small|medium|tiny)?int(eger)?'.$num.'/is' => 'INTEGER' |
|
| 2437 | 2437 | ); |
| 2438 | 2438 | // pour les int non autoincrement, il faut un DEFAULT |
| 2439 | 2439 | $remplace_nonautocinc = array( |
| 2440 | - '/((big|small|medium|tiny)?int(eger)?' . $num . '\s+not\s+null)\s*$/is' => "\\1 DEFAULT 0", |
|
| 2440 | + '/((big|small|medium|tiny)?int(eger)?'.$num.'\s+not\s+null)\s*$/is' => "\\1 DEFAULT 0", |
|
| 2441 | 2441 | ); |
| 2442 | 2442 | |
| 2443 | 2443 | if (is_string($query)) { |
@@ -2479,7 +2479,7 @@ discard block |
||
| 2479 | 2479 | return str_ireplace("BINARY", "COLLATE BINARY", $champ); |
| 2480 | 2480 | } |
| 2481 | 2481 | if (preg_match(",^(char|varchar|(long|small|medium|tiny)?text),i", $champ)) { |
| 2482 | - return $champ . " COLLATE NOCASE"; |
|
| 2482 | + return $champ." COLLATE NOCASE"; |
|
| 2483 | 2483 | } |
| 2484 | 2484 | |
| 2485 | 2485 | return $champ; |
@@ -2566,7 +2566,7 @@ discard block |
||
| 2566 | 2566 | } else { |
| 2567 | 2567 | /* simuler le IF EXISTS - version 2 et sqlite < 3.3a */ |
| 2568 | 2568 | $a = spip_sqlite_showtable($nom, $serveur); |
| 2569 | - if (isset($a['key']['KEY ' . $nom])) { |
|
| 2569 | + if (isset($a['key']['KEY '.$nom])) { |
|
| 2570 | 2570 | return true; |
| 2571 | 2571 | } |
| 2572 | 2572 | } |
@@ -2574,7 +2574,7 @@ discard block |
||
| 2574 | 2574 | } |
| 2575 | 2575 | |
| 2576 | 2576 | $temporary = $temporary ? ' TEMPORARY' : ''; |
| 2577 | - $q = "CREATE$temporary TABLE$ifnotexists $nom ($query" . ($keys ? ",$keys" : '') . ")\n"; |
|
| 2577 | + $q = "CREATE$temporary TABLE$ifnotexists $nom ($query".($keys ? ",$keys" : '').")\n"; |
|
| 2578 | 2578 | |
| 2579 | 2579 | return $q; |
| 2580 | 2580 | } |
@@ -2788,7 +2788,7 @@ discard block |
||
| 2788 | 2788 | $this->serveur = strtolower($serveur); |
| 2789 | 2789 | |
| 2790 | 2790 | if (!($this->link = _sqlite_link($this->serveur)) && (!defined('_ECRIRE_INSTALL') || !_ECRIRE_INSTALL)) { |
| 2791 | - spip_log("Aucune connexion sqlite (link)", 'sqlite.' . _LOG_ERREUR); |
|
| 2791 | + spip_log("Aucune connexion sqlite (link)", 'sqlite.'._LOG_ERREUR); |
|
| 2792 | 2792 | |
| 2793 | 2793 | return false; |
| 2794 | 2794 | } |
@@ -2849,8 +2849,8 @@ discard block |
||
| 2849 | 2849 | |
| 2850 | 2850 | // loger les warnings/erreurs eventuels de sqlite remontant dans PHP |
| 2851 | 2851 | if ($err = (function_exists('error_get_last') ? error_get_last() : "") and $err != $e) { |
| 2852 | - $err = strip_tags($err['message']) . " in " . $err['file'] . " line " . $err['line']; |
|
| 2853 | - spip_log("$err - " . $query, 'sqlite.' . _LOG_ERREUR); |
|
| 2852 | + $err = strip_tags($err['message'])." in ".$err['file']." line ".$err['line']; |
|
| 2853 | + spip_log("$err - ".$query, 'sqlite.'._LOG_ERREUR); |
|
| 2854 | 2854 | } else { |
| 2855 | 2855 | $err = ""; |
| 2856 | 2856 | } |
@@ -2929,15 +2929,15 @@ discard block |
||
| 2929 | 2929 | // Correction Create Database |
| 2930 | 2930 | // Create Database -> requete ignoree |
| 2931 | 2931 | if (strpos($this->query, 'CREATE DATABASE') === 0) { |
| 2932 | - spip_log("Sqlite : requete non executee -> $this->query", 'sqlite.' . _LOG_AVERTISSEMENT); |
|
| 2932 | + spip_log("Sqlite : requete non executee -> $this->query", 'sqlite.'._LOG_AVERTISSEMENT); |
|
| 2933 | 2933 | $this->query = "SELECT 1"; |
| 2934 | 2934 | } |
| 2935 | 2935 | |
| 2936 | 2936 | // Correction Insert Ignore |
| 2937 | 2937 | // INSERT IGNORE -> insert (tout court et pas 'insert or replace') |
| 2938 | 2938 | if (strpos($this->query, 'INSERT IGNORE') === 0) { |
| 2939 | - spip_log("Sqlite : requete transformee -> $this->query", 'sqlite.' . _LOG_DEBUG); |
|
| 2940 | - $this->query = 'INSERT ' . substr($this->query, '13'); |
|
| 2939 | + spip_log("Sqlite : requete transformee -> $this->query", 'sqlite.'._LOG_DEBUG); |
|
| 2940 | + $this->query = 'INSERT '.substr($this->query, '13'); |
|
| 2941 | 2941 | } |
| 2942 | 2942 | |
| 2943 | 2943 | // Correction des dates avec INTERVAL |
@@ -2962,7 +2962,7 @@ discard block |
||
| 2962 | 2962 | // problematique car la jointure ne se fait pas du coup. |
| 2963 | 2963 | if (($this->sqlite_version == 2) && (strpos($this->query, "USING") !== false)) { |
| 2964 | 2964 | spip_log("'USING (champ)' n'est pas reconnu en SQLite 2. Utilisez 'ON table1.champ = table2.champ'", |
| 2965 | - 'sqlite.' . _LOG_ERREUR); |
|
| 2965 | + 'sqlite.'._LOG_ERREUR); |
|
| 2966 | 2966 | $this->query = preg_replace('/USING\s*\([^\)]*\)/', '', $this->query); |
| 2967 | 2967 | } |
| 2968 | 2968 | |
@@ -2982,8 +2982,8 @@ discard block |
||
| 2982 | 2982 | } else { |
| 2983 | 2983 | $suite = ''; |
| 2984 | 2984 | } |
| 2985 | - $pref = ($this->prefixe) ? $this->prefixe . "_" : ""; |
|
| 2986 | - $this->query = preg_replace('/([,\s])spip_/S', '\1' . $pref, $this->query) . $suite; |
|
| 2985 | + $pref = ($this->prefixe) ? $this->prefixe."_" : ""; |
|
| 2986 | + $this->query = preg_replace('/([,\s])spip_/S', '\1'.$pref, $this->query).$suite; |
|
| 2987 | 2987 | |
| 2988 | 2988 | // Correction zero AS x |
| 2989 | 2989 | // pg n'aime pas 0+x AS alias, sqlite, dans le meme style, |