X-Git-Url: http://git.cyclocoop.org/?a=blobdiff_plain;f=www%2Fecrire%2Fbase%2Fconnect_sql.php;fp=www%2Fecrire%2Fbase%2Fconnect_sql.php;h=ef6cb9a5bd88a5cbbeafb2237bef56d988e2b1b4;hb=4f443dce95ff6f8221c189880a70c74ce1c1f238;hp=e215a0e7254510c154ea6f67d258193f59c9bde3;hpb=4a628e9b277d3617535f99d663ca79fa2e891177;p=lhc%2Fweb%2Fwww.git

diff --git a/www/ecrire/base/connect_sql.php b/www/ecrire/base/connect_sql.php
index e215a0e7..ef6cb9a5 100644
--- a/www/ecrire/base/connect_sql.php
+++ b/www/ecrire/base/connect_sql.php
@@ -3,93 +3,120 @@
 /***************************************************************************\
  *  SPIP, Systeme de publication pour l'internet                           *
  *                                                                         *
- *  Copyright (c) 2001-2016                                                *
+ *  Copyright (c) 2001-2017                                                *
  *  Arnaud Martin, Antoine Pitrou, Philippe Riviere, Emmanuel Saint-James  *
  *                                                                         *
  *  Ce programme est un logiciel libre distribue sous licence GNU/GPL.     *
  *  Pour plus de details voir le fichier COPYING.txt ou l'aide en ligne.   *
 \***************************************************************************/
 
-if (!defined('_ECRIRE_INC_VERSION')) return;
+/**
+ * Utilitaires indispensables autour des serveurs SQL
+ *
+ * @package SPIP\Core\SQL
+ **/
+if (!defined('_ECRIRE_INC_VERSION')) {
+	return;
+}
 require_once _ROOT_RESTREINT . 'base/objets.php';
 
-//
-// Utilitaires indispensables autour des serveurs SQL
-//
-
-// API d'appel aux bases de donnees:
-// on charge le fichier config/$serveur ($serveur='connect' pour le principal)
-// qui est cense initaliser la connexion en appelant spip_connect_db
-// laquelle met dans la globale db_ok la description de la connexion
-// On la memorise dans un tableau pour permettre plusieurs serveurs.
-// A l'installation, il faut simuler l'existence de ce fichier
 
-// http://doc.spip.org/@spip_connect
-function spip_connect($serveur='', $version='') {
-	global $connexions, $spip_sql_version;
+/**
+ * Connexion à un serveur de base de données
+ *
+ * On charge le fichier `config/$serveur` (`$serveur='connect'` pour le principal)
+ * qui est censé initaliser la connexion en appelant la fonction `spip_connect_db`
+ * laquelle met dans la globale `db_ok` la description de la connexion.
+ *
+ * On la mémorise dans un tableau pour permettre plusieurs serveurs.
+ *
+ * À l'installation, il faut simuler l'existence de ce fichier.
+ *
+ * @uses spip_connect_main()
+ *
+ * @param string $serveur Nom du connecteur
+ * @param string $version Version de l'API SQL
+ * @return bool|array
+ *     - false si la connexion a échouée,
+ *     - tableau décrivant la connexion sinon
+ **/
+function spip_connect($serveur = '', $version = '') {
 
 	$serveur = !is_string($serveur) ? '' : strtolower($serveur);
 	$index = $serveur ? $serveur : 0;
-	if (!$version) $version = $spip_sql_version;
-	if (isset($connexions[$index][$version])) return $connexions[$index];
+	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($connexions[$index]))) {
+	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
+			? '' // 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)) { 
+		if ($f) {
+			if (is_readable($f)) {
 				include($f);
-			} elseif ($serveur AND !$install) {
+			} 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);
+				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))
+			// 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
+			} 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 $connexions[$index]=false;
+			return $GLOBALS['connexions'][$index] = false;
 		}
-		$connexions[$index] = $GLOBALS['db_ok'];
+		$GLOBALS['connexions'][$index] = $GLOBALS['db_ok'];
 	}
 	// si la connexion a deja ete tentee mais a echoue, le dire!
-	if (!$connexions[$index]) return false;
+	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;
+	$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);
+		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 $connexions[$index][$version] = array();
+			return $GLOBALS['connexions'][$index][$version] = array();
 		}
 	}
-	$connexions[$index][$version] = $GLOBALS[$jeu];
-	if ($old) return $connexions[$index];
+	$GLOBALS['connexions'][$index][$version] = $GLOBALS[$jeu];
+	if ($old) {
+		return $GLOBALS['connexions'][$index];
+	}
 
-	$connexions[$index]['spip_connect_version'] = isset($GLOBALS['spip_connect_version']) ? $GLOBALS['spip_connect_version'] : 0;
+	$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.
@@ -97,106 +124,153 @@ function spip_connect($serveur='', $version='') {
 	// s'ils le connaissent
 
 	if (!$serveur) {
-		$charset = spip_connect_main($GLOBALS[$jeu]);
+		$charset = spip_connect_main($GLOBALS[$jeu], $GLOBALS['db_ok']['charset']);
 		if (!$charset) {
-			unset($connexions[$index]);
+			unset($GLOBALS['connexions'][$index]);
 			spip_log("spip_connect: absence de charset", _LOG_AVERTISSEMENT);
+
 			return false;
 		}
-	} else	{
+	} 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 
-		if ($connexions[$index]['spip_connect_version']
-		AND sql_showtable('spip_meta', true, $serveur)
-		AND $r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'",'','','','',$serveur))
+		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;
+		} else {
+			$charset = -1;
+		}
 	}
 	if ($charset != -1) {
 		$f = $GLOBALS[$jeu]['set_charset'];
-		if (function_exists($f))
+		if (function_exists($f)) {
 			$f($charset, $serveur);
+		}
 	}
-	return $connexions[$index];
+
+	return $GLOBALS['connexions'][$index];
 }
 
-function spip_sql_erreur($serveur='')
-{
+/**
+ * Log la dernière erreur SQL présente sur la connexion indiquée
+ *
+ * @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) . "\n" . $connexion['last'];
+	$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);
+	spip_log($m, $f . '.' . _LOG_ERREUR);
 }
 
-// Cette fonction ne doit etre appelee qu'a travers la fonction sql_serveur
-// definie dans base/abstract_sql
-// Elle existe en tant que gestionnaire de versions,
-// connue seulement des convertisseurs automatiques
-
-// http://doc.spip.org/@spip_connect_sql
-function spip_connect_sql($version, $ins='', $serveur='', $cont=false) {
+/**
+ * Retourne le nom de la fonction adaptée de l'API SQL en fonction du type de serveur
+ *
+ * Cette fonction ne doit être appelée qu'à travers la fonction sql_serveur
+ * définie dans base/abstract_sql
+ *
+ * Elle existe en tant que gestionnaire de versions,
+ * connue seulement des convertisseurs automatiques
+ *
+ * @param string $version Numéro de version de l'API SQL
+ * @param string $ins Instruction de l'API souhaitée, tel que 'allfetsel'
+ * @param string $serveur Nom du connecteur
+ * @param bool $cont true pour continuer même si le serveur SQL ou l'instruction est indisponible
+ * @return array|bool|string
+ *     - string : nom de la fonction à utiliser,
+ *     - false : si la connexion a échouée
+ *     - array : description de la connexion, si l'instruction sql est indisponible pour cette connexion
+ **/
+function spip_connect_sql($version, $ins = '', $serveur = '', $cont = false) {
 	$desc = spip_connect($serveur, $version);
-	if (function_exists($f = @$desc[$version][$ins])) return $f;
-	if ($cont) return $desc;
-	if ($ins)
+	if (function_exists($f = @$desc[$version][$ins])) {
+		return $f;
+	}
+	if ($cont) {
+		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'));
+	echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), array('status' => 503));
 	exit;
 }
 
 /**
- * Fonction appelee par le fichier cree dans config/ a l'instal'.
- * Il contient un appel direct a cette fonction avec comme arguments
+ * Fonction appelée par le fichier connecteur de base de données
+ * crée dans `config/` à l'installation.
+ *
+ * Il contient un appel direct à cette fonction avec comme arguments
  * les identifants de connexion.
- * Si la connexion reussit, la globale db_ok memorise sa description.
- * C'est un tableau egalement retourne en valeur, pour les appels a l'install'
- *
- * http://doc.spip.org/@spip_connect_db
- *
- * @param string $host
- * @param string $port
- * @param string $login
- * @param string $pass
- * @param string $db
- * @param string $type
- * @param string $prefixe
- * @param string $auth
- * @return array
+ *
+ * Si la connexion reussit, la globale `db_ok` mémorise sa description.
+ * C'est un tableau également retourné en valeur, pour les appels
+ * lors de l'installation.
+ *
+ * @param string $host Adresse du serveur de base de données
+ * @param string $port Port utilisé pour la connexion
+ * @param string $login Identifiant de connexion à la base de données
+ * @param string $pass Mot de passe pour cet identifiant
+ * @param string $db Nom de la base de données à utiliser
+ * @param string $type Type de base de données tel que 'mysql', 'sqlite3' (cf ecrire/req/)
+ * @param string $prefixe Préfixe des tables SPIP
+ * @param string $auth Type d'authentification (cas si 'ldap')
+ * @param string $charset Charset de la connexion SQL (optionnel)
+ * @return array          Description de la connexion
  */
-function spip_connect_db($host, $port, $login, $pass, $db='', $type='mysql', $prefixe='', $auth='') {
-	global $db_ok;
-
+function spip_connect_db(
+	$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);
+	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@')
+	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);
+		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)
+	if (!$prefixe) {
 		$prefixe = isset($GLOBALS['table_prefix'])
-		? $GLOBALS['table_prefix'] : $db;
+			? $GLOBALS['table_prefix'] : $db;
+	}
 	$h = charger_fonction($type, 'req', true);
 	if (!$h) {
-		spip_log( "les requetes $type ne sont pas fournies", _LOG_HS);
+		spip_log("les requetes $type ne sont pas fournies", _LOG_HS);
+
 		return;
 	}
 	if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
@@ -208,137 +282,227 @@ function spip_connect_db($host, $port, $login, $pass, $db='', $type='mysql', $pr
 		}
 		$g['authentification'] = $auth;
 		$g['type'] = $type;
-		return $db_ok = $g;
+		$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);
+		spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
 	}
 }
 
-// Premiere connexion au serveur principal:
-// retourner le charset donnee par la table principale
-// mais verifier que le fichier de connexion n'est pas trop vieux
-// Version courante = 0.7 
-// La version 0.7 indique un serveur d'authentification comme 8e arg
-// La version 0.6 indique le prefixe comme 7e arg
-// La version 0.5 indique le serveur comme 6e arg
-//
-// La version 0.0 (non numerotee) doit etre refaite par un admin
-// les autres fonctionnent toujours, meme si :
-// - la version 0.1 est moins performante que la 0.2
-// - la 0.2 fait un include_ecrire('inc_db_mysql.php3').
-
-// http://doc.spip.org/@spip_connect_main
-function spip_connect_main($connexion)
-{
-	if ($GLOBALS['spip_connect_version']< 0.1 AND _DIR_RESTREINT){
+
+/**
+ * Première connexion au serveur principal de base de données
+ *
+ * Retourner le charset donnée par la table principale
+ * mais vérifier que le fichier de connexion n'est pas trop vieux
+ *
+ * @note
+ *   Version courante = 0.8
+ *
+ *   - La version 0.8 indique un charset de connexion comme 9e arg
+ *   - La version 0.7 indique un serveur d'authentification comme 8e arg
+ *   - La version 0.6 indique le prefixe comme 7e arg
+ *   - La version 0.5 indique le serveur comme 6e arg
+ *
+ *   La version 0.0 (non numerotée) doit être refaite par un admin.
+ *   Les autres fonctionnent toujours, même si :
+ *
+ *   - la version 0.1 est moins performante que la 0.2
+ *   - la 0.2 fait un include_ecrire('inc_db_mysql.php3').
+ *
+ * @param array $connexion Description de la connexion
+ * @param string $charset_sql_connexion charset de connexion fourni dans l'appal a spip_connect_db
+ * @return string|bool|int
+ *     - false si pas de charset connu pour la connexion
+ *     - -1 charset non renseigné
+ *     - 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;
+	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))
+	if (!$r = $f('valeur', 'spip_meta', "nom='charset_sql_connexion'")
+		or is_string($r)
+	) {
 		return false;
-	if (!($f = $connexion['fetch'])) return false;
+	}
+	if (!($f = $connexion['fetch'])) {
+		return false;
+	}
 	$r = $f($r);
+
 	return ($r['valeur'] ? $r['valeur'] : -1);
 }
 
-// compatibilite
-function spip_connect_ldap($serveur='') {
+/**
+ * Connection à LDAP
+ *
+ * Fonction présente pour compatibilité
+ *
+ * @deprecated Utiliser l'authentification LDAP de auth/ldap
+ * @uses auth_ldap_connect()
+ *
+ * @param string $serveur Nom du connecteur
+ * @return array
+ */
+function spip_connect_ldap($serveur = '') {
 	include_spip('auth/ldap');
+
 	return auth_ldap_connect($serveur);
 }
 
-// Echappement d'une valeur (num, string, array) sous forme de chaine PHP
-// pour un array(1,'a',"a'") renvoie la chaine "'1','a','a\''"
-// Usage sql un peu deprecie, a remplacer par sql_quote()
-// http://doc.spip.org/@_q
-function _q ($a) {
+/**
+ * Échappement d'une valeur sous forme de chaîne PHP
+ *
+ * Échappe une valeur (num, string, array) pour en faire une chaîne pour PHP.
+ * Un `array(1,'a',"a'")` renvoie la chaine `"'1','a','a\''"`
+ *
+ * @note
+ *   L'usage comme échappement SQL est déprécié, à remplacer par sql_quote().
+ *
+ * @param num|string|array $a Valeur à échapper
+ * @return string Valeur échappée.
+ **/
+function _q($a) {
 	return (is_numeric($a)) ? strval($a) :
 		(!is_array($a) ? ("'" . addslashes($a) . "'")
-		 : join(",", array_map('_q', $a)));
+			: join(",", array_map('_q', $a)));
 }
 
 
-// Recuperer le nom de la table de jointure xxxx sur l'objet yyyy
-// http://doc.spip.org/@table_jointure
+/**
+ * Récupérer le nom de la table de jointure `xxxx` sur l'objet `yyyy`
+ *
+ * @deprecated
+ *     Utiliser l'API editer_liens ou les tables de liaisons spip_xx_liens
+ *     ou spip_yy_liens selon.
+ *
+ * @param string $x Table de destination
+ * @param string $y Objet source
+ * @return array|string
+ *     - array : Description de la table de jointure si connue
+ *     - chaîne vide si non trouvé.
+ **/
 function table_jointure($x, $y) {
 	$trouver_table = charger_fonction('trouver_table', 'base');
 	$xdesc = $trouver_table(table_objet($x));
 	$ydesc = $trouver_table(table_objet($y));
 	$ix = @$xdesc['key']["PRIMARY KEY"];
 	$iy = @$ydesc['key']["PRIMARY KEY"];
-	if ($table = $ydesc['tables_jointures'][$ix]) return $table;
-	if ($table = $xdesc['tables_jointures'][$iy]) return $table;
+	if ($table = $ydesc['tables_jointures'][$ix]) {
+		return $table;
+	}
+	if ($table = $xdesc['tables_jointures'][$iy]) {
+		return $table;
+	}
+
 	return '';
 }
 
 /**
- * Echapper les textes entre ' ' ou " " d'une requete SQL
+ * Echapper les textes entre ' ' ou " " d'une requête SQL
  * avant son pre-traitement
- * On renvoi la query sans textes et les textes separes, dans
+ *
+ * On renvoi la query sans textes et les textes séparés, dans
  * leur ordre d'apparition dans la query
  *
+ * @see query_reinjecte_textes()
+ *
  * @param string $query
  * @return array
  */
-function query_echappe_textes($query){
-	static $codeEchappements = array("''"=>"\x1@##@\x1", "\'"=>"\x2@##@\x2", "\\\""=>"\x3@##@\x3");
+function query_echappe_textes($query) {
+	static $codeEchappements = array("''" => "\x1@##@\x1", "\'" => "\x2@##@\x2", "\\\"" => "\x3@##@\x3");
 	$query = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
-	if (preg_match_all("/((['])[^']*(\\2))|(([\"])[^\"]*(\\5))/S",$query,$textes)){
+	if (preg_match_all("/((['])[^']*(\\2))|(([\"])[^\"]*(\\5))/S", $query, $textes)) {
 		$textes = reset($textes); // indice 0 du match
-		switch(count($textes)){
-			case 0:$replace=array();break;
-			case 1:$replace=array('%1$s');break;
-			case 2:$replace=array('%1$s','%2$s');break;
-			case 3:$replace=array('%1$s','%2$s','%3$s');break;
-			case 4:$replace=array('%1$s','%2$s','%3$s','%4$s');break;
-			case 5:$replace=array('%1$s','%2$s','%3$s','%4$s','%5$s');break;
+		switch (count($textes)) {
+			case 0:
+				$replace = array();
+				break;
+			case 1:
+				$replace = array('%1$s');
+				break;
+			case 2:
+				$replace = array('%1$s', '%2$s');
+				break;
+			case 3:
+				$replace = array('%1$s', '%2$s', '%3$s');
+				break;
+			case 4:
+				$replace = array('%1$s', '%2$s', '%3$s', '%4$s');
+				break;
+			case 5:
+				$replace = array('%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);
+				$replace = range(1, count($textes));
+				$replace = '%' . implode('$s,%', $replace) . '$s';
+				$replace = explode(',', $replace);
 				break;
 		}
-		$query = str_replace($textes,$replace,$query);
-	}
-	else
+		$query = str_replace($textes, $replace, $query);
+	} else {
 		$textes = array();
+	}
 
 	return array($query, $textes);
 }
 
 /**
- * Reinjecter les textes d'une requete SQL a leur place initiale,
- * apres traitement de la requete
+ * Réinjecter les textes d'une requete SQL à leur place initiale,
+ * après traitement de la requête
+ *
+ * @see query_echappe_textes()
  *
  * @param string $query
  * @param array $textes
  * @return string
  */
-function query_reinjecte_textes($query, $textes){
-	static $codeEchappements = array("''"=>"\x1@##@\x1", "\'"=>"\x2@##@\x2", "\\\""=>"\x3@##@\x3");
+function query_reinjecte_textes($query, $textes) {
+	static $codeEchappements = array("''" => "\x1@##@\x1", "\'" => "\x2@##@\x2", "\\\"" => "\x3@##@\x3");
 	# debug de la substitution
 	#if (($c1=substr_count($query,"%"))!=($c2=count($textes))){
 	#	spip_log("$c1 ::". $query,"tradquery"._LOG_ERREUR);
 	#	spip_log("$c2 ::". var_export($textes,1),"tradquery"._LOG_ERREUR);
 	#	spip_log("ini ::". $qi,"tradquery"._LOG_ERREUR);
 	#}
-	switch (count($textes)){
-		case 0:break;
-		case 1:$query=sprintf($query,$textes[0]);break;
-		case 2:$query=sprintf($query,$textes[0],$textes[1]);break;
-		case 3:$query=sprintf($query,$textes[0],$textes[1],$textes[2]);break;
-		case 4:$query=sprintf($query,$textes[0],$textes[1],$textes[2],$textes[3]);break;
-		case 5:$query=sprintf($query,$textes[0],$textes[1],$textes[2],$textes[3],$textes[4]);break;
+	switch (count($textes)) {
+		case 0:
+			break;
+		case 1:
+			$query = sprintf($query, $textes[0]);
+			break;
+		case 2:
+			$query = sprintf($query, $textes[0], $textes[1]);
+			break;
+		case 3:
+			$query = sprintf($query, $textes[0], $textes[1], $textes[2]);
+			break;
+		case 4:
+			$query = sprintf($query, $textes[0], $textes[1], $textes[2], $textes[3]);
+			break;
+		case 5:
+			$query = sprintf($query, $textes[0], $textes[1], $textes[2], $textes[3], $textes[4]);
+			break;
 		default:
-			array_unshift($textes,$query);
-			$query = call_user_func_array('sprintf',$textes);
+			array_unshift($textes, $query);
+			$query = call_user_func_array('sprintf', $textes);
 			break;
 	}
 
@@ -347,12 +511,21 @@ function query_reinjecte_textes($query, $textes){
 	return $query;
 }
 
-// Pour compatibilite. Ne plus utiliser.
-// http://doc.spip.org/@spip_query
-function spip_query($query, $serveur='') {
-	global $spip_sql_version;
-	$f = spip_connect_sql($spip_sql_version, 'query', $serveur, true);
+
+/**
+ * Exécute une requête sur le serveur SQL
+ *
+ * @see sql_query()
+ * @deprecated  Pour compatibilité. Utiliser `sql_query()` ou l'API `sql_*`.
+ *
+ * @param string $query Texte de la requête
+ * @param string $serveur Nom du connecteur pour la base de données
+ * @return bool|mixed
+ *     - false si on ne peut pas exécuter la requête
+ *     - indéfini sinon.
+ **/
+function spip_query($query, $serveur = '') {
+	$f = spip_connect_sql($GLOBALS['spip_sql_version'], 'query', $serveur, true);
+
 	return function_exists($f) ? $f($query, $serveur) : false;
 }
-
-?>