使用mysqli方式增删改查

使用mysqli方式增删改查

数据表

表名:goods

列	类型	注释
id	int(11) 自动增量	主键
title	varchar(20)	名称
price	decimal(10,2)	价格
status	int(2) [1]	状态
create_time	int(10)	创建时间

查询单条记录

<?php
// 查询单条记录
//  连接数据库
require 'connect.php';
// 2. 操作数据库
$sql = "SELECT `id`, `title`,`price` FROM `goods`  WHERE `price` > 3000";
$mysqli_res = $mysqli->query($sql);
// 指针复位
$mysqli_res->data_seek(0);
if ($mysqli_res && $mysqli_res->num_rows > 0 ) {
    while ($goods = $mysqli_res->fetch_assoc()) {
        printf('<pre>%s</pre>', print_r($goods, true));
    }
} else {
    echo '查询失败或没有查询到满足条件的商品';
}
// 3. 关闭连接 释放结果集
$mysqli_res->free_result();
$mysqli->close();

结果

Array
(
[id] => 2
[title] => 苹果手机
[price] => 6999.00
)
Array
(
[id] => 4
[title] => 联想电脑
[price] => 4888.00
)
Array
(
[id] => 5
[title] => 惠普电脑
[price] => 4666.00
)

查询多条记录

<?php
// 查询多条记录
//  连接数据库
require 'connect.php';
// 2. 操作数据库
$sql = "SELECT `id`, `title`,`price` FROM `goods`  WHERE `price` > 3000";
$mysqli_res = $mysqli->query($sql);
if ($mysqli_res && $mysqli_res->num_rows > 0 ) {
    $goods = $mysqli_res->fetch_all();
    printf('<table>');
    printf('<tr><td>编号</td><td>商品</td><td> 价格</td></tr>');
    foreach ($goods as $title) {
        // vprintf() 与 printf()功能一样, 区别 就是参数是数组
        vprintf('<tr><td>%s </td><td> %s</td><td> %s</td></tr>', $title);
    }
    printf('</table>');
} else {
    echo '查询失败或没有查询到满足条件的商品';
}
// 3. 关闭连接 释放结果集
$mysqli_res->free_result();
$mysqli->close();

结果

编号	商品	价格
2	苹果手机	6999.00
4	联想电脑	4888.00
5	惠普电脑	4666.00

新增操作

<?php
// 新增操作
// 1. 连接数据库
require 'connect.php';
// 2. 操作数据库
// 前端表单->json格式的字符串, php将这种json字符串转为数组/对象
$arr = ['苹果电脑', 9999, '1', 1588123456];
array_walk($arr, function(&$item, $key, $length) {
   if ($key < $length-1 )  $item = "'$item'";
}, count($arr));
$data = implode(', ', $arr);
$sql = "INSERT `goods` (`title`,`price`,`status`,`create_time`) VALUES ($data)";
if ($mysqli->query($sql)) {
    if ($mysqli->affected_rows > 0) {
        echo '成功添加了 ' . $mysqli->affected_rows . ' 条记录, 新增记录主键ID: ' . $mysqli->insert_id;
    } else {
        echo '没有添加新记录';
    }
} else {
    die('添加失败'. $mysqli->errno . ' : ' . $mysqli->error);
}
// 3. 关闭连接
// 释放结果集
$mysqli->close();

结果

成功添加了 1 条记录, 新增记录主键ID: 6

删除操作

<?php
// 删除操作
// 1. 连接数据库
require 'connect.php';
// 2. 操作数据库
$sql = "DELETE FROM `goods` WHERE `id` =" . $_GET['id'];
if ($mysqli->query($sql)) {
    if ($mysqli->affected_rows > 0) {
        echo '成功删除了 id=' .$_GET['id'] . '  的记录';
    } else {
        echo '没有删除任何记录';
    }
} else {
    die('删除失败'. $mysqli->errno . ' : ' . $mysqli->error);
}
// 3. 关闭连接
$mysqli->close();

结果

成功删除了 id=6 的记录

更新操作

<?php
// 更新操作
// 1. 连接数据库
require 'connect.php';
// 2. 操作数据库
// 前端表单->json格式的字符串, php将这种json字符串转为数组/对象
$arr = ['title'=>'华为服务器', 'price'=>'39999'];
array_walk($arr, function(&$item, $key) {
    $item = "`$key` = '$item'";
});
$data = implode(', ', $arr);
$sql = "UPDATE `goods` SET " . $data  . " WHERE `id` = 5";
if ($mysqli->query($sql)) {
    if ($mysqli->affected_rows > 0) {
        echo '成功更新了 ' . $mysqli->affected_rows . ' 条记录';
    } else {
        echo '没有更新任何记录';
    }
} else {
    die('更新失败'. $mysqli->errno . ' : ' . $mysqli->error);
}
// 3. 关闭连接
// 释放结果集
$mysqli->close();

结果

成功更新了 1 条记录