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

《PHP实例：PHP基于MysqL数据库实现对象持久层的方法》要点：
本文介绍了PHP实例：PHP基于MysqL数据库实现对象持久层的方法，希望对您有用。如果有疑问，可以联系我们。

本文实例讲述了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,$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 = '[e-mail]'; 
  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程序设计有所赞助.

欢迎参与《PHP实例：PHP基于MysqL数据库实现对象持久层的方法》讨论，分享您的想法，编程之家 jb51.cc为您提供专业教程。