PHP PDO操作MySql数据库 增删改查CURD操作

一、连接MySql数据库

$pdo=new PDO("mysql:host=127.0.0.1;dbname=test","root","root");

二、增删改查 CURD操作

// exec()   :  返回影响行数    添加 删除 修改
// query()  ： 返回查询得结果对象   查询
//$nums=$pdo->exec("INSERT INTO `user` (uid,upwd) VALUES ('zha','456') ");

// $nums=$pdo->exec("DELETE FROM `user` ");    

// $nums=$pdo->exec("UPDATE `user` SET upwd = '111' WHERE id = 6 ");  
// 
   $res=$pdo->query("SELECT * FROM `user` ")->fetchAll();

三、PDO预处理

$id = $_GET['id'];
//  预处理  ：   防SQL注入
//$sql = "DELETE FROM `user` WHERE id = :id ";

$sql2 = "DELETE FROM `user` WHERE id = ? ";

$pdo = new PDO("mysql:host=127.0.0.1;dbname=test","root","root");

$smth=$pdo->prepare($sql2);

//$smth->execute(array(":id"=>$id));
//
//$smth->bindParam(1, $id, PDO::PARAM_INT);
$smth->bindValue(1, $id, PDO::PARAM_INT);

$smth->execute();

四、PDO事务操作

$pdo = new PDO("mysql:host=127.0.0.1;dbname=test","root","root");
$pdo->beginTransaction();
//  会员系统之间转账功能
$sql1 = "UPDATE `user` SET money=money-100 WHERE name='zhangsan' ";
$res1=$pdo->exec($sql1);


$sql2 = "UPDATE `user` SET money=money+100 WHERE name='lisi' ";
$res2 = $pdo->exec($sql2);

if($res1>0 && $res2>0 ){
	$pdo->commit();
echo "pay success";
}else{
	$pdo->rollBack();
echo "pay faild";
}