PHP 中使用 PDO

PDO简介
PDO 是一个“数据库访问抽象层”，作用是统一各种数据库（MySQL、MSSQL、Oracle、DB2、PostgreSQL……）的访问接口，能轻松的在不同的数据库之间完成切换，使得数据库间的移植容易实现。

PDO 驱动

PDO安装
PDO 是 PHP 5.1 发行的，也就是说，在 5.1 之前的版本是不支持 PDO 的，PDO 也是未来 PHP 处理数据库的首选和趋势。

下面介绍 PDO 的安装：

1、Linux 环境

        在 Linux 环境中下为启用对 MySQL 的 PDO 程序驱动支持，需要在安装 PHP （5.1以上版本）的源代码包时，向 configure 命令中添加：

--with-pdo-mysql=/usr/local/mysql   // "/usr/local/mysql"为 MySQL 服务器的安装目录 
--with-pdo-mysql=/usr/local/mysql   // "/usr/local/mysql"为 MySQL 服务器的安装目录
2、Windows 环境

        修改 php.ini 文件，找到如下，把前面的“;”（分号：代表注释）去掉即可！

;extension=php_pdo.dll            // 所有 PDO 驱动共享的扩展，这个必须有 
;extension=php_pdo_mysql.dll  // 使用 MySQL 使用这行 
;extension=php_pdo_mssql.dll  // 使用 MSSQL 使用这行 
;extension=php_pdo.dll            // 所有 PDO 驱动共享的扩展，这个必须有
;extension=php_pdo_mysql.dll  // 使用 MySQL 使用这行
;extension=php_pdo_mssql.dll  // 使用 MSSQL 使用这行
        保存 php.ini 文件，重启 Apache 服务器，查看 phpinfo() 函数，出现下图说明安装成功。

 注意：Windows 环境中，有时可能配置不成功，出现不了上图的现象。这时，把 PHP 安装扩展中的 php_pdo_mysql.dll、php_pdo.dll……等文件拷贝到系统安装路径的 Windows 下。

创建 PDO 对象
PDO 的构造方法原型如下：

__construct(string dsn [,string db_user [,string db_pwd [,array driver_options]]]) 
__construct(string dsn [,string db_user [,string db_pwd [,array driver_options]]])参数说明：
1、dsn(data source name)：数据源名称，定义用到的数据库和驱动；

        a、连接 MySQL 数据库的DSN：mysql:host=localhost;dbname=test  // 主机名为：localhost；数据库名称为：test

        b、连接 Oracle 数据库的DSN：oci:dbname=//localhost:1521/test    // 主机名为：localhost；端口：1521；数据库名称为：test

        ……更多的 DSN 请参考 PHP 手册

2、db_user：数据库用户名；

3、db_pwd：数据库密码；

4、driver_options：是一个数组，用来指定连接所需的所有额外选项

PDO 用来指定连接所需的所有额外选项 

调用 PDO 构造方法（连接数据库）
<?php  
    try { 
        $pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544', array(PDO::ATTR_PERSISTENT=>true)); 
    } catch (PDOException $e) { 
        exit('数据库连接失败，错误信息：'. $e->getMessage()); 
    } 
?> 
<?php
 try {
  $pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544', array(PDO::ATTR_PERSISTENT=>true));
 } catch (PDOException $e) {
  exit('数据库连接失败，错误信息：'. $e->getMessage());
 }
?>

PDO 对象的成员方法
PDO对象中的成员方法

 

使用 PDO 执行 SQL 语句

1、使用 PDO::exec() 方法

PDO::exec() 方法多用在 SQL 中的 INSERT、UPDATE、DELETE，返回的为受影响的行数

<?php  
    date_default_timezone_set('PRC'); 
    header('Content-Type:text/html;Charset=utf-8'); 
    try { 
        $pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544'); 
        $pdo->setAttribute(PDO::ATTR_PERSISTENT, true);  // 设置数据库连接为持久连接  
        $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  // 设置抛出错误  
        $pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true);  // 设置当字符串为空转换为 SQL 的 NULL  
        $pdo->query('SET NAMES utf8');  // 设置数据库编码  
    } catch (PDOException $e) { 
        exit('数据库连接错误，错误信息：'. $e->getMessage()); 
    } 
    $addTime = date('Y-m-d H:i:s', time()); 
    $sql = "INSERT INTO think_user(userName,email,age,addTime) VALUES ('酒井法子','jiujinfazi@sina.com.cn','28','{$addTime}')"; 
    $row = $pdo->exec($sql); 
    if ($row) { 
        echo '添加成功'; 
    } else { 
        echo '添加失败'; 
    } 
?> 
<?php
 date_default_timezone_set('PRC');
 header('Content-Type:text/html;Charset=utf-8');
 try {
  $pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544');
  $pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 设置数据库连接为持久连接
  $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  // 设置抛出错误
  $pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true);  // 设置当字符串为空转换为 SQL 的 NULL
  $pdo->query('SET NAMES utf8');  // 设置数据库编码
 } catch (PDOException $e) {
  exit('数据库连接错误，错误信息：'. $e->getMessage());
 }
 $addTime = date('Y-m-d H:i:s', time());
 $sql = "INSERT INTO think_user(userName,email,age,addTime) VALUES ('酒井法子','jiujinfazi@sina.com.cn','28','{$addTime}')";
 $row = $pdo->exec($sql);
 if ($row) {
  echo '添加成功';
 } else {
  echo '添加失败';
 }
?>
2、使用 PDO::query() 方法

PDO::query() 方法用在 SQL 中的 SELECT 查询上。如果该方法执行成功，那么将返回一个 PDOStatement 对象，使用 rowCount() 方法可以返回影响的行数

<?php  
    header('Content-Type:text/html;Charset=utf-8'); 
    try { 
        $pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544'); 
        $pdo->setAttribute(PDO::ATTR_PERSISTENT, true);  // 设置数据库连接为持久连接  
        $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  // 设置抛出错误  
        $pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true);  // 设置当字符串为空转换为 SQL 的 NULL  
        $pdo->query('SET NAMES utf8');  // 设置数据库编码  
    } catch (PDOException $e) { 
        exit('数据库连接错误，错误信息：'. $e->getMessage()); 
    } 
    $sql = "SELECT userName,email,age,addTime FROM think_user"; 
    try { 
        $result = $pdo->query($sql); 
        foreach ($result as $row) { 
            echo $row['userName'] . "/t" . $row['email'] . "/t" .$row['age']  . "/t" .$row['addTime'] . '<br />'; 
        } 
        echo '总共'. $result->rowCount() .'条'; 
    } catch (PDOException $e) { 
        exit($e->getMessage()); 
    } 
?> 
<?php
 header('Content-Type:text/html;Charset=utf-8');
 try {
  $pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544');
  $pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 设置数据库连接为持久连接
  $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  // 设置抛出错误
  $pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true);  // 设置当字符串为空转换为 SQL 的 NULL
  $pdo->query('SET NAMES utf8');  // 设置数据库编码
 } catch (PDOException $e) {
  exit('数据库连接错误，错误信息：'. $e->getMessage());
 }
 $sql = "SELECT userName,email,age,addTime FROM think_user";
 try {
  $result = $pdo->query($sql);
  foreach ($result as $row) {
   echo $row['userName'] . "/t" . $row['email'] . "/t" .$row['age']  . "/t" .$row['addTime'] . '<br />';
  }
  echo '总共'. $result->rowCount() .'条';
 } catch (PDOException $e) {
  exit($e->getMessage());
 }
?>

PDO 对预处理语句的支持

摘自 Lee.的专栏