加入收藏 | 设为首页 | 会员中心 | 我要投稿 安卓应用网 (https://www.0791zz.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > PHP > 正文

PHP基于MySQL数据库实现对象持久层的方法

发布时间:2020-05-23 21:59:46 所属栏目:PHP 来源:互联网
导读:这篇文章主要介绍了PHP基于MySQL数据库实现对象持久层的方法,实例分析了php实现持久层的相关技巧,需要的朋友可以参考下

本文实例讲述了PHP基于MySQL数据库实现对象持久层的方法。分享给大家供大家参考。具体如下:

心血来潮,做了一下PHP的对象到数据库的简单持久层。

不常用PHP,对PHP也不熟,关于PHP反射的大部分内容都是现学的。

目前功能比较弱,只是完成一些简单的工作,对象之间的关系还没法映射,并且对象的成员只能支持string或者integer两种类型的。

成员变量的值也没有转义一下。。。

下面就贴一下代码:

首先是数据库的相关定义,该文件定义了数据库的连接属性:

下面是数据库访问的简单封装:

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;
}
?>

其实上面的两个文件都是之前写好的,持久层的东西是下面的:

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,$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);
}
?>

(编辑:安卓应用网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读