|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
/***************************************************************************\ |
|
4
|
|
|
* SPIP, Systeme de publication pour l'internet * |
|
5
|
|
|
* * |
|
6
|
|
|
* Copyright (c) 2001-2016 * |
|
7
|
|
|
* Arnaud Martin, Antoine Pitrou, Philippe Riviere, Emmanuel Saint-James * |
|
8
|
|
|
* * |
|
9
|
|
|
* Ce programme est un logiciel libre distribue sous licence GNU/GPL. * |
|
10
|
|
|
* Pour plus de details voir le fichier COPYING.txt ou l'aide en ligne. * |
|
11
|
|
|
\***************************************************************************/ |
|
12
|
|
|
|
|
13
|
|
|
if (!defined('_ECRIRE_INC_VERSION')) return; |
|
14
|
|
|
require_once _ROOT_RESTREINT . 'base/objets.php'; |
|
15
|
|
|
|
|
16
|
|
|
// |
|
17
|
|
|
// Utilitaires indispensables autour des serveurs SQL |
|
18
|
|
|
// |
|
19
|
|
|
|
|
20
|
|
|
// API d'appel aux bases de donnees: |
|
21
|
|
|
// on charge le fichier config/$serveur ($serveur='connect' pour le principal) |
|
22
|
|
|
// qui est cense initaliser la connexion en appelant spip_connect_db |
|
23
|
|
|
// laquelle met dans la globale db_ok la description de la connexion |
|
24
|
|
|
// On la memorise dans un tableau pour permettre plusieurs serveurs. |
|
25
|
|
|
// A l'installation, il faut simuler l'existence de ce fichier |
|
26
|
|
|
|
|
27
|
|
|
// http://doc.spip.org/@spip_connect |
|
28
|
|
|
function spip_connect($serveur='', $version='') { |
|
29
|
|
|
global $connexions, $spip_sql_version; |
|
30
|
|
|
|
|
31
|
|
|
$serveur = !is_string($serveur) ? '' : strtolower($serveur); |
|
32
|
|
|
$index = $serveur ? $serveur : 0; |
|
33
|
|
|
if (!$version) $version = $spip_sql_version; |
|
34
|
|
|
if (isset($connexions[$index][$version])) return $connexions[$index]; |
|
35
|
|
|
|
|
36
|
|
|
include_spip('base/abstract_sql'); |
|
37
|
|
|
$install = (_request('exec') == 'install'); |
|
38
|
|
|
|
|
39
|
|
|
// Premiere connexion ? |
|
40
|
|
|
if (!($old = isset($connexions[$index]))) { |
|
41
|
|
|
$f = (!preg_match('/^[\w\.]*$/', $serveur)) |
|
42
|
|
|
? '' // nom de serveur mal ecrit |
|
43
|
|
|
: ($serveur ? |
|
44
|
|
|
( _DIR_CONNECT. $serveur . '.php') // serveur externe |
|
45
|
|
|
: (_FILE_CONNECT ? _FILE_CONNECT // serveur principal ok |
|
46
|
|
|
: ($install ? _FILE_CONNECT_TMP // init du serveur principal |
|
47
|
|
|
: ''))); // installation pas faite |
|
48
|
|
|
|
|
49
|
|
|
unset($GLOBALS['db_ok']); |
|
50
|
|
|
unset($GLOBALS['spip_connect_version']); |
|
51
|
|
|
if ($f) { |
|
52
|
|
|
if (is_readable($f)) { |
|
53
|
|
|
include($f); |
|
54
|
|
|
} elseif ($serveur AND !$install) { |
|
55
|
|
|
// chercher une declaration de serveur dans le path |
|
56
|
|
|
// qui pourra un jour servir a declarer des bases sqlite |
|
57
|
|
|
// par des plugins. Et sert aussi aux boucles POUR. |
|
58
|
|
|
find_in_path("$serveur.php",'connect/',true); |
|
59
|
|
|
} |
|
60
|
|
|
} |
|
61
|
|
|
if (!isset($GLOBALS['db_ok'])) { |
|
62
|
|
|
// fera mieux la prochaine fois |
|
63
|
|
|
if ($install) return false; |
|
64
|
|
|
if ($f AND is_readable($f)) |
|
65
|
|
|
spip_log("spip_connect: fichier de connexion '$f' OK.", _LOG_INFO_IMPORTANTE); |
|
66
|
|
|
else |
|
67
|
|
|
spip_log("spip_connect: fichier de connexion '$f' non trouve", _LOG_INFO_IMPORTANTE); |
|
68
|
|
|
spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.", _LOG_HS); |
|
69
|
|
|
// ne plus reessayer si ce n'est pas l'install |
|
70
|
|
|
return $connexions[$index]=false; |
|
71
|
|
|
} |
|
72
|
|
|
$connexions[$index] = $GLOBALS['db_ok']; |
|
73
|
|
|
} |
|
74
|
|
|
// si la connexion a deja ete tentee mais a echoue, le dire! |
|
75
|
|
|
if (!$connexions[$index]) return false; |
|
76
|
|
|
|
|
77
|
|
|
// la connexion a reussi ou etait deja faite. |
|
78
|
|
|
// chargement de la version du jeu de fonctions |
|
79
|
|
|
// si pas dans le fichier par defaut |
|
80
|
|
|
$type = $GLOBALS['db_ok']['type']; |
|
81
|
|
|
$jeu = 'spip_' . $type .'_functions_' . $version; |
|
82
|
|
|
if (!isset($GLOBALS[$jeu])) { |
|
83
|
|
|
if (!find_in_path($type . '_' . $version . '.php', 'req/', true)){ |
|
84
|
|
|
spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS); |
|
85
|
|
|
// ne plus reessayer |
|
86
|
|
|
return $connexions[$index][$version] = array(); |
|
87
|
|
|
} |
|
88
|
|
|
} |
|
89
|
|
|
$connexions[$index][$version] = $GLOBALS[$jeu]; |
|
90
|
|
|
if ($old) return $connexions[$index]; |
|
91
|
|
|
|
|
92
|
|
|
$connexions[$index]['spip_connect_version'] = isset($GLOBALS['spip_connect_version']) ? $GLOBALS['spip_connect_version'] : 0; |
|
93
|
|
|
|
|
94
|
|
|
// initialisation de l'alphabet utilise dans les connexions SQL |
|
95
|
|
|
// si l'installation l'a determine. |
|
96
|
|
|
// Celui du serveur principal l'impose aux serveurs secondaires |
|
97
|
|
|
// s'ils le connaissent |
|
98
|
|
|
|
|
99
|
|
|
if (!$serveur) { |
|
100
|
|
|
$charset = spip_connect_main($GLOBALS[$jeu]); |
|
101
|
|
|
if (!$charset) { |
|
102
|
|
|
unset($connexions[$index]); |
|
103
|
|
|
spip_log("spip_connect: absence de charset", _LOG_AVERTISSEMENT); |
|
104
|
|
|
return false; |
|
105
|
|
|
} |
|
106
|
|
|
} else { |
|
107
|
|
|
// spip_meta n'existe pas toujours dans la base |
|
108
|
|
|
// C'est le cas d'un dump sqlite par exemple |
|
109
|
|
|
if ($connexions[$index]['spip_connect_version'] |
|
110
|
|
|
AND sql_showtable('spip_meta', true, $serveur) |
|
111
|
|
|
AND $r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'",'','','','',$serveur)) |
|
112
|
|
|
$charset = $r; |
|
113
|
|
|
else $charset = -1; |
|
114
|
|
|
} |
|
115
|
|
|
if ($charset != -1) { |
|
116
|
|
|
$f = $GLOBALS[$jeu]['set_charset']; |
|
117
|
|
|
if (function_exists($f)) |
|
118
|
|
|
$f($charset, $serveur); |
|
119
|
|
|
} |
|
120
|
|
|
return $connexions[$index]; |
|
121
|
|
|
} |
|
122
|
|
|
|
|
123
|
|
|
function spip_sql_erreur($serveur='') |
|
124
|
|
|
{ |
|
125
|
|
|
$connexion = spip_connect($serveur); |
|
126
|
|
|
$e = sql_errno($serveur); |
|
127
|
|
|
$t = (isset($connexion['type']) ? $connexion['type'] : 'sql'); |
|
128
|
|
|
$m = "Erreur $e de $t: " . sql_error($serveur) . "\n" . $connexion['last']; |
|
129
|
|
|
$f = $t . $serveur; |
|
130
|
|
|
spip_log($m, $f.'.'._LOG_ERREUR); |
|
131
|
|
|
} |
|
132
|
|
|
|
|
133
|
|
|
// Cette fonction ne doit etre appelee qu'a travers la fonction sql_serveur |
|
134
|
|
|
// definie dans base/abstract_sql |
|
135
|
|
|
// Elle existe en tant que gestionnaire de versions, |
|
136
|
|
|
// connue seulement des convertisseurs automatiques |
|
137
|
|
|
|
|
138
|
|
|
// http://doc.spip.org/@spip_connect_sql |
|
139
|
|
|
function spip_connect_sql($version, $ins='', $serveur='', $cont=false) { |
|
140
|
|
|
$desc = spip_connect($serveur, $version); |
|
141
|
|
|
if (function_exists($f = @$desc[$version][$ins])) return $f; |
|
142
|
|
|
if ($cont) return $desc; |
|
143
|
|
|
if ($ins) |
|
144
|
|
|
spip_log("Le serveur '$serveur' version $version n'a pas '$ins'", _LOG_ERREUR); |
|
145
|
|
|
include_spip('inc/minipres'); |
|
146
|
|
|
echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique')); |
|
147
|
|
|
exit; |
|
|
|
|
|
|
148
|
|
|
} |
|
149
|
|
|
|
|
150
|
|
|
/** |
|
151
|
|
|
* Fonction appelee par le fichier cree dans config/ a l'instal'. |
|
152
|
|
|
* Il contient un appel direct a cette fonction avec comme arguments |
|
153
|
|
|
* les identifants de connexion. |
|
154
|
|
|
* Si la connexion reussit, la globale db_ok memorise sa description. |
|
155
|
|
|
* C'est un tableau egalement retourne en valeur, pour les appels a l'install' |
|
156
|
|
|
* |
|
157
|
|
|
* http://doc.spip.org/@spip_connect_db |
|
158
|
|
|
* |
|
159
|
|
|
* @param string $host |
|
160
|
|
|
* @param string $port |
|
161
|
|
|
* @param string $login |
|
162
|
|
|
* @param string $pass |
|
163
|
|
|
* @param string $db |
|
164
|
|
|
* @param string $type |
|
165
|
|
|
* @param string $prefixe |
|
166
|
|
|
* @param string $auth |
|
167
|
|
|
* @return array |
|
|
|
|
|
|
168
|
|
|
*/ |
|
169
|
|
|
function spip_connect_db($host, $port, $login, $pass, $db='', $type='mysql', $prefixe='', $auth='') { |
|
170
|
|
|
global $db_ok; |
|
171
|
|
|
|
|
172
|
|
|
// temps avant nouvelle tentative de connexion |
|
173
|
|
|
// suite a une connection echouee |
|
174
|
|
|
if (!defined('_CONNECT_RETRY_DELAY')) |
|
175
|
|
|
define('_CONNECT_RETRY_DELAY',30); |
|
176
|
|
|
|
|
177
|
|
|
$f = ""; |
|
178
|
|
|
// un fichier de identifiant par combinaison (type,host,port,db) |
|
179
|
|
|
// pour ne pas declarer tout indisponible d'un coup |
|
180
|
|
|
// si en cours d'installation ou si db=@test@ on ne pose rien |
|
181
|
|
|
// car c'est un test de connexion |
|
182
|
|
|
if (!defined('_ECRIRE_INSTALL') AND !$db=="@test@") |
|
183
|
|
|
$f = _DIR_TMP . $type . '.' . substr(md5($host.$port.$db),0,8) . '.out'; |
|
184
|
|
|
elseif ($db=='@test@') |
|
185
|
|
|
$db = ''; |
|
186
|
|
|
|
|
187
|
|
|
if ($f |
|
188
|
|
|
AND @file_exists($f) |
|
189
|
|
|
AND (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)) { |
|
190
|
|
|
spip_log( "Echec : $f recent. Pas de tentative de connexion", _LOG_HS); |
|
191
|
|
|
return; |
|
192
|
|
|
} |
|
193
|
|
|
|
|
194
|
|
|
if (!$prefixe) |
|
195
|
|
|
$prefixe = isset($GLOBALS['table_prefix']) |
|
196
|
|
|
? $GLOBALS['table_prefix'] : $db; |
|
197
|
|
|
$h = charger_fonction($type, 'req', true); |
|
198
|
|
|
if (!$h) { |
|
199
|
|
|
spip_log( "les requetes $type ne sont pas fournies", _LOG_HS); |
|
200
|
|
|
return; |
|
201
|
|
|
} |
|
202
|
|
|
if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) { |
|
203
|
|
|
|
|
204
|
|
|
if (!is_array($auth)) { |
|
205
|
|
|
// compatibilite version 0.7 initiale |
|
206
|
|
|
$g['ldap'] = $auth; |
|
207
|
|
|
$auth = array('ldap' => $auth); |
|
208
|
|
|
} |
|
209
|
|
|
$g['authentification'] = $auth; |
|
210
|
|
|
$g['type'] = $type; |
|
211
|
|
|
return $db_ok = $g; |
|
212
|
|
|
} |
|
213
|
|
|
// En cas d'indisponibilite du serveur, eviter de le bombarder |
|
214
|
|
|
if ($f) { |
|
215
|
|
|
@touch($f); |
|
|
|
|
|
|
216
|
|
|
spip_log( "Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type.'.'._LOG_HS); |
|
217
|
|
|
} |
|
218
|
|
|
} |
|
219
|
|
|
|
|
220
|
|
|
// Premiere connexion au serveur principal: |
|
221
|
|
|
// retourner le charset donnee par la table principale |
|
222
|
|
|
// mais verifier que le fichier de connexion n'est pas trop vieux |
|
223
|
|
|
// Version courante = 0.7 |
|
224
|
|
|
// La version 0.7 indique un serveur d'authentification comme 8e arg |
|
225
|
|
|
// La version 0.6 indique le prefixe comme 7e arg |
|
226
|
|
|
// La version 0.5 indique le serveur comme 6e arg |
|
227
|
|
|
// |
|
228
|
|
|
// La version 0.0 (non numerotee) doit etre refaite par un admin |
|
229
|
|
|
// les autres fonctionnent toujours, meme si : |
|
230
|
|
|
// - la version 0.1 est moins performante que la 0.2 |
|
231
|
|
|
// - la 0.2 fait un include_ecrire('inc_db_mysql.php3'). |
|
232
|
|
|
|
|
233
|
|
|
// http://doc.spip.org/@spip_connect_main |
|
234
|
|
|
function spip_connect_main($connexion) |
|
235
|
|
|
{ |
|
236
|
|
|
if ($GLOBALS['spip_connect_version']< 0.1 AND _DIR_RESTREINT){ |
|
237
|
|
|
include_spip('inc/headers'); |
|
238
|
|
|
redirige_url_ecrire('upgrade', 'reinstall=oui'); |
|
239
|
|
|
} |
|
240
|
|
|
|
|
241
|
|
|
if (!($f = $connexion['select'])) return false; |
|
242
|
|
|
// en cas d'erreur select retourne la requette (is_string=true donc) |
|
243
|
|
|
if (!$r = $f('valeur','spip_meta', "nom='charset_sql_connexion'") |
|
244
|
|
|
OR is_string($r)) |
|
245
|
|
|
return false; |
|
246
|
|
|
if (!($f = $connexion['fetch'])) return false; |
|
247
|
|
|
$r = $f($r); |
|
248
|
|
|
return ($r['valeur'] ? $r['valeur'] : -1); |
|
249
|
|
|
} |
|
250
|
|
|
|
|
251
|
|
|
// compatibilite |
|
252
|
|
|
function spip_connect_ldap($serveur='') { |
|
253
|
|
|
include_spip('auth/ldap'); |
|
254
|
|
|
return auth_ldap_connect($serveur); |
|
255
|
|
|
} |
|
256
|
|
|
|
|
257
|
|
|
// Echappement d'une valeur (num, string, array) sous forme de chaine PHP |
|
258
|
|
|
// pour un array(1,'a',"a'") renvoie la chaine "'1','a','a\''" |
|
259
|
|
|
// Usage sql un peu deprecie, a remplacer par sql_quote() |
|
260
|
|
|
// http://doc.spip.org/@_q |
|
261
|
|
|
function _q ($a) { |
|
262
|
|
|
return (is_numeric($a)) ? strval($a) : |
|
263
|
|
|
(!is_array($a) ? ("'" . addslashes($a) . "'") |
|
264
|
|
|
: join(",", array_map('_q', $a))); |
|
265
|
|
|
} |
|
266
|
|
|
|
|
267
|
|
|
|
|
268
|
|
|
// Recuperer le nom de la table de jointure xxxx sur l'objet yyyy |
|
269
|
|
|
// http://doc.spip.org/@table_jointure |
|
270
|
|
|
function table_jointure($x, $y) { |
|
271
|
|
|
$trouver_table = charger_fonction('trouver_table', 'base'); |
|
272
|
|
|
$xdesc = $trouver_table(table_objet($x)); |
|
273
|
|
|
$ydesc = $trouver_table(table_objet($y)); |
|
274
|
|
|
$ix = @$xdesc['key']["PRIMARY KEY"]; |
|
275
|
|
|
$iy = @$ydesc['key']["PRIMARY KEY"]; |
|
276
|
|
|
if ($table = $ydesc['tables_jointures'][$ix]) return $table; |
|
277
|
|
|
if ($table = $xdesc['tables_jointures'][$iy]) return $table; |
|
278
|
|
|
return ''; |
|
279
|
|
|
} |
|
280
|
|
|
|
|
281
|
|
|
/** |
|
282
|
|
|
* Echapper les textes entre ' ' ou " " d'une requete SQL |
|
283
|
|
|
* avant son pre-traitement |
|
284
|
|
|
* On renvoi la query sans textes et les textes separes, dans |
|
285
|
|
|
* leur ordre d'apparition dans la query |
|
286
|
|
|
* |
|
287
|
|
|
* @param string $query |
|
288
|
|
|
* @return array |
|
|
|
|
|
|
289
|
|
|
*/ |
|
290
|
|
|
function query_echappe_textes($query){ |
|
291
|
|
|
static $codeEchappements = array("''"=>"\x1@##@\x1", "\'"=>"\x2@##@\x2", "\\\""=>"\x3@##@\x3"); |
|
292
|
|
|
$query = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query); |
|
293
|
|
|
if (preg_match_all("/((['])[^']*(\\2))|(([\"])[^\"]*(\\5))/S",$query,$textes)){ |
|
294
|
|
|
$textes = reset($textes); // indice 0 du match |
|
295
|
|
|
switch(count($textes)){ |
|
296
|
|
|
case 0:$replace=array();break; |
|
297
|
|
|
case 1:$replace=array('%1$s');break; |
|
298
|
|
|
case 2:$replace=array('%1$s','%2$s');break; |
|
299
|
|
|
case 3:$replace=array('%1$s','%2$s','%3$s');break; |
|
300
|
|
|
case 4:$replace=array('%1$s','%2$s','%3$s','%4$s');break; |
|
301
|
|
|
case 5:$replace=array('%1$s','%2$s','%3$s','%4$s','%5$s');break; |
|
302
|
|
|
default: |
|
303
|
|
|
$replace = range(1,count($textes)); |
|
304
|
|
|
$replace = '%'.implode('$s,%',$replace).'$s'; |
|
305
|
|
|
$replace = explode(',',$replace); |
|
306
|
|
|
break; |
|
307
|
|
|
} |
|
308
|
|
|
$query = str_replace($textes,$replace,$query); |
|
309
|
|
|
} |
|
310
|
|
|
else |
|
311
|
|
|
$textes = array(); |
|
312
|
|
|
|
|
313
|
|
|
return array($query, $textes); |
|
314
|
|
|
} |
|
315
|
|
|
|
|
316
|
|
|
/** |
|
317
|
|
|
* Reinjecter les textes d'une requete SQL a leur place initiale, |
|
318
|
|
|
* apres traitement de la requete |
|
319
|
|
|
* |
|
320
|
|
|
* @param string $query |
|
321
|
|
|
* @param array $textes |
|
322
|
|
|
* @return string |
|
323
|
|
|
*/ |
|
324
|
|
|
function query_reinjecte_textes($query, $textes){ |
|
325
|
|
|
static $codeEchappements = array("''"=>"\x1@##@\x1", "\'"=>"\x2@##@\x2", "\\\""=>"\x3@##@\x3"); |
|
326
|
|
|
# debug de la substitution |
|
327
|
|
|
#if (($c1=substr_count($query,"%"))!=($c2=count($textes))){ |
|
328
|
|
|
# spip_log("$c1 ::". $query,"tradquery"._LOG_ERREUR); |
|
329
|
|
|
# spip_log("$c2 ::". var_export($textes,1),"tradquery"._LOG_ERREUR); |
|
330
|
|
|
# spip_log("ini ::". $qi,"tradquery"._LOG_ERREUR); |
|
331
|
|
|
#} |
|
332
|
|
|
switch (count($textes)){ |
|
333
|
|
|
case 0:break; |
|
334
|
|
|
case 1:$query=sprintf($query,$textes[0]);break; |
|
335
|
|
|
case 2:$query=sprintf($query,$textes[0],$textes[1]);break; |
|
336
|
|
|
case 3:$query=sprintf($query,$textes[0],$textes[1],$textes[2]);break; |
|
337
|
|
View Code Duplication |
case 4:$query=sprintf($query,$textes[0],$textes[1],$textes[2],$textes[3]);break; |
|
|
|
|
|
|
338
|
|
View Code Duplication |
case 5:$query=sprintf($query,$textes[0],$textes[1],$textes[2],$textes[3],$textes[4]);break; |
|
|
|
|
|
|
339
|
|
|
default: |
|
340
|
|
|
array_unshift($textes,$query); |
|
341
|
|
|
$query = call_user_func_array('sprintf',$textes); |
|
342
|
|
|
break; |
|
343
|
|
|
} |
|
344
|
|
|
|
|
345
|
|
|
$query = str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query); |
|
346
|
|
|
|
|
347
|
|
|
return $query; |
|
348
|
|
|
} |
|
349
|
|
|
|
|
350
|
|
|
// Pour compatibilite. Ne plus utiliser. |
|
351
|
|
|
// http://doc.spip.org/@spip_query |
|
352
|
|
|
function spip_query($query, $serveur='') { |
|
353
|
|
|
global $spip_sql_version; |
|
354
|
|
|
$f = spip_connect_sql($spip_sql_version, 'query', $serveur, true); |
|
355
|
|
|
return function_exists($f) ? $f($query, $serveur) : false; |
|
356
|
|
|
} |
|
357
|
|
|
|
|
358
|
|
|
?> |
|
|
|
|
|
|
359
|
|
|
|
An exit expression should only be used in rare cases. For example, if you write a short command line script.
In most cases however, using an
exitexpression makes the code untestable and often causes incompatibilities with other libraries. Thus, unless you are absolutely sure it is required here, we recommend to refactor your code to avoid its usage.