<?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或者数组
#@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@
#**查找数据
#
#
?>Salin selepas log masuk
Bagaimana untuk membuka fail php
Bagaimana untuk mengalih keluar beberapa elemen pertama tatasusunan dalam php
Apa yang perlu dilakukan jika penyahserialisasian php gagal
Bagaimana untuk menyambungkan php ke pangkalan data mssql
Bagaimana untuk menyambung php ke pangkalan data mssql
Bagaimana untuk memuat naik html
Bagaimana untuk menyelesaikan aksara bercelaru dalam PHP
Bagaimana untuk membuka fail php pada telefon bimbit
![[Web front-end] Permulaan pantas Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
