PDO

查询用query  执行增加，删除，修改用exec

$stmt=$pdo->query('select *  from user');

$stmt=$pdo->exec(“update user set phone=’’1231231’ where name=’xxxx’”); //修改

$stmt=$pdo->exec(“insert  into  username(username,password)  values(fang,123)”);//添加

$stmt=$pdo->exec(“delete from  dingdan id=3 or id=4”);//删除

PDO获取数据的三种方法

 * 1.fetchALL(); 获取关联数组 用PDO::FETCH_ASSOC （NUM，BOTH）

 * 2.fetch();获取单挑数组

 *    遍历使用while

 *    while($arr=$stmt->fetch(PDO::FETCH_ASSOC)){

echo "<pre>";

print_r($arr);

echo "</pre>";

echo "<hr/>";

}

3.可以通过foreach遍历PDOStatement对象来获取数组

<?php

$pdo=new PDO('mysql:host=localhost;dbname=db66demo','root','root'); $stmt=$pdo->query('select * from user');

$arr=$stmt->fetchAll(PDO::FETCH_ASSOC);

foreach($arr as $v){

$id=$v['id'];

$username=$v['username'];

$password=$v['password'];

echo "<tr>";

echo "<td>{$id}</td>";

echo "<td>{$username}</td>";

echo "<td>{$password}</td>";

echo "</tr>";

}

?>

   我们往往要设置PDO的错误处理方式（建议使用异常的方式）

 * PDO 对错误的处理

 * 1.抛出异常 PDO::ERRMODE_EXCEPTION

 * 2.warning PDO::ERRMODE_WARNING

 * 3.silent PDO::ERRMODE_SILENT

try{

$pdo=new PDO('mysql:host=localhost;dbname=db66demo','root','root');

$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);//设置PDO对于错误的处理方式

$stmt=$pdo->query('select * from user2');

$arr=$stmt->fetchAll(PDO::FETCH_ASSOC);

foreach($arr as $v){

print_r($v);

echo "<hr/>";

}

}catch(PDOException $e){

echo $e->getMessage();

}

容错：<?php

try{

$dsn="mysql:host=localhost;dbname=db66";

$pdo=new PDO($dsn,'root','root',array(PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION));

//$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);

$stmt=$pdo->query('select * from user');

$arr=$stmt->fetchAll(PDO::FETCH_ASSOC);

echo "<pre>";

print_r($arr);

echo "</pre>";

}catch(PDOException $e){

echo $e->getMessage();

}

?>

绑定

try{

$dsn="mysql:host=localhost;dbname=db66demo";

$pdo=new PDO($dsn,'root','root',array(PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION));

$sql="select * from user where id=? or username=?";

$stmt=$pdo->prepare($sql);

//$id=4;

//$username='ztz';

$stmt->bindParam(1,$id);       //只能是变量

$stmt->bindParam(2,$username);

$stmt->execute();

/*

$stmt->bindValue(1,4);       //只能是变量

$stmt->bindValue(2,'ztz');

$stmt->execute();

*/

$arr=$stmt->fetchAll();

echo "<pre>";

print_r($arr);

echo "</pre>";

}catch(PDOException $e){

echo $e->getMessage();

}

?>

* 使用预处理的好处：

 * 1.安全性高

 * 2.多次执行方便

预处理绑定的参数只能是可以加单引号的值，不能使反引号的表结构部分

$sql="insert into user(`username`) values(:username1),(:username2)";

$stmt=$pdo->prepare($sql);

$stmt->bindParam(':username1',$username1);

$stmt->bindParam(':username2',$username2);

$username1='gege';

$username2='lady in air';

$stmt->execute();

echo $stmt->rowCount();//影响行数

echo $pdo->lastInsertId();//获取插入数据的ID号  只有username1时

事务

<?php

/*

 * 1.关闭自动提交 set autocommit=0;

 * 2.开启事务     start transaction;

 * 3.正常执行sql

 * 4.根据实际情况决定是否提交或者回滚 commit | rollback

 *

 * */

try{

$money=50;

$pdo=new PDO('mysql:host=localhost;dbname=db66demo','root','root',array(PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION));

 // 1.关闭自动提交

set autocommit=0;

$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,false);

// 2.开启事务     

start transaction;

$pdo->beginTransaction();

// 3.正常执行sql

$n1=$pdo->exec("update zt set money=money-{$money} where id=1");

$n2=$pdo->exec("update ztz2 set money=money+{$money} where id=1");

if($n1>0 && $n2>0){

$pdo->commit();

}else{

$pdo->rollback();

}

 // 4.根据实际情况决定是否提交或者回滚 commit | rollback

}catch(PDOException $e){

echo $e->getMessage();

$pdo->rollback();

}

?>