本文實例講述了PHP基於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;
}
?>
其實上面的兩個文件都是之前寫好的，持久層的東西是下面的：
<?php
/*
* Filename: sinorm.php
* Created on 2012-11-4
* Created by RobinTang
* 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,
$v
);
}
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->id;";
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->id;";
return SinORM_ExecSql($sql);
}
function SinORM_DeleteAll($class){
$tb = SinORM_GetTableName($class);
$sql = "DELETE FROM `$tb`;";
return SinORM_ExecSql($sql);
}
?>
下面是使用的例子：
<?php
/*
* Filename: demo.php
* Created on 2012-11-4
* Created by RobinTang
* 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 = '[email protected]';
SinORM_SaveObject($user1); // 把對象保存到數據庫中
// 保存之後會自動給id的
$id = $user1->id;
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程序設計有所幫助。
