【php】个人对PDO的封装以及使用

类封装

类只适合简单的，原生PHP开发的简单项目使用。

这个类中，一共分为3个文件：

• db_config.php
• db.class.php
• mypdo.class.php

db_config.php

<?php
$config = array(
    'dbhost' => 'localhost',
    'dbuser' => 'design0505',
    'dbpsw' => 'sj0505',
    'dbname' => 'xincards',
    'dbcharset' => 'utf8'
);

db.class.php

主要用于对mypdo.class类进行二次的封装，让类静态化，方便调用。

<?php
require 'db_config.php';

class DB {
    private static $conn;
    public static function init($config) {
        require('mypdo.class.php');
        self::$conn = new Mypdo($config);
        if (!self::$conn) {
            $res = [
                'error' => 5,
                'msg' => '数据库链接错误',
                'data' => false
            ];
            echo json_encode($res, JSON_UNESCAPED_UNICODE);
            exit;
        }
    }

    public static function handle($sql, $parameters = [])
    {
        return self::$conn->handle($sql, $parameters);
    }

    // 执行查询
    public static function query($sql, $parameters = [])
    {
        return self::$conn->query($sql, $parameters);
    }


    /**
     * [增 删 改 返回受影响的行数以及 最后插入的id]
     * array(2) { ["row"]=>int(1)  ["lastId"]=> "0"}
     * @return   [arr]             [插入返回成功的Id 和受影响的行数]
     */
    public static function getResult()
    {
        return self::$conn->getResult();
    }

    // 返回失败状态的信息
    public static function getError()
    {
        return self::$conn->getError();
    }

}

DB::init($config);

mypdo.class.php

核心库，实现对sql的查询以及其他操作。

<?php

class Mypdo {
    // mysql链接
    private $dsn;
    // 数据库用户名
    private $user;
    // 数据库密码
    private $password;
    // 数据库字符集
    private $charset;
    // PDO对象
    private $pdoInstance;
    // sql对象 查询获取的资源
    private $pdoStmt;
    // 存储错误码
    private $errArr;
    // 存储更新成功后影响的行数以及插入的id
    private $result;

    public function __construct($config) {
        if (!isset($config)) {
            return false;
        }
        $this->dsn = "mysql:host={$config['dbhost']};dbname={$config['dbname']}";
        $this->user = $config['dbuser'];
        $this->password = $config['dbpsw'];
        $this->charset = $config['dbcharset'];
        if (!$this->connect()) {
            return false;
        }
    }

    private function connect()
    {
        if (!$this->pdoInstance) {
            $options = array(
                PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES '.$this->charset
            );

            $this->pdoInstance = new PDO($this->dsn, $this->user, $this->password, $options);
            if (!$this->pdoInstance) {
               return false;
            }
            $this->pdoInstance->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        }
    }

    public function query($sql, $parameters = []) {
        if (!is_array($parameters)) {
            $parameters = array($parameters);
        }
        $this->pdoStmt = $this->pdoInstance->prepare($sql);
        $index = 1;
        foreach ($parameters as $parameter) {
            $this->pdoStmt->bindValue($index++, $parameter[0], $parameter[1]);
        }
        $execRe = $this->pdoStmt->execute();
        if (!$execRe) {
            $this->errArr = array(
                'code' => $this->pdoStmt->errorCode(),
                'info' => $this->pdoStmt->errorInfo()[2]
            );
            return false;
        }
        $data = $this->pdoStmt->fetchAll(PDO::FETCH_ASSOC);
        return $data;
    }

    // 增 删 改 操作
    public function handle($sql, $parameters = [])
    {
        if (!is_array($parameters)) {
            $parameters = array($parameters);
        }
        $this->pdoStmt = $this->pdoInstance->prepare($sql);
        if (count($parameters) > 0) {
            $index = 1;
            foreach ($parameters as $parameter) {
                // var_dump($parameter);
                $this->pdoStmt->bindValue($index++, $parameter[0], $parameter[1]);
            }
        }
        $execRe = $this->pdoStmt->execute();
        // var_dump($sql);
        // exit();
        if (!$execRe) {
            $this->errArr = array(
                'code' => $this->pdoStmt->errorCode(),
                'info' => $this->pdoStmt->errorInfo()[2]
            );
            return false;
        }
        $this->result = [
            // 影响的行数
            'row' => $this->pdoStmt->rowCount(),
            // 插入的id
            'lastId' => $this->pdoInstance->lastInsertId()
        ];
        return true;
    }

    public function getError()
    {
        // 如果错误状态数组返回true
        if ((bool)$this->errArr) {
            $err = $this->errArr;
        } else {
            $err = array();
        }
        return $err;
    }

    // 返回插入 修改 删除的结果
    public function getResult()
    {
        if (!is_array($this->result) && empty($this->result)) {
            $this->result = array();
        }
        return $this->result;
    }


}

使用例

查询

$pageSize = 10;
$offset = $pageSize * (2 - 1);
 $sql = "
       SELECT template_id,
              template_name as template_title,
              template_preview,
              template_public,
              created_at
       FROM `{$table}`
       ORDER BY template_id DESC
       LIMIT ? OFFSET ?
";
$res = DB::query($sql, [
    [ $pageSize, PDO::PARAM_INT ],
    [ $offset, PDO::PARAM_INT ]
]);

if(!($res === false) && 
    is_array($res) &&
    count($res) >= 0
) {
    // 查询成功
} else {
    // 查询失败
}

这里注意，如果查询失败，那么会返回false，但是不能仅仅使用!$res来判断，因为当没有相匹配的条数，但是查询是成功的，那么返回的就是空数组，这时候![] 得到的也是true！

insert

$sql = "
       INSERT INTO `{$table}` (
       template_id,
       card_name,
       card_data,
       card_template_bak,
       card_author,
       created_at,
       updated_at
       ) VALUES (
       ?,
       ?,
       ?,
       ?,
       ?,
       NOW(),
       NOW()
       )
";

try {
       $res_db = DB::handle($sql, [
              [ $template_id, PDO::PARAM_INT ],
              [ $title, PDO::PARAM_STR ],
              [ $template['compdata'], PDO::PARAM_STR ],
              [ $template['html'], PDO::PARAM_STR ],
              [ $realname, PDO::PARAM_STR ]
       ]);
       if ($res_db && DB::getResult()['row'] > 0) {
              // 插入成功
       } else {
              // 插入失败
       }
} catch (Exception $e) {
       $msg = '插入失败, ' . $e->getMessage();
       exit($msg);
}

update

$sql = "
    UPDATE `{$table}`
    SET template_name = ?,
        template_preview = ?,
        template_public = ?,
        template_path = ?,
        template_html = ?,
        template_data = ?,
        updated_at = NOW()
    WHERE template_id = ?
";
$res = DB::handle($sql, [
    [$title, PDO::PARAM_STR],
    [$preview, PDO::PARAM_STR],
    [$public, PDO::PARAM_INT],
    [$path, PDO::PARAM_STR],
    [$html, PDO::PARAM_STR],
    [$data, PDO::PARAM_STR],
    [$templateId, PDO::PARAM_INT]
]);

if($res && DB::getResult()['row'] >= 1) {
    // 更新成功
} else {
    // 更新失败    
}

delete

$sql = "
    DELETE FROM `{$table}`
    WHERE card_id = ?
";
$res = DB::handle($sql, [
    [ $cardId, PDO::PARAM_INT ]
]);
if($res && DB::getResult()['row'] > 0) {
    // 删除成功
} else {
    // 删除失败
}

PDO中的常量列表

PDO使用类常量自PHP 5.1。

附件下载

相关资料