11月21日-PDO操作数据库-***线上九期班

一、PDO操作数据库之增删改查CURD

创建连接文件：connect.php

<?php
$db = [
    'type'     => 'mysql',
    'host'     => '127.0.0.1',
    'dbname'   => 'mt',
    'username' => 'root',
    'password' => '111',
];
$dsn = "{$db['type']}:host = {$db['host']};dbname = {$db['dbname']}";
try{
    $pdo = new PDO($dsn,$db['username'],$db['password']);
    echo "Connection Success!";
}catch (PDOException $e){
    die('Connection Failed!' . $e -> getMessage());
}

1、新增记录

代码：

<?php
//1.连接
require __DIR__.'/connect.php';
//2.创建sql语句模板
$sql = 'INSERT INTO `category` SET `name` = :name , `alias` = :alias';
//3.创建sql语句对象
$stmt = $pdo ->prepare($sql);
//4.绑定参数
$name = 'bjst';
$alias = '巴勒斯坦';
$stmt ->bindParam('name',$name,PDO::PARAM_STR);
$stmt ->bindParam('alias',$alias,PDO::PARAM_STR);
//5.执行查询
if($stmt -> execute()){
    if($stmt -> rowCount() > 0){
        echo '新增记录'.$stmt -> rowCount().'条';
    }
}else{
    die($stmt -> errorInfo());
}
//6.关闭连接
$pdo = null;

结果：

2、更新记录

代码：

<?php
//1.连接
require __DIR__.'/connect.php';
//2.创建sql语句模板
$sql = 'UPDATE `category` SET `alias` = :alias WHERE `cate_id` = 4';
//3.创建sql语句对象
$stmt = $pdo -> prepare($sql);
//4.绑定参数
$alias = '巴基斯坦';
$stmt ->bindParam('alias',$alias,PDO::PARAM_STR);
//5.执行查询
if($stmt -> execute()){
    if($stmt -> rowCount() > 0){
        echo '更新记录'.$stmt -> rowCount().'条';
    }
}else{
    die($stmt -> errorInfo());
}
//6.关闭连接
$pdo = null;

结果：

3、查询记录

代码：

<?php
//1.连接
require __DIR__ . '/connect.php';
//2.创建sql语句模板
$sql = 'SELECT * FROM `category` WHERE `cate_id` > :cate_id';
//3.创建sql语句对象
$stmt = $pdo -> prepare($sql);
//4.绑定参数
$cate_id = 2;
$stmt -> bindParam('cate_id',$cate_id,PDO::PARAM_INT);
//5.执行查询
if ($stmt -> execute()){
    if ($stmt -> rowCount() > 0){
        $cates = $stmt -> fetchAll(PDO::FETCH_BOTH);
        foreach ($cates as $cate){
            echo '<pre>';
            print_r($cate);
        }
    }
}else{
    die($stmt -> errorInfo());
}
//6.关闭连接
$pdo = null;

结果：

4、删除记录

代码：

<?php
//1.连接
require __DIR__ . '/connect.php';
//2.创建sql语句模板
$sql = 'DELETE FROM `category` WHERE `cate_id` = :cate_id';
//3.创建sql语句对象
$stmt = $pdo->prepare($sql);
//4.绑定参数
$cate_id = 4;
$stmt->bindParam('cate_id', $cate_id, PDO::PARAM_INT);
//5.执行查询
if ($stmt->execute()) {
    if ($stmt->rowCount() > 0) {
        echo '删除记录' . $stmt->rowCount() . '条';
    }
} else {
    die('$stmt -> errorInfo()');
}
//6.关闭连接
$pdo = null;

结果：

二、手抄代码：

总结

绑定参数也可以这样：
$stmt -> execute([‘name’ => $name,’alias’ => $alias]);