PDO简单使用示例

PDO简单使用示例基础操作：

<?php  
$dbh = new PDO('mysql:host=localhost;dbname=access_control' 'root' '');    
$dbh->setAttribute(PDO::ATTR_ERRMODE PDO::ERRMODE_EXCEPTION);    
$dbh->exec('set names utf8');   
/*添加*/  
//$sql = "INSERT INTO `user` SET `login`=:login AND `password`=:password";   
$sql = "INSERT INTO `user` (`login` `password`)VALUES (:login :password)"; 
 $stmt = $dbh->prepare($sql);  $stmt->execute(array(':login'=>'kevin2'':password'=>''));    
echo $dbh->lastinsertid();    
/*修改*/  
$sql = "UPDATE `user` SET `password`=:password WHERE `user_id`=:userId";    
$stmt = $dbh->prepare($sql);    
$stmt->execute(array(':userId'=>'7' ':password'=>'4607e782c4d86fd5364d7e4508bb10d9'));    
echo $stmt->rowCount();   
/*删除*/  
$sql = "DELETE FROM `user` WHERE `login` LIKE 'kevin_'"; //kevin%    
$stmt = $dbh->prepare($sql);    
$stmt->execute();    
echo $stmt->rowCount();    
/*查询*/  
$login = 'kevin%';    
$sql = "SELECT * FROM `user` WHERE `login` LIKE :login";    
$stmt = $dbh->prepare($sql);    
$stmt->execute(array(':login'=>$login));    
while($row = $stmt->fetch(PDO::FETCH_ASSOC)){       
 print_r($row);    
}    
print_r( $stmt->fetchAll(PDO::FETCH_ASSOC));   
?>

1. 建立数据库连接：

   <?php  
   $dbh=newPDO('mysql:host=localhost;port=3306; dbname=test'$user$passarray(  
   PDO::ATTR_PERSISTENT=>true  
   ));  
   ?>
   

持久性链接则指定：PDO::ATTR_PERSISTENT=>true。

1. 捕捉错误

   <?php  
   try{  
   $dbh=newPDO('mysql:host=localhost;dbname=test'$user$pass);  
   
   $dbh->setAttribute(PDO::ATTR_ERRMODEPDO::ERRMODE_EXCEPTION);  
   
   $dbh->exec("SET CHARACTER SET utf8");  
   $dbh=null; //断开连接  
   }catch(PDOException$e){  
   print"Error!:".$e->getMessage()."<br/>";  
   die();  
   }  
   ?>
   

1. 事务处理

   <?php  
   try{  
   $dbh->setAttribute(PDO::ATTR_ERRMODEPDO::ERRMODE_EXCEPTION);  
   
   $dbh->beginTransaction();//开启事务  
   $dbh->exec("insertintostaff(idfirstlast)values(23'Joe''Bloggs')");  
   $dbh->exec("insertintosalarychange(idamountchangedate)  
   values(2350000NOW())");  
   $dbh->commit();//提交事务  
   
   }catch(Exception$e){  
   $dbh->rollBack();//错误回滚  
   echo"Failed:".$e->getMessage();  
   }  
   ?>
   

1. 错误处理

a. 静默模式(默认模式)

$dbh->setAttribute(PDO::ATTR_ERRMODEPDO::ERRMODE_SILENT); //不显示错误

$dbh->setAttribute(PDO::ATTR_ERRMODE PDO::ERRMODE_WARNING);//显示警告错误，并继续执行

$dbh->setAttribute(PDO::ATTR_ERRMODEPDO::ERRMODE_EXCEPTION);//产生致命错误，PDOException

<?php  
try{      
 $dbh = new PDO($dsn $user $password);      
 $sql = 'Select * from city where CountryCode =:country';      
 $dbh->setAttribute(PDO::ATTR_ERRMODE PDO::ERRMODE_WARNING);      
 $stmt = $dbh->prepare($sql);      
 $stmt->bindParam(':country' $country PDO::PARAM_STR);      
 $stmt->execute();      
 while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {        
  print $row['Name'] . "/t";      
 }    
}   // if there is a problem we can handle it here    
catch (PDOException $e)  {      
 echo 'PDO Exception Caught.  ';      
 echo 'Error with the database: <br />';      
 echo 'SQL Query: ' $sql;     
 echo 'Error: ' . $e->getMessage();    
}   
?>