PDO_CURD操作

pdo_connect.php

实例

<?php
$dsn = 'mysql:host=127.0.0.1;dbname=php;charset=utf8;port=3306';
$user = 'root';
$pass = 'root';
$options = [
	PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, //错误模式
	PDO::ATTR_CASE => PDO::CASE_NATURAL, // 自然名称
	PDO::ATTR_EMULATE_PREPARES => true, // 启用模拟功能
	PDO::ATTR_PERSISTENT => true,
];
try {
	$pdo = new PDO($dsn, $user, $pass, $options);
//	echo 'connect ok!';
} catch (PDOException $e) {
	print '连接错误' . $e->getMessage();
	die();
}
// unset($pdo)
// $pdo = null

pdo_pre_insert.php

实例

<?php
// 创建pdo对象
$pdo = new PDO('mysql:dbname=php', 'root', 'root');
// 准备sql语句
$sql = "insert `user` set `user_name` = :user_name, `email` = :email, `password` = sha1(:password)";
// 创建预处理对象
$stmt = $pdo->prepare($sql);
// 绑定参数
$info = ['user_name'=>'张三丰', 'email'=>'zsf@zsf.com', 'password'=>'123'];
$stmt->bindParam(':user_name',$info['user_name'],PDO::PARAM_STR);
$stmt->bindParam(':email',$info['email'],PDO::PARAM_STR);
$stmt->bindParam(':password',$info['password'],PDO::PARAM_STR);
if ($stmt->execute()) {
	echo '添加了' . $stmt->rowCount() . '条记录';
} else {
	echo '添加失败';
	print_r($stmt->errorInfo());
	die();
}

pdo_pre_delete.php 

实例

<?php
$pdo = new PDO('mysql:dbname=php', 'root', 'root');
$sql = "delete from user where user_id  = :id";
$stmt = $pdo->prepare($sql);
$id = 4;
// $data = ['user_id'=> 4]
$stmt->bindParam(':id',$id,PDO::PARAM_INT);

//if ($stmt->execute($data)){
if ($stmt->execute()){
	echo '成功的删除了' . $stmt->rowCount() . '数据';
}else {
	echo '删除失败';
	print_r($stmt->errorInfo());
}

pdo_pre_update.php 

实例

<?php
$pdo = new PDO('mysql:dbname=php', 'root', 'root');
$pdo->prepare("update user set user_name = :user_name, email = :email where user_id = :user_id")->execute(['user_name'=>'张老道','email'=>'oye@oye.com','user_id'=>5]);

pdo_pre_query.php

实例

<?php
//创建pdo对象
$pdo = new PDO('mysql:dbname=php', 'root', 'root');
$sql = "select * from staff where age > :age";
//创建预处理语句
$stmt = $pdo->prepare($sql);
// 绑定参数
$age = 30;
$stmt->bindParam(':age', $age, PDO::PARAM_INT); // bindParam第二个参数只能是变量
//$stmt->bindValue(':age', 22, PDO::PARAM_INT) // bindValue 第二个参数可以是字面量
// 执行查询
$stmt->execute();
// 得到结果集
//$stmt->setFetchMode(PDO::FETCH_ASSOC);

//while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
//	echo '<pre>';
//		print_r($row);
//	echo '</pre>';
//}
$rows = $stmt->fetchAll();
echo '<pre>';
print_r($rows);
echo '</pre>';

pdo_pre_query2.php

实例

<?php
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php', 'root', 'root');
$stmt = $pdo->prepare("select * from staff where age > :f_age");
$stmt->execute(['f_age' => 30]);
// 将结果集中的列与变量进行绑定
$stmt->bindColumn('name', $name);
$stmt->bindColumn('age', $age);
while ($stmt->fetch()) {
	echo '姓名为: ' . $name . ' 年纪为: ' . $age;
	echo '<hr>';
}
//$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);

pdo_pre_query3.php

实例

<?php
/*
 * 预处理多语句查询操作
 */
// 创建pdo对象
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php', 'root', 'root');

// 准备sql语句
$sql1 = "select * from staff where salary < :salary";
$sql2 = "select * from staff where age > :age";
$stmt1 = $pdo->prepare($sql1);
$stmt2 = $pdo->prepare($sql2);

// 查找工资小于5000的员工
$stmt1->execute(['salary' => 5000]);
echo '<pre>';
	var_export($stmt1->fetchAll(PDO::FETCH_ASSOC));
echo '</pre>';

//关闭第一个预处理对象
$stmt1->closeCursor();

echo '<hr>';
// 查找年纪大于50的员工
$stmt2->execute(['age' => 50]);
echo '<pre>';
var_export($stmt2->fetchAll(PDO::FETCH_ASSOC));
echo '</pre>';