Wygodna klasa obslugi mysql, klasa obslugi mysql lub innych baz po drobnej modyfikacji funkcji Opcje

[ergo]

co sadzicie o takim podejsciu do biblioteki obslugujacej baze ?
dziala w php4, zawiera raportowanie bledow, posiada mozliwosc wyboru pomiedzy buforowaniem zapytan, potrafi cacheowac zapytania, i ma wsparcie dla transakcji.

chetnie uslysze co jest nie tak oraz co mozna ulepszyc.

przyklad uzycia

[PHP] pobierz, plaintext 
<?php
$db = new sqlklasa(DB_HOST,DB_LOGIN,DB_PASS,DB_NAME);
 
if($validator->ok['login'] && $validator->ok['password']){
	$db->fetcharray('SELECT * FROM '.DB_PREFIX.'users WHERE login='.$db->sqlquote($input->post('login')).' AND pass='.$db->sqlquote(md5($input->post('password'))));
	if(!empty($db->rekordy)){
		$_SESSION['user']=$db->rekordy[0];
	$db->zapytaj('UPDATE '.DB_PREFIX.'users SET data_ostatniego_logowania='.time().' WHERE id='.$_SESSION['user']['id']);
	}
}
 
?>
[PHP] pobierz, plaintext 

[PHP] pobierz, plaintext 
<?php
/**
 * Tworzy polaczenie do bazy i zapewnia uniwersalny interfejs zapytan
 * @author ergo
 * @version 1.0
 * @access public
 */
class sqlklasa {
	/**
	 * nazwa bazy
	 *
	 * @var integer
	 */
	var $baza;
	/**
	 * ilosc wykonanych zapytan
	 *
	 * @var integer
	 */
	var $zapytan;
	/**
	 * wynik wykonania zapytania
	 *
	 * @var mixed
	 */
	var $wynik;
	/**
	 * rekordy zwrocone przez serwer sql
	 *
	 * @var array
	 */
	var $rekordy;
	/**
	 * identyfikator polaczenia sql
	 *
	 * @var unknown_type
	 */
	var $link;
	/**
	 * tablica zawierajaca blednie wykonane zapytania
	 *
	 * @var array
	 */
	var $error;
	/**
	 * tablice zawierajaca dobrze wykonane zapytania
	 *
	 * @var array
	 */
	var $sql;
	/**
	 * buforujemy czy nie
	 *
	 * @var boolean
	 */
	var $buffered;
	/**
	 * postarcza polaczenia z baza danych
	 *
	 * @param string $host
	 * @param string $login
	 * @param string $pass
	 * @param string $baza
	 */
	function sqlklasa($host, $login, $pass, $baza) {
		$this->link = mysql_connect($host, $login, $pass);
		$this->baza = $baza;
		$this->buffered = false;
		if (!$this->link) {
			$this->error[]=mysql_errno($this->link).':'.mysql_error($this->link);
		}
		$db_selected = mysql_select_db($this->baza, $this->link);
		if (!$db_selected) {
			$this->error[]=mysql_errno($this->link).':'.mysql_error($this->link);
		}
	}
	/**
	 * rozpoczyna transakcje 
	 */
	function rozpocznij_transakcje(){
		$this->zapytaj('SET AUTOCOMMIT = 0');
		$this->zapytaj('BEGIN');
	}
	/**
	 * zakoncza transakcje
	 */
	function zakoncz_transakcje(){
		if(!empty($this->error)){
			$this->zapytaj('ROLLBACK');
		}else{
			$this->zapytaj('COMMIT');
		}
	}
	/**
	 * wykonuje zapytanie do bazy
	 *
	 * @param string $zmienna
	 */
	function zapytaj($zmienna) {
		$db_selected = mysql_select_db($this->baza, $this->link);
		if (!$db_selected) {
			$this->error[]=mysql_errno($this->link).':'.mysql_error($this->link);
		}
		$this->zapytan++;
		$this->rekordy = NULL;
		if($this->buffered==false){
			$this->wynik = @mysql_unbuffered_query($zmienna, $this->link);
		}else{
			$this->wynik = @mysql_query($zmienna, $this->link);
		}
 
		if ($this->wynik === false) {
			$this->error[]=mysql_errno($this->link).':'.mysql_error($this->link).' - '.$zmienna;
			return false;
		}
		else{
			$this->sql[]=$zmienna;
			return $this->wynik;
		}
	}
 
	/**
	 * pobiera dane jako tablice
	 * @param string $zmienna
	 * @param integer $cached [opcja]
	 * @param string $gdzie [opcja]
	 */
	function fetcharray($zmienna,$cached=false,$gdzie=NULL) {
		$db_selected = mysql_select_db($this->baza, $this->link);
		if (!$db_selected) {
			$this->error[]=mysql_errno($this->link).':'.mysql_error($this->link);
		}
		if(is_integer($cached) && !empty($gdzie) && (@filemtime(KATALOG_CACHE.$gdzie.'.sqlcache')>time()-$cached)) {
			$this->rekordy=@unserialize(@file_get_contents(KATALOG_CACHE.$gdzie.'.sqlcache'));
			$this->sql[]=$zmienna;
		}
		else{
			$this->rekordy = NULL;
			$this->zapytaj($zmienna);
			while ($wiersz = @mysql_fetch_array($this->wynik)) {
				$this->rekordy[] = $wiersz;
			}
			if(is_integer($cached) && !empty($gdzie)){
				$handle = fopen(KATALOG_CACHE.$gdzie.'.sqlcache', 'wb');
				fwrite($handle,serialize($this->rekordy));
				fclose($handle);
			}
		}
 
	}
	/**
	 * zwalnia wynik zapytania z pamieci
	 *
	 */
	function zwolnij() {
		@mysql_free_result($this->wynik);
	}
	/**
	 * zamyka polaczenie z baza
	 *
	 */
	function zamknij() {
		@mysql_close($this->link);
	}
	/**
	 * zabezpiecza zmienna przed sql injection
	 *
	 * @param string $zmienna
	 * @return string
	 */
	function sqlquote($zmienna) {
		if (get_magic_quotes_gpc()) {
			$zmienna = stripslashes($zmienna);
		}
		if (is_numeric($zmienna) == FALSE) {
			$zmienna = "'".mysql_real_escape_string($zmienna)."'";
		}
		return $zmienna;
	}
?>
[PHP] pobierz, plaintext 

Ten post edytował ergo 8.07.2006, 11:30:48

[siemakuba]

w metodzie sqlquote powinieneś jeszcze sprawdzać stan magic_quotes_gpc. Jeżeli będą włączone i przekażesz dane z $_POST np. do mysql_real_escape_string zrobi się kiszka.

[PHP] pobierz, plaintext 
<?php
function sqlquote($zmienna)
{
	if(get_magic_quotes_gpc())
	{	$zmienna = stripslashes($zmienna);
	}
   // ....
}
?>
[PHP] pobierz, plaintext 

pozdr.