数据库的增删改查--2019年6月5日22:30分

实例

<?php
// 查询数据

// 1. 连接数据库
require __DIR__ . '/inc/connect.php';

// 2. 创建SQL语句模板
$sql = 'SELECT * FROM `movies` WHERE `cate_id` = :cate_id';

// 3. 创建SQL语句对象
$stmt = $pdo->prepare($sql);

// 4. 将变量绑定到SQL语句模板的命名占位符上
$cate_id = 1;
$stmt->bindParam('cate_id', $cate_id, PDO::PARAM_INT);

// 5. 执行SQL操作
$stmt->execute();

// 遍历数据
while($movie = $stmt->fetch(PDO::FETCH_ASSOC)){
        echo '<pre>' . print_r($movie, true);
}

// 6. 销毁pdo, 关闭连接
$pdo = null;   // unset($pdo) 等价

实例

<?php


// 更新数据

// 1.连接数据库
require __DIR__ . '/inc/connect.php';

// 2.创建数据库语句模板
$sql = 'UPDATE `category` SET `name` =:name, `alias`=:alias wHERE `cate_id`= :cate_id';


// 3. 创建SQL语句对象
$stmt = $pdo->prepare($sql);


// 4. 将变量绑定到SQL语句模板的命名占位符上
$name = 'xjj';
$alias = '小姐姐';
$cate_id = 8;
$stmt->bindParam('name', $name, PDO::PARAM_STR);
$stmt->bindParam('alias', $alias, PDO::PARAM_STR);
$stmt->bindParam('cate_id', $cate_id, PDO::PARAM_INT);


// 5. 执行SQL操作
if($stmt->execute()){
    if($stmt->rowCount() > 0){
        echo '成功更新了' . $stmt->rowCount() . '条记录';
    }
}else {
    die('<pre>' . print_r($stmt->errorInfo(), true));
}

实例

<?php
// 新增数据




// 1.连接数据库
require __DIR__ . '/inc/connect.php';

// 2. 创建SQL语句模板
$sql = 'INSERT INTO `category` SET `name` = :name,`alias` = :alias ';

// 3. 创建SQL语句对象
$stmt = $pdo->prepare($sql);

// 4. 将变量绑定到SQL语句模板的命名占位符上
$name = 'zn';
$alias = '最新的';
$stmt->bindParam('name',$name,PDO::PARAM_STR);
$stmt->bindParam('alias',$alias,PDO::PARAM_STR);

// 5. 执行SQL操作
if ($stmt->execute()) {
    if ($stmt->rowCount() > 0) {
        echo '成功添加' . $stmt->rowCount(). '条记录, 该记录的主键id是: ' . $pdo->lastInsertId();
    }
} else {
    die('<pre>' . print_r($stmt->errorInfo(), true));
}
// 6. 销毁pdo, 关闭连接
$pdo = null;   // unset($pdo) 等价

 

实例

<?php
// 删除数据

// 连接数据库
require __DIR__ . '/inc/connect.php';

// 创建sql语句
$sql = 'DELETE FROM `category` WHERE `cate_id`=:cate_id';

// 3. 创建SQL语句对象

$stmt = $pdo->prepare($sql);

// 4. 将变量绑定到SQL语句模板的命名占位符上
$cate_id = 7;
$stmt->bindParam('cate_id',$cate_id,PDO::PARAM_INT);

// 5. 执行SQL操作
if ($stmt->execute()){
    if($stmt->rowCount() > 0){
        echo '成功删除了' . $stmt->rowCount() . '条记录';
    }else{
        die('<pre>' . print_r($stmt->errorInfo(), true));
    }
}

// 6. 销毁pdo, 关闭连接
$pdo = null;   // unset($pdo) 等价