Subversion Repositories Sites.tela-botanica.org

<?php

/***************************************************************************\
 *  SPIP, Systeme de publication pour l'internet                           *
 *                                                                         *
 *  Copyright (c) 2001-2005                                                *
 *  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.   *
\***************************************************************************/


//
// Ce fichier ne sera execute qu'une fois
if (defined("_ECRIRE_INC_DB_MYSQL")) return;
define("_ECRIRE_INC_DB_MYSQL", "1");

//
// Appel de requetes SQL
//

function spip_query_db($query) {
        global $spip_mysql_link;
        static $tt = 0;
        $my_admin = (($GLOBALS['connect_statut'] == '0minirezo') OR ($GLOBALS['auteur_session']['statut'] == '0minirezo'));
        $my_profile = ($GLOBALS['mysql_profile'] AND $my_admin);
        $my_debug = ($GLOBALS['mysql_debug'] AND $my_admin);

        $query = traite_query($query);

        #spip_log($query);
        if ($my_profile)
                $m1 = microtime();

        if ($GLOBALS['mysql_rappel_connexion'] AND $spip_mysql_link)
                $result = mysql_query($query, $spip_mysql_link);
        else
                $result = mysql_query($query);

        if ($my_profile) {
                $m2 = microtime();
                list($usec, $sec) = explode(" ", $m1);
                list($usec2, $sec2) = explode(" ", $m2);
                $dt = $sec2 + $usec2 - $sec - $usec;
                $tt += $dt;
                echo "<small>".htmlentities($query);
                echo " -> <font color='blue'>".sprintf("%3f", $dt)."</font> ($tt)</small><p>\n";

        }

        if ($s = mysql_error()) {
                if ($my_debug) {
                        echo _T('info_erreur_requete')." ".htmlentities($query)."<br>";
                        echo "&laquo; ".htmlentities($s)." &raquo;<p>";
                }
                spip_log($GLOBALS['REQUEST_METHOD'].' '.$GLOBALS['REQUEST_URI'], 'mysql');
                spip_log("$s - $query", 'mysql');
        }

        # spip_log("$s - $query", 'mysql');

        return $result;
}

// fonction appelant la precedente 
// specifiquement pour les select des squelettes
// c'est une instance de spip_abstract_select, voir ses specs dans inc_calcul
// les \n et \t sont utiles au debusqueur
// traite_query pourrait y est fait d'avance, à moindre cout

function spip_mysql_select($select, $from, $where,
                           $groupby, $orderby, $limit,
                           $sousrequete, $having,
                           $table, $id, $serveur) {

        $q = ($from  ?("\nFROM " . join(",\n\t", $from)) : '')
          .  ($where ? ("\nWHERE " . join("\n\tAND ", $where)) : '')
          .  ($groupby ? "\nGROUP BY $groupby" : '')
          .  ($having  ? "\nHAVING $having" : '')
          .  ($orderby ? ("\nORDER BY " . join(", ", $orderby)) : '')
          .  ($limit ? "\nLIMIT $limit" : '');

        if (!$sousrequete)
                $q = " SELECT ". join(", ", $select) . $q;
        else
                $q = " SELECT S_" . join(", S_", $select)
                . " FROM (" . join(", ", $select)
                . ", COUNT(".$sousrequete.") AS compteur " . $q
                .") AS S_$table WHERE compteur=" . $cpt;

        // Erreur ? C'est du debug de squelette, ou une erreur du serveur

        if ($GLOBALS['var_mode'] == 'debug') {
                boucle_debug_resultat($id, 'requete', $q);
        }

        if (!($res = @spip_query($q))) {
                include_ecrire('inc_debug_sql.php3');
                erreur_requete_boucle($q, $id, $table,
                                      spip_sql_errno(),
                                      spip_sql_error());
        }
#        spip_log($serveur . spip_num_rows($res) . $q);
        return $res;
}

//
// Passage d'une requete standardisee
// Quand tous les appels SQL seront abstraits on pourra l'ameliorer

function traite_query($query) {
        if ($GLOBALS['table_prefix']) $table_pref = $GLOBALS['table_prefix']."_";
        else $table_pref = "";

        if ($GLOBALS['mysql_rappel_nom_base'] AND $db = $GLOBALS['spip_mysql_db'])
                $db = '`'.$db.'`.';

        // changer les noms des tables ($table_prefix)
        if (preg_match('/\s(SET|VALUES|WHERE)\s/i', $query, $regs)) {
                $suite = strstr($query, $regs[0]);
                $query = substr($query, 0, -strlen($suite));
        }
        $query = preg_replace('/([,\s])spip_/', '\1'.$db.$table_pref, $query) . $suite;

        return $query;
}

//
// Connexion a la base
//

function spip_connect_db($host, $port, $login, $pass, $db) {
        global $spip_mysql_link, $spip_mysql_db;        // pour connexions multiples

        // gerer le fichier ecrire/data/mysql_out
        ## TODO : ajouter md5(parametres de connexion)
        if (@file_exists(_FILE_MYSQL_OUT)
        AND (time() - @filemtime(_FILE_MYSQL_OUT) < 120)
        AND !defined('_ECRIRE_INSTALL'))
                return $GLOBALS['db_ok'] = false;

        if ($port > 0) $host = "$host:$port";
        $spip_mysql_link = @mysql_connect($host, $login, $pass);
        $spip_mysql_db = $db;
        $ok = @mysql_select_db($db);

        $GLOBALS['db_ok'] = $ok
        AND !!@spip_num_rows(@spip_query_db('SELECT COUNT(*) FROM spip_meta'));

        // En cas d'erreur marquer le fichier mysql_out
        if (!$GLOBALS['db_ok']
        AND !defined('_ECRIRE_INSTALL')) {
                spip_log("La connexion MySQL est out!");
                @touch(_FILE_MYSQL_OUT);
        }

        return $GLOBALS['db_ok'];
}


//
// Recuperation des resultats
//

function spip_fetch_array($r) {
        if ($r)
                return mysql_fetch_array($r);
}

/* Appels obsoletes
function spip_fetch_object($r) {
        if ($r)
                return mysql_fetch_object($r);
}

function spip_fetch_row($r) {
        if ($r)
                return mysql_fetch_row($r);
}
*/

function spip_sql_error() {
        return mysql_error();
}

function spip_sql_errno() {
        return mysql_errno();
}

function spip_num_rows($r) {
        if ($r)
                return mysql_num_rows($r);
}

function spip_free_result($r) {
        if ($r)
                return mysql_free_result($r);
}

function spip_mysql_insert($table, $champs, $valeurs) {
        spip_query("INSERT INTO $table $champs VALUES $valeurs");
        return  mysql_insert_id();
}

function spip_insert_id() {
        return mysql_insert_id();
}

//
// Poser un verrou local a un SPIP donne
//
function spip_get_lock($nom, $timeout = 0) {
        global $spip_mysql_db, $table_prefix;
        if ($table_prefix) $nom = "$table_prefix:$nom";
        if ($spip_mysql_db) $nom = "$spip_mysql_db:$nom";

        $nom = addslashes($nom);
        $q = spip_query("SELECT GET_LOCK('$nom', $timeout)");
        list($lock_ok) = spip_fetch_array($q);

        if (!$lock_ok) spip_log("pas de lock sql pour $nom");
        return $lock_ok;
}

function spip_release_lock($nom) {
        global $spip_mysql_db, $table_prefix;
        if ($table_prefix) $nom = "$table_prefix:$nom";
        if ($spip_mysql_db) $nom = "$spip_mysql_db:$nom";

        $nom = addslashes($nom);
        spip_query("SELECT RELEASE_LOCK('$nom')");
}


//
// IN (...) est limite a 255 elements, d'ou cette fonction assistante
//
function calcul_mysql_in($val, $valeurs, $not='') {
        if (!$valeurs) return '0=0';

        $n = $i = 0;
        $in_sql ="";
        while ($n = strpos($valeurs, ',', $n+1)) {
          if ((++$i) >= 255) {
                        $in_sql .= "($val $not IN (" .
                          substr($valeurs, 0, $n) .
                          "))\n" .
                          ($not ? "AND\t" : "OR\t");
                        $valeurs = substr($valeurs, $n+1);
                        $i = $n = 0;
                }
        }
        $in_sql .= "($val $not IN ($valeurs))";

        return "($in_sql)";
}

?>