php 设计模式-数据映射模式(应用程序与数据库交互模式)

前面提到的设计模式大大提高了代码的可读性与可维护性。然而,在WEB应用设计与开发中一个基本的需求与挑战:数据库应用,这些设计模式都没有涉及到。数据映射模式使您能更好的组织你的应用程序与数据库进行交互。

下面我将用实际代码说明,如果一个表发生变动。我们要修改客户端代码就可以了。特别是游戏项目,需求经常可能会经常变动。修改表结构,可能引起大片代码的改动。

首先我们使用pdo进行数据库访问:

<?php  
/** 
 * Filename:db.class.php 
 *  
 * db class ,use PDO lib 
 *  
 * @author guisu.huang 
 * @version 1.0 
 *  
 */  
class Db {  
    public static $db = null;  
    private $_dbh = null;  
    public static function getInstance()  
    {  
        if( self::$db == null ){  
            self::$db = new self(BACKEND_DBHOST ,BACKEND_DBUSER ,BACKEND_DBPW ,BACKEND_DBNAME);  
        }  
        return self::$db;  
  
    }  
  
    private function __construct( $host ,$user ,$pass ,$dbname ){  
        try {  
            $this->_dbh = new PDO('mysql:dbname='.$dbname.';host='.$host,$user,$pass);  
            $this->_dbh->query('SET NAMES '. BACKEND_DBCHARSET);  
            $this->_dbh->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);  
            $this->_dbh->setAttribute(PDO::ATTR_ERRMODE, true);  
        } catch (PDOException $e) {  
            throw new Exception('Can not connect db');  
        }  
    }  
  
    private function getExecuteResult($sql, $sth){  
        $type = strtolower(substr(trim($sql), 0,6));  
        switch ($type) {  
            case 'update': case 'delete':  
                $result = $sth->rowcount();//返回影响的行数  
            break;  
            case 'insert':  
                $result = $this->getLastId();  
                break;  
            case 'select':  
                $result = $sth->fetchAll(PDO::FETCH_ASSOC);  
                break;  
            default:  
                break;  
        }  
        return $result;  
    }  
      
    /**************************************sql ************************/  
      
    public function getOne($sql){  
        try {  
            $rs = $this->_dbh->query($sql);  
            $result = $rs->fetch(PDO::FETCH_ASSOC);  
            if(!empty($result)) {  
                return $result;  
            }  
        } catch (PDOException $e) {  
            throw new Exception($this->_dbh->errorInfo());  
        }  
        return false;  
    }  
  
    public function getAll($sql){  
        try {  
            $rs = $this->_dbh->query($sql);  
            $result = $rs->fetchAll(PDO::FETCH_ASSOC);  
            if(!empty($result)) {  
                return $result;  
            }  
        } catch (PDOException $e) {  
            throw new Exception($this->_dbh->errorInfo());  
        }  
        return false;  
    }  
  
    public function exec($sql){  
        try {  
            $exec = $this->_dbh->exec($sql);  
        } catch (PDOException $e){  
            throw new Exception($this->_dbh->errorInfo());  
        }  
        return $exec;  
  
    }  
    /** 
     * 不关注键值 
     *  Execute a prepared statement by passing an array of values  
        $sth = $dbh->prepare('SELECT name, colour, calories 
            FROM fruit 
            WHERE calories < ? AND colour = ?'); 
        $sth->execute(array(150, 'red')); 
        $red = $sth->fetchAll(); 
        $sth->execute(array(175, 'yellow')); 
        $yellow = $sth->fetchAll(); 
 
     * @param unknown_type $sql 
     * @param unknown_type $arr 
     * @return unknown 
     */  
    public function executeArr($sql, $arr){  
        try {  
            $sth = $this->_dbh->prepare($sql);  
            $r = $sth->execute($arr);  
            if ($r) {  
                return  $this->getExecuteResult($sql, $sth);  
            }  
        } catch (PDOException $e){  
            throw new Exception($e->getMessage() . $this->_dbh->errorInfo());  
        }     
    }  
    /** 
     * 关联数组: 
     *  Execute a prepared statement by passing an array of values  
            $sql = 'SELECT name, colour, calories 
            FROM fruit 
            WHERE calories < :calories AND colour = :colour'; 
        $sth = $dbh->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)); 
        $sth->execute(array(':calories' => 150, ':colour' => 'red')); 
        $red = $sth->fetchAll(); 
     * 
     * @param unknown_type $sql 
     * @param unknown_type $arr 
     * @return unknown 
     */  
    public function executeAsoc($sql, $arr){  
        try {  
            $array = array();  
            if ($arr) {  
                foreach ($arr as $key=>$v) {  
                    if (strpos($sql, ':' . $key )!==false) {  
                        $array[':' . $key] = $v;  
                    }  
                }  
            }  
            $sth = $this->_dbh->prepare($sql);  
            $r = $sth->execute($array);  
            if ($r) {  
                return  $this->getExecuteResult($sql, $sth);  
            }  
        } catch (PDOException $e){  
            throw new Exception($e->getMessage() . $this->_dbh->errorInfo());  
        }     
    }  
      
    public function beginTransaction(){  
        return $this->_dbh->beginTransaction();  
    }  
  
    public function commit(){  
        return $this->_dbh->commit();  
    }  
  
    public function rollBack(){  
        return $this->_dbh->rollBack();  
    }  
  
    public function getLastId()  
    {  
        return $this->_dbh->lastInsertId();  
    }  
  
      
      
}  
  
?>

数据映相关类射类,使用__call达到动态生成getter 和setter方法.

<?php  
/** 
 * 抽象数据映射 
 * 
 */  
abstract  class Table{  
  
    public function __call($method, $args) {  
        if (preg_match('/^(get|set)(\w+)/', strtolower($method), $match)  
        && $attribute = $this->validateAttribute($match[2])) {  
            if ('get' == $match[1]) {  
                return $this->$attribute;  
            } else {  
                $this->$attribute = $args[0];  
            }  
        }else {  
            throw new Exception(  
            'Call to undefined method ' . __CLASS__  . '::'.$method.'()');  
        }  
    }  
  
    protected function validateAttribute($method) {  
        if ( in_array(strtolower($method), array_keys(get_class_vars(get_class($this))))) {  
            return strtolower($method);  
        }  
  
    }  
      
      
}  
  
/** 
 * 数据映射到表 
 * 一般根据表的结构由工具自动生成, 
 * 要不然程序员经常得copy和修改这个类 
 * 
 */  
class UserTable extends Table {  
    /** 
     * fields 
     * 
     * @var unknown_type 
     */  
    protected $uid = null;  
  
    protected $username = null ;  
  
    protected $level = null;  
  
    protected $exp = null;  
  
    protected $ctime = null;  
  
    protected $mtime = null;  
    /** 
     * table  
     * 
     * @var unknown_type 
     */  
    public   $tableName = 'user';  
  
    public  $primaryKey = 'uid';  
      
    public  static $tablefileds = array(  
                        'uid',  
                        'username',  
                        'level',  
                        'exp',  
                        'ctime',  
                        'mtime',  
    );  
      
    /** 
     * 对象生成数组 
     * 
     * @return array 
     */  
    function toArray(){  
        $arr = array();  
        foreach (UserTable::$tablefileds as $filed) {  
            $getMethod  = 'get' .ucwords($filed);  
            $value = $this->$getMethod();  
            if ($value !== null) {  
                $arr[$filed] = $value;  
            }  
        }  
        return $arr;  
    }  
      
    /** 
     * 数组生成对象 
     * 
     * @return array 
     */  
    function toObj($arr){  
        if (!$arr) {  
            return $this;  
        }  
        foreach (UserTable::$tablefileds as $filed) {  
            $setMethod  = 'set' .ucwords($filed);  
            $this->$setMethod($arr[$filed]);  
        }  
        return $this;  
    }  
}  
  
/** 
 *  
 * 
 */  
class Mapper{  
      
    protected  $conn = null;  
      
    /** 
     * 自动插入 
     * 不想对某一列插入,把对应的属性设置成null就ok 
     * 
     * @param Table $table 
     * @return unknown 
     */  
    function save(Table $table){  
        $arr  =  $table->toArray();  
        $set = '';  
        if ($arr) {  
            foreach ($arr as $field=> $v) {  
                if ($set) $set .=',';  
                $set .= $field . "='" . $v ."'";  
            }  
        }  
        if ($set) {  
            $this->conn->exec( 'insert into ' . $table->tableName . ' SET ' . $set);  
            return $this->conn->getLastId();  
        }  
          
          
    }  
      
    /** 
     * 更新 
     * 不想对某一列更新,把对应的属性设置成null就ok 
     * 
     * @param Table $table 
     * @return unknown 
     */  
    function update(Table $table){  
        $arr  =  $table->toArray();  
        $set = '';  
        if ($arr) {  
            foreach ($arr as $field=> $v) {  
                if ($set) $set .=',';  
                $set .= $field . "='" . $v ."'";  
            }  
        }  
        $primayGet = 'get'.ucwords($table->primaryKey);  
        if ($set) {  
            return $this->conn->exec( 'update ' . $table->tableName . ' SET ' . $set . ' where ' . $table->primaryKey ."='" . $table->$primayGet() . "'" );  
        }  
    }  
  
      
}  
class UserMapper extends Mapper {  
      
    const INSERT_SQL = "insert into user (username, level,exp, ctime, mtime) values (:username, :level, :exp, now(), now())";  
    const UPDATE_SQL = "update user SET username=:username, level=:level, exp=:exp WHERE uid=:uid ";  
    const SELECT_SQL = "select * from user  WHERE uid=:uid ";  
    const DELETE_SQL = "delete from user  WHERE uid=:uid ";  
      
    function __construct(){  
        $this->conn =  Db::getInstance();  
    }  
    /** 
     * 我们可以实现覆盖save 
     * 
     * @param unknown_type $userTable 
     */  
    public function save2($userTable) {  
        $rs =  Db::getInstance()->executeArr( self::INSERT_SQL, $userTable->toArray());  
        return $rs;  
    }  
      
    /** 
     * Enter description here... 
     * 
     * @param unknown_type $userTable 
     */  
    public function update2($userTable) {  
        return $this->conn->execute(self::UPDATE_SQL, $userTable->toArray());  
    }  
      
    /** 
     * Enter description here... 
     * 
     * @param unknown_type $arr 
     */  
    public function find($userTable) {  
        $rs = $this->conn->executeAsoc( self::SELECT_SQL, $userTable->toArray());  
        return $rs ? $userTable->toObj($rs[0]) : $userTable;  
    }  
}  
  
  
?>

实际客户测试:

<?php  
  
/** 
 * 数据库配置文件 
 * 
 */  
define('BACKEND_DBHOST', 'localhost');  
define('BACKEND_DBUSER', 'root');  
define('BACKEND_DBPW', '123456');  
define('BACKEND_DBNAME', 'sample');  
define('BACKEND_DBCHARSET', 'utf-8');  
  
//sql  
/* 
CREATE TABLE IF NOT EXISTS `user` ( 
  `uid` int(11) NOT NULL AUTO_INCREMENT, 
  `username` varchar(64) NOT NULL, 
  `level` int(11) NOT NULL DEFAULT '0', 
  `exp` int(11) NOT NULL DEFAULT '0', 
  `ctime` datetime NOT NULL DEFAULT '0000-00-00 00:00:00', 
  `mtime` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00', 
  PRIMARY KEY (`uid`), 
  KEY `username` (`username`) 
) ENGINE=InnoDB  DEFAULT CHARSET=latin1 AUTO_INCREMENT=12 ; 
*/  
  
class client{  
    static function main(){  
        $userMapper = new UserMapper();  
        $user = new UserTable();  
        //插入  
        //$user->setUserName('guisu');  
        //$user->setLevel(1);  
        //$user->setExp(10);  
        //  
        //$userMapper = new UserMapper();  
        //$r = $userMapper->save($user);  
          
        //查找  
        $user->setUid(10);  
        $user = $userMapper->find($user);  
        var_dump($user);  
        //更新  
        $user->setUserName('guisu2');  
        $r = $userMapper->update($user);  
        var_dump($r);  
    }  
      
}

一般,client是业务逻辑层,UserMapper是数据访问层。UserTable底层数据结构。

我们尽量做到如果表User修改了:

1)工具重新自动生成UserTable类

2)只修改client代码和少量的UserMapper代码,一般修改UserMapper的常量const的内容就可以了。

转自:http://blog.csdn.net/hguisu/article/details/7569968

原创文章,作者:s19930811,如若转载,请注明出处:http://www.178linux.com/2827

(0)
s19930811s19930811
上一篇 2015-04-07
下一篇 2015-04-07

相关推荐

  • N25第六周作业

    vim 是vi编辑的升级版,同样有三种工作模式:编辑、命令和一般 模式 #:指定行号位置 #,#:指定多少行到多少行 #,+#:指定范围,多少行开始,加#行 $:最后一行 .:当前行 .,$-1,当前行到倒数第二行 1,$:全文 %:全文 /从上往下,?:从下往上 搜索 /pattern/:从光标所在处起始向文件尾部第一次被模式所匹配到的行 s/要查找的内容…

    Linux干货 2017-01-11
  • LVS管理平台使用手册(第一版)[原创]

     为了更好管理、维护LVS平台,本人基于Django+certmaster+func开发了一套管理平台,主要功能模块分为性能图表、数据中心、虚拟IP池、主机管理、监控模块等功能,基本上是按F5-LTM管理平台思路来设计,下面只要对这几大块功能进行说明。1、性能图表 功能说明:以小时、日、星期、月、年的图表展示LVS SERVER、VIP、SERVE…

    Linux干货 2015-03-28
  • 初学Linux之标准 I/O 和管道

    前面我们已经了解了文件系统的部分内容,我们可以通过 ls 命令让当前目录下的内容都显示在屏幕上,也可以使用 pwd 命令,显示当前的所在的目录路径。但是我们输入的是命令,本身并没有输入“显示”这类命令和要求,但是系统就自动的在屏幕上输出我们命令指定的信息。由此可以想象到,系统自身有默认的一种输出方式,同时,有输出就有输入,当输入的和系统无关,系统也会自动提示错误,以上就是我们接下来要了解的基础内容——标准 I/O。具体的涉及内容包括:三种 I/O 设备,把 I/O 重定向入文件,tr 命令的使用,使用管道链接命令。

    2017-12-02
  • 第七周作业

    1、创建一个10G分区,并格式为ext4文件系统;    (1) 要求其block大小为2048, 预留空间百分比为2, 卷标为MYDATA, 默认挂载属性包含acl;        (2) 挂载至/data/mydata目录,要求挂载时禁止程序自动运行,且不更新文件的访问时间戳; [ro…

    2017-04-05
  • LAMP部署之NFS共享网络存储

    LAMP部署之NFS共享网络存储 架构图: 说明:     当一个网站的访问量上来之后,一台WebServer服务器无法应付那么高的并发,需要横向扩展Web服务器数量,     当我们访问网页,向Web服务器请求资源时,资源主要分为静态资源和动态资源(程序处理),  &…

    Linux干货 2016-06-20
  • 推荐-Linux命令帮助的获取

    帮助命令 1. 使用帮助命令和帮助选项来获取帮助 2. 使用man来查看命令使用手册(manual) 3. 使用info来查看命令的信息页 4. 程序自身的帮助文档 5. 程序官方文档 6. 发行版的官方文档 7. 使用Google搜索关键字 1. 使用帮助命令和帮助选项来获取帮助 Linux系统中命令分为【内部命令】和【外部命令】。 【内部命令】:内部命令…

    Linux干货 2016-03-25