PDO简介
PDO 是一个“数据库访问抽象层”，作用是统一各种数据库（MySQL、MSSQL、Oracle、DB2、PostgreSQL……）的访问接口，能轻松的在不同的数据库之间完成切换，使得数据库间的移植容易实现。
PDO 驱动
| 支持PDO 的驱动及相应的数据库列表 | |
| 驱动名 | 对应访问的数据库 |
| PDO_DBLIB | FreeTDS / Microsoft SQL Server / Sybase |
| PDO_FIREBIRD | Firebird / Interbase 6 |
| PDO_MYSQL | MySQL |
| PDO_OCI | Oracle |
| PDO_ODBC | ODBC v3 |
| PDO_PGSQL | PostgreSQL |
| PDO_SQLITE | SQLite |
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::ATTR_AUTOCOMMIT | 确定PDO 是否关闭自动提交功能，设置FALSE 为关闭 |
| PDO::ATTR_CASE | 强制PDO 获取的表字段字符的大小写转换，或原样使用列信息 |
| PDO::ATTR_ERRMODE | 设置错误处理的模式 |
| PDO::ATTR_PERSISTENT | 确定连接是否为持久连接，默认为FALSE，不持久连接 |
| PDO::ATTR_ORACLE_NULLS | 将返回的空字符串转换为SQL 的NULL |
| PDO::ATTR_PREFETCH | 设置应用程序提前获取的数据大小，以K 字节为单位 |
| PDO::ATTR_TIMEOUT | 设置超时之前的等待时间（秒为单位） |
| PDO::ATTR_SERVER_INFO | 包含与数据库特有的服务器信息 |
| PDO::ATTR_SERVER_VERSION | 包含与数据库服务器版本号有关的信息 |
| PDO::ATTR_CLIENT_VERSION | 包含与数据库客户端版本号有关的信息 |
| PDO::ATTR_CONNECTION_STATUS | 设置超时之前的等待时间（秒为单位） |
调用 PDO 构造方法（连接数据库）
try {
$pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544', array(PDO::ATTR_PERSISTENT=>true));
} catch (PDOException $e) {
exit('数据库连接失败，错误信息：'. $e->getMessage());
}
?>
try {
$pdo = new PDO('mysql:host=localhost;dbname=test', 'root', '1715544', array(PDO::ATTR_PERSISTENT=>true));
} catch (PDOException $e) {
exit('数据库连接失败，错误信息：'. $e->getMessage());
}
?>
PDO 对象的成员方法
PDO对象中的成员方法
| 方法名 | 描述 |
| getAttribute() | 获取一个“数据库连接对象”的属性 |
| setAttribute() | 为一个“数据库连接对象”设定属性 |
| errorCode() | 获取错误码 |
| errorInfo() | 获取错误信息 |
| exec() | 处理一条SQL 语句，并返回所影响的行数 |
| query() | 处理一条SQL 语句，并返回一个"PDOStatement" 对象 |
| quote() | 为某个SQL 中的字符串添加引号 |
| lastInsertId() | 获取插入到表中的最后一条数据的主键值 |
| prepare() | 负责准备执行的SQL 语句 |
| getAvailableDrivers() | 获取有效的PDO 驱动器名称 |
| beginTransaction() | 开始一个事务，标明回滚起始点 |
| commit() | 提交一个事务，并执行SQL |
| rollback() | 回滚一个事务 |
使用 PDO 执行 SQL 语句
1、使用 PDO::exec() 方法
PDO::exec() 方法多用在 SQL 中的 INSERT、UPDATE、DELETE，返回的为受影响的行数
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 '添加失败';
}
?>
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() 方法可以返回影响的行数
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'] . '
';
}
echo '总共'. $result->rowCount() .'条';
} catch (PDOException $e) {
exit($e->getMessage());
}
?>
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'] . '
';
}
echo '总共'. $result->rowCount() .'条';
} catch (PDOException $e) {
exit($e->getMessage());
}
?>
PDO 对预处理语句的支持
摘自 Lee.的专栏
