本篇文章主要介绍php实现持久层的方法，感兴趣的朋友参考下，希望对大家有所帮助。
本文实例讲述了PHP基于MySQL数据库实现对象持久层的方法。具体如下：
心血来潮，做了一下PHP的对象到数据库的简单持久层。
不常用PHP，对PHP也不熟，关于PHP反射的大部分内容都是现学的。
目前功能比较弱，只是完成一些简单的工作，对象之间的关系还没法映射，并且对象的成员只能支持string或者integer两种类型的。
立即学习“PHP免费学习笔记（深入）”；
成员变量的值也没有转义一下。。。
下面就贴一下代码：
首先是数据库的相关定义，该文件定义了数据库的连接属性：
下面是数据库访问的简单封装：
白月生产企业订单管理系统GBK2.0 Build 080807
下载
请注意以下说明:1、本程序允许任何人免费使用。2、本程序采用PHP+MYSQL架构编写。并且经过ZEND加密，所以运行环境需要有ZEND引擎支持。3、需要售后服务的，请与本作者联系，联系方式见下方。4、本程序还可以与您的网站想整合，可以实现用户在线服务功能，可以让客户管理自己的信息，可以查询自己的订单状况。以及返点信息等相关客户利益的信息。这个功能可提高客户的向心度。安装方法：1、解压本系统，放在
其实上面的两个文件都是之前写好的，持久层的东西是下面的：
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);
}
?>下面是使用的例子：
name = 'TRB'; $user1->age = 22; $user1->email = 'trbbadboy@qq.com'; SinORM_SaveObject($user1); // 把对象保存到数据库中 // 保存之后会自动给id的 $id = $user1->id; echo $id . '
'; $user2 = SinORM_GetObject('User', $id); // 通过ID从数据库创建一个对象 echo $user2->name . '
'; $user1->name = 'trb'; // 改变一下 SinORM_Update($user1); // 更新到数据库 $user3 = SinORM_GetObject('User', $id); // 重新读出 echo $user3->name . '
'; ?>
总结：以上就是本篇文的全部内容，希望能对大家的学习有所帮助。
相关推荐：
