spip / SPIP

ecrire/req/mysql.php

Indentation +816 added lines, -816 removed lines

@@ -20,11 +20,11 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 if (!defined('_MYSQL_NOPLANES')) {
-	define('_MYSQL_NOPLANES', true);
+    define('_MYSQL_NOPLANES', true);
 }
 
 /**
@@ -41,108 +41,108 @@ 
  *     - tableau décrivant la connexion sinon
  */
 function req_mysql_dist($host, $port, $login, $pass, $db = '', $prefixe = '') {
-	if (!extension_loaded('mysqli')) {
-		return false;
-	}
-
-	// si port est fourni mais pas host, c'est un socket -> compat avec vieille syntaxe de mysql_connect() et anciens fichiers connect.php
-	if (
-		$port and !is_numeric($socket = $port)
-		and (!$host or $host == 'localhost')
-	) {
-		$link = @mysqli_connect($host, $login, $pass, '', null, $socket);
-	}
-	elseif ($port) {
-		$link = @mysqli_connect($host, $login, $pass, '', $port);
-	}
-	else {
-		$link = @mysqli_connect($host, $login, $pass);
-	}
-
-	if (!$link) {
-		spip_log('Echec mysqli_connect. Erreur : ' . mysqli_connect_error(), 'mysql.' . _LOG_HS);
-
-		return false;
-	}
-	$last = '';
-	if (!$db) {
-		$ok = $link;
-		$db = 'spip';
-	} else {
-		$ok = mysqli_select_db($link, $db);
-		if (
-			defined('_MYSQL_SET_SQL_MODE')
-			or defined('_MYSQL_SQL_MODE_TEXT_NOT_NULL') // compatibilite
-		) {
-			mysqli_query($link, $last = "set sql_mode=''");
-		}
-	}
-
-	spip_log(
-		"Connexion MySQLi vers $host, base $db, prefixe $prefixe " . ($ok ? 'operationnelle' : 'impossible'),
-		_LOG_DEBUG
-	);
-
-	return !$ok ? false : [
-		'db' => $db,
-		'last' => $last,
-		'prefixe' => $prefixe ? $prefixe : $db,
-		'link' => $link,
-		'total_requetes' => 0,
-	];
+    if (!extension_loaded('mysqli')) {
+        return false;
+    }
+
+    // si port est fourni mais pas host, c'est un socket -> compat avec vieille syntaxe de mysql_connect() et anciens fichiers connect.php
+    if (
+        $port and !is_numeric($socket = $port)
+        and (!$host or $host == 'localhost')
+    ) {
+        $link = @mysqli_connect($host, $login, $pass, '', null, $socket);
+    }
+    elseif ($port) {
+        $link = @mysqli_connect($host, $login, $pass, '', $port);
+    }
+    else {
+        $link = @mysqli_connect($host, $login, $pass);
+    }
+
+    if (!$link) {
+        spip_log('Echec mysqli_connect. Erreur : ' . mysqli_connect_error(), 'mysql.' . _LOG_HS);
+
+        return false;
+    }
+    $last = '';
+    if (!$db) {
+        $ok = $link;
+        $db = 'spip';
+    } else {
+        $ok = mysqli_select_db($link, $db);
+        if (
+            defined('_MYSQL_SET_SQL_MODE')
+            or defined('_MYSQL_SQL_MODE_TEXT_NOT_NULL') // compatibilite
+        ) {
+            mysqli_query($link, $last = "set sql_mode=''");
+        }
+    }
+
+    spip_log(
+        "Connexion MySQLi vers $host, base $db, prefixe $prefixe " . ($ok ? 'operationnelle' : 'impossible'),
+        _LOG_DEBUG
+    );
+
+    return !$ok ? false : [
+        'db' => $db,
+        'last' => $last,
+        'prefixe' => $prefixe ? $prefixe : $db,
+        'link' => $link,
+        'total_requetes' => 0,
+    ];
 }
 
 
 $GLOBALS['spip_mysql_functions_1'] = [
-	'alter' => 'spip_mysql_alter',
-	'count' => 'spip_mysql_count',
-	'countsel' => 'spip_mysql_countsel',
-	'create' => 'spip_mysql_create',
-	'create_base' => 'spip_mysql_create_base',
-	'create_view' => 'spip_mysql_create_view',
-	'date_proche' => 'spip_mysql_date_proche',
-	'delete' => 'spip_mysql_delete',
-	'drop_table' => 'spip_mysql_drop_table',
-	'drop_view' => 'spip_mysql_drop_view',
-	'errno' => 'spip_mysql_errno',
-	'error' => 'spip_mysql_error',
-	'explain' => 'spip_mysql_explain',
-	'fetch' => 'spip_mysql_fetch',
-	'seek' => 'spip_mysql_seek',
-	'free' => 'spip_mysql_free',
-	'hex' => 'spip_mysql_hex',
-	'in' => 'spip_mysql_in',
-	'insert' => 'spip_mysql_insert',
-	'insertq' => 'spip_mysql_insertq',
-	'insertq_multi' => 'spip_mysql_insertq_multi',
-	'listdbs' => 'spip_mysql_listdbs',
-	'multi' => 'spip_mysql_multi',
-	'optimize' => 'spip_mysql_optimize',
-	'query' => 'spip_mysql_query',
-	'quote' => 'spip_mysql_quote',
-	'replace' => 'spip_mysql_replace',
-	'replace_multi' => 'spip_mysql_replace_multi',
-	'repair' => 'spip_mysql_repair',
-	'select' => 'spip_mysql_select',
-	'selectdb' => 'spip_mysql_selectdb',
-	'set_charset' => 'spip_mysql_set_charset',
-	'get_charset' => 'spip_mysql_get_charset',
-	'showbase' => 'spip_mysql_showbase',
-	'showtable' => 'spip_mysql_showtable',
-	'update' => 'spip_mysql_update',
-	'updateq' => 'spip_mysql_updateq',
-
-	// association de chaque nom http d'un charset aux couples MySQL
-	'charsets' => [
-		'cp1250' => ['charset' => 'cp1250', 'collation' => 'cp1250_general_ci'],
-		'cp1251' => ['charset' => 'cp1251', 'collation' => 'cp1251_general_ci'],
-		'cp1256' => ['charset' => 'cp1256', 'collation' => 'cp1256_general_ci'],
-		'iso-8859-1' => ['charset' => 'latin1', 'collation' => 'latin1_swedish_ci'],
+    'alter' => 'spip_mysql_alter',
+    'count' => 'spip_mysql_count',
+    'countsel' => 'spip_mysql_countsel',
+    'create' => 'spip_mysql_create',
+    'create_base' => 'spip_mysql_create_base',
+    'create_view' => 'spip_mysql_create_view',
+    'date_proche' => 'spip_mysql_date_proche',
+    'delete' => 'spip_mysql_delete',
+    'drop_table' => 'spip_mysql_drop_table',
+    'drop_view' => 'spip_mysql_drop_view',
+    'errno' => 'spip_mysql_errno',
+    'error' => 'spip_mysql_error',
+    'explain' => 'spip_mysql_explain',
+    'fetch' => 'spip_mysql_fetch',
+    'seek' => 'spip_mysql_seek',
+    'free' => 'spip_mysql_free',
+    'hex' => 'spip_mysql_hex',
+    'in' => 'spip_mysql_in',
+    'insert' => 'spip_mysql_insert',
+    'insertq' => 'spip_mysql_insertq',
+    'insertq_multi' => 'spip_mysql_insertq_multi',
+    'listdbs' => 'spip_mysql_listdbs',
+    'multi' => 'spip_mysql_multi',
+    'optimize' => 'spip_mysql_optimize',
+    'query' => 'spip_mysql_query',
+    'quote' => 'spip_mysql_quote',
+    'replace' => 'spip_mysql_replace',
+    'replace_multi' => 'spip_mysql_replace_multi',
+    'repair' => 'spip_mysql_repair',
+    'select' => 'spip_mysql_select',
+    'selectdb' => 'spip_mysql_selectdb',
+    'set_charset' => 'spip_mysql_set_charset',
+    'get_charset' => 'spip_mysql_get_charset',
+    'showbase' => 'spip_mysql_showbase',
+    'showtable' => 'spip_mysql_showtable',
+    'update' => 'spip_mysql_update',
+    'updateq' => 'spip_mysql_updateq',
+
+    // association de chaque nom http d'un charset aux couples MySQL
+    'charsets' => [
+        'cp1250' => ['charset' => 'cp1250', 'collation' => 'cp1250_general_ci'],
+        'cp1251' => ['charset' => 'cp1251', 'collation' => 'cp1251_general_ci'],
+        'cp1256' => ['charset' => 'cp1256', 'collation' => 'cp1256_general_ci'],
+        'iso-8859-1' => ['charset' => 'latin1', 'collation' => 'latin1_swedish_ci'],
 //'iso-8859-6'=>array('charset'=>'latin1','collation'=>'latin1_swedish_ci'),
-		'iso-8859-9' => ['charset' => 'latin5', 'collation' => 'latin5_turkish_ci'],
+        'iso-8859-9' => ['charset' => 'latin5', 'collation' => 'latin5_turkish_ci'],
 //'iso-8859-15'=>array('charset'=>'latin1','collation'=>'latin1_swedish_ci'),
-		'utf-8' => ['charset' => 'utf8', 'collation' => 'utf8_general_ci']
-	]
+        'utf-8' => ['charset' => 'utf8', 'collation' => 'utf8_general_ci']
+    ]
 ];
 
 
@@ -153,9 +153,9 @@ 
  * @return Object Information de connexion pour mysqli
  */
 function _mysql_link($serveur = '') {
-	$link = &$GLOBALS['connexions'][$serveur ? $serveur : 0]['link'];
+    $link = &$GLOBALS['connexions'][$serveur ? $serveur : 0]['link'];
 
-	return $link;
+    return $link;
 }
 
 
@@ -168,10 +168,10 @@ 
  * @return resource       Ressource de résultats pour fetch()
  */
 function spip_mysql_set_charset($charset, $serveur = '', $requeter = true) {
-	$connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-	spip_log('changement de charset sql : ' . 'SET NAMES ' . _q($charset), _LOG_DEBUG);
+    $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+    spip_log('changement de charset sql : ' . 'SET NAMES ' . _q($charset), _LOG_DEBUG);
 
-	return mysqli_query($connexion['link'], $connexion['last'] = 'SET NAMES ' . _q($charset));
+    return mysqli_query($connexion['link'], $connexion['last'] = 'SET NAMES ' . _q($charset));
 }
 
 
@@ -184,11 +184,11 @@ 
  * @return array                Description du charset (son nom est dans 'charset')
  */
 function spip_mysql_get_charset($charset = [], $serveur = '', $requeter = true) {
-	$connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-	$connexion['last'] = $c = 'SHOW CHARACTER SET'
-		. (!$charset ? '' : (' LIKE ' . _q($charset['charset'])));
+    $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+    $connexion['last'] = $c = 'SHOW CHARACTER SET'
+        . (!$charset ? '' : (' LIKE ' . _q($charset['charset'])));
 
-	return spip_mysql_fetch(mysqli_query($connexion['link'], $c), null, $serveur);
+    return spip_mysql_fetch(mysqli_query($connexion['link'], $c), null, $serveur);
 }
 
 /**
@@ -204,66 +204,66 @@ 
  */
 function spip_mysql_query($query, $serveur = '', $requeter = true) {
 
-	$connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-	$prefixe = $connexion['prefixe'];
-	$link = $connexion['link'];
-	$db = $connexion['db'];
-
-	$query = _mysql_traite_query($query, $db, $prefixe);
-
-	// renvoyer la requete inerte si demandee
-	if (!$requeter) {
-		return $query;
-	}
-
-	if (isset($_GET['var_profile']) or (defined('_DEBUG_TRACE_QUERIES') and _DEBUG_TRACE_QUERIES)) {
-		include_spip('public/tracer');
-		$t = trace_query_start();
-	} else {
-		$t = 0;
-	}
-
-	$connexion['last'] = $query;
-	$connexion['total_requetes']++;
-
-	// ajouter un debug utile dans log/mysql-slow.log ?
-	$debug = '';
-	if (defined('_DEBUG_SLOW_QUERIES') and _DEBUG_SLOW_QUERIES) {
-		if (isset($GLOBALS['debug']['aucasou'])) {
-			list(, $id, , $infos) = $GLOBALS['debug']['aucasou'];
-			$debug .= "BOUCLE$id @ " . (isset($infos[0]) ? $infos[0] : '') . ' | ';
-		}
-		if (isset($_SERVER['REQUEST_URI'])) {
-			$debug .= $_SERVER['REQUEST_URI'];
-		}
-		if (!empty($GLOBALS['ip'])) {
-			$debug .= ' + ' . $GLOBALS['ip'];
-		}
-		$debug = ' /* ' . mysqli_real_escape_string($link, str_replace('*/', '@/', $debug)) . ' */';
-	}
-
-	$r = mysqli_query($link, $query . $debug);
-
-	//Eviter de propager le GoneAway sur les autres requetes d'un même processus PHP
-	if ($e = spip_mysql_errno($serveur)) {  // Log d'un Gone Away
-		if ($e == 2006) { //Si Gone Away on relance une connexion vierge
-			//Fermer la connexion defaillante
-			mysqli_close($connexion['link']);
-			unset($GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0]);
-			//Relancer une connexion vierge
-			spip_connect($serveur);
-			$connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-			$link = $connexion['link'];
-			//On retente au cas où
-			$r = mysqli_query($link, $query . $debug);
-		}
-	}
-
-	// Log de l'erreur eventuelle
-	if ($e = spip_mysql_errno($serveur)) {
-		$e .= spip_mysql_error($query, $serveur);
-	} // et du fautif
-	return $t ? trace_query_end($query, $t, $r, $e, $serveur) : $r;
+    $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+    $prefixe = $connexion['prefixe'];
+    $link = $connexion['link'];
+    $db = $connexion['db'];
+
+    $query = _mysql_traite_query($query, $db, $prefixe);
+
+    // renvoyer la requete inerte si demandee
+    if (!$requeter) {
+        return $query;
+    }
+
+    if (isset($_GET['var_profile']) or (defined('_DEBUG_TRACE_QUERIES') and _DEBUG_TRACE_QUERIES)) {
+        include_spip('public/tracer');
+        $t = trace_query_start();
+    } else {
+        $t = 0;
+    }
+
+    $connexion['last'] = $query;
+    $connexion['total_requetes']++;
+
+    // ajouter un debug utile dans log/mysql-slow.log ?
+    $debug = '';
+    if (defined('_DEBUG_SLOW_QUERIES') and _DEBUG_SLOW_QUERIES) {
+        if (isset($GLOBALS['debug']['aucasou'])) {
+            list(, $id, , $infos) = $GLOBALS['debug']['aucasou'];
+            $debug .= "BOUCLE$id @ " . (isset($infos[0]) ? $infos[0] : '') . ' | ';
+        }
+        if (isset($_SERVER['REQUEST_URI'])) {
+            $debug .= $_SERVER['REQUEST_URI'];
+        }
+        if (!empty($GLOBALS['ip'])) {
+            $debug .= ' + ' . $GLOBALS['ip'];
+        }
+        $debug = ' /* ' . mysqli_real_escape_string($link, str_replace('*/', '@/', $debug)) . ' */';
+    }
+
+    $r = mysqli_query($link, $query . $debug);
+
+    //Eviter de propager le GoneAway sur les autres requetes d'un même processus PHP
+    if ($e = spip_mysql_errno($serveur)) {  // Log d'un Gone Away
+        if ($e == 2006) { //Si Gone Away on relance une connexion vierge
+            //Fermer la connexion defaillante
+            mysqli_close($connexion['link']);
+            unset($GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0]);
+            //Relancer une connexion vierge
+            spip_connect($serveur);
+            $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+            $link = $connexion['link'];
+            //On retente au cas où
+            $r = mysqli_query($link, $query . $debug);
+        }
+    }
+
+    // Log de l'erreur eventuelle
+    if ($e = spip_mysql_errno($serveur)) {
+        $e .= spip_mysql_error($query, $serveur);
+    } // et du fautif
+    return $t ? trace_query_end($query, $t, $r, $e, $serveur) : $r;
 }
 
 /**
@@ -278,12 +278,12 @@ 
  *     - array  : Tableau décrivant requête et temps d'exécution si var_profile actif pour tracer.
  */
 function spip_mysql_alter($query, $serveur = '', $requeter = true) {
-	// ici on supprime les ` entourant le nom de table pour permettre
-	// la transposition du prefixe, compte tenu que les plugins ont la mauvaise habitude
-	// d'utiliser ceux-ci, copie-colle de phpmyadmin
-	$query = preg_replace(',^TABLE\s*`([^`]*)`,i', "TABLE \\1", $query);
+    // ici on supprime les ` entourant le nom de table pour permettre
+    // la transposition du prefixe, compte tenu que les plugins ont la mauvaise habitude
+    // d'utiliser ceux-ci, copie-colle de phpmyadmin
+    $query = preg_replace(',^TABLE\s*`([^`]*)`,i', "TABLE \\1", $query);
 
-	return spip_mysql_query('ALTER ' . $query, $serveur, $requeter); # i.e. que PG se debrouille
+    return spip_mysql_query('ALTER ' . $query, $serveur, $requeter); # i.e. que PG se debrouille
 }
 
 
@@ -296,9 +296,9 @@ 
  * @return bool            Toujours true
  */
 function spip_mysql_optimize($table, $serveur = '', $requeter = true) {
-	spip_mysql_query('OPTIMIZE TABLE ' . $table);
+    spip_mysql_query('OPTIMIZE TABLE ' . $table);
 
-	return true;
+    return true;
 }
 
 
@@ -311,18 +311,18 @@ 
  * @return array           Tableau de l'explication
  */
 function spip_mysql_explain($query, $serveur = '', $requeter = true) {
-	if (strpos(ltrim($query), 'SELECT') !== 0) {
-		return [];
-	}
-	$connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-	$prefixe = $connexion['prefixe'];
-	$link = $connexion['link'];
-	$db = $connexion['db'];
-
-	$query = 'EXPLAIN ' . _mysql_traite_query($query, $db, $prefixe);
-	$r = mysqli_query($link, $query);
-
-	return spip_mysql_fetch($r, null, $serveur);
+    if (strpos(ltrim($query), 'SELECT') !== 0) {
+        return [];
+    }
+    $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+    $prefixe = $connexion['prefixe'];
+    $link = $connexion['link'];
+    $db = $connexion['db'];
+
+    $query = 'EXPLAIN ' . _mysql_traite_query($query, $db, $prefixe);
+    $r = mysqli_query($link, $query);
+
+    return spip_mysql_fetch($r, null, $serveur);
 }
 
 
@@ -351,35 +351,35 @@ 
  *     - array  : Tableau décrivant requête et temps d'exécution si var_profile actif pour tracer.
  */
 function spip_mysql_select(
-	$select,
-	$from,
-	$where = '',
-	$groupby = '',
-	$orderby = '',
-	$limit = '',
-	$having = '',
-	$serveur = '',
-	$requeter = true
+    $select,
+    $from,
+    $where = '',
+    $groupby = '',
+    $orderby = '',
+    $limit = '',
+    $having = '',
+    $serveur = '',
+    $requeter = true
 ) {
 
 
-	$from = (!is_array($from) ? $from : spip_mysql_select_as($from));
-	$query =
-		calculer_mysql_expression('SELECT', $select, ', ')
-		. calculer_mysql_expression('FROM', $from, ', ')
-		. calculer_mysql_expression('WHERE', $where)
-		. calculer_mysql_expression('GROUP BY', $groupby, ',')
-		. calculer_mysql_expression('HAVING', $having)
-		. ($orderby ? ("\nORDER BY " . spip_mysql_order($orderby)) : '')
-		. ($limit ? "\nLIMIT $limit" : '');
+    $from = (!is_array($from) ? $from : spip_mysql_select_as($from));
+    $query =
+        calculer_mysql_expression('SELECT', $select, ', ')
+        . calculer_mysql_expression('FROM', $from, ', ')
+        . calculer_mysql_expression('WHERE', $where)
+        . calculer_mysql_expression('GROUP BY', $groupby, ',')
+        . calculer_mysql_expression('HAVING', $having)
+        . ($orderby ? ("\nORDER BY " . spip_mysql_order($orderby)) : '')
+        . ($limit ? "\nLIMIT $limit" : '');
 
-	// renvoyer la requete inerte si demandee
-	if ($requeter === false) {
-		return $query;
-	}
-	$r = spip_mysql_query($query, $serveur, $requeter);
+    // renvoyer la requete inerte si demandee
+    if ($requeter === false) {
+        return $query;
+    }
+    $r = spip_mysql_query($query, $serveur, $requeter);
 
-	return $r ? $r : $query;
+    return $r ? $r : $query;
 }
 
 
@@ -396,7 +396,7 @@ 
  * @return string Texte du orderby préparé
  */
 function spip_mysql_order($orderby) {
-	return (is_array($orderby)) ? join(', ', $orderby) : $orderby;
+    return (is_array($orderby)) ? join(', ', $orderby) : $orderby;
 }
 
 
@@ -419,26 +419,26 @@ 
  *     Contrainte pour clause WHERE
  */
 function calculer_mysql_where($v) {
-	if (!is_array($v)) {
-		return $v;
-	}
-
-	$op = array_shift($v);
-	if (!($n = count($v))) {
-		return $op;
-	} else {
-		$arg = calculer_mysql_where(array_shift($v));
-		if ($n == 1) {
-			return "$op($arg)";
-		} else {
-			$arg2 = calculer_mysql_where(array_shift($v));
-			if ($n == 2) {
-				return "($arg $op $arg2)";
-			} else {
-				return "($arg $op ($arg2) : $v[0])";
-			}
-		}
-	}
+    if (!is_array($v)) {
+        return $v;
+    }
+
+    $op = array_shift($v);
+    if (!($n = count($v))) {
+        return $op;
+    } else {
+        $arg = calculer_mysql_where(array_shift($v));
+        if ($n == 1) {
+            return "$op($arg)";
+        } else {
+            $arg2 = calculer_mysql_where(array_shift($v));
+            if ($n == 2) {
+                return "($arg $op $arg2)";
+            } else {
+                return "($arg $op ($arg2) : $v[0])";
+            }
+        }
+    }
 }
 
 /**
@@ -453,21 +453,21 @@ 
  * @return string            Texte de l'expression, une partie donc, du texte la requête.
  */
 function calculer_mysql_expression($expression, $v, $join = 'AND') {
-	if (empty($v)) {
-		return '';
-	}
-
-	$exp = "\n$expression ";
-
-	if (!is_array($v)) {
-		return $exp . $v;
-	} else {
-		if (strtoupper($join) === 'AND') {
-			return $exp . join("\n\t$join ", array_map('calculer_mysql_where', $v));
-		} else {
-			return $exp . join($join, $v);
-		}
-	}
+    if (empty($v)) {
+        return '';
+    }
+
+    $exp = "\n$expression ";
+
+    if (!is_array($v)) {
+        return $exp . $v;
+    } else {
+        if (strtoupper($join) === 'AND') {
+            return $exp . join("\n\t$join ", array_map('calculer_mysql_where', $v));
+        } else {
+            return $exp . join($join, $v);
+        }
+    }
 }
 
 
@@ -478,26 +478,26 @@ 
  * @return string Sélection de colonnes pour une clause SELECT
  */
 function spip_mysql_select_as($args) {
-	$res = '';
-	foreach ($args as $k => $v) {
-		if (substr($k, -1) == '@') {
-			// c'est une jointure qui se refere au from precedent
-			// pas de virgule
-			$res .= '  ' . $v;
-		} else {
-			if (!is_numeric($k)) {
-				$p = strpos($v, ' ');
-				if ($p) {
-					$v = substr($v, 0, $p) . " AS `$k`" . substr($v, $p);
-				} else {
-					$v .= " AS `$k`";
-				}
-			}
-			$res .= ', ' . $v;
-		}
-	}
-
-	return substr($res, 2);
+    $res = '';
+    foreach ($args as $k => $v) {
+        if (substr($k, -1) == '@') {
+            // c'est une jointure qui se refere au from precedent
+            // pas de virgule
+            $res .= '  ' . $v;
+        } else {
+            if (!is_numeric($k)) {
+                $p = strpos($v, ' ');
+                if ($p) {
+                    $v = substr($v, 0, $p) . " AS `$k`" . substr($v, $p);
+                } else {
+                    $v .= " AS `$k`";
+                }
+            }
+            $res .= ', ' . $v;
+        }
+    }
+
+    return substr($res, 2);
 }
 
 
@@ -521,48 +521,48 @@ 
  */
 function _mysql_traite_query($query, $db = '', $prefixe = '') {
 
-	if ($GLOBALS['mysql_rappel_nom_base'] and $db) {
-		$pref = '`' . $db . '`.';
-	} else {
-		$pref = '';
-	}
-
-	if ($prefixe) {
-		$pref .= $prefixe . '_';
-	}
-
-	if (!preg_match('/\s(SET|VALUES|WHERE|DATABASE)\s/i', $query, $regs)) {
-		$suite = '';
-	} else {
-		$suite = strstr($query, $regs[0]);
-		$query = substr($query, 0, -strlen($suite));
-		// propager le prefixe en cas de requete imbriquee
-		// il faut alors echapper les chaine avant de le faire, pour ne pas risquer de
-		// modifier une requete qui est en fait juste du texte dans un champ
-		if (stripos($suite, 'SELECT') !== false) {
-			list($suite_echap, $textes) = query_echappe_textes($suite);
-			if (preg_match('/^(.*?)([(]\s*SELECT\b.*)$/si', $suite_echap, $r)) {
-				$suite_echap = $r[1] . _mysql_traite_query($r[2], $db, $prefixe);
-				$suite = query_reinjecte_textes($suite_echap, $textes);
-			}
-		}
-	}
-	$r = preg_replace(_SQL_PREFIXE_TABLE_MYSQL, '\1' . $pref, $query) . $suite;
-
-	// en option, remplacer les emoji (que mysql ne sait pas gérer) en 💩
-	// remplacer les emoji (que mysql ne sait pas gérer) en 💩
-	if (
-		defined('_MYSQL_NOPLANES')
-		and _MYSQL_NOPLANES
-		and !empty($GLOBALS['meta']['charset_sql_connexion'])
-		and $GLOBALS['meta']['charset_sql_connexion'] == 'utf8'
-	) {
-		include_spip('inc/charsets');
-		$r = utf8_noplanes($r);
-	}
-
-	#spip_log("_mysql_traite_query: " . substr($r,0, 50) . ".... $db, $prefixe", _LOG_DEBUG);
-	return $r;
+    if ($GLOBALS['mysql_rappel_nom_base'] and $db) {
+        $pref = '`' . $db . '`.';
+    } else {
+        $pref = '';
+    }
+
+    if ($prefixe) {
+        $pref .= $prefixe . '_';
+    }
+
+    if (!preg_match('/\s(SET|VALUES|WHERE|DATABASE)\s/i', $query, $regs)) {
+        $suite = '';
+    } else {
+        $suite = strstr($query, $regs[0]);
+        $query = substr($query, 0, -strlen($suite));
+        // propager le prefixe en cas de requete imbriquee
+        // il faut alors echapper les chaine avant de le faire, pour ne pas risquer de
+        // modifier une requete qui est en fait juste du texte dans un champ
+        if (stripos($suite, 'SELECT') !== false) {
+            list($suite_echap, $textes) = query_echappe_textes($suite);
+            if (preg_match('/^(.*?)([(]\s*SELECT\b.*)$/si', $suite_echap, $r)) {
+                $suite_echap = $r[1] . _mysql_traite_query($r[2], $db, $prefixe);
+                $suite = query_reinjecte_textes($suite_echap, $textes);
+            }
+        }
+    }
+    $r = preg_replace(_SQL_PREFIXE_TABLE_MYSQL, '\1' . $pref, $query) . $suite;
+
+    // en option, remplacer les emoji (que mysql ne sait pas gérer) en 💩
+    // remplacer les emoji (que mysql ne sait pas gérer) en 💩
+    if (
+        defined('_MYSQL_NOPLANES')
+        and _MYSQL_NOPLANES
+        and !empty($GLOBALS['meta']['charset_sql_connexion'])
+        and $GLOBALS['meta']['charset_sql_connexion'] == 'utf8'
+    ) {
+        include_spip('inc/charsets');
+        $r = utf8_noplanes($r);
+    }
+
+    #spip_log("_mysql_traite_query: " . substr($r,0, 50) . ".... $db, $prefixe", _LOG_DEBUG);
+    return $r;
 }
 
 /**
@@ -580,13 +580,13 @@ 
  *     - False en cas d'erreur.
  **/
 function spip_mysql_selectdb($db, $serveur = '', $requeter = true) {
-	$link = _mysql_link($serveur);
-	$ok = mysqli_select_db($link, $db);
-	if (!$ok) {
-		spip_log('Echec mysqli_selectdb. Erreur : ' . mysqli_error($link), 'mysql.' . _LOG_CRITIQUE);
-	}
+    $link = _mysql_link($serveur);
+    $ok = mysqli_select_db($link, $db);
+    if (!$ok) {
+        spip_log('Echec mysqli_selectdb. Erreur : ' . mysqli_error($link), 'mysql.' . _LOG_CRITIQUE);
+    }
 
-	return $ok;
+    return $ok;
 }
 
 
@@ -607,14 +607,14 @@ 
  *     Liste de noms de bases de données
  **/
 function spip_mysql_listdbs($serveur = '', $requeter = true) {
-	$dbs = [];
-	if ($res = spip_mysql_query('SHOW DATABASES', $serveur)) {
-		while ($row = mysqli_fetch_assoc($res)) {
-			$dbs[] = $row['Database'];
-		}
-	}
-
-	return $dbs;
+    $dbs = [];
+    if ($res = spip_mysql_query('SHOW DATABASES', $serveur)) {
+        while ($row = mysqli_fetch_assoc($res)) {
+            $dbs[] = $row['Database'];
+        }
+    }
+
+    return $dbs;
 }
 
 
@@ -637,73 +637,73 @@ 
  *     - true si la requête réussie, false sinon.
  */
 function spip_mysql_create(
-	$nom,
-	$champs,
-	$cles,
-	$autoinc = false,
-	$temporary = false,
-	$serveur = '',
-	$requeter = true
+    $nom,
+    $champs,
+    $cles,
+    $autoinc = false,
+    $temporary = false,
+    $serveur = '',
+    $requeter = true
 ) {
 
-	$query = '';
-	$keys = '';
-	$s = '';
-	$p = '';
-
-	// certains plugins declarent les tables  (permet leur inclusion dans le dump)
-	// sans les renseigner (laisse le compilo recuperer la description)
-	if (!is_array($champs) || !is_array($cles)) {
-		return;
-	}
-
-	$res = spip_mysql_query('SELECT version() as v', $serveur);
-	if (($row = mysqli_fetch_array($res)) && (version_compare($row['v'], '5.0', '>='))) {
-		spip_mysql_query("SET sql_mode=''", $serveur);
-	}
-
-	foreach ($cles as $k => $v) {
-		$keys .= "$s\n\t\t$k ($v)";
-		if ($k == 'PRIMARY KEY') {
-			$p = $v;
-		}
-		$s = ',';
-	}
-	$s = '';
-
-	$character_set = '';
-	if (@$GLOBALS['meta']['charset_sql_base']) {
-		$character_set .= ' CHARACTER SET ' . $GLOBALS['meta']['charset_sql_base'];
-	}
-	if (@$GLOBALS['meta']['charset_collation_sql_base']) {
-		$character_set .= ' COLLATE ' . $GLOBALS['meta']['charset_collation_sql_base'];
-	}
-
-	foreach ($champs as $k => $v) {
-		$v = _mysql_remplacements_definitions_table($v);
-		if (preg_match(',([a-z]*\s*(\(\s*[0-9]*\s*\))?(\s*binary)?),i', $v, $defs)) {
-			if (
-				preg_match(',(char|text),i', $defs[1])
-				and !preg_match(',(binary|CHARACTER|COLLATE),i', $v)
-			) {
-				$v = $defs[1] . $character_set . ' ' . substr($v, strlen($defs[1]));
-			}
-		}
-
-		$query .= "$s\n\t\t$k $v"
-			. (($autoinc && ($p == $k) && preg_match(',\b(big|small|medium)?int\b,i', $v))
-				? ' auto_increment'
-				: ''
-			);
-		$s = ',';
-	}
-	$temporary = $temporary ? 'TEMPORARY' : '';
-	$q = "CREATE $temporary TABLE IF NOT EXISTS $nom ($query" . ($keys ? ",$keys" : '') . ')'
-		. ' ENGINE=MyISAM'
-		. ($character_set ? " DEFAULT $character_set" : '')
-		. "\n";
-
-	return spip_mysql_query($q, $serveur);
+    $query = '';
+    $keys = '';
+    $s = '';
+    $p = '';
+
+    // certains plugins declarent les tables  (permet leur inclusion dans le dump)
+    // sans les renseigner (laisse le compilo recuperer la description)
+    if (!is_array($champs) || !is_array($cles)) {
+        return;
+    }
+
+    $res = spip_mysql_query('SELECT version() as v', $serveur);
+    if (($row = mysqli_fetch_array($res)) && (version_compare($row['v'], '5.0', '>='))) {
+        spip_mysql_query("SET sql_mode=''", $serveur);
+    }
+
+    foreach ($cles as $k => $v) {
+        $keys .= "$s\n\t\t$k ($v)";
+        if ($k == 'PRIMARY KEY') {
+            $p = $v;
+        }
+        $s = ',';
+    }
+    $s = '';
+
+    $character_set = '';
+    if (@$GLOBALS['meta']['charset_sql_base']) {
+        $character_set .= ' CHARACTER SET ' . $GLOBALS['meta']['charset_sql_base'];
+    }
+    if (@$GLOBALS['meta']['charset_collation_sql_base']) {
+        $character_set .= ' COLLATE ' . $GLOBALS['meta']['charset_collation_sql_base'];
+    }
+
+    foreach ($champs as $k => $v) {
+        $v = _mysql_remplacements_definitions_table($v);
+        if (preg_match(',([a-z]*\s*(\(\s*[0-9]*\s*\))?(\s*binary)?),i', $v, $defs)) {
+            if (
+                preg_match(',(char|text),i', $defs[1])
+                and !preg_match(',(binary|CHARACTER|COLLATE),i', $v)
+            ) {
+                $v = $defs[1] . $character_set . ' ' . substr($v, strlen($defs[1]));
+            }
+        }
+
+        $query .= "$s\n\t\t$k $v"
+            . (($autoinc && ($p == $k) && preg_match(',\b(big|small|medium)?int\b,i', $v))
+                ? ' auto_increment'
+                : ''
+            );
+        $s = ',';
+    }
+    $temporary = $temporary ? 'TEMPORARY' : '';
+    $q = "CREATE $temporary TABLE IF NOT EXISTS $nom ($query" . ($keys ? ",$keys" : '') . ')'
+        . ' ENGINE=MyISAM'
+        . ($character_set ? " DEFAULT $character_set" : '')
+        . "\n";
+
+    return spip_mysql_query($q, $serveur);
 }
 
 
@@ -716,25 +716,25 @@ 
  *     Définition SQL adaptée pour MySQL d'un champ de table
  */
 function _mysql_remplacements_definitions_table($query) {
-	// quelques remplacements
-	$num = '(\s*\([0-9]*\))?';
-	$enum = '(\s*\([^\)]*\))?';
-
-	$remplace = [
-		'/VARCHAR(\s*[^\s\(])/is' => 'VARCHAR(255)\\1',
-		'/^TIMESTAMP($| NULL DEFAULT NULL)/is' => 'TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP',
-	];
-
-	if (is_string($query)) {
-		$query = preg_replace(array_keys($remplace), $remplace, $query);
-	} elseif (is_array($query)) {
-		$keys = array_keys($remplace);
-		foreach ($query as $k => $q) {
-			$query[$k] = preg_replace($keys, $remplace, $q);
-		}
-	}
-
-	return $query;
+    // quelques remplacements
+    $num = '(\s*\([0-9]*\))?';
+    $enum = '(\s*\([^\)]*\))?';
+
+    $remplace = [
+        '/VARCHAR(\s*[^\s\(])/is' => 'VARCHAR(255)\\1',
+        '/^TIMESTAMP($| NULL DEFAULT NULL)/is' => 'TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP',
+    ];
+
+    if (is_string($query)) {
+        $query = preg_replace(array_keys($remplace), $remplace, $query);
+    } elseif (is_array($query)) {
+        $keys = array_keys($remplace);
+        foreach ($query as $k => $q) {
+            $query[$k] = preg_replace($keys, $remplace, $q);
+        }
+    }
+
+    return $query;
 }
 
 
@@ -747,7 +747,7 @@ 
  * @return bool true si la base est créee.
  **/
 function spip_mysql_create_base($nom, $serveur = '', $requeter = true) {
-	return spip_mysql_query("CREATE DATABASE `$nom`", $serveur, $requeter);
+    return spip_mysql_query("CREATE DATABASE `$nom`", $serveur, $requeter);
 }
 
 
@@ -768,19 +768,19 @@ 
  *     - string texte de la requête si $requeter vaut false
  */
 function spip_mysql_create_view($nom, $query_select, $serveur = '', $requeter = true) {
-	if (!$query_select) {
-		return false;
-	}
-	// vue deja presente
-	if (sql_showtable($nom, false, $serveur)) {
-		spip_log("Echec creation d'une vue sql ($nom) car celle-ci existe deja (serveur:$serveur)", _LOG_ERREUR);
+    if (!$query_select) {
+        return false;
+    }
+    // vue deja presente
+    if (sql_showtable($nom, false, $serveur)) {
+        spip_log("Echec creation d'une vue sql ($nom) car celle-ci existe deja (serveur:$serveur)", _LOG_ERREUR);
 
-		return false;
-	}
+        return false;
+    }
 
-	$query = "CREATE VIEW $nom AS " . $query_select;
+    $query = "CREATE VIEW $nom AS " . $query_select;
 
-	return spip_mysql_query($query, $serveur, $requeter);
+    return spip_mysql_query($query, $serveur, $requeter);
 }
 
 
@@ -796,11 +796,11 @@ 
  *     - true si la requête a réussie, false sinon
  */
 function spip_mysql_drop_table($table, $exist = '', $serveur = '', $requeter = true) {
-	if ($exist) {
-		$exist = ' IF EXISTS';
-	}
+    if ($exist) {
+        $exist = ' IF EXISTS';
+    }
 
-	return spip_mysql_query("DROP TABLE$exist $table", $serveur, $requeter);
+    return spip_mysql_query("DROP TABLE$exist $table", $serveur, $requeter);
 }
 
 /**
@@ -815,11 +815,11 @@ 
  *     - true si la requête a réussie, false sinon
  */
 function spip_mysql_drop_view($view, $exist = '', $serveur = '', $requeter = true) {
-	if ($exist) {
-		$exist = ' IF EXISTS';
-	}
+    if ($exist) {
+        $exist = ' IF EXISTS';
+    }
 
-	return spip_mysql_query("DROP VIEW$exist $view", $serveur, $requeter);
+    return spip_mysql_query("DROP VIEW$exist $view", $serveur, $requeter);
 }
 
 /**
@@ -836,7 +836,7 @@ 
  *     Ressource à utiliser avec sql_fetch()
  **/
 function spip_mysql_showbase($match, $serveur = '', $requeter = true) {
-	return spip_mysql_query('SHOW TABLES LIKE ' . _q($match), $serveur, $requeter);
+    return spip_mysql_query('SHOW TABLES LIKE ' . _q($match), $serveur, $requeter);
 }
 
 /**
@@ -852,7 +852,7 @@ 
  *     - true si la requête a réussie, false sinon
  */
 function spip_mysql_repair($table, $serveur = '', $requeter = true) {
-	return spip_mysql_query("REPAIR TABLE `$table`", $serveur, $requeter);
+    return spip_mysql_query("REPAIR TABLE `$table`", $serveur, $requeter);
 }
 
 
@@ -876,86 +876,86 @@ 
  *     - array description de la table sinon
  */
 function spip_mysql_showtable($nom_table, $serveur = '', $requeter = true) {
-	$s = spip_mysql_query("SHOW CREATE TABLE `$nom_table`", $serveur, $requeter);
-	if (!$s) {
-		return '';
-	}
-	if (!$requeter) {
-		return $s;
-	}
-
-	list(, $a) = mysqli_fetch_array($s, MYSQLI_NUM);
-	if (preg_match(_MYSQL_RE_SHOW_TABLE, $a, $r)) {
-		$desc = $r[1];
-		// extraction d'une KEY éventuelle en prenant garde de ne pas
-		// relever un champ dont le nom contient KEY (ex. ID_WHISKEY)
-		if (preg_match('/^(.*?),([^,]*\sKEY[ (].*)$/s', $desc, $r)) {
-			$namedkeys = $r[2];
-			$desc = $r[1];
-		} else {
-			$namedkeys = '';
-		}
-
-		$fields = [];
-		foreach (preg_split('/,\s*`/', $desc) as $v) {
-			preg_match('/^\s*`?([^`]*)`\s*(.*)/', $v, $r);
-			$fields[strtolower($r[1])] = $r[2];
-		}
-		$keys = [];
-
-		foreach (preg_split('/\)\s*(,|$)/', $namedkeys) as $v) {
-			if (preg_match('/^\s*([^(]*)\(([^(]*(\(\d+\))?)$/', $v, $r)) {
-				$k = str_replace('`', '', trim($r[1]));
-				$t = strtolower(str_replace('`', '', $r[2]));
-				if ($k && !isset($keys[$k])) {
-					$keys[$k] = $t;
-				} else {
-					$keys[] = $t;
-				}
-			}
-		}
-		spip_mysql_free($s);
-
-		return ['field' => $fields, 'key' => $keys];
-	}
-
-	$res = spip_mysql_query("SHOW COLUMNS FROM `$nom_table`", $serveur);
-	if ($res) {
-		$nfields = [];
-		$nkeys = [];
-		while ($val = spip_mysql_fetch($res)) {
-			$nfields[$val['Field']] = $val['Type'];
-			if ($val['Null'] == 'NO') {
-				$nfields[$val['Field']] .= ' NOT NULL';
-			}
-			if ($val['Default'] === '0' || $val['Default']) {
-				if (preg_match('/[A-Z_]/', $val['Default'])) {
-					$nfields[$val['Field']] .= ' DEFAULT ' . $val['Default'];
-				} else {
-					$nfields[$val['Field']] .= " DEFAULT '" . $val['Default'] . "'";
-				}
-			}
-			if ($val['Extra']) {
-				$nfields[$val['Field']] .= ' ' . $val['Extra'];
-			}
-			if ($val['Key'] == 'PRI') {
-				$nkeys['PRIMARY KEY'] = $val['Field'];
-			} else {
-				if ($val['Key'] == 'MUL') {
-					$nkeys['KEY ' . $val['Field']] = $val['Field'];
-				} else {
-					if ($val['Key'] == 'UNI') {
-						$nkeys['UNIQUE KEY ' . $val['Field']] = $val['Field'];
-					}
-				}
-			}
-		}
-		spip_mysql_free($res);
-
-		return ['field' => $nfields, 'key' => $nkeys];
-	}
-
-	return '';
+    $s = spip_mysql_query("SHOW CREATE TABLE `$nom_table`", $serveur, $requeter);
+    if (!$s) {
+        return '';
+    }
+    if (!$requeter) {
+        return $s;
+    }
+
+    list(, $a) = mysqli_fetch_array($s, MYSQLI_NUM);
+    if (preg_match(_MYSQL_RE_SHOW_TABLE, $a, $r)) {
+        $desc = $r[1];
+        // extraction d'une KEY éventuelle en prenant garde de ne pas
+        // relever un champ dont le nom contient KEY (ex. ID_WHISKEY)
+        if (preg_match('/^(.*?),([^,]*\sKEY[ (].*)$/s', $desc, $r)) {
+            $namedkeys = $r[2];
+            $desc = $r[1];
+        } else {
+            $namedkeys = '';
+        }
+
+        $fields = [];
+        foreach (preg_split('/,\s*`/', $desc) as $v) {
+            preg_match('/^\s*`?([^`]*)`\s*(.*)/', $v, $r);
+            $fields[strtolower($r[1])] = $r[2];
+        }
+        $keys = [];
+
+        foreach (preg_split('/\)\s*(,|$)/', $namedkeys) as $v) {
+            if (preg_match('/^\s*([^(]*)\(([^(]*(\(\d+\))?)$/', $v, $r)) {
+                $k = str_replace('`', '', trim($r[1]));
+                $t = strtolower(str_replace('`', '', $r[2]));
+                if ($k && !isset($keys[$k])) {
+                    $keys[$k] = $t;
+                } else {
+                    $keys[] = $t;
+                }
+            }
+        }
+        spip_mysql_free($s);
+
+        return ['field' => $fields, 'key' => $keys];
+    }
+
+    $res = spip_mysql_query("SHOW COLUMNS FROM `$nom_table`", $serveur);
+    if ($res) {
+        $nfields = [];
+        $nkeys = [];
+        while ($val = spip_mysql_fetch($res)) {
+            $nfields[$val['Field']] = $val['Type'];
+            if ($val['Null'] == 'NO') {
+                $nfields[$val['Field']] .= ' NOT NULL';
+            }
+            if ($val['Default'] === '0' || $val['Default']) {
+                if (preg_match('/[A-Z_]/', $val['Default'])) {
+                    $nfields[$val['Field']] .= ' DEFAULT ' . $val['Default'];
+                } else {
+                    $nfields[$val['Field']] .= " DEFAULT '" . $val['Default'] . "'";
+                }
+            }
+            if ($val['Extra']) {
+                $nfields[$val['Field']] .= ' ' . $val['Extra'];
+            }
+            if ($val['Key'] == 'PRI') {
+                $nkeys['PRIMARY KEY'] = $val['Field'];
+            } else {
+                if ($val['Key'] == 'MUL') {
+                    $nkeys['KEY ' . $val['Field']] = $val['Field'];
+                } else {
+                    if ($val['Key'] == 'UNI') {
+                        $nkeys['UNIQUE KEY ' . $val['Field']] = $val['Field'];
+                    }
+                }
+            }
+        }
+        spip_mysql_free($res);
+
+        return ['field' => $nfields, 'key' => $nkeys];
+    }
+
+    return '';
 }
 
 
@@ -971,12 +971,12 @@ 
  * @return array           Ligne de résultat
  */
 function spip_mysql_fetch($r, $t = '', $serveur = '', $requeter = true) {
-	if (!$t) {
-		$t = MYSQLI_ASSOC;
-	}
-	if ($r) {
-		return mysqli_fetch_array($r, $t);
-	}
+    if (!$t) {
+        $t = MYSQLI_ASSOC;
+    }
+    if ($r) {
+        return mysqli_fetch_array($r, $t);
+    }
 }
 
 /**
@@ -989,9 +989,9 @@ 
  * @return bool True si déplacement réussi, false sinon.
  **/
 function spip_mysql_seek($r, $row_number, $serveur = '', $requeter = true) {
-	if ($r and mysqli_num_rows($r)) {
-		return mysqli_data_seek($r, $row_number);
-	}
+    if ($r and mysqli_num_rows($r)) {
+        return mysqli_data_seek($r, $row_number);
+    }
 }
 
 
@@ -1009,26 +1009,26 @@ 
  *     - int Nombre de lignes (0 si la requête n'a pas réussie)
  **/
 function spip_mysql_countsel(
-	$from = [],
-	$where = [],
-	$groupby = '',
-	$having = [],
-	$serveur = '',
-	$requeter = true
+    $from = [],
+    $where = [],
+    $groupby = '',
+    $having = [],
+    $serveur = '',
+    $requeter = true
 ) {
-	$c = !$groupby ? '*' : ('DISTINCT ' . (is_string($groupby) ? $groupby : join(',', $groupby)));
-
-	$r = spip_mysql_select("COUNT($c)", $from, $where, '', '', '', $having, $serveur, $requeter);
-	if (!$requeter) {
-		return $r;
-	}
-	if (!$r instanceof mysqli_result) {
-		return 0;
-	}
-	list($c) = mysqli_fetch_array($r, MYSQLI_NUM);
-	mysqli_free_result($r);
-
-	return $c;
+    $c = !$groupby ? '*' : ('DISTINCT ' . (is_string($groupby) ? $groupby : join(',', $groupby)));
+
+    $r = spip_mysql_select("COUNT($c)", $from, $where, '', '', '', $having, $serveur, $requeter);
+    if (!$requeter) {
+        return $r;
+    }
+    if (!$r instanceof mysqli_result) {
+        return 0;
+    }
+    list($c) = mysqli_fetch_array($r, MYSQLI_NUM);
+    mysqli_free_result($r);
+
+    return $c;
 }
 
 
@@ -1051,16 +1051,16 @@ 
  *     Erreur eventuelle
  **/
 function spip_mysql_error($query = '', $serveur = '', $requeter = true) {
-	$link = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0]['link'];
-	$s = mysqli_error($link);
-	if ($s) {
-		$trace = debug_backtrace();
-		if ($trace[0]['function'] != 'spip_mysql_error') {
-			spip_log("$s - $query - " . sql_error_backtrace(), 'mysql.' . _LOG_ERREUR);
-		}
-	}
-
-	return $s;
+    $link = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0]['link'];
+    $s = mysqli_error($link);
+    if ($s) {
+        $trace = debug_backtrace();
+        if ($trace[0]['function'] != 'spip_mysql_error') {
+            spip_log("$s - $query - " . sql_error_backtrace(), 'mysql.' . _LOG_ERREUR);
+        }
+    }
+
+    return $s;
 }
 
 
@@ -1075,18 +1075,18 @@ 
  *     0, pas d'erreur. Autre, numéro de l'erreur.
  **/
 function spip_mysql_errno($serveur = '', $requeter = true) {
-	$link = $GLOBALS['connexions'][$serveur ? $serveur : 0]['link'];
-	$s = mysqli_errno($link);
-	// 2006 MySQL server has gone away
-	// 2013 Lost connection to MySQL server during query
-	if (in_array($s, [2006, 2013])) {
-		define('spip_interdire_cache', true);
-	}
-	if ($s) {
-		spip_log("Erreur mysql $s", _LOG_ERREUR);
-	}
-
-	return $s;
+    $link = $GLOBALS['connexions'][$serveur ? $serveur : 0]['link'];
+    $s = mysqli_errno($link);
+    // 2006 MySQL server has gone away
+    // 2013 Lost connection to MySQL server during query
+    if (in_array($s, [2006, 2013])) {
+        define('spip_interdire_cache', true);
+    }
+    if ($s) {
+        spip_log("Erreur mysql $s", _LOG_ERREUR);
+    }
+
+    return $s;
 }
 
 
@@ -1100,9 +1100,9 @@ 
  * @return int               Nombre de lignes
  */
 function spip_mysql_count($r, $serveur = '', $requeter = true) {
-	if ($r) {
-		return mysqli_num_rows($r);
-	}
+    if ($r) {
+        return mysqli_num_rows($r);
+    }
 }
 
 
@@ -1118,7 +1118,7 @@ 
  * @return bool              True si réussi
  */
 function spip_mysql_free($r, $serveur = '', $requeter = true) {
-	return (($r instanceof mysqli_result) ? mysqli_free_result($r) : false);
+    return (($r instanceof mysqli_result) ? mysqli_free_result($r) : false);
 }
 
 
@@ -1146,49 +1146,49 @@ 
  **/
 function spip_mysql_insert($table, $champs, $valeurs, $desc = [], $serveur = '', $requeter = true) {
 
-	$connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-	$link = $connexion['link'];
-	$table = prefixer_table_spip($table, $connexion['prefixe']);
-
-	// remplacer les emoji (que mysql ne sait pas gérer) en 💩
-	if (
-		defined('_MYSQL_NOPLANES')
-		and _MYSQL_NOPLANES
-		and !empty($GLOBALS['meta']['charset_sql_connexion'])
-		and $GLOBALS['meta']['charset_sql_connexion'] == 'utf8'
-	) {
-		include_spip('inc/charsets');
-		$valeurs = utf8_noplanes($valeurs);
-	}
-
-	$query = "INSERT INTO $table $champs VALUES $valeurs";
-	if (!$requeter) {
-		return $query;
-	}
-
-	if (isset($_GET['var_profile'])) {
-		include_spip('public/tracer');
-		$t = trace_query_start();
-		$e = '';
-	} else {
-		$t = 0;
-	}
-
-	$connexion['last'] = $query;
-	#spip_log($query, 'mysql.'._LOG_DEBUG);
-	$r = false;
-	if (mysqli_query($link, $query)) {
-		$r = mysqli_insert_id($link);
-	} else {
-		// Log de l'erreur eventuelle
-		if ($e = spip_mysql_errno($serveur)) {
-			$e .= spip_mysql_error($query, $serveur);
-		} // et du fautif
-	}
-
-	return $t ? trace_query_end($query, $t, $r, $e, $serveur) : $r;
-
-	// return $r ? $r : (($r===0) ? -1 : 0); pb avec le multi-base.
+    $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+    $link = $connexion['link'];
+    $table = prefixer_table_spip($table, $connexion['prefixe']);
+
+    // remplacer les emoji (que mysql ne sait pas gérer) en 💩
+    if (
+        defined('_MYSQL_NOPLANES')
+        and _MYSQL_NOPLANES
+        and !empty($GLOBALS['meta']['charset_sql_connexion'])
+        and $GLOBALS['meta']['charset_sql_connexion'] == 'utf8'
+    ) {
+        include_spip('inc/charsets');
+        $valeurs = utf8_noplanes($valeurs);
+    }
+
+    $query = "INSERT INTO $table $champs VALUES $valeurs";
+    if (!$requeter) {
+        return $query;
+    }
+
+    if (isset($_GET['var_profile'])) {
+        include_spip('public/tracer');
+        $t = trace_query_start();
+        $e = '';
+    } else {
+        $t = 0;
+    }
+
+    $connexion['last'] = $query;
+    #spip_log($query, 'mysql.'._LOG_DEBUG);
+    $r = false;
+    if (mysqli_query($link, $query)) {
+        $r = mysqli_insert_id($link);
+    } else {
+        // Log de l'erreur eventuelle
+        if ($e = spip_mysql_errno($serveur)) {
+            $e .= spip_mysql_error($query, $serveur);
+        } // et du fautif
+    }
+
+    return $t ? trace_query_end($query, $t, $r, $e, $serveur) : $r;
+
+    // return $r ? $r : (($r===0) ? -1 : 0); pb avec le multi-base.
 }
 
 /**
@@ -1213,26 +1213,26 @@ 
  **/
 function spip_mysql_insertq($table, $couples = [], $desc = [], $serveur = '', $requeter = true) {
 
-	if (!$desc) {
-		$desc = description_table($table, $serveur);
-	}
-	if (!$desc) {
-		$couples = [];
-	}
-	$fields = isset($desc['field']) ? $desc['field'] : [];
-
-	foreach ($couples as $champ => $val) {
-		$couples[$champ] = spip_mysql_cite($val, $fields[$champ]);
-	}
-
-	return spip_mysql_insert(
-		$table,
-		'(' . join(',', array_keys($couples)) . ')',
-		'(' . join(',', $couples) . ')',
-		$desc,
-		$serveur,
-		$requeter
-	);
+    if (!$desc) {
+        $desc = description_table($table, $serveur);
+    }
+    if (!$desc) {
+        $couples = [];
+    }
+    $fields = isset($desc['field']) ? $desc['field'] : [];
+
+    foreach ($couples as $champ => $val) {
+        $couples[$champ] = spip_mysql_cite($val, $fields[$champ]);
+    }
+
+    return spip_mysql_insert(
+        $table,
+        '(' . join(',', array_keys($couples)) . ')',
+        '(' . join(',', $couples) . ')',
+        $desc,
+        $serveur,
+        $requeter
+    );
 }
 
 
@@ -1257,34 +1257,34 @@ 
  **/
 function spip_mysql_insertq_multi($table, $tab_couples = [], $desc = [], $serveur = '', $requeter = true) {
 
-	if (!$desc) {
-		$desc = description_table($table, $serveur);
-	}
-	if (!$desc) {
-		$tab_couples = [];
-	}
-	$fields = isset($desc['field']) ? $desc['field'] : [];
-
-	$cles = '(' . join(',', array_keys(reset($tab_couples))) . ')';
-	$valeurs = [];
-	$r = false;
-
-	// Quoter et Inserer par groupes de 100 max pour eviter un debordement de pile
-	foreach ($tab_couples as $couples) {
-		foreach ($couples as $champ => $val) {
-			$couples[$champ] = spip_mysql_cite($val, $fields[$champ]);
-		}
-		$valeurs[] = '(' . join(',', $couples) . ')';
-		if (count($valeurs) >= 100) {
-			$r = spip_mysql_insert($table, $cles, join(', ', $valeurs), $desc, $serveur, $requeter);
-			$valeurs = [];
-		}
-	}
-	if (count($valeurs)) {
-		$r = spip_mysql_insert($table, $cles, join(', ', $valeurs), $desc, $serveur, $requeter);
-	}
-
-	return $r; // dans le cas d'une table auto_increment, le dernier insert_id
+    if (!$desc) {
+        $desc = description_table($table, $serveur);
+    }
+    if (!$desc) {
+        $tab_couples = [];
+    }
+    $fields = isset($desc['field']) ? $desc['field'] : [];
+
+    $cles = '(' . join(',', array_keys(reset($tab_couples))) . ')';
+    $valeurs = [];
+    $r = false;
+
+    // Quoter et Inserer par groupes de 100 max pour eviter un debordement de pile
+    foreach ($tab_couples as $couples) {
+        foreach ($couples as $champ => $val) {
+            $couples[$champ] = spip_mysql_cite($val, $fields[$champ]);
+        }
+        $valeurs[] = '(' . join(',', $couples) . ')';
+        if (count($valeurs) >= 100) {
+            $r = spip_mysql_insert($table, $cles, join(', ', $valeurs), $desc, $serveur, $requeter);
+            $valeurs = [];
+        }
+    }
+    if (count($valeurs)) {
+        $r = spip_mysql_insert($table, $cles, join(', ', $valeurs), $desc, $serveur, $requeter);
+    }
+
+    return $r; // dans le cas d'une table auto_increment, le dernier insert_id
 }
 
 /**
@@ -1309,19 +1309,19 @@ 
  *     - array Tableau décrivant la requête et son temps d'exécution si var_profile est actif
  */
 function spip_mysql_update($table, $champs, $where = '', $desc = [], $serveur = '', $requeter = true) {
-	$set = [];
-	foreach ($champs as $champ => $val) {
-		$set[] = $champ . "=$val";
-	}
-	if (!empty($set)) {
-		return spip_mysql_query(
-			calculer_mysql_expression('UPDATE', $table, ',')
-			. calculer_mysql_expression('SET', $set, ',')
-			. calculer_mysql_expression('WHERE', $where),
-			$serveur,
-			$requeter
-		);
-	}
+    $set = [];
+    foreach ($champs as $champ => $val) {
+        $set[] = $champ . "=$val";
+    }
+    if (!empty($set)) {
+        return spip_mysql_query(
+            calculer_mysql_expression('UPDATE', $table, ',')
+            . calculer_mysql_expression('SET', $set, ',')
+            . calculer_mysql_expression('WHERE', $where),
+            $serveur,
+            $requeter
+        );
+    }
 }
 
 /**
@@ -1354,29 +1354,29 @@ 
  */
 function spip_mysql_updateq($table, $champs, $where = '', $desc = [], $serveur = '', $requeter = true) {
 
-	if (!$champs) {
-		return;
-	}
-	if (!$desc) {
-		$desc = description_table($table, $serveur);
-	}
-	if (!$desc) {
-		$champs = [];
-	} else {
-		$fields = $desc['field'];
-	}
-	$set = [];
-	foreach ($champs as $champ => $val) {
-		$set[] = $champ . '=' . spip_mysql_cite($val, @$fields[$champ]);
-	}
-
-	return spip_mysql_query(
-		calculer_mysql_expression('UPDATE', $table, ',')
-		. calculer_mysql_expression('SET', $set, ',')
-		. calculer_mysql_expression('WHERE', $where),
-		$serveur,
-		$requeter
-	);
+    if (!$champs) {
+        return;
+    }
+    if (!$desc) {
+        $desc = description_table($table, $serveur);
+    }
+    if (!$desc) {
+        $champs = [];
+    } else {
+        $fields = $desc['field'];
+    }
+    $set = [];
+    foreach ($champs as $champ => $val) {
+        $set[] = $champ . '=' . spip_mysql_cite($val, @$fields[$champ]);
+    }
+
+    return spip_mysql_query(
+        calculer_mysql_expression('UPDATE', $table, ',')
+        . calculer_mysql_expression('SET', $set, ',')
+        . calculer_mysql_expression('WHERE', $where),
+        $serveur,
+        $requeter
+    );
 }
 
 /**
@@ -1392,22 +1392,22 @@ 
  *     - False en cas d'erreur.
  **/
 function spip_mysql_delete($table, $where = '', $serveur = '', $requeter = true) {
-	$res = spip_mysql_query(
-		calculer_mysql_expression('DELETE FROM', $table, ',')
-		. calculer_mysql_expression('WHERE', $where),
-		$serveur,
-		$requeter
-	);
-	if (!$requeter) {
-		return $res;
-	}
-	if ($res) {
-		$link = _mysql_link($serveur);
-
-		return mysqli_affected_rows($link);
-	} else {
-		return false;
-	}
+    $res = spip_mysql_query(
+        calculer_mysql_expression('DELETE FROM', $table, ',')
+        . calculer_mysql_expression('WHERE', $where),
+        $serveur,
+        $requeter
+    );
+    if (!$requeter) {
+        return $res;
+    }
+    if ($res) {
+        $link = _mysql_link($serveur);
+
+        return mysqli_affected_rows($link);
+    } else {
+        return false;
+    }
 }
 
 
@@ -1436,10 +1436,10 @@ 
  *     - False en cas d'erreur.
  **/
 function spip_mysql_replace($table, $couples, $desc = [], $serveur = '', $requeter = true) {
-	return spip_mysql_query("REPLACE $table (" . join(',', array_keys($couples)) . ') VALUES (' . join(
-		',',
-		array_map('_q', $couples)
-	) . ')', $serveur, $requeter);
+    return spip_mysql_query("REPLACE $table (" . join(',', array_keys($couples)) . ') VALUES (' . join(
+        ',',
+        array_map('_q', $couples)
+    ) . ')', $serveur, $requeter);
 }
 
 
@@ -1468,14 +1468,14 @@ 
  *     - False en cas d'erreur.
  **/
 function spip_mysql_replace_multi($table, $tab_couples, $desc = [], $serveur = '', $requeter = true) {
-	$cles = '(' . join(',', array_keys($tab_couples[0])) . ')';
-	$valeurs = [];
-	foreach ($tab_couples as $couples) {
-		$valeurs[] = '(' . join(',', array_map('_q', $couples)) . ')';
-	}
-	$valeurs = implode(', ', $valeurs);
-
-	return spip_mysql_query("REPLACE $table $cles VALUES $valeurs", $serveur, $requeter);
+    $cles = '(' . join(',', array_keys($tab_couples[0])) . ')';
+    $valeurs = [];
+    foreach ($tab_couples as $couples) {
+        $valeurs[] = '(' . join(',', array_map('_q', $couples)) . ')';
+    }
+    $valeurs = implode(', ', $valeurs);
+
+    return spip_mysql_query("REPLACE $table $cles VALUES $valeurs", $serveur, $requeter);
 }
 
 
@@ -1490,32 +1490,32 @@ 
  * @return string       Texte de sélection pour la requête
  */
 function spip_mysql_multi($objet, $lang) {
-	$lengthlang = strlen("[$lang]");
-	$posmulti = 'INSTR(' . $objet . ", '<multi>')";
-	$posfinmulti = 'INSTR(' . $objet . ", '</multi>')";
-	$debutchaine = 'LEFT(' . $objet . ", $posmulti-1)";
-	$finchaine = 'RIGHT(' . $objet . ', CHAR_LENGTH(' . $objet . ") -(7+$posfinmulti))";
-	$chainemulti = 'TRIM(SUBSTRING(' . $objet . ", $posmulti+7, $posfinmulti -(7+$posmulti)))";
-	$poslang = "INSTR($chainemulti,'[" . $lang . "]')";
-	$poslang = "IF($poslang=0,INSTR($chainemulti,']')+1,$poslang+$lengthlang)";
-	$chainelang = 'TRIM(SUBSTRING(' . $objet . ", $posmulti+7+$poslang-1,$posfinmulti -($posmulti+7+$poslang-1) ))";
-	$posfinlang = 'INSTR(' . $chainelang . ", '[')";
-	$chainelang = "IF($posfinlang>0,LEFT($chainelang,$posfinlang-1),$chainelang)";
-	//$chainelang = "LEFT($chainelang,$posfinlang-1)";
-	$retour = "(TRIM(IF($posmulti = 0 , " .
-		'     TRIM(' . $objet . '), ' .
-		'     CONCAT( ' .
-		"          $debutchaine, " .
-		'          IF( ' .
-		"               $poslang = 0, " .
-		"                     $chainemulti, " .
-		"               $chainelang" .
-		'          ), ' .
-		"          $finchaine" .
-		'     ) ' .
-		'))) AS multi';
-
-	return $retour;
+    $lengthlang = strlen("[$lang]");
+    $posmulti = 'INSTR(' . $objet . ", '<multi>')";
+    $posfinmulti = 'INSTR(' . $objet . ", '</multi>')";
+    $debutchaine = 'LEFT(' . $objet . ", $posmulti-1)";
+    $finchaine = 'RIGHT(' . $objet . ', CHAR_LENGTH(' . $objet . ") -(7+$posfinmulti))";
+    $chainemulti = 'TRIM(SUBSTRING(' . $objet . ", $posmulti+7, $posfinmulti -(7+$posmulti)))";
+    $poslang = "INSTR($chainemulti,'[" . $lang . "]')";
+    $poslang = "IF($poslang=0,INSTR($chainemulti,']')+1,$poslang+$lengthlang)";
+    $chainelang = 'TRIM(SUBSTRING(' . $objet . ", $posmulti+7+$poslang-1,$posfinmulti -($posmulti+7+$poslang-1) ))";
+    $posfinlang = 'INSTR(' . $chainelang . ", '[')";
+    $chainelang = "IF($posfinlang>0,LEFT($chainelang,$posfinlang-1),$chainelang)";
+    //$chainelang = "LEFT($chainelang,$posfinlang-1)";
+    $retour = "(TRIM(IF($posmulti = 0 , " .
+        '     TRIM(' . $objet . '), ' .
+        '     CONCAT( ' .
+        "          $debutchaine, " .
+        '          IF( ' .
+        "               $poslang = 0, " .
+        "                     $chainemulti, " .
+        "               $chainelang" .
+        '          ), ' .
+        "          $finchaine" .
+        '     ) ' .
+        '))) AS multi';
+
+    return $retour;
 }
 
 /**
@@ -1529,7 +1529,7 @@ 
  *     Valeur hexadécimale pour MySQL
  **/
 function spip_mysql_hex($v) {
-	return '0x' . $v;
+    return '0x' . $v;
 }
 
 /**
@@ -1545,15 +1545,15 @@ 
  *    Donnée prête à être utilisée par le gestionnaire SQL
  */
 function spip_mysql_quote($v, $type = '') {
-	if (!is_array($v)) {
-		return spip_mysql_cite($v, $type);
-	}
-
-	// si c'est un tableau, le parcourir en propageant le type
-	foreach ($v as $k => $r) {
-		$v[$k] = spip_mysql_quote($r, $type);
-	}
-	return implode(',', $v);
+    if (!is_array($v)) {
+        return spip_mysql_cite($v, $type);
+    }
+
+    // si c'est un tableau, le parcourir en propageant le type
+    foreach ($v as $k => $r) {
+        $v[$k] = spip_mysql_quote($r, $type);
+    }
+    return implode(',', $v);
 }
 
 /**
@@ -1569,18 +1569,18 @@ 
  *     Expression SQL
  **/
 function spip_mysql_date_proche($champ, $interval, $unite) {
-	$use_now = ( ($champ === 'maj' or strpos($champ, '.maj')) ? true : false );
-	return '('
-	. $champ
-	. (($interval <= 0) ? '>' : '<')
-	. (($interval <= 0) ? 'DATE_SUB' : 'DATE_ADD')
-	. '('
-	. ($use_now ? 'NOW()' : sql_quote(date('Y-m-d H:i:s')))
-	. ', INTERVAL '
-	. (($interval > 0) ? $interval : (0 - $interval))
-	. ' '
-	. $unite
-	. '))';
+    $use_now = ( ($champ === 'maj' or strpos($champ, '.maj')) ? true : false );
+    return '('
+    . $champ
+    . (($interval <= 0) ? '>' : '<')
+    . (($interval <= 0) ? 'DATE_SUB' : 'DATE_ADD')
+    . '('
+    . ($use_now ? 'NOW()' : sql_quote(date('Y-m-d H:i:s')))
+    . ', INTERVAL '
+    . (($interval > 0) ? $interval : (0 - $interval))
+    . ' '
+    . $unite
+    . '))';
 }
 
 
@@ -1604,7 +1604,7 @@ 
  *     Expression de requête SQL
  **/
 function spip_mysql_in($val, $valeurs, $not = '', $serveur = '', $requeter = true) {
-	return "($val $not IN ($valeurs))";
+    return "($val $not IN ($valeurs))";
 }
 
 
@@ -1616,38 +1616,38 @@ 
  * @return string|number     Texte ou nombre échappé
  */
 function spip_mysql_cite($v, $type) {
-	if (!$type) {
-		if (is_bool($v)) {
-			return strval(intval($v));
-		}
-		elseif (is_numeric($v)) {
-			return strval($v);
-		}
-		return "'" . addslashes($v) . "'";
-	}
-
-	if (
-		is_null($v)
-		and stripos($type, 'NOT NULL') === false
-	) {
-		return 'NULL';
-	} // null php se traduit en NULL SQL
-	if (sql_test_date($type) and preg_match('/^\w+\(/', $v)) {
-		return $v;
-	}
-	if (sql_test_int($type)) {
-		if (
-			is_numeric($v) or (ctype_xdigit(substr($v, 2))
-				and $v[0] == '0' and $v[1] == 'x')
-		) {
-			return $v;
-		} // si pas numerique, forcer le intval
-		else {
-			return intval($v);
-		}
-	}
-
-	return ("'" . addslashes($v) . "'");
+    if (!$type) {
+        if (is_bool($v)) {
+            return strval(intval($v));
+        }
+        elseif (is_numeric($v)) {
+            return strval($v);
+        }
+        return "'" . addslashes($v) . "'";
+    }
+
+    if (
+        is_null($v)
+        and stripos($type, 'NOT NULL') === false
+    ) {
+        return 'NULL';
+    } // null php se traduit en NULL SQL
+    if (sql_test_date($type) and preg_match('/^\w+\(/', $v)) {
+        return $v;
+    }
+    if (sql_test_int($type)) {
+        if (
+            is_numeric($v) or (ctype_xdigit(substr($v, 2))
+                and $v[0] == '0' and $v[1] == 'x')
+        ) {
+            return $v;
+        } // si pas numerique, forcer le intval
+        else {
+            return intval($v);
+        }
+    }
+
+    return ("'" . addslashes($v) . "'");
 }
 
 /**
@@ -1657,7 +1657,7 @@ 
  *     True si on a les fonctions, false sinon
  */
 function spip_versions_mysql() {
-	return function_exists('mysqli_query');
+    return function_exists('mysqli_query');
 }
 
 
@@ -1670,20 +1670,20 @@ 
  *     - chaîne : code compilé pour le faire désactiver par SPIP sinon
  */
 function test_rappel_nom_base_mysql($server_db) {
-	$GLOBALS['mysql_rappel_nom_base'] = true;
-	sql_delete('spip_meta', "nom='mysql_rappel_nom_base'", $server_db);
-	$ok = spip_query("INSERT INTO spip_meta (nom,valeur) VALUES ('mysql_rappel_nom_base', 'test')", $server_db);
+    $GLOBALS['mysql_rappel_nom_base'] = true;
+    sql_delete('spip_meta', "nom='mysql_rappel_nom_base'", $server_db);
+    $ok = spip_query("INSERT INTO spip_meta (nom,valeur) VALUES ('mysql_rappel_nom_base', 'test')", $server_db);
 
-	if ($ok) {
-		sql_delete('spip_meta', "nom='mysql_rappel_nom_base'", $server_db);
+    if ($ok) {
+        sql_delete('spip_meta', "nom='mysql_rappel_nom_base'", $server_db);
 
-		return '';
-	} else {
-		$GLOBALS['mysql_rappel_nom_base'] = false;
+        return '';
+    } else {
+        $GLOBALS['mysql_rappel_nom_base'] = false;
 
-		return "\$GLOBALS['mysql_rappel_nom_base'] = false; " .
-		"/* echec de test_rappel_nom_base_mysql a l'installation. */\n";
-	}
+        return "\$GLOBALS['mysql_rappel_nom_base'] = false; " .
+        "/* echec de test_rappel_nom_base_mysql a l'installation. */\n";
+    }
 }
 
 /**
@@ -1697,13 +1697,13 @@ 
  *     - chaîne : code compilé pour l'indiquer le résultat du test à SPIP
  */
 function test_sql_mode_mysql($server_db) {
-	$res = sql_select('version() as v', '', '', '', '', '', '', $server_db);
-	$row = sql_fetch($res, $server_db);
-	if (version_compare($row['v'], '5.0.0', '>=')) {
-		defined('_MYSQL_SET_SQL_MODE') || define('_MYSQL_SET_SQL_MODE', true);
+    $res = sql_select('version() as v', '', '', '', '', '', '', $server_db);
+    $row = sql_fetch($res, $server_db);
+    if (version_compare($row['v'], '5.0.0', '>=')) {
+        defined('_MYSQL_SET_SQL_MODE') || define('_MYSQL_SET_SQL_MODE', true);
 
-		return "defined('_MYSQL_SET_SQL_MODE') || define('_MYSQL_SET_SQL_MODE',true);\n";
-	}
+        return "defined('_MYSQL_SET_SQL_MODE') || define('_MYSQL_SET_SQL_MODE',true);\n";
+    }
 
-	return '';
+    return '';
 }

ecrire/base/connect_sql.php

Indentation +294 added lines, -294 removed lines

@@ -16,7 +16,7 @@ 
  * @package SPIP\Core\SQL
  **/
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 require_once _ROOT_RESTREINT . 'base/objets.php';
 
@@ -42,119 +42,119 @@ 
  **/
 function spip_connect($serveur = '', $version = '') {
 
-	$serveur = !is_string($serveur) ? '' : strtolower($serveur);
-	$index = $serveur ? $serveur : 0;
-	if (!$version) {
-		$version = $GLOBALS['spip_sql_version'];
-	}
-	if (isset($GLOBALS['connexions'][$index][$version])) {
-		return $GLOBALS['connexions'][$index];
-	}
-
-	include_spip('base/abstract_sql');
-	$install = (_request('exec') == 'install');
-
-	// Premiere connexion ?
-	if (!($old = isset($GLOBALS['connexions'][$index]))) {
-		$f = (!preg_match('/^[\w\.]*$/', $serveur))
-			? '' // nom de serveur mal ecrit
-			: ($serveur ?
-				(_DIR_CONNECT . $serveur . '.php') // serveur externe
-				: (_FILE_CONNECT ? _FILE_CONNECT // serveur principal ok
-					: ($install ? _FILE_CONNECT_TMP // init du serveur principal
-						: ''))); // installation pas faite
-
-		unset($GLOBALS['db_ok']);
-		unset($GLOBALS['spip_connect_version']);
-		if ($f) {
-			if (is_readable($f)) {
-				include($f);
-			} elseif ($serveur and !$install) {
-				// chercher une declaration de serveur dans le path
-				// qui pourra un jour servir a declarer des bases sqlite
-				// par des plugins. Et sert aussi aux boucles POUR.
-				find_in_path("$serveur.php", 'connect/', true);
-			}
-		}
-		if (!isset($GLOBALS['db_ok'])) {
-			// fera mieux la prochaine fois
-			if ($install) {
-				return false;
-			}
-			if ($f and is_readable($f)) {
-				spip_log("spip_connect: fichier de connexion '$f' OK.", _LOG_INFO_IMPORTANTE);
-			} else {
-				spip_log("spip_connect: fichier de connexion '$f' non trouve", _LOG_INFO_IMPORTANTE);
-			}
-			spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.", _LOG_HS);
-
-			// ne plus reessayer si ce n'est pas l'install
-			return $GLOBALS['connexions'][$index] = false;
-		}
-		$GLOBALS['connexions'][$index] = $GLOBALS['db_ok'];
-	}
-	// si la connexion a deja ete tentee mais a echoue, le dire!
-	if (!$GLOBALS['connexions'][$index]) {
-		return false;
-	}
-
-	// la connexion a reussi ou etait deja faite.
-	// chargement de la version du jeu de fonctions
-	// si pas dans le fichier par defaut
-	$type = $GLOBALS['db_ok']['type'];
-	$jeu = 'spip_' . $type . '_functions_' . $version;
-	if (!isset($GLOBALS[$jeu])) {
-		if (!find_in_path($type . '_' . $version . '.php', 'req/', true)) {
-			spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS);
-
-			// ne plus reessayer
-			return $GLOBALS['connexions'][$index][$version] = [];
-		}
-	}
-	$GLOBALS['connexions'][$index][$version] = $GLOBALS[$jeu];
-	if ($old) {
-		return $GLOBALS['connexions'][$index];
-	}
-
-	$GLOBALS['connexions'][$index]['spip_connect_version'] = isset($GLOBALS['spip_connect_version']) ? $GLOBALS['spip_connect_version'] : 0;
-
-	// initialisation de l'alphabet utilise dans les connexions SQL
-	// si l'installation l'a determine.
-	// Celui du serveur principal l'impose aux serveurs secondaires
-	// s'ils le connaissent
-
-	if (!$serveur) {
-		$charset = spip_connect_main($GLOBALS[$jeu], $GLOBALS['db_ok']['charset']);
-		if (!$charset) {
-			unset($GLOBALS['connexions'][$index]);
-			spip_log('spip_connect: absence de charset', _LOG_AVERTISSEMENT);
-
-			return false;
-		}
-	} else {
-		if ($GLOBALS['db_ok']['charset']) {
-			$charset = $GLOBALS['db_ok']['charset'];
-		}
-		// spip_meta n'existe pas toujours dans la base
-		// C'est le cas d'un dump sqlite par exemple
-		elseif (
-			$GLOBALS['connexions'][$index]['spip_connect_version']
-			and sql_showtable('spip_meta', true, $serveur)
-			and $r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'", '', '', '', '', $serveur)
-		) {
-			$charset = $r;
-		} else {
-			$charset = -1;
-		}
-	}
-	if ($charset != -1) {
-		$f = $GLOBALS[$jeu]['set_charset'];
-		if (function_exists($f)) {
-			$f($charset, $serveur);
-		}
-	}
-
-	return $GLOBALS['connexions'][$index];
+    $serveur = !is_string($serveur) ? '' : strtolower($serveur);
+    $index = $serveur ? $serveur : 0;
+    if (!$version) {
+        $version = $GLOBALS['spip_sql_version'];
+    }
+    if (isset($GLOBALS['connexions'][$index][$version])) {
+        return $GLOBALS['connexions'][$index];
+    }
+
+    include_spip('base/abstract_sql');
+    $install = (_request('exec') == 'install');
+
+    // Premiere connexion ?
+    if (!($old = isset($GLOBALS['connexions'][$index]))) {
+        $f = (!preg_match('/^[\w\.]*$/', $serveur))
+            ? '' // nom de serveur mal ecrit
+            : ($serveur ?
+                (_DIR_CONNECT . $serveur . '.php') // serveur externe
+                : (_FILE_CONNECT ? _FILE_CONNECT // serveur principal ok
+                    : ($install ? _FILE_CONNECT_TMP // init du serveur principal
+                        : ''))); // installation pas faite
+
+        unset($GLOBALS['db_ok']);
+        unset($GLOBALS['spip_connect_version']);
+        if ($f) {
+            if (is_readable($f)) {
+                include($f);
+            } elseif ($serveur and !$install) {
+                // chercher une declaration de serveur dans le path
+                // qui pourra un jour servir a declarer des bases sqlite
+                // par des plugins. Et sert aussi aux boucles POUR.
+                find_in_path("$serveur.php", 'connect/', true);
+            }
+        }
+        if (!isset($GLOBALS['db_ok'])) {
+            // fera mieux la prochaine fois
+            if ($install) {
+                return false;
+            }
+            if ($f and is_readable($f)) {
+                spip_log("spip_connect: fichier de connexion '$f' OK.", _LOG_INFO_IMPORTANTE);
+            } else {
+                spip_log("spip_connect: fichier de connexion '$f' non trouve", _LOG_INFO_IMPORTANTE);
+            }
+            spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.", _LOG_HS);
+
+            // ne plus reessayer si ce n'est pas l'install
+            return $GLOBALS['connexions'][$index] = false;
+        }
+        $GLOBALS['connexions'][$index] = $GLOBALS['db_ok'];
+    }
+    // si la connexion a deja ete tentee mais a echoue, le dire!
+    if (!$GLOBALS['connexions'][$index]) {
+        return false;
+    }
+
+    // la connexion a reussi ou etait deja faite.
+    // chargement de la version du jeu de fonctions
+    // si pas dans le fichier par defaut
+    $type = $GLOBALS['db_ok']['type'];
+    $jeu = 'spip_' . $type . '_functions_' . $version;
+    if (!isset($GLOBALS[$jeu])) {
+        if (!find_in_path($type . '_' . $version . '.php', 'req/', true)) {
+            spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS);
+
+            // ne plus reessayer
+            return $GLOBALS['connexions'][$index][$version] = [];
+        }
+    }
+    $GLOBALS['connexions'][$index][$version] = $GLOBALS[$jeu];
+    if ($old) {
+        return $GLOBALS['connexions'][$index];
+    }
+
+    $GLOBALS['connexions'][$index]['spip_connect_version'] = isset($GLOBALS['spip_connect_version']) ? $GLOBALS['spip_connect_version'] : 0;
+
+    // initialisation de l'alphabet utilise dans les connexions SQL
+    // si l'installation l'a determine.
+    // Celui du serveur principal l'impose aux serveurs secondaires
+    // s'ils le connaissent
+
+    if (!$serveur) {
+        $charset = spip_connect_main($GLOBALS[$jeu], $GLOBALS['db_ok']['charset']);
+        if (!$charset) {
+            unset($GLOBALS['connexions'][$index]);
+            spip_log('spip_connect: absence de charset', _LOG_AVERTISSEMENT);
+
+            return false;
+        }
+    } else {
+        if ($GLOBALS['db_ok']['charset']) {
+            $charset = $GLOBALS['db_ok']['charset'];
+        }
+        // spip_meta n'existe pas toujours dans la base
+        // C'est le cas d'un dump sqlite par exemple
+        elseif (
+            $GLOBALS['connexions'][$index]['spip_connect_version']
+            and sql_showtable('spip_meta', true, $serveur)
+            and $r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'", '', '', '', '', $serveur)
+        ) {
+            $charset = $r;
+        } else {
+            $charset = -1;
+        }
+    }
+    if ($charset != -1) {
+        $f = $GLOBALS[$jeu]['set_charset'];
+        if (function_exists($f)) {
+            $f($charset, $serveur);
+        }
+    }
+
+    return $GLOBALS['connexions'][$index];
 }
 
 /**
@@ -163,12 +163,12 @@ 
  * @param string $serveur Nom du connecteur de bdd utilisé
  **/
 function spip_sql_erreur($serveur = '') {
-	$connexion = spip_connect($serveur);
-	$e = sql_errno($serveur);
-	$t = (isset($connexion['type']) ? $connexion['type'] : 'sql');
-	$m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim($connexion['last']);
-	$f = $t . $serveur;
-	spip_log($m, $f . '.' . _LOG_ERREUR);
+    $connexion = spip_connect($serveur);
+    $e = sql_errno($serveur);
+    $t = (isset($connexion['type']) ? $connexion['type'] : 'sql');
+    $m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim($connexion['last']);
+    $f = $t . $serveur;
+    spip_log($m, $f . '.' . _LOG_ERREUR);
 }
 
 /**
@@ -190,19 +190,19 @@ 
  *     - array : description de la connexion, si l'instruction sql est indisponible pour cette connexion
  **/
 function spip_connect_sql($version, $ins = '', $serveur = '', $continue = false) {
-	$desc = spip_connect($serveur, $version);
-	if (function_exists($f = @$desc[$version][$ins])) {
-		return $f;
-	}
-	if ($continue) {
-		return $desc;
-	}
-	if ($ins) {
-		spip_log("Le serveur '$serveur' version $version n'a pas '$ins'", _LOG_ERREUR);
-	}
-	include_spip('inc/minipres');
-	echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), ['status' => 503]);
-	exit;
+    $desc = spip_connect($serveur, $version);
+    if (function_exists($f = @$desc[$version][$ins])) {
+        return $f;
+    }
+    if ($continue) {
+        return $desc;
+    }
+    if ($ins) {
+        spip_log("Le serveur '$serveur' version $version n'a pas '$ins'", _LOG_ERREUR);
+    }
+    include_spip('inc/minipres');
+    echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), ['status' => 503]);
+    exit;
 }
 
 /**
@@ -228,70 +228,70 @@ 
  * @return array          Description de la connexion
  */
 function spip_connect_db(
-	$host,
-	$port,
-	$login,
-	$pass,
-	$db = '',
-	$type = 'mysql',
-	$prefixe = '',
-	$auth = '',
-	$charset = ''
+    $host,
+    $port,
+    $login,
+    $pass,
+    $db = '',
+    $type = 'mysql',
+    $prefixe = '',
+    $auth = '',
+    $charset = ''
 ) {
-	// temps avant nouvelle tentative de connexion
-	// suite a une connection echouee
-	if (!defined('_CONNECT_RETRY_DELAY')) {
-		define('_CONNECT_RETRY_DELAY', 30);
-	}
-
-	$f = '';
-	// un fichier de identifiant par combinaison (type,host,port,db)
-	// pour ne pas declarer tout indisponible d'un coup
-	// si en cours d'installation ou si db=@test@ on ne pose rien
-	// car c'est un test de connexion
-	if (!defined('_ECRIRE_INSTALL') and $db !== '@test@') {
-		$f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
-	} elseif ($db == '@test@') {
-		$db = '';
-	}
-
-	if (
-		$f
-		and @file_exists($f)
-		and (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
-	) {
-		spip_log("Echec : $f recent. Pas de tentative de connexion", _LOG_HS);
-
-		return;
-	}
-
-	if (!$prefixe) {
-		$prefixe = isset($GLOBALS['table_prefix'])
-			? $GLOBALS['table_prefix'] : $db;
-	}
-	$h = charger_fonction($type, 'req', true);
-	if (!$h) {
-		spip_log("les requetes $type ne sont pas fournies", _LOG_HS);
-
-		return;
-	}
-	if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
-		if (!is_array($auth)) {
-			// compatibilite version 0.7 initiale
-			$g['ldap'] = $auth;
-			$auth = ['ldap' => $auth];
-		}
-		$g['authentification'] = $auth;
-		$g['type'] = $type;
-		$g['charset'] = $charset;
-
-		return $GLOBALS['db_ok'] = $g;
-	}
-	// En cas d'indisponibilite du serveur, eviter de le bombarder
-	if ($f) {
-		@touch($f);
-		spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
-	}
+    // temps avant nouvelle tentative de connexion
+    // suite a une connection echouee
+    if (!defined('_CONNECT_RETRY_DELAY')) {
+        define('_CONNECT_RETRY_DELAY', 30);
+    }
+
+    $f = '';
+    // un fichier de identifiant par combinaison (type,host,port,db)
+    // pour ne pas declarer tout indisponible d'un coup
+    // si en cours d'installation ou si db=@test@ on ne pose rien
+    // car c'est un test de connexion
+    if (!defined('_ECRIRE_INSTALL') and $db !== '@test@') {
+        $f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
+    } elseif ($db == '@test@') {
+        $db = '';
+    }
+
+    if (
+        $f
+        and @file_exists($f)
+        and (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
+    ) {
+        spip_log("Echec : $f recent. Pas de tentative de connexion", _LOG_HS);
+
+        return;
+    }
+
+    if (!$prefixe) {
+        $prefixe = isset($GLOBALS['table_prefix'])
+            ? $GLOBALS['table_prefix'] : $db;
+    }
+    $h = charger_fonction($type, 'req', true);
+    if (!$h) {
+        spip_log("les requetes $type ne sont pas fournies", _LOG_HS);
+
+        return;
+    }
+    if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
+        if (!is_array($auth)) {
+            // compatibilite version 0.7 initiale
+            $g['ldap'] = $auth;
+            $auth = ['ldap' => $auth];
+        }
+        $g['authentification'] = $auth;
+        $g['type'] = $type;
+        $g['charset'] = $charset;
+
+        return $GLOBALS['db_ok'] = $g;
+    }
+    // En cas d'indisponibilite du serveur, eviter de le bombarder
+    if ($f) {
+        @touch($f);
+        spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
+    }
 }
 
 
@@ -323,32 +323,32 @@ 
  *     - nom du charset sinon
  **/
 function spip_connect_main($connexion, $charset_sql_connexion = '') {
-	if ($GLOBALS['spip_connect_version'] < 0.1 and _DIR_RESTREINT) {
-		include_spip('inc/headers');
-		redirige_url_ecrire('upgrade', 'reinstall=oui');
-	}
-
-	if (!($f = $connexion['select'])) {
-		return false;
-	}
-	// si le charset est fourni, l'utiliser
-	if ($charset_sql_connexion) {
-		return $charset_sql_connexion;
-	}
-	// sinon on regarde la table spip_meta
-	// en cas d'erreur select retourne la requette (is_string=true donc)
-	if (
-		!$r = $f('valeur', 'spip_meta', "nom='charset_sql_connexion'")
-		or is_string($r)
-	) {
-		return false;
-	}
-	if (!($f = $connexion['fetch'])) {
-		return false;
-	}
-	$r = $f($r);
-
-	return (isset($r['valeur']) && $r['valeur']) ? $r['valeur'] : -1;
+    if ($GLOBALS['spip_connect_version'] < 0.1 and _DIR_RESTREINT) {
+        include_spip('inc/headers');
+        redirige_url_ecrire('upgrade', 'reinstall=oui');
+    }
+
+    if (!($f = $connexion['select'])) {
+        return false;
+    }
+    // si le charset est fourni, l'utiliser
+    if ($charset_sql_connexion) {
+        return $charset_sql_connexion;
+    }
+    // sinon on regarde la table spip_meta
+    // en cas d'erreur select retourne la requette (is_string=true donc)
+    if (
+        !$r = $f('valeur', 'spip_meta', "nom='charset_sql_connexion'")
+        or is_string($r)
+    ) {
+        return false;
+    }
+    if (!($f = $connexion['fetch'])) {
+        return false;
+    }
+    $r = $f($r);
+
+    return (isset($r['valeur']) && $r['valeur']) ? $r['valeur'] : -1;
 }
 
 /**
@@ -364,9 +364,9 @@ 
  * @return array
  */
 function spip_connect_ldap($serveur = '') {
-	include_spip('auth/ldap');
+    include_spip('auth/ldap');
 
-	return auth_ldap_connect($serveur);
+    return auth_ldap_connect($serveur);
 }
 
 /**
@@ -382,9 +382,9 @@ 
  * @return string Valeur échappée.
  **/
 function _q($a) {
-	return (is_numeric($a)) ? strval($a) :
-		(!is_array($a) ? ("'" . addslashes($a) . "'")
-			: join(',', array_map('_q', $a)));
+    return (is_numeric($a)) ? strval($a) :
+        (!is_array($a) ? ("'" . addslashes($a) . "'")
+            : join(',', array_map('_q', $a)));
 }
 
 /**
@@ -400,66 +400,66 @@ 
  * @return array
  */
 function query_echappe_textes($query, $uniqid=null) {
-	static $codeEchappements = null;
-	if (is_null($codeEchappements) or $uniqid) {
-		if (is_null($uniqid)) {
-			$uniqid = uniqid();
-		}
-		$uniqid = substr(md5($uniqid), 0, 4);
-		$codeEchappements = ["\\\\" => "\x1@#{$uniqid}#@\x1", "\\'" => "\x2@#{$uniqid}#@\x2", '\\"' => "\x3@#{$uniqid}#@\x3"];
-	}
-	if ($query === null) {
-		return $codeEchappements;
-	}
-
-	// si la query contient deja des codes d'echappement on va s'emmeler les pinceaux et donc on ne touche a rien
-	// ce n'est pas un cas legitime
-	foreach ($codeEchappements as $codeEchappement) {
-		if (strpos($query, $codeEchappement) !== false) {
-			return [$query, []];
-		}
-	}
-
-	$query_echappees = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
-	if (preg_match_all("/('[^']*')|(\"[^\"]*\")/S", $query_echappees, $textes)) {
-		$textes = reset($textes); // indice 0 du match
-		switch (count($textes)) {
-			case 0:
-				$replace = [];
-				break;
-			case 1:
-				$replace = ['%1$s'];
-				break;
-			case 2:
-				$replace = ['%1$s', '%2$s'];
-				break;
-			case 3:
-				$replace = ['%1$s', '%2$s', '%3$s'];
-				break;
-			case 4:
-				$replace = ['%1$s', '%2$s', '%3$s', '%4$s'];
-				break;
-			case 5:
-				$replace = ['%1$s', '%2$s', '%3$s', '%4$s', '%5$s'];
-				break;
-			default:
-				$replace = range(1, count($textes));
-				$replace = '%' . implode('$s,%', $replace) . '$s';
-				$replace = explode(',', $replace);
-				break;
-		}
-		$query_echappees = str_replace($textes, $replace, $query_echappees);
-	} else {
-		$textes = [];
-	}
-
-	// si il reste des quotes simples ou doubles, c'est qu'on s'est emmelles les pinceaux
-	// dans le doute on ne touche a rien
-	if (strpbrk($query_echappees, "'\"") !== false) {
-		return [$query, []];
-	}
-
-	return [$query_echappees, $textes];
+    static $codeEchappements = null;
+    if (is_null($codeEchappements) or $uniqid) {
+        if (is_null($uniqid)) {
+            $uniqid = uniqid();
+        }
+        $uniqid = substr(md5($uniqid), 0, 4);
+        $codeEchappements = ["\\\\" => "\x1@#{$uniqid}#@\x1", "\\'" => "\x2@#{$uniqid}#@\x2", '\\"' => "\x3@#{$uniqid}#@\x3"];
+    }
+    if ($query === null) {
+        return $codeEchappements;
+    }
+
+    // si la query contient deja des codes d'echappement on va s'emmeler les pinceaux et donc on ne touche a rien
+    // ce n'est pas un cas legitime
+    foreach ($codeEchappements as $codeEchappement) {
+        if (strpos($query, $codeEchappement) !== false) {
+            return [$query, []];
+        }
+    }
+
+    $query_echappees = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
+    if (preg_match_all("/('[^']*')|(\"[^\"]*\")/S", $query_echappees, $textes)) {
+        $textes = reset($textes); // indice 0 du match
+        switch (count($textes)) {
+            case 0:
+                $replace = [];
+                break;
+            case 1:
+                $replace = ['%1$s'];
+                break;
+            case 2:
+                $replace = ['%1$s', '%2$s'];
+                break;
+            case 3:
+                $replace = ['%1$s', '%2$s', '%3$s'];
+                break;
+            case 4:
+                $replace = ['%1$s', '%2$s', '%3$s', '%4$s'];
+                break;
+            case 5:
+                $replace = ['%1$s', '%2$s', '%3$s', '%4$s', '%5$s'];
+                break;
+            default:
+                $replace = range(1, count($textes));
+                $replace = '%' . implode('$s,%', $replace) . '$s';
+                $replace = explode(',', $replace);
+                break;
+        }
+        $query_echappees = str_replace($textes, $replace, $query_echappees);
+    } else {
+        $textes = [];
+    }
+
+    // si il reste des quotes simples ou doubles, c'est qu'on s'est emmelles les pinceaux
+    // dans le doute on ne touche a rien
+    if (strpbrk($query_echappees, "'\"") !== false) {
+        return [$query, []];
+    }
+
+    return [$query_echappees, $textes];
 }
 
 /**
@@ -473,14 +473,14 @@ 
  * @return string
  */
 function query_reinjecte_textes($query, $textes) {
-	// recuperer les codes echappements
-	$codeEchappements = query_echappe_textes(null);
+    // recuperer les codes echappements
+    $codeEchappements = query_echappe_textes(null);
 
-	$query = sprintf($query, ...$textes);
+    $query = sprintf($query, ...$textes);
 
-	$query = str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
+    $query = str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
 
-	return $query;
+    return $query;
 }
 
 
@@ -499,7 +499,7 @@ 
  **/
 function spip_query($query, $serveur = '') {
 
-	$f = spip_connect_sql($GLOBALS['spip_sql_version'], 'query', $serveur, true);
+    $f = spip_connect_sql($GLOBALS['spip_sql_version'], 'query', $serveur, true);
 
-	return function_exists($f) ? $f($query, $serveur) : false;
+    return function_exists($f) ? $f($query, $serveur) : false;
 }