File Source for vmsql.mysqli.php

<?php
/**
* LIBRERIA SQL per MySQL(i) con gestione errori ed altre utility
*
* @package VFront
* @subpackage DB-Libraries
* @author Mario Marcello Verona <marcelloverona@gmail.com>
* @copyright 2007 Mario Marcello Verona
* @version 0.90
* @see vmsql.postgres.php
* @license http://www.gnu.org/licenses/gpl.html GNU Public License
*/
/**
* @desc Esegue una query $sql
* @param string $sql
* @param object $link_db
* @param bool $transazione
* @return object
*/
function vmsql_query($sql,$link_db,$transazione=false){
if($GLOBALS['DEBUG_SQL']) $GLOBALS['DEBUG_SQL_STRING'][] = $sql;
$obj = @mysqli_query($link_db,$sql,MYSQLI_STORE_RESULT) or vmsql_error($sql,mysqli_error($link_db),$transazione,$link_db);
return $obj;
/*else {
vmsql_error($sql,"Link al DB non disponibile",$transazione,$link_db);
return false;
}*/
}
/**
* Esegue una query $sql e restisce vero|falso a seconda dell'esito
* il secure_mode (di default) permette l'uso di sole query SELECT.
* Se l'sql contiene errori la funzione restituisce false, ma l'esecuzione prosegue.
*
* @param string $sql
* @param object $link_db
* @param bool $secure_mode
* @return bool
*/
function vmsql_try($sql,$link_db,$secure_mode=true,$prendi_errorn=false){
$sql=trim(str_replace(array("\n","\r")," ",$sql));
if($secure_mode){
// piccolo accorgimento per la sicurezza...
if(!preg_match("'^SELECT 'i",$sql)) return 0;
$sql=preg_replace("'([\W](UPDATE)|(DELETE)|(INSERT)|(DROP)|(ALTER)|(UNION)[\W])|;'ui","",$sql);
}
if(is_object($link_db)){
$res = @mysqli_query($link_db,$sql);
if($res) @mysqli_free_result($res);
}
// se si vuole intercettare l'eventuale codice errore
if($prendi_errorn){
$errn = @mysqli_errno($link_db);
if($errn>0){
$fp=@fopen("./rpc.debug.txt","a");
fwrite($fp,date("Y-m-d H:i:s")." --- $errn ---".@mysqli_error($link_db)."\n");
fclose($fp);
return $errn;
}
}
return ($res) ? 1:0;
}
/**
* @desc Funzione di fetch_row
* @return array
* @param resource $res
*/
function vmsql_fetch_row(&$res){
if(is_object($res)){
$RS= @mysqli_fetch_row($res);
if($RS) return $RS;
else return false;
}
}
/**
* @desc Funzione di fetch_assoc
* @return array
* @param resource $res
*/
function vmsql_fetch_assoc(&$res){
if(is_object($res)){
$RS= @mysqli_fetch_assoc($res);
if($RS) return $RS;
else return false;
}
}
/**
* @desc Funzione di fetch_array
* @return array
* @param resource $res
*/
function vmsql_fetch_array(&$res){
if(is_object($res)){
$RS= @mysqli_fetch_array($res);
if($RS) return $RS;
else return false;
}
}
/**
* @desc Funzione di num_rows
* @return array
* @param resource $res
*/
function vmsql_num_rows(&$res){
if(is_object($res)){
return @mysqli_num_rows($res);
}
}
/**
* @desc Funzione di insert ID che restituisce l'ultimo ID autoincrement inserito (MySQL)
* @param resource $res
* @param string $tablename Per compatibilità con Postgres
* @param string $fieldname Per compatibilità con Postgres
* @return int
*/
function vmsql_insert_id($link,$tablename=null,$fieldname=null){
if(is_object($link)){
return mysqli_insert_id($link);
}
else{
return null;
}
}
/**
* @desc Funzione di affected_rows
* @return int
* @param resource $link
* @param resource $query Per compatibilità con Postgres
*/
function vmsql_affected_rows($link,$query){
if(is_object($link)){
return @mysqli_affected_rows($link);
}
}
/**
* @desc Funzione di num_fields
* @return int
* @param string $dbname
*/
function vmsql_num_fields($dbname){
return @mysqli_num_fields($dbname);
}
/**
* @desc Funzione di free_result
* @return void
* @param string $result
*/
function vmsql_free_result($result){
mysqli_free_result($result);
}
#########################################################################################
#
#
# FUNZIONI DI ELABORAZIONE
#
/**
* @return array (matrice)
* @param resource $res
* @desc Funzione utility di fetch_assoc che restituisce tutta la matrice dei risultati
*/
function vmsql_fetch_assoc_all(&$res, $reverse=false){
if(is_object($res)){
$matrice=array();
while($RS= vmsql_fetch_assoc($res)) $matrice[]=$RS;
vmsql_free_result($res);
if($reverse)
return vmsql_reverse_matrix($matrice);
else
return $matrice;
}
}
/**
* @return matrix
* @param matrix $matrix
* @desc restituisce una traslata della matrice partendo da indici numerici
*/
function vmsql_reverse_matrix($matrix){
if(!is_array($matrix)) return false;
$keys = array_keys($matrix[0]);
for($i=0;$i<count($matrix);$i++){
for($j=0;$j<count($keys);$j++) $rev[$keys[$j]][$i] = $matrix[$i][$keys[$j]];
}
return $rev;
}
/**
* @return resource
* @param resource $res
* @desc Funzione utility di fetch_row che restituisce tutta la matrice dei risultati
*/
function vmsql_fetch_row_all(&$res,$reverse=false){
if(is_object($res)){
while($RS= vmsql_fetch_row($res)) $matrice[]=$RS;
vmsql_free_result($res);
if($reverse)
return vmsql_reverse_matrix($matrice);
else
return $matrice;
}
}
/**
* Funzione che recupera le informazioni sui campi di una tabella data
*
* @param string $tabella
* @param resource $link_db
* @return array
*/
/*function vmsql_fields($tabella,$link_db){
$res = vmsql_query("SELECT * FROM $tabella LIMIT 1",$link_db);
$i = @pg_num_fields($res);
for ($j = 0; $j < $i; $j++) {
$fieldname = @pg_field_name($res, $j);
$tab_fields[$fieldname]=@pg_field_type($res, $j);
}
return $tab_fields;
}*/
/**
* Recupera informazioni dal file e dalla query ed apre la funzione openError del file design/layouts.php dove cancella il buffer e manda a video l'errore codificato
*
* @return void
* @param string $sql
* @param string $message
* @desc Handler degli errori per le query.
*/
function vmsql_error($sql, $message, $transazione=false, $link_db=false){
global $file_DB_error_log;
$GLOBALS['VMSQL_ERROR']=true;
if($transazione){
vmsql_rollback($link_db);
}
// se è impostato il DEBUG si ferma qui.
if($GLOBALS['DEBUG_SQL']) return vmsql_error_debug($sql,$message);
// prende il tipo query (SELECT , INSERT, UPDATE, DELETE) se il tipo è diverso ahi ahi
$tipo_query = substr(trim($sql), 0 , strpos(trim($sql)," "));
// restituisci la query che ha dato errore
$sql_una_linea = str_replace(array("\n","\t")," ",$sql);
$sql_una_linea = trim(preg_replace("'[ ]+'"," ",$sql_una_linea));
// Scrittura del file di errore
$dascrivere= date("Y-m-d H:i:s")."\t"
. realpath(basename($_SERVER['PHP_SELF'])) . "\t"
. $_SERVER['HTTP_HOST']. " (".$_SERVER['SERVER_ADDR']. ")\t"
. $_SESSION['sessid'] . "\t"
. "Errore in ".$tipo_query . "\t"
. $linea_err . "\t"
. $message . "\t"
. $sql_una_linea. "\n";
$fp=fopen($file_DB_error_log,"a");
fwrite($fp,$dascrivere);
fclose($fp);
if(!function_exists('openError')){
include_once(FRONT_REALPATH."/inc/layouts.php");
}
// richiamo la funzione openError
openError($tipo_query, str_replace("\t","\n",$dascrivere));
exit;
}
/**
* Questa funzione viene eseguita da {@link vmsql_query} qualora il debug sia attivato
* @desc Funzione che restituisce a video l'SQL che ha generato l'errore
* @param unknown_type $sql
* @param unknown_type $message
*/
function vmsql_error_debug($sql,$message=""){
echo "<pre>Errore su: ".$sql."\n".$message."</pre>";
}
// FUNZIONI DI TRANSAZIONE
/**
* @desc Funzione di transazione che corrisponde ad un BEGIN
* @param resource $link_db
*/
function vmsql_begin($link_db){
mysqli_autocommit($link_db, FALSE);
}
/**
* @desc Funzione di transazione di ROLLBACK
* @param resource $link_db
*/
function vmsql_rollback($link_db){
mysqli_rollback($link_db);
}
/**
* @desc Funzione di transazione di COMMIT
* @param resource $link_db
*/
function vmsql_commit($link_db){
mysqli_commit($link_db);
}
/**
* Funzione di utilità
* Testa l'esistenza di un $valore (di solito l'ID) nel $campo di una $tabella,
* con eventuali clausole $and
*
* @param resource $link_db
* @param string $campo
* @param mixed $valore_id
* @param string $tabella
* @param string $and
* @return bool
*/
function vmsql_test_id($link_db,$campo,$valore_id,$tabella,$and="",$secure_test=false){
$sql= "SELECT * FROM $tabella WHERE $campo=$valore_id $and";
if($secure_test){
if(vmsql_try($sql,$link_db)){
$q=vmsql_query($sql,$link_db);
return (vmsql_num_rows($q)>0) ? true:false;
}
else return null;
}
else{
$q=vmsql_query($sql,$link_db);
return (vmsql_num_rows($q)>0) ? true:false;
}
}
?>

	VFront DB-Libraries

[ class tree: VFront ] [ index: VFront ] [ all elements ]

Source for file vmsql.mysqli.php