function db_q($query) {
global $DB;
if (!$link = @mysql_pconnect($DB[host], $DB[username], $DB[password])) {
$result = 0;
d_err("Errore nella connessione a $DB[host]!","pconnect","DATABASE");
}
else {
if (!@mysql_select_db($DB[database], $link)) {
$result = 0;
d_err("
Errore nella selezione del DB: $DB[database]
","select_db","DATABASE");
}
else {
//d_info("$DB[database]","select_db","DATABASE");
if (!$result = @mysql_query($query, $link)) {
$result = 0;
d_err("Errore nella query: $query!","query","DATABASE");
} else {
d_info("$query","query","DATABASE");
}
}
}
return $result;
}
//ritorna una array delle righe
function db_qa($query,$chiave=NULL) {
global $DB;
$q = db_q($query);
while ($riga = @mysql_fetch_array($q,MYSQL_ASSOC)) {
$a = $riga[$chiave];
//print "+$a+";
if($chiave) $array["$a"] = $riga;
else $array[] = $riga;
}
return $array;
}
//ritorna una sola riga
function db_qr($query) {
global $DB;
$q = db_q($query);
$riga = @mysql_fetch_array($q,MYSQL_ASSOC);
return $riga;
}
function db_qrs($query,$campo) {
global $DB;
$q = db_q($query);
$riga = @mysql_fetch_array($q,MYSQL_ASSOC);
return $riga[$campo];
}
function db_qf($query,$funzione="db_qf_array") {
//funzione di base
function db_qf_array($V){
return $V;
}
global $DB;
$q = db_q($query);
while ($V = @mysql_fetch_array($q,MYSQL_ASSOC)) {
$out[] = $funzione($V);
}
return $out;
}
//queri con risultati separati da un separatore
function db_qsep($query,$campo,$sep="|") {
global $DB;
$q = db_q($query);
while ($riga = @mysql_fetch_array($q,MYSQL_ASSOC)) {
$a = $riga[$campo];
//print "+$a+";
$out .= $a.$sep;
}
return $out;
}
//queri con risultati in un array chiave valore
function db_qkv($query,$kk,$vv) {
global $DB;
$q = db_q($query);
while ($riga = @mysql_fetch_array($q,MYSQL_ASSOC)) {
$k = $riga["$kk"];
$v = $riga["$vv"];
//print "+$a+";
$out[$k] = $v;
}
return $out;
}
function db_connect()
{
global $DB;
if (!$DB[link] = @mysql_pconnect($DB[host], $DB[username], $DB[password])) {
$result = 0;
print ("
Errore nella connessione a $db_host!");
}
else {
if (!@mysql_select_db($DB[database], $DB[link])) {
$result = 0;
print ("
Errore nella selezione del
");
}
}
}
function db_connect2()
{
global $db, $var_Global;
$db = mysql_connect($var_Global["db_host"], $var_Global["db_username"], $var_Global["db_password"]);
if (!$db) die("Impossibile collegarsi al database\n");
if (!mysql_select_db($var_Global["db_nome"], $db)) die("Impossibile selezionare il database\n");
}
function db_query($sql,$msg="")
{
global $DB;
$res = mysql_query($sql, $DB[link]);
if(!$res) {
print "
ERRORE: ".mysql_error()." query SQL: [ $sql ]";
if($msg){
echo " - $msg
";
die();
}
}
return $res;
}
function db_lastid($tabella,$campo)
{
global $DB;
$res=db_query("select $campo from $tabella order by $campo desc limit 1","Impossibile selezionare l'ultimo id");
list($lastid) = mysql_fetch_row($res);
return $lastid + 1;
}
?>