1.定义接口方法

文件: I_dao.interface.php

<?php
namespace framework\dao;
//接口用来约束一个类应该有哪些方法
//通常用来封装增删改查的方法
interface I_DAO
{
    //查询所有数据的方法
    	public function getAll($sql='');

    //查询一条记录的方法
    	public function getRow($sql='');

    //查询一个字段的值
   	 public function getOne($sql='');

    //受影响的记录数
    	public function affectedRows();

    //执行增、删、改操作的方法,通常返回成功与否
 	public function exec($sql='');

    //查询刚刚执行插入操作返回的主键的值
    	public function lastInsertId();

    //对外来数据进行引号转义、并引号包裹
    	public function quoteValue($data);
}

2.继承接口并实现这些方法

文件: DaoPDO.class.php

<?php
namespace framework\dao;
use framework\dao\I_DAO;
use \PDO;

class DAOPDO implements I_DAO
{
    //保证这个类只实例化一个对象，单例模式
    //定义私有的静态属性来保存该对象
    private static $instance;
    private $pdo;
    
    //私有的构造方法
    private function __construct($options)
    {
        //初始化数据库服务器的信息
        $this -> initOptions($options);
        //初始化PDO对象
        $this -> initPDO();
    }
    //初始化数据库服务器的配置
    private function initOptions($options)
    {
        $this -> host = isset($options['host'])?$options['host']:'';
        $this -> dbname = isset($options['dbname'])?$options['dbname']:'';
        $this -> user = isset($options['user'])?$options['user']:'';
        $this -> pass = isset($options['pass'])?$options['pass']:'';
        $this -> port = isset($options['port'])?$options['port']:'';
        $this -> charset = isset($options['charset'])?$options['charset']:'';
    }
    //初始化pdo对象
    private function initPDO()
    {
        $dsn = "mysql:host=$this->host;dbname=$this->dbname;port=$this->port;charset=$this->charset";
        $this -> pdo = new PDO($dsn,$this->user,$this->pass);
    }
    //私有的克隆方法
    private function __clone()
    {
        
    }    
    //公共的静态方法实例化当前类的对象
    public static function getSingleton($options)
    {
        if(!self::$instance instanceof self){
            self::$instance = new self($options);
        }
        return self::$instance;
    }
    //查询所有数据的方法
    public function getAll($sql='')
    {
        $pdo_statement = $this -> pdo -> query($sql); 
        //获得执行查询操作受影响的记录数
        $this -> totalRows = $pdo_statement -> rowCount();
        if($pdo_statement==false){
            //说明sql有错误，输出错误信息
            $error_info = $this -> pdo -> errorInfo();
            $error_str = "SQL语句有错误，详细信息如下:<br>".$error_info[2];
            echo $error_str;
            return false;
        }
        return $pdo_statement -> fetchAll(PDO::FETCH_ASSOC);
    }
    //查询一条记录的方法
    public function getRow($sql='')
    {
        $pdo_statement = $this -> pdo -> query($sql);
        if($pdo_statement==false){
            //说明sql有错误，输出错误信息
            $error_info = $this -> pdo -> errorInfo();
            $error_str = "SQL语句有错误，详细信息如下:<br>".$error_info[2];
            echo $error_str;
            return false;
        }
        return $pdo_statement -> fetch(PDO::FETCH_ASSOC);
    }
    //查询一个字段的值
    public function getOne($sql='')
    {
        $pdo_statement = $this -> pdo -> query($sql);
        if($pdo_statement==false){
            //说明sql有错误，输出错误信息
            $error_info = $this -> pdo -> errorInfo();
            $error_str = "SQL语句有错误，详细信息如下:<br>".$error_info[2];
            echo $error_str;
            return false;
        }
        return $pdo_statement -> fetchColumn();
    }
    //受影响的记录数
    public function affectedRows(){
        //通常是用来获得查询语句返回的所有的结果数
        return $this -> totalRows;
    }
    //执行增、删、改操作的方法,通常返回成功与否
    public function exec($sql=''){
        //返回执行成功、失败
        $result = $this -> pdo -> exec($sql);
        return $result;
    }
    //查询刚刚执行插入操作返回的主键的值
    public function lastInsertId(){
        return $this->pdo->lastInsertId();
    }
    //封装引号转义并包裹
    public function quoteValue($data)
    {
        return $this->pdo->quote($data);
    }
}