1、编程:MySQLi面向对象中的查询操作
<?php
/**
* 预处理查询操作
*/
//连接数据库
$db_host = '127.0.0.1';
$db_user = 'root';
$db_pass = 'root';
$db_name = 'php';
$db_charset = 'utf8';
//准备SQL语句
$sql = "SELECT `id`,`name`,`salary` FROM `staff` WHERE `salary` > ? ;";
// 创建预处理对象
$stmt = $mysqli->stmt_init();
if ($stmt->prepare($sql)) {
//绑定参数
$stmt->bind_param('i', $salary);
//设置参数
$salary = 5000;
if ($stmt->execute()) {
//获取结果集并放到缓存区
$stmt->store_result();
//将结果集中的列绑定到变量上
$stmt->bind_result($id,$name, $salary);
//结果集是否不为,只有不为空的时候才遍历
if ($stmt->num_rows > 0) {
// 循环遍历结果集
// fetch()每次获取一条记录,并将指针自动下移
while ($stmt->fetch()) {
echo '<p>id:'.$id.'---姓名:' .$name.'---工资:'.$salary.'</p>';
}
} else {
exit('<p>当前表中没有数据</p>');
}
// 释放结果集
$stmt->free_result();
} else {
//返回执行阶段的出错信息
exit($stmt->errno. ': ' . $stmt->error);
}
} else {
//返回sql语句检测阶段的出错信息
exit($stmt->errno. ': ' . $stmt->error);
}点击 "运行实例" 按钮查看在线实例
---------------------------------------------------------------------------------
2. 问答: PDO 的优势
答:
1:PDO真正的以底层实现的统一接口数库操作接口,不管后端使用的是何种数据库,如果代码封装好了以后,应用层调用基本上差不多的,当后端数据库更换了以后,应用层代码基本不用修改.
2:PDO支持更高级的DB特性操作,如:存储过程的调度等,mysql原生库是不支持的.
3:PDO是PHP官方的PECL库,兼容性稳定性必然要高于MySQL Extension,可以直接使用 pecl upgrade pdo 命令升级.
4:PDO可以防止SQL注入,确保数据库更加安全
------------------------------------------------------------------------------------
3. 编程:PDO 连接数据库
<?php
/**
* PDO PHP数据对象,是PHP操作所有数据库的抽象层,提供了一个统一的访问接口
*/
// 数据源:设置数据库的类型,以及数据库服务器和默认的数据库
$dsn = 'mysql:host=127.0.0.1; dbname=php';
//用户名
$user = 'root';
//密码
$pass = 'root';
//实例化PDO类,创建pdo对象,并完成了数据库的连接
try {
$pdo = new PDO($dsn, $user, $pass);
// echo '<h2>连接成功</h2>';
} catch (PDOException $e) {
die('Connect ERROR! :'. $e->getMessage());
}点击 "运行实例" 按钮查看在线实例
4. 编程:PDO新增数据
<?php
/**
* 新增记录
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "INSERT `user` SET `name`= :name , `email`= :email, `password`= sha1(:password)";
//创建预处理对象
$stmt = $pdo->prepare($sql);
//绑定参数
$data = ['name'=>'杨过','email'=>'yg@php.cn','password'=>'123'];
$stmt->bindParam(':name',$data['name'],PDO::PARAM_STR);
$stmt->bindParam(':email',$data['email'],PDO::PARAM_STR);
$stmt->bindParam(':password',$data['password'],PDO::PARAM_STR);
if ($stmt->execute()) {
// rowCount(): 返回受影响的记录数量
echo '<h3>成功添加了'.$stmt->rowCount().'条记录</h3>';
} else {
echo '<h3>添加失败</h3>';
print_r($stmt->errorInfo());
exit();
}
$stmt = null;
// 关闭连接
$pdo = null;点击 "运行实例" 按钮查看在线实例
5.编程: PDO更新数据
<?php
/**
* 更新记录
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "UPDATE `user` SET `email`= :email WHERE `id`= :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
$stmt->execute(['email'=>'yzf@qq.com','id'=>5]);
echo '<h3>成功更新了'.$stmt->rowCount().'条记录</h3>';
$stmt = null;
// 关闭连接
$pdo = null;点击 "运行实例" 按钮查看在线实例
6. 编程: PDO 删除数据
<?php
/**
* 更新记录
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
$sql = "DELETE FROM `user` WHERE `id`= :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
if ($stmt->execute(['id'=>11])) {
// rowCount(): 返回受影响的记录数量
echo '<h3>成功删除了'.$stmt->rowCount().'条记录</h3>';
} else {
echo '<h3>无删除</h3>';
print_r($stmt->errorInfo());
exit();
}点击 "运行实例" 按钮查看在线实例
7. 编程:PDO查询数据
<?php
/**
* PDO 预处理查询
*/
//连接数据库
$pdo = new PDO('mysql:host=127.0.0.1;dbname=php','root','root');
//准备SQL语句,占位符我们不再用?,用"命名占位符"
$sql = "SELECT `name`,`email` FROM `user` WHERE `id` < :id";
//创建预处理对象
$stmt = $pdo->prepare($sql);
//执行查询
$stmt->execute(['id'=>5]);
// 一次性取出
//$rows = $stmt->fetchAll();
//foreach ($rows as $row) {
// echo 'name: ',$row['name'],', email: ',$row['email'],'<br>';
//}
while($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
echo var_export($row),'<br>';
}点击 "运行实例" 按钮查看在线实例
8. 问答: 获取结果集记录数量的正确方式是什么?
用fetchColumn(),如果用rowCount()可能由于其他的数据库,拿不到数据。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号