<?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或者数组
#@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#**查找数据
#
#
?>로그인 후 복사
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
