<?php

class db {

	/*	Members
	 */

	private $db_user;
	
	private $db_pass;
	
	private $db_name;
	
	private $db_server;

	private $link;
	
	private $result_id;


	/*	Methods
	 */
	
	public function __construct($user=DB_USER, $pass=DB_PASS, $name=DB_NAME, $server=DB_SERVER){
	
		$this->db_user = $user;
		$this->db_pass = $pass;
		$this->db_name = $name;
		$this->db_server = $server;
	
		$this->connect();
	
	}
	
	private function connect(){
		
		$this->link = @mysql_connect($this->db_server,$this->db_user,$this->db_pass) or die("can't connect to database");
		@mysql_select_db($this->db_name,$this->link) or die("can't select db (".$this->db_name.")";		
	
	}	
	
	private function disconnect(){
	
		@mysql_close($this->link);
		
	}
	
	public function select($params){
	
		extract($params);
	
		$sql = 'SELECT '.$fields.' FROM '.$table;
		
		if(!empty($where)){
			$sql .= ' WHERE '.$where;
		}
		
		if(!empty($group_by)){
			$sql .= ' GROUP BY '.$group_by;
		}
		
		if(!empty($order_by)){
			$sql .= ' ORDER BY '.$order_by;
		}
		
		if(!empty($limit)){
			$sql .= ' LIMIT '.$limit;
		}

		$this->result_id = $this->query($sql);
		
		if($this->result_id){
			$rows = $this->fetch_rows();
		}

		return $rows;
	}	
	
	public function insert($params){
		
		extract($params);
		
		$sql = 'INSERT INTO '.$table.' ('.$fields.') VALUES ('.$values.')';
		
		$this->query($sql);
		
		if($this->result_id){
			$affected_rows = $this->affected_rows();
		}
		
		return $affected_rows;	
	
	}
	
	public function delete($params){
	
		extract($params);
		
		$sql = 'DELETE FROM '.$table.' WHERE '.$where;
	
		if(is_numeric($limit)){
			$sql .= ' LIMIT '.$limit;
		}

		$this->query($sql);
		
		if($this->result_id){
			$affected_rows = $this->affected_rows();
		}
		
		return $affected_rows;		
	
	}
	
	public function update($params){
		
		extract($params);
		
		$sql = 'UPDATE '.$table.' SET '.$values.' WHERE '.$where;
		
		if(is_numeric($limit)){
			$sql .= ' LIMIT '.$limit;
		}

		$this->query($sql);
		
		if($this->result_id){
			$affected_rows = $this->affected_rows();
		}
		
		return $affected_rows;				
	
	}
	
	private function query($sql){
	
		$this->result_id = @mysql_query($sql);
		
		return $this->fetch_rows();
	
	
	}	
	
	private function fetch_rows(){
		
		$rows = array();
	
		if($this->result_id){
			while($row = @mysql_fetch_object($this->result_id)){
				$rows[] = $row;
			}			
		}

		return $rows;	
		
	}
	
	private function affected_rows(){
	
		return mysql_affected_rows($this->link);
	
	}
	
	public function __destruct(){
	
		$this->disconnect();
			
	}

}
?>