<?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或者数组 # @@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ # **查找数据 # # ?>
?
相关文章
