【PHP】PDO常用的CURD操作 - PHP编程

Home > List of blog posts > 【PHP】PDO常用的CURD操作

Blogger Information

Blog 94

fans 0

comment 0

visits 92758

Special Recommendation

More>

Related recommendations

PDO常用的CURD操作

1.数据库配置文件，示例

<?php
// database.php
// 数据库连接默认参数
return [
    // 数据库的类型
    'type' => 'mysql',
    // 数据库默认主机
    'host' => 'localhost',
    // 默认数据库
    'dbname' => 'dbname',
     // 默认的用户名
    'username' =>  'username',
    // 默认的用户密码
    'password' => 'username',
    // 默认端口号
    'port' => '3306',
    // 默认字符编码集
    'charset' =>  'utf8',
];

2.数据库连接文件，示例

2.1 获取配置项
2.2 自定义数据库配置
2.3 用自定义数组替换获取的配置项
$config = array_merge($config, $custom);
2.4 解析配置项（将配置项中的数组值解析到变量）
['username'=>$username,'password'=>$password] = $config;
2.5 创建数据源DSN（连接语句对象化）
2.6 创建PDO实例（连接数据库，在此时进行传参）

<?php
// 连接数据库
// 1. 获取配置项
$config = require __DIR__ . '/database.php';
// print_r($config);
// 自定义配置
$custom = [
    // 数据库默认主机
    'host' => 'localhost',
    // 默认数据库
    'dbname' => 'phpedu',
     // 默认的用户名
    'username' =>  'root',
    // 默认的用户密码
    'password' => 'root',
];
// 数组替换更新
$config = array_merge($config, $custom);
// print_r($config);
// 2. 解析配置项
// ['id'=>$id, 'name'=>$name]=['id'=>1,'name'=>'a'];
['type'=>$type,'host'=>$host,'dbname'=>$dbname] = $config;
['username'=>$username,'password'=>$password] = $config;
['port'=>$port,'charset'=>$charset] = $config;
// echo $type, $username, $charset;
// extract($config);
// 3. 创建数据源DSN
// echo vsprintf('%s,%s,%s', ['php','cn','zhu']);
$tmpl = '%s:host=%s;dbname=%s;port=%s;charset=%s';
$params = [$type,$host,$dbname,$port,$charset];
$dsn = vsprintf($tmpl, $params);
// echo $dsn;
// 4. 创建PDO实例(连接数据库)
try {
    $db = new PDO($dsn, $username, $password);
    // if ($db) {
    //     echo '连接成功';
    // }
    // var_dump($db);
    // 设置结果集的获取模式: 仅返回关联部分
    $db->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
} catch (PDOException $e) {
    die('连接失败' . $e->getMessage());
}

3. 连接数据库实例(单一文件)

<?php
// 快速预览
// 1.连接数据库
$db = new PDO('mysql:dbname=phpedu','root','root');
// 2.执行SQL
$stmt = $db->prepare('select id,name,email from user limit 1');
$stmt ->execute();
print_r($stmt->fetch(PDO::FETCH_ASSOC));
// 3.关闭连接
unset($db);

简化版

<?php
// ? 连接数据库
// 1. 连接数据库: PDO类实例
$username = 'root';
$password = 'root';
$dsn = 'mysql:dbname=phpedu';
try {
    $db = new PDO($dsn, $username, $password);
    if ($db) {
        echo '连接成功';
    }
} catch (PDOException $e) {
    die('连接失败' . $e->getMessage());
}

4.数据库操作之：新增（Insert）（命名占位符）

<?php
// ? 新增: INSERT-1
// 1. 连接数据库
require __DIR__ . '/config/connect.php';
// 2. 执行操作
// sql: 预处理,sql中的数据使用占位符(参数)
// 参数有二种: (1) 命名占位符 ":email" (2) 匿名占位符: "?"
$sql = 'INSERT user VALUES (null,:uname,:email,:password)';
// ? 创建sql语句对象 PDOStatement的实例
$stmt = $db->prepare($sql);
// var_dump($stmt);
// ? 将具体的值绑定到参数上
$stmt->bindValue('uname', '老张');
$stmt->bindValue('email', 'lz@qq.com');
$stmt->bindValue('password', md5('123'));
// 查看一下预处理sql语句
// $stmt->debugDumpParams();
// ? 执行sql
if ($stmt->execute()) {
    // 成功
    echo '新增成功, 新记录的主键ID = ' . $db->lastInsertId();
} else {
    echo '新增失败';
    print_r($stmt->errorInfo());
}
// 3. 关闭连接(可选)
// unset($db);
// $db = null;

4.数据库操作之：新增2（匿名占位符）

<?php
// ? 新增: INSERT-2
// 1. 连接数据库
require __DIR__ . '/config/connect.php';
// 2. 执行操作
// sql: 预处理,sql中的数据使用占位符(参数)
// 参数有二种: (1) 命名占位符 ":email" (2) 匿名占位符: "?"
$sql = 'INSERT user VALUES (null,?,?,?)';
// ? 创建sql语句对象 PDOStatement的实例
$stmt = $db->prepare($sql);
// ? 执行sql
if ($stmt->execute(['小猪', 'xz@php.cn', md5('abc')])) {
    // 成功
    echo '新增成功, 新记录的主键ID = ' . $db->lastInsertId();
} else {
    echo '新增失败';
    print_r($stmt->errorInfo());
}
// 3. 关闭连接(可选)
// unset($db);
// $db = null;

5. 数据库操作之：更新

<?php
// ? 更新: UPDATE
// 1. 连接数据库
require __DIR__ . '/config/connect.php';
// 2. 执行操作
$sql = 'UPDATE user SET uname= ?  WHERE id = ?';
// $sql = 'UPDATE user SET uname= ?';
// 检测sql语句中是否存在 where 条件?没有则禁止执行
if (!stristr($sql, 'WHERE')) {
    die('禁止无条件更新');
}
// ? 创建sql语句对象
$stmt = $db->prepare($sql);
// ? 将某个变量绑定到参数上
$stmt->bindParam(1, $uname);
$stmt->bindParam(2, $id);
$uname = '西门庆';
$id = 4;
// ? 执行sql
if ($stmt->execute()) {
    // $stmt->debugDumpParams();
    // 更新成功有二种情况,1.数据变化了,2.数据没有发生变化
    // rowCount(): 返回受影响的记录数量(修改了)
    if ($stmt->rowCount() > 0) {
        echo '更新成功';
    } else {
        echo '没有记录被更新';
    }
} else {
    // echo '更新失败';
    // print_r($stmt->errorInfo());
    die('更新失败: '. $stmt->errorInfo()[2]);
}

6.数据库操作之：删除

<?php
// ? 删除: DELETE
// 1. 连接数据库
require __DIR__ . '/config/connect.php';
// 2. 执行操作
$sql = 'DELETE FROM user  WHERE id = ?';
// $sql = 'DELETE FROM user';
// 检测sql语句中是否存在 where 条件?没有则禁止执行
if (!stristr($sql, 'WHERE')) {
    die('禁止无条件删除');
}
// ? 创建sql语句对象
$stmt = $db->prepare($sql);
// ? 执行sql
if ($stmt->execute([4])) {
    if ($stmt->rowCount() > 0) {
        echo '删除成功';
    } else {
        echo '没有记录被删除';
    }
} else {
    die('删除失败: '. $stmt->errorInfo()[2]);
}

7.数据库操作之：查询1

<?php
// ? 查询: SELECT-1
// 1. 连接数据库
require __DIR__ . '/config/connect.php';
// 2. 执行操作
$sql = 'SELECT id,uname,email FROM user WHERE id IN (?,?,?)';
// ? 创建sql语句对象
$stmt = $db->prepare($sql);
// ? 执行sql
if ($stmt->execute([2, 3, 6])) {
    // 查询成功,结果集解析到数组中
    // 1. 逐条: fetch + while
    // 2. 多条: fetchAll + foreach
    // print_r($stmt->fetch());
    // print_r($stmt->fetch());
    // print_r($stmt->fetch());
    // print_r($stmt->fetch(PDO::FETCH_ASSOC));
    // print_r($stmt->fetch(PDO::FETCH_NUM));
    // fetch + while
    while ($user = $stmt->fetch()) {
        print_r($user);
    }
} else {
    die('查询失败: ' . $stmt->errorInfo()[2]);
}

7.数据库操作之：查询2

<?php
// ? 查询: SELECT-1
// 1. 连接数据库
require __DIR__ . '/config/connect.php';
// 2. 执行操作
$sql = 'SELECT id,uname,email FROM user WHERE id IN (?,?,?)';
// ? 创建sql语句对象
$stmt = $db->prepare($sql);
// ? 执行sql
if ($stmt->execute([2, 3, 6])) {
    // 查询成功,结果集解析到数组中
    // 1. 逐条: fetch + while
    // 2. 多条: fetchAll + foreach
    // print_r($stmt->fetch());
    // print_r($stmt->fetch());
    // print_r($stmt->fetch());
    // print_r($stmt->fetch(PDO::FETCH_ASSOC));
    // print_r($stmt->fetch(PDO::FETCH_NUM));
    // fetch + while
    while ($user = $stmt->fetch()) {
        print_r($user);
    }
} else {
    die('查询失败: ' . $stmt->errorInfo()[2]);
}

7.数据库操作之：查询3

<?php
// ? 查询: SELECT-3: 将列名绑定到变量上
// 1. 连接数据库
require __DIR__ . '/config/connect.php';
// 2. 执行操作
$sql = 'SELECT id,uname,email FROM user WHERE id IN (?,?,?)';
// ? 创建sql语句对象
$stmt = $db->prepare($sql);
// ? 执行sql
if ($stmt->execute([2,3,6])) {
    // 将每一列的值,绑定到指定变量上
    // 三个字段,三个变量
    // 字段的索引,1,2,3,4....
    // $stmt->bindColumn(1, $id);
    // $stmt->bindColumn(2, $uname);
    // $stmt->bindColumn(3, $email);
    // 用字段名称
    $stmt->bindColumn('id', $id);
    $stmt->bindColumn('uname', $uname);
    $stmt->bindColumn('email', $email);
    while ($stmt->fetch()) {
        printf("%d: %s ( %s )\n", $id, $uname, $email);
    }
} else {
    die('查询失败: '. $stmt->errorInfo()[2]);
}

Statement of this Website

The copyright of this blog article belongs to the blogger. Please specify the address when reprinting! If there is any infringement or violation of the law, please contact admin@php.cn Report processing!

All comments Speak rationally on civilized internet, please comply with News Comment Service Agreement

0 comments

Author's latest blog post

【HTML】文档结构与元素，标签，属性的类型

2022-11-27 20:51:59