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

[Jojo]

Ameryki to Ty nie odkryłeś. Jakbyś przeszukał forum, to zobaczyłbyś, że podobna klasa już była tu prezentowana.

Moim zdaniem to co pokazujesz to nic specjalnego...

[ergo]

Ameryki to Ty nie odkryłeś. Jakbyś przeszukał forum, to zobaczyłbyś, że podobna klasa już była tu prezentowana.

Moim zdaniem to co pokazujesz to nic specjalnego...

za to ty zbyt konstruktywny nie jestes, to ze nie jest odkrywcze to wiem, ja sie pytam co mozna ulepszyc i rozszerzyc, byle nie kosztem wydajnosci.

[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.

[ergo]

dzieki , juz poprawilem

[NuLL]

A co kiedy ja musze jednoczesnie operowac na dwoch wynikach dwoch zapytan

[ergo]

przyznam sie ze nie mialem takiej sytuacji jeszcze, mozesz podac jakis konkretny przyklad zastosowania? bo nie bardzo widze do czego zmierzasz i jak by to moglo byc uzyte ( wiec zaimplementowane).