PDO exec() query() prepare() PDOException 事务处理
http://hi.baidu.com/gaolamp/item/4bbfe657ba16f7c79e266763
 
基于驱动的。
php_pdo.dll
php_pdo_mysql.dll
php.ini 
       打开扩展。
三个类：
      PDO类
      PDOsatement
      PDOexcaption
      常量
PDO __construct();
一，创建PDO对象
dsn(data source name)数据源名
$pdo=new PDO();
$pdo=new PDO("url=pash","","");
php.ini  配置pdo.dsn.mysqlpdo=mysql:host= ;dbname= 
try{
    $pdo=new PDO("mysql:host= ;dbname= ","","");
}catch(PDOException $w){
                echo "数据库连接成功：".$w->getMessage();
                exit;
}
----------------------
<?php
 try{    //调优参数
  $driver_opts=array(PDO::ATTR_AUTOCOMMIT=>0, PDO::ATTR_PERSISTENT=>true); 
  $pdo=new PDO("mysql:host=localhost;dbname=xsphpdb", "root", "123456", $driver_opts);
         //设置属性
  $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 0);
  $pdo->setAttribute(PDO::ATTR_PERSISTENT, true);
 }catch(PDOException $e){
  echo "数据库连接失败：".$e->getMessage();
  exit;
 }
         //获取信息
 echo $pdo->getAttribute(PDO::ATTR_PERSISTENT)."<br>"; 持久连接
 echo $pdo->getAttribute(PDO::ATTR_AUTOCOMMIT)."<br>";
 echo $pdo->getAttribute(PDO::ATTR_CLIENT_VERSION)."<br>";
 echo $pdo->getAttribute(PDO::ATTR_SERVER_INFO)."<br>";
 echo $pdo->getAttribute(PDO::ATTR_SERVER_VERSION)."<br>";
 echo $pdo->getAttribute(PDO::ATTR_DRIVER_NAME)."<br>";
------------------------------------方法
<?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()返回的是影响的行数
echo "影响的行数".$pdo->exec("insert into shops(name1, price, num, desn) values('aa', '12.1', '10', 'good')");
         
设置错误报告模式 
              ERRMODE_SILENT   
              ERRMODE_WARNING  警告模式

                echo $pdo->errorCode()."<br>";
  print_r($pdo->errorInfo());
           $pdo->setAttribute(PDO::ATTR_ERRMODE,  PDO::ERRMODE_EXCEPTION/2)
$affected_rows 影响行数
 if(!$affected_rows){   
  echo $pdo->errorCode()."<br>";
  print_r($pdo->errorInfo()); 
 }else{
  echo "执行成功！";
 }

 --------------------------------------------使用这样模式
try{
  $pdo=new PDO("mysql:host=localhost;dbname=xsphpdb", "root", "123456");
  $pdo->setAttribute(PDO::ATTR_ERRMODE,  PDO::ERRMODE_EXCEPTION);//异常模式设置1，2，3
 }catch(PDOException $e){
  echo "数据库连接失败：".$e->getMessage();
  exit;
 }
 //执行SQL语句 exec() query()  prepare()
 //一是有结果集的query()， 执行select语句
 //exec()用来执行有影响行数的，update, delete insert, other
 //exec()返回的是影响的行数
 try{
  $affected_rows=$pdo->exec("insert into shops(name1, price, num, desn) values('aa', '12.1', '10', 'good')");
 }catch(PDOException $e){
  echo $e->getMessage();
 }
---------------------------------------------------
try{
  $pdo=new PDO("mysql:host=localhost;dbname=xsphpdb", "root", "123456");
  $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()返回的是影响的行数
 try{
  $affected_rows=$pdo->exec("insert into shops(name, price, num, desn) values('bb', '12.1', '10', 'good')");
  echo "最后插入的自动增长的ID：".$pdo->lastInsertId();//获取自动增长的ID
 }catch(PDOException $e){
  echo $e->getMessage();
 }
--------------------------------------------------------------执行查询语句
try{
  $stmt=$pdo->query("select * from shops");
  foreach($stmt as $row){   支持遍历
   print_r($row);
   echo '<br>';
  }
 }catch(PDOException $e){
  echo $e->getMessage();
 }
 
-------------------------------------------------------------
 事务处理
  *     张三从李四那里买了一台 2000 元的电脑
  *
  *     从张三帐号中扣出 2000元
  *
  *     向李四账号中加入 2000元
  *
  *     从商品表中减少一台电脑
  *
  *     MyIsAM     InnoDB支持事务处理，速度慢
  
                           //type=InnoDB
                PDO::ATTR_AUTOCOMMIT, 0  //关闭自动提交
 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
--------------------------------------------------------
PDOStatement类    预处理语句

 帮我们准一个语句和在PDO中对象的exec()以及query()相比
 
 优点：  执行效率高
  安全性更高
 帮我们处理结果集
 prepare（）；
        
 是推荐使用
 /* pdo中有两种占位符号
  *  
  *  ? 参数             --- 索引数组， 按索引顺序使用
  *  名子参数           ----关联数组， 按名称使用，和顺序无关
  */ 
 

try {
  $pdo=new PDO("mysql:host=localhost;dbname=xsphpdb", "root", "123456");
 }catch(PDOException $e){
  echo $e->getMessage();
 }
 
 //获取结果   fetch(常量)关联 索引    一条一条获取
                     fetchAll();  关联 索引  
         setFetchMode(常量);设置模式

 
 $stmt=$pdo->prepare("select id, name, price, num, desn from shops where id > :id order by id");
            //绑定列 顺序或列名
 $stmt->bindColumn("id", $id, PDO::PARAM_INT);
 $stmt->bindColumn("price", $price);
 $stmt->bindColumn("name", $name, PDO::PARAM_STR);
 $stmt->bindColumn(4, $num);
 $stmt->bindColumn(5, $desn);
 $stmt->execute(array(":id"=>100));  返回的是BOOL
 echo '<table border=1 width=900 align="center">';
 echo '<tr>';
       
   //获取列信息
 for($i=0; $i<$stmt->columnCount(); $i++){
  $field=$stmt->getColumnMeta($i);   
  echo '<th>'.$field["name"]."</th>";
 }
 echo '</tr>';
 while($stmt->fetch()){
  echo '<tr>';
  echo '<td>'.$id.'</td>';
  echo '<td>'.$name.'</td>';
  echo '<td>'.$price.'</td>';
  echo '<td>'.$num.'</td>';
  echo '<td>'.$desn.'</td>';
  echo '</tr>';
 }
 echo '</table>';
 echo "总记录数：".$stmt->rowCount()."<br>";
 echo "总字段数：".$stmt->columnCount()."<br>";
---------------------------------------------------------
try {
  $pdo=new PDO("mysql:host=localhost;dbname=xsphpdb", "root", "123456");
 }catch(PDOException $e){
  echo $e->getMessage();
 }
 
 pdo中有两种占位符号
  *  
  *  ? 参数             --- 索引数组， 按索引顺序使用
  *  名子参数           ----关联数组， 按名称使用，和顺序无关
 

 $stmt=$pdo->prepare("insert into shops(name, price, num, desn) values(?, ?, ?, ?)"); //所有SQL都可执行
 
 //准备好了一条语句，并入到服务器端，也已经编译过来了，就差为它分配数据过来
// $stmt=$pdo->prepare("insert into shops(name, price, num, desn) values(:name,:price, :num, :desn)"); 
 
 //绑定名字参数
/* $stmt->bindParam(":name", $name);
 $stmt->bindParam(":num", $num);
 $stmt->bindParam(":desn", $desn);
 $stmt->bindParam(":price", $p);
 */
 //绑定？参数  顺序绑定
 $stmt->bindParam(1, $name, PDO::PARAM_STR);//预定义常量类型
 $stmt->bindParam(3, $num, PDO::PARAM_INT);
 $stmt->bindParam(4, $desn, PDO::PARAM_STR);
 $stmt->bindParam(2, $p, PDO::PARAM_STR);
 $name="wwww1";
 $num=101;
 $desn="hello1";
 $p=34.51;
 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($_POST);
 $stmt->execute(array(":price"=>99, ":name"=>"kkk1", ":num"=>"451", ":desn"=>"aaaaaa1"));
 $stmt->execute(array(":price"=>88, ":name"=>"kkk2", ":num"=>"452", ":desn"=>"aaaaaa2"));
 $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->execute(array("myname2", 11.2, 54, "very good"));
 $stmt->execute(array("myname3", 11.2, 56, "very good"));