PDO(PHP Data Object)扩展学习（一）

19条回复

1、PDO知识学习
（1）了解PDO及建立数据库连接
PDO（PHP Data Object）扩展是一个与数据库通讯交互的扩展，与以往使用的mysql或mysqli类似，旨在解决不同数据库的连接及处理一致性问题，奈何在这个追求个性的时代，各个数据库厂家之间的SQL脚本都有自家的个性，有所差异，目前PDO还未完全解决针对所有数据库交互的一致性。
PDO针对数据库提供了一组相对比较简洁的功能，用于查询及获取数据集。其使用相对也比较简单，首先是一如既往的要跟将要操作的数据库取得联系，然后完成各种操作，与数据库取得联系，一般要创建一个PDO对象，然后核对暗号（DNS），匹配后该PDO对象就打入敌人内部，从而开展各项活动，该向外传递情报就传递，该破坏敌人内部就破坏。以MySQL为例我们来一个示例。

$dbConn = new PDO('mysql:host = localhost; dbname=db', 'dbuser', 'dbpwd');

创建成功后再$dbConn中存储PDO对象，然后就可以该干啥干啥了。
（2）基础查询
先看看基础查询，基础查询主要使用PDO对象的query方法，该方法接受SQL查询语句，返回一个叫PDOStatement的对象，返回的对象的fetch方法或者fetchAll方法就可以获得数据集了，具体如下：

$dbConn = new PDO('mysql:host = localhost; dbname=db', 'dbuser', 'dbpwd');
$stmt = $dbConn->query('SELECT Field1,Field2 FROM table_name');
while($row = $stmt->fetch()) {
    echo $row['field1'] . ' ---' $row['field2'] . "\n";
}

（3）数据提取模式
PDOStatement对象的fetch方法与fetchAll方法可接受相应的参数，该参数用于指定数据提取模式，主要反映在结果数据集格式化的模式，共有四个常量，分别是：FETCH_ASSOC、FETCH_NUM、FETCH_BOTH、FETCH_CLASS，其中FETCH_BOTH为默认值。
FETCH_ASSOC：返回的结果集为数组，以查询字段名作为数组的键值，上面的基础查询中输出中的应用；
FETCH_NUM：返回的结果集为数组，以数字作为数组的键值；
FETCH_BOTH：返回的结果集为数组，包含上两者，既有以字段名作为数组的键值，又有以数字作为数组的键值；
FETCH_CLASS：返回的结果集为一个已经命名的类的对象，以查询列名设置到类对象的属性中；
（4）参数及预处理
PDO扩展还可以对查询脚本参数进行预处理操作，可以在SQL语句中针对查询条件设定参数，可以在执行过程中给参数设定具体的值，等于说将PDOStatement对象的Query分为两步来运行，先传入预处理SQL语句，然后再赋值执行。使用预处理的好处是编译一次，多次执行，能够提高效率，要快于query查询，另外可以有效的防止SQL注入。另外参数也可以用？来代替，需要顺序给参数赋值。预处理还中的参数可以绑定一个值，也可以绑定一个变量。

// 基本操作
$sql = "SELECT * FROM tablename WHERE field = :param";
$stmt = $dbConn->prepare($sql);
$stmt->execute(array("field" => value));
$result = $stmt->fetch();
// 用？代替参数
$sql = "SELECT * FROM tablename WHERE field1 = ? AND field2 = ?";
$stmt = $dbConn->prepare($sql);
$stmt->execute(array(value1,value2));
$result = $stmt->fetch();
// 绑定值、预处理中的变量
$sql = "SELECT * FROM tablename WHERE field1 = :field1 AND field2 = :field2;
$stmt = $dbConn->prepare($sql);
$stmt->bindValue(':field1', value1);
$stmt->bindValue(':field2', value2);
$stmt->execute();
$result = $stmt->fetch();
// 可改变某一参数绑定的值，继续执行
$stmt->bindValue(':field2', value3);
$stmt->execute();
$result2 = $stmt->fetch();
// 还可以给参数绑定变量
$stmt->bindParam(':field2',$value4);
$value4 = value;
$stmt->execute();
$result3 = $stmt->fetch();

（6）数据库操作中的常用操作
（A）获取新插入数据的ID
执行后调用PDO对象的lastInsertId()方法可获得新插入数据的ID。

$sql = "INSERT INTO tablename(field1,field2,field3) VALUES(:field,:field2,:field3)";
$stmt = $dbConn->prepare($sql);
$stmt->execute(array(
        ':field1' => value1,
        ':field2' => value2,
        ':field3' => value3)
);
echo "New insert id : " . $dbConn->lastInsertId();

（B）获取操作影响的行数
执行后调用PDOStatement对象的rowCount方法获得操作影响到行数，参考数据删除操作影响的行数。
（C）数据删除

$sql = "DELETE FROM tablename WHERE field = :field";
$stmt = $dbConn->prepare($sql);
$stmt->execute(array(":field" => value));
echo $stmt->rowCount() . ' rows deleted';

（7）异常处理
连接数据库失败会抛出PDOException异常，预处理失败会返回false或抛出PDOException，可使用getMessage方法获得抛出异常的原因，执行成功返回true，失败返回false，如果执行失败，可使用PDOStatement对象的errorInfo方法获得错误产生的原因。提取数据错误返回false，同样可以使用errorInfo方法获得错误的信息，需要注意的是提取数据会返回空数组或者其他 依据数据提取模式结果，这是没有错误状态的。

        try {
              $dbConn = new PDO("...");
        } catch (PDOException $e) {
              echo "Could not connect to database";
              exit;        
        }
        $sql = "...";
        try {
              $stmt = $dbConn->prepare($sql);
              if($stmt) {
                   if($stmt->execute(...)) {
                       $result = $stmt->fetch();
                   } else {
                       $error = $stmt->errorInfo();
                       ...
                   }
              }
        } catch(PDOException $e) {
            echo $e->getMessage();
        }

（8）PDO的事务处理
PDO对于事物处理的前提是数据库要支持事务处理，对于MySQL来讲表类型为Inno的支持事务，对于一组SQL语句需要进行事务处理，在任何SQL语句运行前调用PDO对象的beginTransaction方法启动事务，所有SQL语句运行成功后，调用PDO对象的commit方法，在运行中改组SQL语句有一个没运行成功，调用PDO对象的rollback方法回滚。

–未完待续 —