彷hibernate数据库操作

<?php
	/**
	 * @author:zhangmingshuang
	 * @version:2011-10-13
	 * @param:
	 */
	function __autoload($class_name){
		require(HIBERNATE_PATH.$class_name.".hbm.php");
	}
	
	
/**
 * 类似JAVA的HIBERNATE操作
 * 注意点：
 * 1.模型层文件命名型为：tablename.hbm.php (如果要使用别的命名方式，则需要更改autoload方法里的文件名格式)
 * 2.模型层的class的名为：表名 (例：class tablename{.......})
 * 3.模型层的字段需要与表的字段一致
 *
 */
class hibernate{

	
	private $table_name = "";
	private $table_fileds = "";
	private $fileds_value = "";
	
	//private
	var $host; //地址localhost:3306
	var $name; //用户名
	var $pass; //密码
	var $db; //数据库名
	var $encode; //字符编码 ，utf8, 不是utf-8。or gbk

	//构造函数
	function __construct($host, $name, $pass, $db, $encode='utf8'){
		$this->host = $host;
		$this->name = $name;
		$this->pass = $pass;
		$this->db = $db;
		$this->encode = $encode;
		$this->connect();
	}
	
	//连结数据库
	function connect(){
		$conn = mysql_connect($this->host, $this->name, $this->pass) 
		           or die("Could not connect : " . $this->error());
		mysql_select_db($this->db) 
		    or die ("Could not select database : " . $this->error());
		mysql_query("SET NAMES '$this->encode'"); //设置编码，防止中文乱码
	}
	
	//析构函数
	function __destruct(){
		$this->close();
	}
	
	
	/**
	 * 保存数据
	 * @param $class_handle : 类句柄
	 */
	function save($class_handle){
		
		$this->set_table_filed($class_handle);
		
		$fileds = substr($this->table_fileds, strpos($this->table_fileds,",")+1,strlen($this->table_fileds));
		$values = substr($this->fileds_value, strpos($this->fileds_value,",")+1,strlen($this->fileds_value));
		
		$sql = "INSERT INTO `".$this->table_name."`(".$fileds.") VALUES(".$values.")";
		
		$this->query($sql);
	}
	
	/**
	 * 得取刚新增的ID
	 */
    function get_insert_id(){
    	return mysql_insert_id();
    }
    
    /**
     * 获取数据
     * @param  $class_handle : 类句柄
     * @param  $val : 值
     * @param  $primary_key : 主建字段（默认为：模型层的第一个var）
     */
    function get($class_handle,$primary_key_val,$primary_key=''){
    	
    	$table_name = $this->get_table_name($class_handle);//取得表名
    	$filed_value_array = $this->get_filed_value($class_handle);//取得字段与值
		if(empty($primary_key)){//如果主键未输入，则默认为模型层的第一个VAR
			//取得模型层的第一个VAR
			foreach ($filed_value_array as $key=>$value) {
				$primary_key = $key;
				break;
			}
		}
    	
    	
    	$sql = "SELECT * FROM `".$table_name."` WHERE `".$primary_key."` = '".$primary_key_val."'";
    	$res = $this->query($sql);
    	//mysql_fetch_array 为 mysql_fetch_row 扩展 可取出字段
    	$rows = mysql_fetch_array($res);
    	if(!empty($rows)){
	    	foreach($rows as $key=>$val){
	    		if(is_numeric($key)){//删除 key 为数字的数据
	    			unset($rows[$key]);
	    		}
	    	}
	    	$set_array = $this->get_class_set($class_handle);//取得字段
	
	    	if(class_exists($table_name)){
	    		$obj = new $table_name();
	    		//将值SET进类中
	    		foreach($rows as $key=>$val){
					//取出取得的数据库数据的第一个记录（如：ID）匹配
					foreach ($set_array as $k => $v){
						if(strtolower($v)=='set'.$key){
							$obj->$v($val);                     
						}
					}    			
	    		}
				return $obj;    		
	    	}
    	}else{
    		return new $table_name();
    	}
    }
    
    /**
     * * 更新数据
     * @param $class_handle : 类句柄
     * @param $primary_key : 主建字段（默认为：模型层的第一个var）
     */
    function update($class_handle,$primary_key=""){
				
    	$table_name = $this->get_table_name($class_handle);//取得表名
		$filed_value_array = $this->get_filed_value($class_handle);
		if(empty($primary_key)){
			//取得模型层的第一个VAR
			foreach ($filed_value_array as $key=>$value) {
				$primary_key = $key;
				break;
			}
		}
		foreach ($filed_value_array as $k=>$v){
			if($k!=$primary_key){
				$set_sql .= "`".$k."`='".$v."',";
			}
		}
		$set_sql = rtrim($set_sql,",")."WHERE `".$primary_key."`='".$filed_value_array[$primary_key]."'";
		$sql = "UPDATE `".$table_name."` SET ".$set_sql;
		
		$this->query($sql);
    }
    
    /**
     * 删除数据
     * @param  $class_handle : 类句柄
     * @param  $primary_key_val : 要删除的值
     * @param  $primary_key : 主建字段（默认为：模型层的第一个var）
     */
    function delete($class_handle,$primary_key_val,$primary_key=''){
    	$table_name = $this->get_table_name($class_handle);//取得表名
		$filed_value_array = $this->get_filed_value($class_handle);
		if(empty($primary_key)){
			//取得模型层的第一个VAR
			foreach ($filed_value_array as $key=>$value) {
				$primary_key = $key;
				break;
			}
		}
		$sql = "DELETE FROM `".$table_name."` WHERE `".$primary_key."` = '".$primary_key_val."'";
		if(is_array($primary_key_val)){
			$primary_key_val = implode(",", $primary_key_val);
			$sql = "DELETE FROM `".$table_name."` WHERE `".$primary_key."`in(".$primary_key_val.")";
		}
		$this->query($sql);
    }
    /**
     * 查找数据
     * @param $class_handle
     */
    function find($class_handle,$order="",$order_by="DESC"){
    	$table_name = $this->get_table_name($class_handle);//取得表名
    	$sql = "SELECT * FROM `".$table_name."` WHERE 1 = 1";
    	if(!empty($order)){
    		$sql .= " ORDER BY ".$order." ".$order_by;
    	}
    	return $this->query($sql);
    }
    /**
     * 根据条件查找数据
     * @param  $sql : SQL语句
     * @param  $filed_arr : 条件
     */
	//阻止sql注入
	function p_filterXss($str){
		$str = addslashes($str);
		$str = mysql_real_escape_string($str);
		return $str;
	}
	
    function query_by_sql($sql,$filed_arr){
    	//取出SQL语句中的？代替为字段
    	for($i=0;$i<count($filed_arr);$i++){
    		$filed_obj = mysql_real_escape_string(addslashes(trim($filed_arr[$i])));
			if(strstr($sql,"?")){
				$x_index = strpos($sql,"?");//找到第一个?
				//将语句分成二段
				$sql = substr($sql, 0,$x_index)."'".$filed_arr[$i]."'".substr($sql, $x_index+1,strlen($sql));
			}    		
    	}
    	return $this->query($sql);
    }
    
	/**
     * 分頁查詢
     * @param  $sql 查詢語句
     * @param  $page 當前頁
     * @param  $pageSize 每頁條數
     */
    function find_by_page($sql,$page,$page_size=10,$filed_arr=array()){
   		 //取出SQL语句中的？代替为字段
    	for($i=0;$i<count($filed_arr);$i++){
    		$filed_obj = mysql_real_escape_string(addslashes(trim($filed_arr[$i])));
			if(strstr($sql,"?")){
				$x_index = strpos($sql,"?");//找到第一个?
				//将语句分成二段
				$sql = substr($sql, 0,$x_index)."'".$filed_arr[$i]."'".substr($sql, $x_index+1,strlen($sql));
			}    		
    	}
    	$page = empty($page) ? 1 : $page;
    	return $this->query($sql." LIMIT " . ($page-1) * $page_size . ",$page_size");
    }
    
	//返回记录集	
	function get_rows($result){
		$rowNum = @mysql_num_rows($result);
		if ($rowNum > 0){
			for ($i=0; $i<$rowNum; $i++){
				$rows[$i] = mysql_fetch_array($result);
			}
		}
		return $rows;		
	}
	//返回错误
	function error(){
		return mysql_error();
	}
	//关闭
	function close() {
		return @mysql_close();
	}
	/**
	 * mysql_query() 仅对 SELECT，SHOW，EXPLAIN 或 DESCRIBE 语句返回一个资源标识符，如果查询执行不正确则返回 FALSE。
	 * 对于其它类型的 SQL 语句，mysql_query() 在执行成功时返回 TRUE，出错时返回 FALSE。	 * 
	 * @param string $sql
	 * return TRUE/FALSE or 资源标识符
	 */
	function query($sql){
		$result =  mysql_query($sql) 
		          or die("Query failed : " . $this->error());
		return $result;
	}
	
	//統計記錄數
	function count($result){
		$rows_num = mysql_num_rows($result);
		return $rows_num;		
	}
    
	/**
	 * 将类名（表名）与类里的var（字段名）历遍取出
	 * @param $class_handle:类句柄
	 */
	function set_table_filed($class_handle){
		
		$this->table_name = get_class($class_handle);	  //取得表名
		$object_vars = get_object_vars($class_handle);//取得字段与值
		//将字段数组转成字符串
		$filed_array = array();$value_array = array();
		foreach ($object_vars as $key=>$val){
			array_push($filed_array, '`'.$key.'`');
			array_push($value_array, '\''.$val.'\'');
		}
		$this->table_fileds = implode(",", $filed_array);
		$this->fileds_value = implode(",", $value_array);
	}
	/**
	 * 获取表名
	 * @param unknown_type $class_hanle
	 */
	function get_table_name($class_handle){
		return get_class($class_handle);
	}
	/**
	 * 取得类中的属性，生成SET的方法
	 * @param unknown_type $class_handle
	 */
	function get_class_set($class_handle){
		$new_array = array();
		$filed_array = get_object_vars($class_handle);//取得字段与值
		foreach ($filed_array as $key=>$val){
			array_push($new_array, "set".ucfirst($key));
		}
		return $new_array;
	}
	/**
	 * 取得类中的属性及对应值
	 * @param unknown_type $class_handle
	 */
	function get_filed_value($class_handle){
		return get_object_vars($class_handle);//取得字段与值
	}
}




#--------------------Example-------------------------------
#	要使用此方法需要配置HIBERNATE_PATH常量，指向：模型层的路径（model/）
#  	model模层建立规则：
#	1.名字：类名.hbm.php 
#	2.类名：table_name   (class table_name{   })
#	3.字段：即对表相对应的字段名（要与数据库一致）  (var $id="";var $username="".....)
#	4.要配置GET  AND SET 方法
#	@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#	使用方法
#	首先，需要实例化：hibernate对像即
#	$hibernate = new hibernate(DB_HOST, DB_USER, DB_PASS, DB_NAME);
#	@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#	**调用保存
#   $admin = new admin(); //不用配置inclue(require  or include_once  or require_once)
#	$admin->setUsername('admin');
#	$admin->setNo('no');
#	....
#	$hibernate->save($admin);
#	**获取刚刚新增的数据ID
#	$id = $hibernate->get_insert_id();
#	@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#	**根据ID获取数据
#	$admin = new admin();//因为无法预知是否会事先初使化数据，所以，所有方法需要调进句柄
#	$admin_get = $hibernate->get($admin,$id);//具体参数请自己查看
#	@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#	**更新
#	$admin = new admin();
#	$admin_get = $hibernate->get($admin,$id);
#	$admin_get->setUsername('admin');
#	$admin_get->setNo('no');
#  	$hibernate->update($admin_get);//更新的时候，不传ID 但是不能执行 $admin_get->setId(1)，这样就更新别的数据了
#	@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#	**删除
#	$admin = new admin();
#	$hibernate->delete(id);//ID可以为1或者数组
#	@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#	**查找数据
#		
#
?>