前言
MySQL的使用
MySQL多表同时删除方案
MySQL跨表、多表更新SQL语句总结
MySQL存储引擎
安装
常规方式编译安装MySQL
采用cmake方式编译安装MySQL
使用rpm包安装MySQL
使用yum方式安装MySQL
采用二进制方式免编译安装MySQL
多实例的安装
什么是多实例
多实例的作用、问题以及应用场景
多实例安装01【推荐】
多实例官方安装方案02
启动、用户和权限管理
单实例MySQL的启动和关闭的方法
设置及修改MySQL root用户密码
找回丢失的MySQL root用户密码
创建MySQL用户及用户权限管理
基础命令的操作
MySQL库和表相关操作
MySQL中的索引操作
MySQL常用命令
MySQL的错误代码
MySQL复习秘籍
备份与恢复
备份
恢复
mysqlbinlog命令
服务日志
主从复制
主从复制部署配置问题汇总
主从复制读写分离
灾难恢复
配置phpmyadmin连接多实例MySQL
MySQL语句大全
用户创建、权限、删除
数据库与表显示、创建、删除
Mysql表复制及备份还原
数据库表中数据操作
修改表中的指定一条数据
查询表
日志
批量修改Mysql表引擎为InnoDB的方法
数据库抽象层 PDO
PDO对象常用方法
PDO 事务处理
PDO 与 MySQLi 二者效率简单比较
大小写敏感性 lower_case_table_names
CentOS7安装MySQL5.7密码查看与修改
©
This document uses PHP Chinese website manual Release
characters
PDO 对象常用方法
PDO 对象方法
| 方法 | 描述 |
|---|---|
exec() | 执行一条 SQL 语句，并返回其受影响的行数，如果没有受影响的行数则返回 0 |
query() | 执行一条 SQL 语句，返回一个 PDOStatement 对象 |
prepare() | 准备要执行的 SQL 语句，返回 PDOStatement 对象 |
quote() | 返回一个添加引号的字符串，用于 SQL 语句中 |
lastInertId | 返回最后插入的行的ID |
setAttribute() | 设置数据库连接属性 |
getAttribute() | 获取数据库连接属性 |
errorCode() | 获取跟数据库句柄上一次操作相关的 SQLSTATE |
errorInfo() | 获取跟数据库句柄上一次操作的错误信息 |
PDOStatement 对象方法
| 方法 | 描述 |
|---|---|
execute() | 执行一条预处理语句 |
rowCount() | 返回上一个 SQL 语句影响的行数 |
fetch() | 从结果集中获取一行 |
fetchAll() | 返回一个包含结果集中所有行的数组 |
setFetchMode() | 为语句设置默认的获取模式 |
fetchColumn() | 从结果集下一行返回单独的行 |
fetchObject() | 获取下一行并作为一个对象返回 |
bindParam() | 绑定一个参数到指定的变量名 |
bindValue() | 把一个值绑定到一个参数 |
bindColumn() | 绑定一列到一个 PHP 变量 |
getColumnMeta() | 返回结果集中一列的元数据 |
columnCount() | 返回结果集中的列数 |
setAttribute() | 设置一个语句属性 |
getAttribute | 获取一个语句属性 |
errorCode() | 获取跟上一个语句句柄操作相关的SQLSTATE |
errorInfo() | 获取跟上一个语句句柄操作相关的拓展错误信息 |
debugDumpParams() | 打印一条 SQL 预处理命令 |
nextRowset() | 在一个多行集语句句柄中推进到下一个行集 |
exec() 方法
exec() 写入
exec() 方法可以用来执行数据库的 INSERT 、UPDATE、DELETE操作。并且不支持 SELECT 相关操作
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8"));
// 建表 SQL
$sql = <<<EOF
CREATE TABLE IF NOT EXISTS user(
id INT UNSIGNED NOT NULL AUTO_INCREMENT,
username VARCHAR(20) NOT NULL UNIQUE,
password CHAR(32) NOT NULL,
email VARCHAR(30) NOT NULL,
PRIMARY KEY (id)
)ENGINE=InnoDB DEFAULT CHARSET UTF8;
EOF;
$pdo->exec($sql); // 使用 PDO 对象的 exec()方法执行建表语句
// 写入 SQL 语句
$rand = mt_rand(0, 999);
$sql = sprintf('INSERT INTO user (username, password, email) VALUES ("%s","%s","%s")', 'user' . $rand, md5($rand), 'email' . $rand . '@163.com');
$pdo->exec($sql); // 执行成功，返回 int(1)
$pdo->lastInsertId(); // 返回最后写入的主键值,即主键的自增值
// 一次写入多条
$arr = [
['username' => 'username' . mt_rand(0, 999), 'password' => md5(mt_rand(0, 999)), 'email' => 'email' . mt_rand(0, 999) . '@outlook.com'],
['username' => 'username' . mt_rand(0, 999), 'password' => md5(mt_rand(0, 999)), 'email' => 'email' . mt_rand(0, 999) . '@icloud.com'],
['username' => 'username' . mt_rand(0, 999), 'password' => md5(mt_rand(0, 999)), 'email' => 'email' . mt_rand(0, 999) . '@163.com'],
];
$sql = 'INSERT INTO user (username, password, email) VALUES ';
foreach ($arr as $v) {
$sql .= "('{$v['username']}', '{$v['password']}', '{$v['email']}'),";
}
$sql = rtrim($sql, ',');
$pdo->exec($sql); // 返回受影响行数 int(3)
} catch (PDOException $e) {
echo $e->getMessage();
}
执行 pdo 对象的
exec()方法返回受影响的行数、0[例如上例执行创建表的语句返回0] 或者false[当 SQL 语句错误,使用errorInfo()方法获取错误信息。]
exec() 更新与删除
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8"));
// 更新
$sql = "UPDATE user SET username='user1' where id = 1;";
$pdo->exec($sql); // 返回受影响行数
// 删除
$sql = 'DELETE FROM user where id = 1;';
$pdo->exec($sql); // 返回受影响的行数
// 执行 SELECT 操作
$sql = 'SELECT * FROM user;';
$pdo->exec($sql); // 返回 int(0)
} catch (PDOException $e) {
echo $e->getMessage();
}
不允许使用
exec()进行 SELECT 操作。
query() 查询
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8"));
$sql = 'SELECT * FROM user where id = 2';
$res = $pdo->query($sql); // object(PDOStatement)#2 (1) { ["queryString"]=> string(31) "SELECT * FROM user where id = 2" }
// 通过 foreach 遍历对象
foreach ($res as $row) {
print_r($row);
}
} catch (PDOException $e) {
echo $e->getMessage();
}
设置数据库连接属性
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$options = [PDO::ATTR_AUTOCOMMIT => 0];
$pdo = new PDO($dsn, $username, $passwd, $options); // 实例化 PDO 对象时传入属性
/**
* PDO::ATTR_AUTOCOMMIT 自动提交
* PDO::ATTR_CASE 字段名大小写
* PDO::ATTR_CLIENT_VERSION 客户端版本
* PDO::ATTR_CONNECTION_STATUS 连接状态信息
* PDO::ATTR_DRIVER_NAME
* PDO::ATTR_ERRMODE 错误处理模式
* PDO::ATTR_ORACLE_NULLS 空字符串转换成SQL时的 Null
* PDO::ATTR_PERSISTENT
* PDO::ATTR_PREFETCH
* PDO::ATTR_SERVER_INFO 服务器信息
* PDO::ATTR_SERVER_VERSION 服务器版本
* PDO::ATTR_TIMEOUT 超时时间
*/
$pdo->getAttribute(PDO::ATTR_AUTOCOMMIT); // 获取连接属性值
$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 0); // 设置连接属性
} catch (PDOException $e) {
echo $e->getMessage();
}
错误信息
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8"));
$sql = 'SELECT * FROM users'; // 表名不正确
$res = $pdo->exec($sql);
if ($res === false) {
echo $pdo->errorCode(); // 返回SQLSTATE的值 42S02
print_r($pdo->errorInfo()); // 返回错误信息的数组，[0=>'SQLSTATE值', 1=>'错误码', 2=>'错误提示'],Array ( [0] => 42S02 [1] => 1146 [2] => Table 'test.users' doesn't exist )
}
} catch (PDOException $e) {
echo $e->getMessage();
}
quote() 防止 SQL 注入
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$username = ' or 1 = 1 #';
// $pdo->quote('username');
$pdo->quote($username); // quote() 过滤 SQL 字符串中特殊字符
$sql = "SELECT * FROM user where username = '{$username}'";
$pdo->query($sql);
} catch (PDOException $e) {
echo $e->getMessage();
}
使用
quote()方法会转移特殊字符，防止SQL注入，但是不建议这样操作。
预处理查询
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8"));
$sql = "SELECT * FROM user";
// 准备一条 SQL 语句
$res = $pdo->prepare($sql); // object(PDOStatement)#2 (1) { ["queryString"]=> string(43) "SELECT * FROM user where username='user291'" }
// execute() 执行 SQL 语句
$r = $res->execute(); // 返回 boolean
$res->setFetchMode(PDO::FETCH_ASSOC); // 设置返回数据的格式
// $res->fetchAll();
if ($r) {
while ($row = $res->fetch(PDO::FETCH_ASSOC)) { // 获取结果集中一条数据 PDO::FETCH_ASSOC 参数返回关联数组
var_dump($row);
}
}
} catch (PDOException $e) {
echo $e->getMessage();
}
预处理语句中占位符的使用
在调用
execute()的时候传入对应的值，进行语句的预处理。
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$username = ' or 1 = 1 #'; // 'username430'
$sql = "SELECT * FROM user where username = :username"; // 不用给字符串 :username 加上引号
$res = $pdo->prepare($sql); // prepare() 过滤 SQL 字符串中特殊字符
$res->execute([':username' => $username]);
} catch (PDOException $e) {
echo $e->getMessage();
}
使用
?占位符，预处理完 SQL 后使用
excute()的时候，相当于传递一个索引数组。
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$username = 'username430';// ' or 1 = 1 #'; // 'username430'
$sql = "SELECT * FROM user where username = ?"; // 不用给字符串 :username 加上引号
$res = $pdo->prepare($sql); // prepare() 过滤 SQL 字符串中特殊字符
$res->execute([$username]);
var_dump($res->rowCount());
} catch (PDOException $e) {
echo $e->getMessage();
}
bindParam()方法绑定参数
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$sql = 'INSERT INTO user (username, password, email) VALUES (:username, :password, :email)';
$statement = $pdo->prepare($sql); // 预执行SQL
$statement->bindParam(':username', $username, PDO::PARAM_STR); // 绑定参数 :username
$statement->bindParam(':password', $password, PDO::PARAM_STR);
$statement->bindParam(':email', $email, PDO::PARAM_STR);
// 参数赋值
$rand = mt_rand(0, 999);
$username = 'username' . $rand;
$password = md5($rand);
$email = $username . '@qq.com';
$statement->execute();
} catch (PDOException $e) {
echo $e->getMessage();
}
bindValue() 将值绑定到参数
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$sql = 'INSERT INTO user (username, password, email) VALUES (:username, :password, :email)';
$statement = $pdo->prepare($sql);
$rand = mt_rand(0, 999);
$username = 'username' . $rand;
$password = md5($rand);
$statement->bindValue(':username', $username);
$statement->bindValue(':password',$password);
$statement->bindValue(':email',$rand . '@126.com');
$statement->execute();
echo $statement->rowCount();
// 再次绑定值，但是 email 字段使用上面的值
$rand = mt_rand(0, 999);
$username = 'username' . $rand;
$password = md5($rand);
$statement->bindValue(':username', $username);
$statement->bindValue(':password',$password);
$statement->execute();
echo $statement->rowCount();
} catch (PDOException $e) {
echo $e->getMessage();
}
注意： 赋值的
$username和$password的赋值要在bindValue()之前。
bindColum() 绑定参数到列
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$sql = 'SELECT username,password,email FROM user';
$statement = $pdo->prepare($sql);
$statement->execute();
$statement->columnCount(); // 获取结果集中列数
$statement->bindColumn(1, $username);
$statement->bindColumn(2, $password);
$statement->bindColumn(3, $email);
while ($statement->fetch(PDO::FETCH_BOUND)) {
echo 'username：',$username,'，password：',$password,'，email：',$email;
}
} catch (PDOException $e) {
echo $e->getMessage();
}
fetchColumn() 从结果集下一行返回单独的行
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$sql = 'SELECT username,password,email FROM user';
$statement = $pdo->prepare($sql);
$statement->execute();
echo $statement->fetchColumn();
echo $statement->fetchColumn(2); // 获取第 2 行的 password 字段值
} catch (PDOException $e) {
echo $e->getMessage();
}
debugDumpParams() 打印预处理语句
<?php
try {
$dsn = 'mysql:host=localhost;dbname=test';
$username = 'root'; // 数据库用户名
$passwd = 'aaaaaa'; // 数据库密码
$pdo = new PDO($dsn, $username, $passwd, array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES UTF8")); // 实例化 PDO 对象时传入属性
$sql = 'SELECT username,password,email FROM user WHERE id > :id';
$statement = $pdo->prepare($sql);
$statement->bindParam(':id', $id, PDO::PARAM_INT);
$id = 10;
$statement->execute();
print_r($statement->debugDumpParams());
} catch (PDOException $e) {
echo $e->getMessage();
}