3 /* *************************************************************************\
4 * SPIP, Systeme de publication pour l'internet *
6 * Copyright (c) 2001-2016 *
7 * Arnaud Martin, Antoine Pitrou, Philippe Riviere, Emmanuel Saint-James *
9 * Ce programme est un logiciel libre distribue sous licence GNU/GPL. *
10 * Pour plus de details voir le fichier COPYING.txt ou l'aide en ligne. *
11 \***************************************************************************/
14 * Ce fichier contient les fonctions gerant
15 * les instructions SQL pour MySQL
17 * @package SPIP\SQL\MySQL
20 if (!defined('_ECRIRE_INC_VERSION')) return;
22 // fonction pour la premiere connexion a un serveur MySQL
24 // http://doc.spip.org/@req_mysql_dist
31 * @param string $prefixe
35 function req_mysql_dist($host, $port, $login, $pass, $db='', $prefixe='') {
36 if (!charger_php_extension('mysql')) return false;
37 if ($port > 0) $host = "$host:$port";
38 $link = @mysql_connect
($host, $login, $pass, true);
40 spip_log('Echec mysql_connect. Erreur : ' . mysql_error(),'mysql.'._LOG_HS
);
48 $ok = spip_mysql_selectdb($db);
49 if (defined('_MYSQL_SET_SQL_MODE')
50 OR defined('_MYSQL_SQL_MODE_TEXT_NOT_NULL') // compatibilite
52 mysql_query($last = "set sql_mode=''");
54 spip_log("Connexion vers $host, base $db, prefixe $prefixe " . ($ok ?
"operationnelle sur $link" : 'impossible'), _LOG_DEBUG
);
56 return !$ok ?
false : array(
59 'prefixe' => $prefixe ?
$prefixe : $db,
60 'link' => $GLOBALS['mysql_rappel_connexion'] ?
$link : false,
64 $GLOBALS['spip_mysql_functions_1'] = array(
65 'alter' => 'spip_mysql_alter',
66 'count' => 'spip_mysql_count',
67 'countsel' => 'spip_mysql_countsel',
68 'create' => 'spip_mysql_create',
69 'create_base' => 'spip_mysql_create_base',
70 'create_view' => 'spip_mysql_create_view',
71 'date_proche' => 'spip_mysql_date_proche',
72 'delete' => 'spip_mysql_delete',
73 'drop_table' => 'spip_mysql_drop_table',
74 'drop_view' => 'spip_mysql_drop_view',
75 'errno' => 'spip_mysql_errno',
76 'error' => 'spip_mysql_error',
77 'explain' => 'spip_mysql_explain',
78 'fetch' => 'spip_mysql_fetch',
79 'seek' => 'spip_mysql_seek',
80 'free' => 'spip_mysql_free',
81 'hex' => 'spip_mysql_hex',
82 'in' => 'spip_mysql_in',
83 'insert' => 'spip_mysql_insert',
84 'insertq' => 'spip_mysql_insertq',
85 'insertq_multi' => 'spip_mysql_insertq_multi',
86 'listdbs' => 'spip_mysql_listdbs',
87 'multi' => 'spip_mysql_multi',
88 'optimize' => 'spip_mysql_optimize',
89 'query' => 'spip_mysql_query',
90 'quote' => 'spip_mysql_quote',
91 'replace' => 'spip_mysql_replace',
92 'replace_multi' => 'spip_mysql_replace_multi',
93 'repair' => 'spip_mysql_repair',
94 'select' => 'spip_mysql_select',
95 'selectdb' => 'spip_mysql_selectdb',
96 'set_charset' => 'spip_mysql_set_charset',
97 'get_charset' => 'spip_mysql_get_charset',
98 'showbase' => 'spip_mysql_showbase',
99 'showtable' => 'spip_mysql_showtable',
100 'update' => 'spip_mysql_update',
101 'updateq' => 'spip_mysql_updateq',
103 // association de chaque nom http d'un charset aux couples MySQL
105 'cp1250'=>array('charset'=>'cp1250','collation'=>'cp1250_general_ci'),
106 'cp1251'=>array('charset'=>'cp1251','collation'=>'cp1251_general_ci'),
107 'cp1256'=>array('charset'=>'cp1256','collation'=>'cp1256_general_ci'),
108 'iso-8859-1'=>array('charset'=>'latin1','collation'=>'latin1_swedish_ci'),
109 //'iso-8859-6'=>array('charset'=>'latin1','collation'=>'latin1_swedish_ci'),
110 'iso-8859-9'=>array('charset'=>'latin5','collation'=>'latin5_turkish_ci'),
111 //'iso-8859-15'=>array('charset'=>'latin1','collation'=>'latin1_swedish_ci'),
112 'utf-8'=>array('charset'=>'utf8','collation'=>'utf8_general_ci'))
117 * Définit un charset pour la connexion avec Mysql
119 * @param string $charset Charset à appliquer
120 * @param string $serveur Nom de la connexion
121 * @param bool $requeter inutilisé
122 * @return resource Ressource de résultats pour fetch()
124 function spip_mysql_set_charset($charset, $serveur='',$requeter=true){
125 $connexion = &$GLOBALS['connexions'][$serveur ?
strtolower($serveur) : 0];
126 spip_log("changement de charset sql : "."SET NAMES "._q($charset), _LOG_DEBUG
);
127 return mysql_query($connexion['last'] = "SET NAMES "._q($charset));
132 * Teste si le charset indiqué est disponible sur le serveur SQL
134 * @param array|string $charset Nom du charset à tester.
135 * @param string $serveur Nom de la connexion
136 * @param bool $requeter inutilisé
137 * @return array Description du charset (son nom est dans 'charset')
139 function spip_mysql_get_charset($charset=array(), $serveur='',$requeter=true){
140 $connexion = &$GLOBALS['connexions'][$serveur ?
strtolower($serveur) : 0];
141 $connexion['last'] = $c = "SHOW CHARACTER SET"
142 . (!$charset ?
'' : (" LIKE "._q($charset['charset'])));
144 return spip_mysql_fetch(mysql_query($c), NULL, $serveur);
147 // obsolete, ne plus utiliser
148 // http://doc.spip.org/@spip_query_db
149 function spip_query_db($query, $serveur='',$requeter=true) {
150 return spip_mysql_query($query, $serveur, $requeter);
153 // Fonction de requete generale, munie d'une trace a la demande
155 // http://doc.spip.org/@spip_mysql_query
159 * @param string $serveur
160 * @param bool $requeter
161 * @return array|null|resource|string
164 function spip_mysql_query($query, $serveur='',$requeter=true) {
166 $connexion = &$GLOBALS['connexions'][$serveur ?
strtolower($serveur) : 0];
167 $prefixe = $connexion['prefixe'];
168 $link = $connexion['link'];
169 $db = $connexion['db'];
171 $query = traite_query($query, $db, $prefixe);
173 // renvoyer la requete inerte si demandee
174 if (!$requeter) return $query;
176 if (isset($_GET['var_profile'])) {
177 include_spip('public/tracer');
178 $t = trace_query_start();
181 $connexion['last'] = $query;
183 // ajouter un debug utile dans log/mysql-slow.log ?
185 if (defined('_DEBUG_SLOW_QUERIES') AND _DEBUG_SLOW_QUERIES
){
186 if(isset($GLOBALS['debug']['aucasou'])){
187 list(,$id,, $infos) = $GLOBALS['debug']['aucasou'];
188 $debug .= "BOUCLE$id @ ".$infos[0] ." | ";
190 $debug .= $_SERVER['REQUEST_URI'].' + '.$GLOBALS['ip'];
191 $debug = ' /* '. mysql_real_escape_string(str_replace('*/','@/',$debug)). ' */';
194 $r = $link ?
mysql_query($query.$debug, $link) : mysql_query($query.$debug);
196 if ($e = spip_mysql_errno($serveur)) // Log de l'erreur eventuelle
197 $e .= spip_mysql_error($query, $serveur); // et du fautif
198 return $t ?
trace_query_end($query, $t, $r, $e, $serveur) : $r;
201 // http://doc.spip.org/@spip_mysql_alter
204 * @param string $serveur
205 * @param bool $requeter
206 * @return array|null|resource|string
208 function spip_mysql_alter($query, $serveur='',$requeter=true){
209 // ici on supprime les ` entourant le nom de table pour permettre
210 // la transposition du prefixe, compte tenu que les plugins ont la mauvaise habitude
211 // d'utiliser ceux-ci, copie-colle de phpmyadmin
212 $query = preg_replace(",^TABLE\s*`([^`]*)`,i","TABLE \\1",$query);
213 return spip_mysql_query("ALTER ".$query, $serveur, $requeter); # i.e. que PG se debrouille
216 // http://doc.spip.org/@spip_mysql_optimize
219 * @param string $serveur
220 * @param bool $requeter
223 function spip_mysql_optimize($table, $serveur='',$requeter=true){
224 spip_mysql_query("OPTIMIZE TABLE ". $table);
228 // http://doc.spip.org/@spip_mysql_explain
231 * @param string $serveur
232 * @param bool $requeter
235 function spip_mysql_explain($query, $serveur='',$requeter=true){
236 if (strpos(ltrim($query), 'SELECT') !== 0) return array();
237 $connexion = &$GLOBALS['connexions'][$serveur ?
strtolower($serveur) : 0];
238 $prefixe = $connexion['prefixe'];
239 $link = $connexion['link'];
240 $db = $connexion['db'];
242 $query = 'EXPLAIN ' . traite_query($query, $db, $prefixe);
243 $r = $link ?
mysql_query($query, $link) : mysql_query($query);
244 return spip_mysql_fetch($r, NULL, $serveur);
246 // fonction instance de sql_select, voir ses specs dans abstract.php
247 // traite_query pourrait y etre fait d'avance ce serait moins cher
248 // Les \n et \t sont utiles au debusqueur.
251 // http://doc.spip.org/@spip_mysql_select
255 * @param string $where
256 * @param string $groupby
257 * @param string $orderby
258 * @param string $limit
259 * @param string $having
260 * @param string $serveur
261 * @param bool $requeter
262 * @return array|null|resource|string
264 function spip_mysql_select($select, $from, $where='',
265 $groupby='', $orderby='', $limit='', $having='',
266 $serveur='',$requeter=true) {
269 $from = (!is_array($from) ?
$from : spip_mysql_select_as($from));
271 calculer_mysql_expression('SELECT', $select, ', ')
272 . calculer_mysql_expression('FROM', $from, ', ')
273 . calculer_mysql_expression('WHERE', $where)
274 . calculer_mysql_expression('GROUP BY', $groupby, ',')
275 . calculer_mysql_expression('HAVING', $having)
276 . ($orderby ?
("\nORDER BY " . spip_mysql_order($orderby)) :'')
277 . ($limit ?
"\nLIMIT $limit" : '');
279 // renvoyer la requete inerte si demandee
280 if ($requeter === false) return $query;
281 $r = spip_mysql_query($query, $serveur, $requeter);
282 return $r ?
$r : $query;
285 // 0+x avec un champ x commencant par des chiffres est converti par MySQL
286 // en le nombre qui commence x.
287 // Pas portable malheureusement, on laisse pour le moment.
289 // http://doc.spip.org/@spip_mysql_order
294 function spip_mysql_order($orderby)
296 return (is_array($orderby)) ?
join(", ", $orderby) : $orderby;
300 // http://doc.spip.org/@calculer_mysql_where
303 * @return array|mixed|string
305 function calculer_mysql_where($v)
310 $op = array_shift($v);
314 $arg = calculer_mysql_where(array_shift($v));
318 $arg2 = calculer_mysql_where(array_shift($v));
320 return "($arg $op $arg2)";
321 } else return "($arg $op ($arg2) : $v[0])";
326 // http://doc.spip.org/@calculer_mysql_expression
330 * @param string $join
333 function calculer_mysql_expression($expression, $v, $join = 'AND'){
337 $exp = "\n$expression ";
342 if (strtoupper($join) === 'AND')
343 return $exp . join("\n\t$join ", array_map('calculer_mysql_where', $v));
345 return $exp . join($join, $v);
349 // http://doc.spip.org/@spip_mysql_select_as
354 function spip_mysql_select_as($args)
357 foreach($args as $k => $v) {
358 if (substr($k,-1)=='@') {
359 // c'est une jointure qui se refere au from precedent
364 if (!is_numeric($k)) {
365 $p = strpos($v, " ");
367 $v = substr($v,0,$p) . " AS `$k`" . substr($v,$p);
368 else $v .= " AS `$k`";
374 return substr($res,2);
378 // Changer les noms des tables ($table_prefix)
379 // Quand tous les appels SQL seront abstraits on pourra l'ameliorer
381 define('_SQL_PREFIXE_TABLE', '/([,\s])spip_/S');
383 // http://doc.spip.org/@traite_query
387 * @param string $prefixe
388 * @return array|null|string
390 function traite_query($query, $db='', $prefixe='') {
392 if ($GLOBALS['mysql_rappel_nom_base'] AND $db)
393 $pref = '`'. $db.'`.';
397 $pref .= $prefixe . "_";
399 if (!preg_match('/\s(SET|VALUES|WHERE|DATABASE)\s/i', $query, $regs)) {
402 $suite = strstr($query, $regs[0]);
403 $query = substr($query, 0, -strlen($suite));
404 // propager le prefixe en cas de requete imbriquee
405 // il faut alors echapper les chaine avant de le faire, pour ne pas risquer de
406 // modifier une requete qui est en fait juste du texte dans un champ
407 if (stripos($suite,"SELECT")!==false) {
408 list($suite,$textes) = query_echappe_textes($suite);
409 if (preg_match('/^(.*?)([(]\s*SELECT\b.*)$/si', $suite, $r))
410 $suite = $r[1] . traite_query($r[2], $db, $prefixe);
411 $suite = query_reinjecte_textes($suite, $textes);
414 $r = preg_replace(_SQL_PREFIXE_TABLE
, '\1'.$pref, $query) . $suite;
416 #spip_log("traite_query: " . substr($r,0, 50) . ".... $db, $prefixe", _LOG_DEBUG);
421 * Selectionne une base de donnees
424 * Nom de la base a utiliser
427 * True cas de success.
428 * False en cas d'erreur.
430 function spip_mysql_selectdb($db) {
431 $ok = mysql_select_db($db);
433 spip_log('Echec mysql_selectdb. Erreur : ' . mysql_error(),'mysql.'._LOG_CRITIQUE
);
439 * Retourne les bases de donnees accessibles
441 * Retourne un tableau du nom de toutes les bases de donnees
442 * accessibles avec les permissions de l'utilisateur SQL
443 * de cette connexion.
444 * Attention on n'a pas toujours les droits !
446 * @param string $serveur
448 * @param bool $requeter
451 * Liste de noms de bases de donnees
453 function spip_mysql_listdbs($serveur='',$requeter=true) {
455 if ($res = spip_mysql_query("SHOW DATABASES")){
456 while($row = mysql_fetch_assoc($res))
457 $dbs[] = $row['Database'];
462 // Fonction de creation d'une table SQL nommee $nom
463 // a partir de 2 tableaux PHP :
464 // champs: champ => type
465 // cles: type-de-cle => champ(s)
466 // si $autoinc, c'est une auto-increment (i.e. serial) sur la Primary Key
467 // Le nom des caches doit etre inferieur a 64 caracteres
469 // http://doc.spip.org/@spip_mysql_create
474 * @param bool $autoinc
475 * @param bool $temporary
476 * @param string $serveur
477 * @param bool $requeter
478 * @return array|null|resource|string
480 function spip_mysql_create($nom, $champs, $cles, $autoinc=false, $temporary=false, $serveur='',$requeter=true) {
482 $query = ''; $keys = ''; $s = ''; $p='';
484 // certains plugins declarent les tables (permet leur inclusion dans le dump)
485 // sans les renseigner (laisse le compilo recuperer la description)
486 if (!is_array($champs) ||
!is_array($cles))
489 $res = spip_mysql_query("SELECT version() as v");
490 if (($row = mysql_fetch_array($res)) && (version_compare($row['v'],'5.0','>='))) {
491 spip_mysql_query("SET sql_mode=''", $serveur);
494 foreach($cles as $k => $v) {
495 $keys .= "$s\n\t\t$k ($v)";
496 if ($k == "PRIMARY KEY")
503 if (@$GLOBALS['meta']['charset_sql_base'])
504 $character_set .= " CHARACTER SET ".$GLOBALS['meta']['charset_sql_base'];
505 if (@$GLOBALS['meta']['charset_collation_sql_base'])
506 $character_set .= " COLLATE ".$GLOBALS['meta']['charset_collation_sql_base'];
508 foreach($champs as $k => $v) {
509 $v = _mysql_remplacements_definitions_table($v);
510 if (preg_match(',([a-z]*\s*(\(\s*[0-9]*\s*\))?(\s*binary)?),i',$v,$defs)){
511 if (preg_match(',(char|text),i',$defs[1])
512 AND !preg_match(',(binary|CHARACTER|COLLATE),i',$v) ){
513 $v = $defs[1] . $character_set . ' ' . substr($v,strlen($defs[1]));
517 $query .= "$s\n\t\t$k $v"
518 . (($autoinc && ($p == $k) && preg_match(',\b(big|small|medium)?int\b,i', $v))
524 $temporary = $temporary ?
'TEMPORARY':'';
525 $q = "CREATE $temporary TABLE IF NOT EXISTS $nom ($query" . ($keys ?
",$keys" : '') . ")".
526 ($character_set?
" DEFAULT $character_set":"")
528 return spip_mysql_query($q, $serveur);
533 * Adapte pour Mysql la declaration SQL d'une colonne d'une table
535 * @param string $query
536 * Definition SQL d'un champ de table
538 * Definition SQL adaptee pour MySQL d'un champ de table
540 function _mysql_remplacements_definitions_table($query){
541 // quelques remplacements
542 $num = "(\s*\([0-9]*\))?";
543 $enum = "(\s*\([^\)]*\))?";
546 '/VARCHAR(\s*[^\s\(])/is' => 'VARCHAR(255)\\1',
549 $query = preg_replace(array_keys($remplace), $remplace, $query);
555 * @param string $serveur
556 * @param bool $requeter
557 * @return array|null|resource|string
559 function spip_mysql_create_base($nom, $serveur='',$requeter=true) {
560 return spip_mysql_query("CREATE DATABASE `$nom`", $serveur, $requeter);
563 // Fonction de creation d'une vue SQL nommee $nom
564 // http://doc.spip.org/@spip_mysql_create_view
567 * @param $query_select
568 * @param string $serveur
569 * @param bool $requeter
570 * @return array|bool|null|resource|string
572 function spip_mysql_create_view($nom, $query_select, $serveur='',$requeter=true) {
573 if (!$query_select) return false;
575 if (sql_showtable($nom, false, $serveur)) {
576 spip_log("Echec creation d'une vue sql ($nom) car celle-ci existe deja (serveur:$serveur)", _LOG_ERREUR
);
580 $query = "CREATE VIEW $nom AS ". $query_select;
581 return spip_mysql_query($query, $serveur, $requeter);
585 // http://doc.spip.org/@spip_mysql_drop_table
588 * @param string $exist
589 * @param string $serveur
590 * @param bool $requeter
591 * @return array|null|resource|string
593 function spip_mysql_drop_table($table, $exist='', $serveur='',$requeter=true)
595 if ($exist) $exist =" IF EXISTS";
596 return spip_mysql_query("DROP TABLE$exist $table", $serveur, $requeter);
600 // http://doc.spip.org/@spip_mysql_drop_view
603 * @param string $exist
604 * @param string $serveur
605 * @param bool $requeter
606 * @return array|null|resource|string
608 function spip_mysql_drop_view($view, $exist='', $serveur='',$requeter=true) {
609 if ($exist) $exist =" IF EXISTS";
610 return spip_mysql_query("DROP VIEW$exist $view", $serveur, $requeter);
614 * Retourne une ressource de la liste des tables de la base de données
616 * @param string $match
617 * Filtre sur tables à récupérer
618 * @param string $serveur
619 * Connecteur de la base
620 * @param bool $requeter
621 * true pour éxecuter la requête
622 * false pour retourner le texte de la requête.
624 * Ressource à utiliser avec sql_fetch()
626 function spip_mysql_showbase($match, $serveur='',$requeter=true)
628 return spip_mysql_query("SHOW TABLES LIKE " . _q($match), $serveur, $requeter);
631 // http://doc.spip.org/@spip_mysql_repair
634 * @param string $serveur
635 * @param bool $requeter
636 * @return array|null|resource|string
638 function spip_mysql_repair($table, $serveur='',$requeter=true)
640 return spip_mysql_query("REPAIR TABLE `$table`", $serveur, $requeter);
643 define('_MYSQL_RE_SHOW_TABLE', '/^[^(),]*\(((?:[^()]*\((?:[^()]*\([^()]*\))?[^()]*\)[^()]*)*[^()]*)\)[^()]*$/');
644 // Recupere la definition d'une table ou d'une vue MySQL
645 // colonnes, indexes, etc.
646 // au meme format que la definition des tables de SPIP
647 // http://doc.spip.org/@spip_mysql_showtable
650 * @param string $serveur
651 * @param bool $requeter
652 * @return array|null|resource|string
654 function spip_mysql_showtable($nom_table, $serveur='',$requeter=true)
656 $s = spip_mysql_query("SHOW CREATE TABLE `$nom_table`", $serveur, $requeter);
658 if (!$requeter) return $s;
660 list(,$a) = mysql_fetch_array($s ,MYSQL_NUM
);
661 if (preg_match(_MYSQL_RE_SHOW_TABLE
, $a, $r)){
663 // extraction d'une KEY éventuelle en prenant garde de ne pas
664 // relever un champ dont le nom contient KEY (ex. ID_WHISKEY)
665 if (preg_match("/^(.*?),([^,]*\sKEY[ (].*)$/s", $desc, $r)) {
673 foreach(preg_split("/,\s*`/",$desc) as $v) {
674 preg_match("/^\s*`?([^`]*)`\s*(.*)/",$v,$r);
675 $fields[strtolower($r[1])] = $r[2];
679 foreach(preg_split('/\)\s*(,|$)/',$namedkeys) as $v) {
680 if (preg_match("/^\s*([^(]*)\(([^(]*(\(\d+\))?)$/",$v,$r)) {
681 $k = str_replace("`", '', trim($r[1]));
682 $t = strtolower(str_replace("`", '', $r[2]));
683 if ($k && !isset($keys[$k])) $keys[$k] = $t; else $keys[] = $t;
687 return array('field' => $fields, 'key' => $keys);
690 $res = spip_mysql_query("SHOW COLUMNS FROM `$nom_table`", $serveur);
694 while($val = spip_mysql_fetch($res)) {
695 $nfields[$val["Field"]] = $val['Type'];
696 if($val['Null']=='NO') {
697 $nfields[$val["Field"]] .= ' NOT NULL';
699 if($val['Default'] === '0' ||
$val['Default']) {
700 if(preg_match('/[A-Z_]/',$val['Default'])) {
701 $nfields[$val["Field"]] .= ' DEFAULT '.$val['Default'];
703 $nfields[$val["Field"]] .= " DEFAULT '".$val['Default']."'";
707 $nfields[$val["Field"]] .= ' '.$val['Extra'];
708 if($val['Key'] == 'PRI') {
709 $nkeys['PRIMARY KEY'] = $val["Field"];
710 } else if($val['Key'] == 'MUL') {
711 $nkeys['KEY '.$val["Field"]] = $val["Field"];
712 } else if($val['Key'] == 'UNI') {
713 $nkeys['UNIQUE KEY '.$val["Field"]] = $val["Field"];
716 spip_mysql_free($res);
717 return array('field' => $nfields, 'key' => $nkeys);
723 // Recuperation des resultats
726 // http://doc.spip.org/@spip_mysql_fetch
730 * @param string $serveur
731 * @param bool $requeter
734 function spip_mysql_fetch($r, $t='', $serveur='',$requeter=true) {
735 if (!$t) $t = MYSQL_ASSOC
;
736 if ($r) return mysql_fetch_array($r, $t);
739 function spip_mysql_seek($r, $row_number, $serveur='',$requeter=true) {
740 if ($r and mysql_num_rows($r)) return mysql_data_seek($r,$row_number);
744 // http://doc.spip.org/@spip_mysql_countsel
748 * @param array $where
749 * @param string $groupby
750 * @param array $having
751 * @param string $serveur
752 * @param bool $requeter
753 * @return array|int|null|resource|string
756 function spip_mysql_countsel($from = array(), $where = array(),
757 $groupby = '', $having = array(), $serveur='',$requeter=true)
759 $c = !$groupby ?
'*' : ('DISTINCT ' . (is_string($groupby) ?
$groupby : join(',', $groupby)));
761 $r = spip_mysql_select("COUNT($c)", $from, $where,'', '', '', $having, $serveur, $requeter);
763 if (!$requeter) return $r;
764 if (!is_resource($r)) return 0;
765 list($c) = mysql_fetch_array($r, MYSQL_NUM
);
766 mysql_free_result($r);
770 // Bien specifier le serveur auquel on s'adresse,
771 // mais a l'install la globale n'est pas encore completement definie
772 // http://doc.spip.org/@spip_mysql_error
774 * @param string $query
775 * @param string $serveur
776 * @param bool $requeter
779 function spip_mysql_error($query='', $serveur='',$requeter=true) {
780 $link = $GLOBALS['connexions'][$serveur ?
strtolower($serveur) : 0]['link'];
781 $s = $link ?
mysql_error($link) : mysql_error();
782 if ($s) spip_log("$s - $query", 'mysql.'._LOG_ERREUR
);
786 // A transposer dans les portages
787 // http://doc.spip.org/@spip_mysql_errno
789 * @param string $serveur
790 * @param bool $requeter
793 function spip_mysql_errno($serveur='',$requeter=true) {
794 $link = $GLOBALS['connexions'][$serveur ?
$serveur : 0]['link'];
795 $s = $link ?
mysql_errno($link) : mysql_errno();
796 // 2006 MySQL server has gone away
797 // 2013 Lost connection to MySQL server during query
798 if (in_array($s, array(2006,2013)))
799 define('spip_interdire_cache', true);
800 if ($s) spip_log("Erreur mysql $s", _LOG_ERREUR
);
804 // Interface de abstract_sql
805 // http://doc.spip.org/@spip_mysql_count
808 * @param string $serveur
809 * @param bool $requeter
812 function spip_mysql_count($r, $serveur='',$requeter=true) {
813 if ($r) return mysql_num_rows($r);
817 // http://doc.spip.org/@spip_mysql_free
820 * @param string $serveur
821 * @param bool $requeter
824 function spip_mysql_free($r, $serveur='',$requeter=true) {
825 return (is_resource($r)?
mysql_free_result($r):false);
828 // http://doc.spip.org/@spip_mysql_insert
833 * @param string $desc
834 * @param string $serveur
835 * @param bool $requeter
838 function spip_mysql_insert($table, $champs, $valeurs, $desc='', $serveur='',$requeter=true) {
840 $connexion = &$GLOBALS['connexions'][$serveur ?
strtolower($serveur) : 0];
841 $prefixe = $connexion['prefixe'];
842 $link = $connexion['link'];
843 $db = $connexion['db'];
845 if ($prefixe) $table = preg_replace('/^spip/', $prefixe, $table);
847 $query ="INSERT INTO $table $champs VALUES $valeurs";
848 if (!$requeter) return $query;
850 if (isset($_GET['var_profile'])) {
851 include_spip('public/tracer');
852 $t = trace_query_start();
855 $connexion['last'] = $query;
856 #spip_log($query, 'mysql.'._LOG_DEBUG);
857 if (mysql_query($query, $link))
858 $r = mysql_insert_id($link);
860 if ($e = spip_mysql_errno($serveur)) // Log de l'erreur eventuelle
861 $e .= spip_mysql_error($query, $serveur); // et du fautif
863 return $t ?
trace_query_end($query, $t, $r, $e, $serveur) : $r;
865 // return $r ? $r : (($r===0) ? -1 : 0); pb avec le multi-base.
868 // http://doc.spip.org/@spip_mysql_insertq
871 * @param array $couples
873 * @param string $serveur
874 * @param bool $requeter
877 function spip_mysql_insertq($table, $couples=array(), $desc=array(), $serveur='',$requeter=true) {
879 if (!$desc) $desc = description_table($table, $serveur);
880 if (!$desc) $couples = array();
881 $fields = isset($desc['field'])?
$desc['field']:array();
883 foreach ($couples as $champ => $val) {
884 $couples[$champ]= spip_mysql_cite($val, $fields[$champ]);
887 return spip_mysql_insert($table, "(".join(',',array_keys($couples)).")", "(".join(',', $couples).")", $desc, $serveur, $requeter);
891 // http://doc.spip.org/@spip_mysql_insertq_multi
894 * @param array $tab_couples
896 * @param string $serveur
897 * @param bool $requeter
898 * @return bool|int|string
900 function spip_mysql_insertq_multi($table, $tab_couples=array(), $desc=array(), $serveur='',$requeter=true) {
902 if (!$desc) $desc = description_table($table, $serveur);
903 if (!$desc) $tab_couples = array();
904 $fields = isset($desc['field'])?
$desc['field']:array();
906 $cles = "(" . join(',',array_keys(reset($tab_couples))) . ')';
910 // Quoter et Inserer par groupes de 100 max pour eviter un debordement de pile
911 foreach ($tab_couples as $couples) {
912 foreach ($couples as $champ => $val){
913 $couples[$champ]= spip_mysql_cite($val, $fields[$champ]);
915 $valeurs[] = '(' .join(',', $couples) . ')';
916 if (count($valeurs)>=100){
917 $r = spip_mysql_insert($table, $cles, join(', ', $valeurs), $desc, $serveur, $requeter);
922 $r = spip_mysql_insert($table, $cles, join(', ', $valeurs), $desc, $serveur, $requeter);
924 return $r; // dans le cas d'une table auto_increment, le dernier insert_id
927 // http://doc.spip.org/@spip_mysql_update
931 * @param string $where
932 * @param string $desc
933 * @param string $serveur
934 * @param bool $requeter
935 * @return array|null|resource|string
937 function spip_mysql_update($table, $champs, $where='', $desc='', $serveur='',$requeter=true) {
939 foreach ($champs as $champ => $val)
940 $set[] = $champ . "=$val";
942 return spip_mysql_query(
943 calculer_mysql_expression('UPDATE', $table, ',')
944 . calculer_mysql_expression('SET', $set, ',')
945 . calculer_mysql_expression('WHERE', $where),
946 $serveur, $requeter);
949 // idem, mais les valeurs sont des constantes a mettre entre apostrophes
950 // sauf les expressions de date lorsqu'il s'agit de fonctions SQL (NOW etc)
951 // http://doc.spip.org/@spip_mysql_updateq
955 * @param string $where
957 * @param string $serveur
958 * @param bool $requeter
959 * @return array|null|resource|string
961 function spip_mysql_updateq($table, $champs, $where='', $desc=array(), $serveur='',$requeter=true) {
963 if (!$champs) return;
964 if (!$desc) $desc = description_table($table, $serveur);
965 if (!$desc) $champs = array(); else $fields = $desc['field'];
967 foreach ($champs as $champ => $val) {
968 $set[] = $champ . '=' . spip_mysql_cite($val, $fields[$champ]);
970 return spip_mysql_query(
971 calculer_mysql_expression('UPDATE', $table, ',')
972 . calculer_mysql_expression('SET', $set, ',')
973 . calculer_mysql_expression('WHERE', $where),
974 $serveur, $requeter);
977 // http://doc.spip.org/@spip_mysql_delete
980 * @param string $where
981 * @param string $serveur
982 * @param bool $requeter
983 * @return array|bool|int|null|resource|string
985 function spip_mysql_delete($table, $where='', $serveur='',$requeter=true) {
986 $res = spip_mysql_query(
987 calculer_mysql_expression('DELETE FROM', $table, ',')
988 . calculer_mysql_expression('WHERE', $where),
989 $serveur, $requeter);
990 if (!$requeter) return $res;
992 $connexion = &$GLOBALS['connexions'][$serveur ?
$serveur : 0];
993 $link = $connexion['link'];
994 return $link ?
mysql_affected_rows($link) : mysql_affected_rows();
1000 // http://doc.spip.org/@spip_mysql_replace
1004 * @param array $desc
1005 * @param string $serveur
1006 * @param bool $requeter
1007 * @return array|null|resource|string
1009 function spip_mysql_replace($table, $couples, $desc=array(), $serveur='',$requeter=true) {
1010 return spip_mysql_query("REPLACE $table (" . join(',',array_keys($couples)) . ') VALUES (' .join(',',array_map('_q', $couples)) . ')', $serveur, $requeter);
1014 // http://doc.spip.org/@spip_mysql_replace_multi
1017 * @param $tab_couples
1018 * @param array $desc
1019 * @param string $serveur
1020 * @param bool $requeter
1021 * @return array|null|resource|string
1023 function spip_mysql_replace_multi($table, $tab_couples, $desc=array(), $serveur='',$requeter=true) {
1024 $cles = "(" . join(',',array_keys($tab_couples[0])). ')';
1026 foreach ($tab_couples as $couples) {
1027 $valeurs[] = '(' .join(',',array_map('_q', $couples)) . ')';
1029 $valeurs = implode(', ',$valeurs);
1030 return spip_mysql_query("REPLACE $table $cles VALUES $valeurs", $serveur, $requeter);
1034 // http://doc.spip.org/@spip_mysql_multi
1043 function spip_mysql_multi ($objet, $lang) {
1044 $lengthlang = strlen("[$lang]");
1045 $posmulti = "INSTR(".$objet.", '<multi>')";
1046 $posfinmulti = "INSTR(".$objet.", '</multi>')";
1047 $debutchaine = "LEFT(".$objet.", $posmulti-1)";
1048 $finchaine = "RIGHT(".$objet.", CHAR_LENGTH(".$objet.") -(7+$posfinmulti))";
1049 $chainemulti = "TRIM(SUBSTRING(".$objet.", $posmulti+7, $posfinmulti -(7+$posmulti)))";
1050 $poslang = "INSTR($chainemulti,'[".$lang."]')";
1051 $poslang = "IF($poslang=0,INSTR($chainemulti,']')+1,$poslang+$lengthlang)";
1052 $chainelang = "TRIM(SUBSTRING(".$objet.", $posmulti+7+$poslang-1,$posfinmulti -($posmulti+7+$poslang-1) ))";
1053 $posfinlang = "INSTR(".$chainelang.", '[')";
1054 $chainelang = "IF($posfinlang>0,LEFT($chainelang,$posfinlang-1),$chainelang)";
1055 //$chainelang = "LEFT($chainelang,$posfinlang-1)";
1056 $retour = "(TRIM(IF($posmulti = 0 , ".
1057 " TRIM(".$objet."), ".
1072 // http://doc.spip.org/@spip_mysql_hex
1077 function spip_mysql_hex($v)
1084 * @param string $type
1085 * @return array|int|string
1087 function spip_mysql_quote($v, $type='') {
1090 return spip_mysql_cite($v,$type);
1091 // si c'est un tableau, le parcourir en propageant le type
1092 foreach($v as $k=>$r)
1093 $v[$k] = spip_mysql_quote($r, $type);
1096 // si on ne connait pas le type, s'en remettre a _q :
1097 // on ne fera pas mieux
1108 function spip_mysql_date_proche($champ, $interval, $unite)
1112 . (($interval <= 0) ?
'>' : '<')
1113 . (($interval <= 0) ?
'DATE_SUB' : 'DATE_ADD')
1115 . sql_quote(date('Y-m-d H:i:s'))
1117 . (($interval > 0) ?
$interval : (0-$interval))
1124 // IN (...) est limite a 255 elements, d'ou cette fonction assistante
1126 // http://doc.spip.org/@spip_mysql_in
1130 * @param string $not
1131 * @param string $serveur
1132 * @param bool $requeter
1135 function spip_mysql_in($val, $valeurs, $not='', $serveur='',$requeter=true) {
1138 while ($n = strpos($valeurs, ',', $n+
1)) {
1139 if ((++
$i) >= 255) {
1140 $in_sql .= "($val $not IN (" .
1141 substr($valeurs, 0, $n) .
1143 ($not ?
"AND\t" : "OR\t");
1144 $valeurs = substr($valeurs, $n+
1);
1148 $in_sql .= "($val $not IN ($valeurs))";
1153 // pour compatibilite. Ne plus utiliser.
1154 // http://doc.spip.org/@calcul_mysql_in
1158 * @param string $not
1161 function calcul_mysql_in($val, $valeurs, $not='') {
1162 if (is_array($valeurs))
1163 $valeurs = join(',', array_map('_q', $valeurs));
1164 elseif ($valeurs[0]===',') $valeurs = substr($valeurs,1);
1165 if (!strlen(trim($valeurs))) return ($not ?
"0=0" : '0=1');
1166 return spip_mysql_in($val, $valeurs, $not);
1169 // http://doc.spip.org/@spip_mysql_cite
1173 * @return int|string
1175 function spip_mysql_cite($v, $type) {
1177 AND stripos($type,"NOT NULL")===false) return 'NULL'; // null php se traduit en NULL SQL
1178 if (sql_test_date($type) AND preg_match('/^\w+\(/', $v))
1180 if (sql_test_int($type)) {
1181 if (is_numeric($v) OR (ctype_xdigit(substr($v,2))
1182 AND $v[0]=='0' AND $v[1]=='x'))
1184 // si pas numerique, forcer le intval
1188 return ("'" . addslashes($v) . "'");
1191 // Ces deux fonctions n'ont pas d'equivalent exact PostGres
1192 // et ne sont la que pour compatibilite avec les extensions de SPIP < 1.9.3
1195 // Poser un verrou local a un SPIP donne
1196 // Changer de nom toutes les heures en cas de blocage MySQL (ca arrive)
1198 // http://doc.spip.org/@spip_get_lock
1201 * @param int $timeout
1204 function spip_get_lock($nom, $timeout = 0) {
1206 define('_LOCK_TIME', intval(time()/3600-316982));
1208 $connexion = &$GLOBALS['connexions'][0];
1209 $bd = $connexion['db'];
1210 $prefixe = $connexion['prefixe'];
1211 $nom = "$bd:$prefixe:$nom" . _LOCK_TIME
;
1213 $connexion['last'] = $q = "SELECT GET_LOCK(" . _q($nom) . ", $timeout) AS n";
1214 $q = @sql_fetch
(mysql_query($q));
1215 if (!$q) spip_log("pas de lock sql pour $nom", _LOG_ERREUR
);
1219 // http://doc.spip.org/@spip_release_lock
1223 function spip_release_lock($nom) {
1225 $connexion = &$GLOBALS['connexions'][0];
1226 $bd = $connexion['db'];
1227 $prefixe = $connexion['prefixe'];
1228 $nom = "$bd:$prefixe:$nom" . _LOCK_TIME
;
1230 $connexion['last'] = $q = "SELECT RELEASE_LOCK(" . _q($nom) . ")";
1234 // Renvoie false si on n'a pas les fonctions mysql (pour l'install)
1235 // http://doc.spip.org/@spip_versions_mysql
1239 function spip_versions_mysql() {
1240 charger_php_extension('mysql');
1241 return function_exists('mysql_query');
1244 // Tester si mysql ne veut pas du nom de la base dans les requetes
1246 // http://doc.spip.org/@test_rappel_nom_base_mysql
1251 function test_rappel_nom_base_mysql($server_db)
1253 $GLOBALS['mysql_rappel_nom_base'] = true;
1254 sql_delete('spip_meta', "nom='mysql_rappel_nom_base'", $server_db);
1255 $ok = spip_query("INSERT INTO spip_meta (nom,valeur) VALUES ('mysql_rappel_nom_base', 'test')", $server_db);
1258 sql_delete('spip_meta', "nom='mysql_rappel_nom_base'", $server_db);
1261 $GLOBALS['mysql_rappel_nom_base'] = false;
1262 return "\$GLOBALS['mysql_rappel_nom_base'] = false; ".
1263 "/* echec de test_rappel_nom_base_mysql a l'installation. */\n";
1267 // http://doc.spip.org/@test_sql_mode_mysql
1272 function test_sql_mode_mysql($server_db){
1273 $res = sql_select("version() as v",'','','','','','',$server_db);
1274 $row = sql_fetch($res,$server_db);
1275 if (version_compare($row['v'],'5.0.0','>=')){
1276 define('_MYSQL_SET_SQL_MODE',true);
1277 return "define('_MYSQL_SET_SQL_MODE',true);\n";