X-Git-Url: http://git.cyclocoop.org/?p=velocampus%2Fweb%2Fwww.git;a=blobdiff_plain;f=www%2Fecrire%2Fbase%2Fconnect_sql.php;fp=www%2Fecrire%2Fbase%2Fconnect_sql.php;h=6e5b8a48e59c6d1f830009c0ca834e4ac2a2e006;hp=0000000000000000000000000000000000000000;hb=80b4d3e85f78d402ed2e73f8f5d1bf4c19962eed;hpb=aaf970bf4cdaf76689ecc10609048e18d073820c

diff --git a/www/ecrire/base/connect_sql.php b/www/ecrire/base/connect_sql.php
new file mode 100644
index 0000000..6e5b8a4
--- /dev/null
+++ b/www/ecrire/base/connect_sql.php
@@ -0,0 +1,358 @@
+<?php
+
+/***************************************************************************\
+ *  SPIP, Systeme de publication pour l'internet                           *
+ *                                                                         *
+ *  Copyright (c) 2001-2011                                                *
+ *  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
+//
+
+// 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;
+
+	$serveur = !is_string($serveur) ? '' : strtolower($serveur);
+	$index = $serveur ? $serveur : 0;
+	if (!$version) $version = $spip_sql_version;
+	if (isset($connexions[$index][$version])) return $connexions[$index];
+
+	include_spip('base/abstract_sql');
+	$install = (_request('exec') == 'install');
+
+	// Premiere connexion ?
+	if (!($old = isset($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 $readable)
+				spip_log("spip_connect: fichier de connexion '$f' OK.");
+			else
+				spip_log("spip_connect: fichier de connexion '$f' non trouve");
+			spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.");
+			// ne plus reessayer si ce n'est pas l'install
+			return $connexions[$index]=false;
+		}
+		$connexions[$index] = $GLOBALS['db_ok'];
+	}
+	// si la connexion a deja ete tentee mais a echoue, le dire!
+	if (!$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'");
+			// ne plus reessayer
+			return $connexions[$index][$version] = array();
+		}
+	}
+	$connexions[$index][$version] = $GLOBALS[$jeu];
+	if ($old) return $connexions[$index];
+
+	$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]);
+		if (!$charset) {
+			unset($connexions[$index]);
+			spip_log("spip_connect: absence de charset");
+			return false;
+		}
+	} else	{
+		if ($connexions[$index]['spip_connect_version']
+		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 $connexions[$index];
+}
+
+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'];
+	$f = $t . $serveur;
+	spip_log($m, $f);
+}
+
+// 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) {
+	$desc = spip_connect($serveur, $version);
+	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'");
+	include_spip('inc/minipres');
+	echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'));
+	exit;
+}
+
+// Fonction appelee par le fichier cree dans config/ a l'instal'.
+// Il contient un appel direct a 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
+function spip_connect_db($host, $port, $login, $pass, $db='', $type='mysql', $prefixe='', $auth='') {
+	global $db_ok;
+
+	## TODO : mieux differencier les serveurs
+	$f = _DIR_TMP . $type . 'out';
+
+	if (@file_exists($f)
+	AND (time() - @filemtime($f) < 30)
+	AND !defined('_ECRIRE_INSTALL')) {
+		spip_log("Echec : $f recent. Pas de tentative de connexion");
+		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");
+		return;
+	}
+	if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
+
+		if (!is_array($auth)) {
+			// compatibilite version 0.7 initiale
+			$g['ldap'] = $auth;
+			$auth = array('ldap' => $auth);
+		}
+		$g['authentification'] = $auth;
+		$g['type'] = $type;
+		return $db_ok = $g;
+	}
+	// En cas d'indisponibilite du serveur, eviter de le bombarder
+	if (!defined('_ECRIRE_INSTALL')) {
+		@touch($f);
+		spip_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type);
+	}
+}
+
+// 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){
+		include_spip('inc/headers');
+		redirige_url_ecrire('upgrade', 'reinstall=oui');
+	}
+
+	if (!($f = $connexion['select'])) return false;
+	if (!$r = $f('valeur','spip_meta', "nom='charset_sql_connexion'"))
+		return false;
+	if (!($f = $connexion['fetch'])) return false;
+	$r = $f($r);
+	return ($r['valeur'] ? $r['valeur'] : -1);
+}
+
+// compatibilite
+function spip_connect_ldap($serveur='') {
+	include_spip('auth/ldap');
+	return auth_ldap_connect($serveur);
+}
+
+// 1 interface de abstract_sql a demenager dans base/abstract_sql a terme
+
+// http://doc.spip.org/@_q
+function _q ($a) {
+	return (is_numeric($a)) ? strval($a) :
+		(!is_array($a) ? ("'" . addslashes($a) . "'")
+		 : join(",", array_map('_q', $a)));
+}
+
+// Nommage bizarre des tables d'objets
+// http://doc.spip.org/@table_objet
+function table_objet($type) {
+	static $surnoms = null;
+	if (!$type) return;
+	if (!$surnoms){
+		// passer dans un pipeline qui permet aux plugins de declarer leurs exceptions
+		$surnoms = pipeline('declarer_tables_objets_surnoms',
+			array(
+				'article' => 'articles',
+				'auteur' => 'auteurs',
+				'breve' => 'breves',
+				'document' => 'documents',
+				'doc' => 'documents', # pour les modeles
+				'img' => 'documents',
+				'emb' => 'documents',
+				'groupe_mots' => 'groupes_mots', # hum
+				'groupe_mot' => 'groupes_mots', # hum
+				'groupe' => 'groupes_mots', # hum (EXPOSE)
+				'message' => 'messages',
+				'mot' => 'mots',
+				'petition' => 'petitions',
+				'rubrique' => 'rubriques',
+				'signature' => 'signatures',
+				'syndic' => 'syndic',
+				'site' => 'syndic', # hum hum
+				'syndic_article' => 'syndic_articles',
+				'type_document' => 'types_documents', # hum
+				'extension' => 'types_documents' # hum
+			));
+	}
+	return isset($surnoms[$type])
+		? $surnoms[$type]
+		: preg_replace(',ss$,', 's', $type."s");
+}
+
+// http://doc.spip.org/@table_objet_sql
+function table_objet_sql($type) {
+	global $table_des_tables;
+	$nom = table_objet($type);
+	include_spip('public/interfaces');
+	if (isset($table_des_tables[$nom])) {
+		$t = $table_des_tables[$nom];
+		$nom = 'spip_' . $t;
+	}
+	return $nom ;
+}
+
+// http://doc.spip.org/@id_table_objet
+function id_table_objet($type,$serveur='') {
+	$type = preg_replace(',^spip_|s$,', '', $type);
+	if ($type == 'type')
+		return 'extension';
+	else {
+		if (!$type) return;
+		$t = table_objet($type);
+		$trouver_table = charger_fonction('trouver_table', 'base');
+		$desc = $trouver_table($t,$serveur);
+		return @$desc['key']["PRIMARY KEY"];
+	}
+}
+
+// http://doc.spip.org/@objet_type
+function objet_type($table_objet){
+	static $surnoms = null;
+	if (!$surnoms){
+		// passer dans un pipeline qui permet aux plugins de declarer leurs exceptions
+		$surnoms = pipeline('declarer_type_surnoms', array());
+	}
+	
+	// scenario de base
+	// le type est decline a partir du nom de la table en enlevant le prefixe eventuel
+	// et la marque du pluriel
+	$type = preg_replace(',^spip_|s$,', '', $table_objet);
+	if (isset($surnoms[$type]))
+		return $surnoms[$type];
+
+	// si le type redonne bien la table c'est bon
+	if ( (table_objet($type)==$table_objet)
+	  OR (table_objet_sql($type)==$table_objet))
+	  return $type;
+
+	// sinon on passe par la cle primaire id_xx pour trouver le type
+	// car le s a la fin est incertain
+	// notamment en cas de pluriel derogatoire
+	// id_jeu/spip_jeux id_journal/spip_journaux qui necessitent tout deux
+	// une declaration jeu => jeux, journal => journaux
+	// dans le pipeline declarer_tables_objets_surnoms
+	$trouver_table = charger_fonction('trouver_table', 'base');
+	if ($desc = $trouver_table($table_objet)
+	  AND isset($desc['key']["PRIMARY KEY"])){
+		$primary = $desc['key']["PRIMARY KEY"];
+		$primary = explode(',',$primary);
+		$primary = reset($primary);
+		$type = preg_replace(',^id_,', '', $primary);
+	}
+	// on a fait ce qu'on a pu
+	return $type;
+}
+
+// Recuperer le nom de la table de jointure xxxx sur l'objet yyyy
+// http://doc.spip.org/@table_jointure
+function table_jointure($x, $y) {
+	$trouver_table = charger_fonction('trouver_table', 'base');
+	$xdesc = $trouver_table(table_objet($x));
+	$ydesc = $trouver_table(table_objet($y));
+	$tx = $xdesc['table'];
+	$ty = $ydesc['table'];
+	$ix = @$xdesc['key']["PRIMARY KEY"];
+	$iy = @$ydesc['key']["PRIMARY KEY"];
+	if ($table = $GLOBALS['tables_jointures'][$ty][$ix]) return $table;
+	if ($table = $GLOBALS['tables_jointures'][$tx][$iy]) return $table;
+	return '';
+}
+
+// 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);
+	return function_exists($f) ? $f($query, $serveur) : false;
+}
+
+?>