在php使用PDO类查询Mysql

在我的PHP开发过程中，数据库的采用都是使用mysql数据库，与数据库有关的操作基本上都是使用php中的mysql扩展函数，例如mysql_query,mysql_connect等函数，使用这些传统的方法来连接查询数据库时，个人觉得有两个弊端，一是没有扩展性，就是只能用在mysql数据库中，如果要更换数据库的之后，使用的PHP扩展函数不同，如果在开发过程中要更换数据库，那么所有与数据库有关的操作都要重来了；第二个是如果过滤语句不严密，就会有SQL注入的风险，导致网站被恶意攻击，失去控制。虽然用mysql_real_escape_string()函数过滤用户提交的值，但是也有缺陷。而使用PHP的PDO扩展的 prepare 方法，就可以有效地避免sql injection 风险。

1、PDO介绍

PDO扩展为PHP访问数据库定义了一个轻量级的、一致性的接口，它提供了一个数据访问抽象层，这样，无论使用什么数据库，都可以通过一致的函数执行查询和获取数据。PDO随PHP5.1发行，在PHP5.0的PECL扩展中也可以使用，无法运行于之前的PHP版本。与mysql和mysqli相比起来，PDO让跨数据库的使用更具有亲和力。

2、PDO的安装与配置

在php5.2.10中，php默认已经安装了pdo。

打开php.ini文件，找到extension=php_pdo.dll这一句，去掉前面的注释符号，然后重启apache即可。如果没有找到这句，可以自己添加一句或者查看系统在安装的时候是否采用了动态链接库文件.so，如果是的话，可以在php目录下找到一个conf.d的文件夹，下面有一个pdo.ini的链接文件，如果里面有一句extension=pdo.so说明已经开启了PDO。

验证一下PHP是否已经开启了PDO，首先写一个脚本，内容是

3、创建一个PDO对象

__construct(string dsn[,string username [,string password [, array driver_options]]]);//pdo的构造方法

如，连接oracle服务器和mysql服务器的DSN格式分别如下所示：

ocl:dbname=//127.0.0.1:1521/mydb //连接oracle服务器的dsn，oci:作为驱动前缀，主机127.0.0.1，端口1521，数据库mydb

mysql:host=127.0.0.1;dbname=testdb //连接Mysql服务器的dsn，mysql:作为驱动前缀，主机127.0.0.1，数据库testdb

$dsn = 'mysql:dbname=testdb;host=127.0.0.1';	$user = 'root';	$password = 'root';	try {		$dbh = new PDO($dsn, $user, $password);	}catch(PDOException $e) {		echo "connect failed: ".$e->getMessage();	}

$dbh->setAttribute(PDO::ATTR_ERrmODE, PDO::ERrmODE_EXCEPTION);

3) 通过设置PDO::ATTR_ORACLE_NULLS类型（包括PDO::NULL_NATURAL，PDO::NULL_EmpTY_STRING，PDO::NULL_TO_STRING）来指定数据库返回的NULL值在php中对应的数值。

5、PDO常用方法及其应用
PDO::query() 主要是用于有记录结果返回的操作，特别是SELECT操作
PDO::exec() 主要是针对没有结果集合返回的操作，如INSERT、UPDATE等操作
PDO::prepare() 主要是预处理操作，需要通过$rs->execute()来执行预处理里面的SQL语句，这个方法可以绑定参数，功能比较强大（防止sql注入就靠这个）
PDO::lastInsertId() 返回上次插入操作，主键列类型是自增的最后的自增ID
PDOStatement::fetch() 是用来获取一条记录
PDOStatement::fetchAll() 是获取所有记录集到一个集合
PDOStatement::fetchColumn() 是获取结果指定第一条记录的某个字段，缺省是第一个字段
PDOStatement::rowCount() :主要是用于PDO::query()和PDO::prepare()进行DELETE、INSERT、UPDATE操作影响的结果集，对PDO::exec()方法和SELECT操作无效。

6、PDO操作MYSQL数据库实例

$sql = "UPDATE article SET title="haha" WHERE id=1";$affected = $dbh->exec($query);if($affected) {	echo "successed";}else {	print_r($dbh->errorINdo());}

$SQLStatament = "INSERT INTO article VALUES(":title, :content")";$param = array(":title" => "something",				":content" => "aaaa");//准备的参数，对应数据库的字段$stmt = $dbh->prepare($SQLStatement);$stmt->execute($param);