php基于mysql数据库实现对象持久层的方法，mysql数据库本文实例讲述了php基于mysql数据库实现对象持久层的方法。分享给大家供大家参考。具体如下：
心血来潮，做了一下php的对象到数据库的简单持久层。
不常用php，对php也不熟，关于php反射的大部分内容都是现学的。
目前功能比较弱，只是完成一些简单的工作，对象之间的关系还没法映射，并且对象的成员只能支持string或者integer两种类型的。
成员变量的值也没有转义一下。。。
下面就贴一下代码：
首先是数据库的相关定义，该文件定义了数据库的连接属性：

下面是数据库访问的简单封装：
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 . '
'; ?>
希望本文所述对大家的php程序设计有所帮助。
http://www.bkjia.com/phpjc/1018528.htmlwww.bkjia.comtruehttp://www.bkjia.com/phpjc/1018528.htmltecharticlephp基于mysql数据库实现对象持久层的方法，mysql数据库 本文实例讲述了php基于mysql数据库实现对象持久层的方法。分享给大家供大家参考。具...