PDO: php data object
数据库访问抽象层
基于驱动：
1、安装扩展
php_pdo.dll
2、安装驱动 php_pdo_mysql.dll
linux 编译时参数：--with-pdo=mysql=/usr/local/mysql
三个类：
PDO类， 数据库连接有关（连接、执行sql）
PDOStatement 准备语句，处理结果集
PDOException
异常处理类
一些常量
相比mysqli方法少，常量多
dsn：data source name（数据源）
#部分参数可以省略,参数没有顺序
mysql: #最短 会自动调取 php.in 中
mysql.default_host 参数信息
dsn示例：
mysql:host=localhost;port=3307;dbname=testdb
mysql:unix_socket=/tmp/mysql.sock;dbname=testdb
获取pdo对象
$dsn = "mysql:host=127.0.0.1;port=3306;dbname=test";
$opts = array(PDO::ATTR_AUTOCOMMIT=>0, PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION, PDO::ATTR_AUTOCOMMIT=>0 #关闭自动提交);
$pdo = new PDO($dsn, ‘root‘, ‘‘, $opts);
ee($pdo->getAttribute(PDO::ATTR_AUTOCOMMIT)); // setAttribute 可以设置属性
执行sql exec() query() perpare();
1、返回 PDOStatement 对象 query select
#PDOStatement是专门用来处理结果集的
2、返回影响行数（int） exec insert delete update
PDO::ERRMODE_SILENT（0） ：默认 不提示任何错误
PDO::ERRMODE_WARNING（1） ：
警告
PDO::ERRMODE_EXCEPTION（2）：异常（推荐使用） 用try catch捕获，也可以手动抛出异常 new
PDOException($message, $code, $previous)
#exec用法
try {
$sql = "insert into limove(`id`, `name`, `order`) values(null, ‘sjk‘, 1)";
$rows = $pdo->exec($sql); //影响的条数
$pdo->lastInsertId(); //最后插入的id
} catch (Exception $e) {
ee($pdo->errorInfo());
}
预处理语句(prepare)示例
$dsn = "mysql:host=127.0.0.1;port=3306;dbname=test";
$opts = array(PDO::ATTR_AUTOCOMMIT=>0, PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION, PDO::ATTR_AUTOCOMMIT=>0);
try {
$pdo = new PDO($dsn, ‘root‘, ‘‘, $opts);
}catch(PDOException $e){
echo $e->getMessage();
}/* pdo中有两种占位符号
*
* ? 参数 --- 索引数组， 按索引顺序使用
* 名子参数 ----关联数组， 按名称使用，和顺序无关
*///准备好了一条语句，并入到服务器端，也已经编译过来了，就差为它分配数据过来
//同样适用于更新操作
$stmt=$pdo->prepare("insert into limove(`name`, `order`) values(:name,:order)");//绑定参数，引用方式传递
$stmt->bindParam(":name", $name);
$stmt->bindParam(":order", $order);// $stmt=$pdo->prepare("insert into limove(`name`, `order`) values(?, ?)"); //所有SQL都可执行
// //绑定参数，引用方式传递
// $stmt->bindParam(1, $name, PDO::PARAM_STR);
// $stmt->bindParam(2, $order, PDO::PARAM_INT);$name="wwww";
$order = 1;if($stmt->execute()){
echo "执行成功";
echo "最后插入的ID：".$pdo->lastInsertId();
}else{
echo "执行失败！";
}
还支持执行时绑定
#无序方式
$stmt=$pdo->prepare("insert into shops(name, price, num, desn) values(:name,:price, :num, :desn)");
$stmt->execute(array(":price"=>77, ":name"=>"kkk3", ":num"=>"453", ":desn"=>"aaaaaa3"));#有序方式
$stmt=$pdo->prepare("insert into shops(name, price, num, desn) values(?, ?, ?, ?)"); //所有SQL都可执行
$stmt->execute(array("myname1", 11.2, 55, "very good"));
获取结果
//获取结果
$stmt = $pdo->prepare("select * from limove where `order` = :order");
$stmt->execute(array(‘:order‘=>8));//设置获取的方式
$stmt->setFetchMode(PDO::FETCH_ASSOC);$data = array();
//方式1
//$data = $stmt->fetchAll();//方式2
while($row = $stmt->fetch(PDO::FETCH_ASSOC))
{
$data[] = $row;
}
ee($data);
//bindColumn 把取出的值绑定到一个变量上
$stmt->bindColumn(‘name‘, $name);
#所有的条数，select insert delete update
$stmp->rowCount();
事务举例：
<?php
try{
$pdo=new PDO("mysql:host=localhost;dbname=xsphpdb", "root", "123456", array(PDO::ATTR_AUTOCOMMIT=>0)); #一定要关闭自动提交
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); #开启异常模式
}catch(PDOException $e){
echo "数据库连接失败：".$e->getMessage();
exit;
}//执行SQL语句 exec() query() prepare()
//一是有结果集的query()， 执行select语句
//exec()用来执行有影响行数的，update, delete insert, other
//exec()返回的是影响的行数
/*
*
* 事务处理
*
* 张三从李四那里买了一台 2000 元的电脑
*
* 从张三帐号中扣出 2000元
*
* 向李四账号中加入 2000元
*
* 从商品表中减少一台电脑
*
* MyIsAM InnoDB
*
*/try{
$pdo->beginTransaction();$price=500;
$sql="update zhanghao set price=price-{$price} where id=1";
$affected_rows=$pdo->exec($sql);
if(!$affected_rows)
throw new PDOException("张三转出失败");$sql="update zhanghao set price=price+{$price} where id=3";
$affected_rows=$pdo->exec($sql);
if(!$affected_rows) #发现问题手动抛出异常
throw new PDOException("向李四转入失败");echo "交易成功！";
$pdo->commit();
}catch(PDOException $e){
echo $e->getMessage();
$pdo->rollback(); //只要捕获异常则回滚
}//不管执行成功还是失败最后都要在关闭自动提交
$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 1);//设置错误报告模式 ERRMODE_SILENT ERRMODE_WARNING