PHP基于MySQL數據庫實現對象持久層的方法

2020-03-22 19:52:12

字體：大中小

來源：轉載

供稿：網友

本文實例講述了PHP基于html' target='_blank'>MySQL數據庫實現對象持久層的方法。分享給大家供大家參考。具體如下：心血來潮，做了一下PHP的對象到數據庫的簡單持久層。不常用PHP，對PHP也不熟，關于PHP反射的大部分內容都是現學的。目前功能比較弱，只是完成一些簡單的工作，對象之間的關系還沒法映射，并且對象的成員只能支持string或者integer兩種類型的。成員變量的值也沒有轉義一下。。。下面就貼一下代碼：首先是數據庫的相關定義，該文件定義了數據庫的連接屬性： php * Filename: config.php * Created on 2012-9-29 * Created by RobinTang * To change the template for this generated file go to * Window - Preferences - PHPeclipse - PHP - Code Templates // About database define('DBHOST', 'localhost'); // 數據庫服務器 define('DBNAME', 'db_wdid'); // 數據庫名稱 define('DBUSER', 'root'); // 登陸用戶名 define('DBPSWD', 'trb'); // 登錄密碼下面是數據庫訪問的簡單封裝： php * Filename: database.php * Created on 2012-9-29 * Created by RobinTang * To change the template for this generated file go to * Window - Preferences - PHPeclipse - PHP - Code Templates include_once("config.php"); $debug = false; $g_out = false; function out($s){ global $g_out; $g_out .= $s; $g_out .= "/r/n"; function db_openconnect(){ $con = mysql_connect(DBHOST, DBUSER, DBPSWD); if(!mysql_set_charset("utf8", $con)){ out("set mysql encoding fail"); if (!$con){ out('Could not connect: ' . mysql_error()); else{ if(!mysql_select_db(DBNAME, $con)){ $dbn = DBNAME; out("Could select database '$dbn' : " . mysql_error()); $sql = "set time_zone = '+8:00';"; if(!db_onlyquery($sql, $con)){ out("select timezone fail!" . mysql_error()); return $con; function db_colseconnect($con){ mysql_close($con); function db_onlyquery($sql, $con){ $r = mysql_query($sql, $con); if(!$r){ out("query '$sql' :fail"); return false; else{ return $r; function db_query($sql){ $con = db_openconnect(); $r = db_onlyquery($sql, $con); $res = false; if($r){ $res = true; db_colseconnect($con); return $r; function db_query_effect_rows($sql){ $con = db_openconnect(); $r = db_onlyquery($sql, $con); $res = false; if($r){ $res = mysql_affected_rows($con); if($res==0){ $res = -1; else{ $res = false; db_colseconnect($con); return $res; function db_getresult($sql){ $con = db_openconnect(); $r = db_onlyquery($sql, $con); $res = false; if($r && $arr = mysql_fetch_row($r)){ $res = $arr[0]; db_colseconnect($con); return $res; function db_getarray($sql){ $con = db_openconnect(); $r = db_onlyquery($sql, $con); $ret = false; if($r){ $row = false; $len = 0; $ret = Array(); $i = 0; while($arr = mysql_fetch_row($r)){ if($row == false || $len==0){ $row = Array(); $len = count($arr); for($i=0;$i $len;++$i){ $key = mysql_field_name($r, $i); array_push($row, $key); $itm = Array(); for($i=0;$i $len;++$i){ $itm[$row[$i]]=$arr[$i]; array_push($ret, $itm); db_colseconnect($con); return $ret;
* To change the template for this generated file go to * Window - Preferences - PHPeclipse - PHP - Code Templates include_once("database.php"); function SinORM_ExecSql($sql) { return db_query($sql); function SinORM_ExecArray($sql) { return db_getarray($sql); function SinORM_ExecResult($sql){ return db_getresult($sql); function SinORM_GetClassPropertys($class) { $r = new ReflectionClass($class); if (!$r- hasProperty('tablename')) { throw new Exception("Class '$class' has no [tablename] property"); $table = $r- getStaticPropertyValue('tablename'); if (!$r- hasProperty('id')) { throw new Exception("Class '$class' has no [id] property"); $mpts = Array (); $pts = $r- getProperties(ReflectionProperty :: IS_PUBLIC); foreach ($pts as $pt) { if (!$pt- isStatic()) { array_push($mpts, $pt); return Array ( $table, $mpts function SinORM_GetPropertyString($pts, $class, $obj = false, $noid = false) { if (is_null($pts)) { list ($tb, $pts) = SinORM_GetClassPropertys($class); $s = false; $v = false; $l = false; foreach ($pts as $pt) { $name = $pt- name; if ($noid == false || $name != 'id') { if ($l) { $s = $s . ','; $s = $s . $name; if ($obj) { if ($l) { $v = $v . ','; $val = $pt- getValue($obj); if (is_null($val)) $v = $v . 'null'; if (is_string($val)) $v = $v . "'$val'"; else $v = $v . $val; $l = true; return Array ( $s, function SinORM_GetTableName($class){ $r = new ReflectionClass($class); if (!$r- hasProperty('tablename')) { throw new Exception("Class '$class' has no [tablename] property"); $table = $r- getStaticPropertyValue('tablename'); if (!$r- hasProperty('id')) { throw new Exception("Class '$class' has no [id] property"); return $table; function SinORM_ResetORM($class) { list ($tb, $pts) = SinORM_GetClassPropertys($class); $sql = "CREATE TABLE `$tb` (`id` int NOT NULL AUTO_INCREMENT"; $r = new ReflectionClass($class); $obj = $r- newInstance(); foreach ($pts as $pt) { $val = $pt- getValue($obj); $name = $pt- name; if ($name != 'id') { $sql = $sql . ','; } else { continue; if (is_null($val)) throw new Exception($class . '- ' . "name must have a default value"); if (is_string($val)) $sql = $sql . "`$name` text NULL"; else $sql = $sql . "`$name` int NULL"; $sql = $sql . ",PRIMARY KEY (`id`));"; $dsql = "DROP TABLE IF EXISTS `$tb`;"; return SinORM_ExecSql($dsql) && SinORM_ExecSql($sql); function SinORM_SaveObject($obj) { $class = get_class($obj); list ($tb, $pts) = SinORM_GetClassPropertys($class); list ($names, $vals) = SinORM_GetPropertyString($pts, $class, $obj, true); $sql = "INSERT INTO `$tb`($names) values($vals)"; if(SinORM_ExecSql($sql)){ $q = "SELECT `id` FROM `$tb` ORDER BY `id` DESC LIMIT 1;"; $id = SinORM_ExecResult($q); if($id){ $obj- id = $id; return false; function SinORM_GetObjects($class) { list ($tb, $pts) = SinORM_GetClassPropertys($class); $sql = "SELECT * from `$tb`;"; $ary = SinORM_ExecArray($sql); $res = false; if (is_array($ary)) { $res = Array (); $ref = new ReflectionClass($class); foreach ($ary as $a) { $obj = $ref- newInstance(); foreach ($pts as $pt) { $name = $pt- name; $olv = $pt- getValue($obj); $val = $a[$name]; if (is_string($olv)) $pt- setValue($obj, $val); else $pt- setValue($obj, intval($val)); array_push($res, $obj); } else { echo 'no'; return $res; function SinORM_GetObject($class, $id) { list ($tb, $pts) = SinORM_GetClassPropertys($class); $sql = "SELECT * from `$tb` where `id`=$id;"; $ary = SinORM_ExecArray($sql); $res = null; if (is_array($ary) && count($ary) 0) { $res = Array (); $ref = new ReflectionClass($class); $a = $ary[0]; $obj = $ref- newInstance(); foreach ($pts as $pt) { $name = $pt- name; $olv = $pt- getValue($obj); $val = $a[$name]; if (is_string($olv)) $pt- setValue($obj, $val); else $pt- setValue($obj, intval($val)); return $obj; return null; function SinORM_Update($obj) { $class = get_class($obj); list ($tb, $pts) = SinORM_GetClassPropertys($class); $sql = "UPDATE `$tb` SET "; $l = false; foreach ($pts as $pt) { $name = $pt- name; $val = $pt- getValue($obj); if ($name == 'id') continue; if ($l) $sql = $sql . ','; if (is_string($val)) $sql = $sql . "$name='$val'"; else $sql = $sql . "$name=$val"; $l = true; $sql = $sql . " WHERE `id`=$obj- "; return SinORM_ExecSql($sql); function SinORM_SaveOrUpdate($obj) { if (SinORM_GetObject(get_class($obj), $obj- id) == null) { SinORM_SaveObject($obj); } else { SinORM_Update($obj); function SinORM_DeleteObject($obj){ $class = get_class($obj); $tb = SinORM_GetTableName($class); $sql = "DELETE FROM `$tb` WHERE `id`=$obj- "; return SinORM_ExecSql($sql); function SinORM_DeleteAll($class){ $tb = SinORM_GetTableName($class); $sql = "DELETE FROM `$tb`;"; return SinORM_ExecSql($sql);
* To change the template for this generated file go to * Window - Preferences - PHPeclipse - PHP - Code Templates include_once("sinorm.php"); // 下面是一個持久對象的類的定義 // 每個持久對象類都必須有一個叫做$tablename靜態成員，它表示數據庫中存儲對象的表名 // 類的每個成員都必須初始化，也就是必須給它一個初始值 // 成員變量只能為字符串或者整型，而且請定義成public的，只有public的成員變量會被映射 class User{ public static $tablename = 't_user'; // 靜態變量，對象的表名，必須的 public $id = 0; // 對象ID,對應表中的主鍵，必須的，而且必須初始化為0 public $name = ''; // 姓名，必須初始化 public $age = 0; // 年齡，必須初始化 public $email = ''; // 必須初始化 // 注意：下面的語句一定要在定義好類之后運行一下，修改了類也需要運行一下，它完成創建表的工作 // SinORM_ResetORM('User'); // 這一句只是一開始執行一次，執行之后就會自動在數據庫中建立User對應的表 $user1 = new User(); // 創建一個對象 $user1- name = 'TRB'; $user1- age = 22; $user1- email = 'trbbadboy@qq.com'; SinORM_SaveObject($user1); // 把對象保存到數據庫中 // 保存之后會自動給id的 $id = $user1- echo $id . ' br/ $user2 = SinORM_GetObject('User', $id); // 通過ID從數據庫創建一個對象 echo $user2- name . ' br/ $user1- name = 'trb'; // 改變一下 SinORM_Update($user1); // 更新到數據庫 $user3 = SinORM_GetObject('User', $id); // 重新讀出 echo $user3- name . ' br/ 希望本文所述對大家的php程序設計有所幫助。PHP教程

鄭重聲明：本文版權歸原作者所有，轉載文章僅為傳播更多信息之目的，如作者信息標記有誤，請第一時間聯系我們修改或刪除，多謝。

上一篇：介紹mysql重建表分區并保留數據的方法

下一篇：PHP中如何使用MySQL的ORDER BY子句排序