PHP基于MySQL数据库实现对象持久层的方法
本文实例讲述了PHP基于MySQL数据库实现对象持久层的方法。分享给大家供大家参考。具体如下：
心血来潮，做了一下PHP的对象到数据库的简单持久层。
不常用PHP，对PHP也不熟，关于PHP反射的大部分内容都是现学的。
目前功能比较弱，只是完成一些简单的工作，对象之间的关系还没法映射，并且对象的成员只能支持string或者integer两种类型的。
成员变量的值也没有转义一下。。。
下面就贴一下代码：
首先是数据库的相关定义，该文件定义了数据库的连接属性：
<?php
/*
*Filename:config.php
*Createdon2012-9-29
*CreatedbyRobinTang
*Tochangethetemplateforthisgeneratedfilegoto
*Window-Preferences-PHPeclipse-PHP-CodeTemplates
*/
//Aboutdatabase
define('DBHOST','localhost');//数据库服务器
define('DBNAME','db_wdid');//数据库名称
define('DBUSER','root');//登陆用户名
define('DBPSWD','trb');//登录密码
?>
下面是数据库访问的简单封装：
<?php
/*
*Filename:database.php
*Createdon2012-9-29
*CreatedbyRobinTang
*Tochangethetemplateforthisgeneratedfilegoto
*Window-Preferences-PHPeclipse-PHP-CodeTemplates
*/
include_once("config.php");
$debug=false;
$g_out=false;
functionout($s){
global$g_out;
$g_out.=$s;
$g_out.="\r\n";
}
functiondb_openconnect(){
$con=mysql_connect(DBHOST,DBUSER,DBPSWD);
if(!mysql_set_charset("utf8",$con)){
out("setmysqlencodingfail");
}
if(!$con){
out('Couldnotconnect:'.mysql_error());
}
else{
if(!mysql_select_db(DBNAME,$con)){
$dbn=DBNAME;
out("Couldselectdatabase'$dbn':".mysql_error());
}
$sql="settime_zone='+8:00';";
if(!db_onlyquery($sql,$con)){
out("selecttimezonefail!".mysql_error());
}
}
return$con;
}
functiondb_colseconnect($con){
mysql_close($con);
}
functiondb_onlyquery($sql,$con){
$r=mysql_query($sql,$con);
if(!$r){
out("query'$sql':fail");
returnfalse;
}
else{
return$r;
}
}
functiondb_query($sql){
$con=db_openconnect();
$r=db_onlyquery($sql,$con);
$res=false;
if($r){
$res=true;
}
db_colseconnect($con);
return$r;
}
functiondb_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;
}
functiondb_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;
}
functiondb_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
*Createdon2012-11-4
*CreatedbyRobinTang
*Tochangethetemplateforthisgeneratedfilegoto
*Window-Preferences-PHPeclipse-PHP-CodeTemplates
*/
include_once("database.php");
functionSinORM_ExecSql($sql){
returndb_query($sql);
}
functionSinORM_ExecArray($sql){
returndb_getarray($sql);
}
functionSinORM_ExecResult($sql){
returndb_getresult($sql);
}
functionSinORM_GetClassPropertys($class){
$r=newReflectionClass($class);
if(!$r->hasProperty('tablename')){
thrownewException("Class'$class'hasno[tablename]property");
}
$table=$r->getStaticPropertyValue('tablename');
if(!$r->hasProperty('id')){
thrownewException("Class'$class'hasno[id]property");
}
$mpts=Array();
$pts=$r->getProperties(ReflectionProperty::IS_PUBLIC);
foreach($ptsas$pt){
if(!$pt->isStatic()){
array_push($mpts,$pt);
}
}
returnArray(
$table,
$mpts
);
}
functionSinORM_GetPropertyString($pts,$class,$obj=false,$noid=false){
if(is_null($pts)){
list($tb,$pts)=SinORM_GetClassPropertys($class);
}
$s=false;
$v=false;
$l=false;
foreach($ptsas$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;
}
}
returnArray(
$s,
$v
);
}
functionSinORM_GetTableName($class){
$r=newReflectionClass($class);
if(!$r->hasProperty('tablename')){
thrownewException("Class'$class'hasno[tablename]property");
}
$table=$r->getStaticPropertyValue('tablename');
if(!$r->hasProperty('id')){
thrownewException("Class'$class'hasno[id]property");
}
return$table;
}
functionSinORM_ResetORM($class){
list($tb,$pts)=SinORM_GetClassPropertys($class);
$sql="CREATETABLE`$tb`(`id`intNOTNULLAUTO_INCREMENT";
$r=newReflectionClass($class);
$obj=$r->newInstance();
foreach($ptsas$pt){
$val=$pt->getValue($obj);
$name=$pt->name;
if($name!='id'){
$sql=$sql.',';
}else{
continue;
}
if(is_null($val))
thrownewException($class.'->'."namemusthaveadefaultvalue");
if(is_string($val))
$sql=$sql."`$name`textNULL";
else
$sql=$sql."`$name`intNULL";
}
$sql=$sql.",PRIMARYKEY(`id`));";
$dsql="DROPTABLEIFEXISTS`$tb`;";
returnSinORM_ExecSql($dsql)&&SinORM_ExecSql($sql);
}
functionSinORM_SaveObject($obj){
$class=get_class($obj);
list($tb,$pts)=SinORM_GetClassPropertys($class);
list($names,$vals)=SinORM_GetPropertyString($pts,$class,$obj,true);
$sql="INSERTINTO`$tb`($names)values($vals)";
if(SinORM_ExecSql($sql)){
$q="SELECT`id`FROM`$tb`ORDERBY`id`DESCLIMIT1;";
$id=SinORM_ExecResult($q);
if($id){
$obj->id=$id;
}
}
returnfalse;
}
functionSinORM_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=newReflectionClass($class);
foreach($aryas$a){
$obj=$ref->newInstance();
foreach($ptsas$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;
}
functionSinORM_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=newReflectionClass($class);
$a=$ary[0];
$obj=$ref->newInstance();
foreach($ptsas$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;
}
returnnull;
}
functionSinORM_Update($obj){
$class=get_class($obj);
list($tb,$pts)=SinORM_GetClassPropertys($class);
$sql="UPDATE`$tb`SET";
$l=false;
foreach($ptsas$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;";
returnSinORM_ExecSql($sql);
}
functionSinORM_SaveOrUpdate($obj){
if(SinORM_GetObject(get_class($obj),$obj->id)==null){
SinORM_SaveObject($obj);
}else{
SinORM_Update($obj);
}
}
functionSinORM_DeleteObject($obj){
$class=get_class($obj);
$tb=SinORM_GetTableName($class);
$sql="DELETEFROM`$tb`WHERE`id`=$obj->id;";
returnSinORM_ExecSql($sql);
}
functionSinORM_DeleteAll($class){
$tb=SinORM_GetTableName($class);
$sql="DELETEFROM`$tb`;";
returnSinORM_ExecSql($sql);
}
?>
下面是使用的例子：
<?php
/*
*Filename:demo.php
*Createdon2012-11-4
*CreatedbyRobinTang
*Tochangethetemplateforthisgeneratedfilegoto
*Window-Preferences-PHPeclipse-PHP-CodeTemplates
*/
include_once("sinorm.php");
//下面是一个持久对象的类的定义
//每个持久对象类都必须有一个叫做$tablename静态成员，它表示数据库中存储对象的表名
//类的每个成员都必须初始化，也就是必须给它一个初始值
//成员变量只能为字符串或者整型，而且请定义成public的，只有public的成员变量会被映射
classUser{
publicstatic$tablename='t_user';//静态变量，对象的表名，必须的
public$id=0;//对象ID,对应表中的主键，必须的，而且必须初始化为0
public$name='';//姓名，必须初始化
public$age=0;//年龄，必须初始化
public$email='';//必须初始化
}
//注意：下面的语句一定要在定义好类之后运行一下，修改了类也需要运行一下，它完成创建表的工作
//SinORM_ResetORM('User');//这一句只是一开始执行一次，执行之后就会自动在数据库中建立User对应的表
$user1=newUser();//创建一个对象
$user1->name='TRB';
$user1->age=22;
$user1->email='trbbadboy@qq.com';
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程序设计有所帮助。