mysqli 方式对商品信息表的 CURD 操作

mysqli 方式对商品信息表的 CURD 操作

1. 商品数据库创建

2.创建数据库参数

<?php
return [
    //连接类型
    'type' => $type ?? 'mysql',
    // 主机名host
    'host' => $host ?? 'localhost',
    //默认字符集utf8
    'charset'->$charset ?? 'utf8',
    //默认端口号3306
    'port' => $port ?? '3306',
    //数据库名
    'dbname' => $dbname ?? 'php_goods',
    //数据库用户名
    'dbusername' => $dbusername ?? 'root',
    //数据库用户的密码
    'dbpassword' => $dbpassword ?? 'root'
];

3. 使用连接数据库

<?php
//定义connect文件的命令空间
namespace php_mysqli_connect;
//导入MYSQLi命令空间
use mysqli;
//导入数据库参数
$config = require __DIR__ . '/config/db_mysqli.php';
/**
 * @var string $type
 * @var string $port
 * @var string $charset
 * @var string $dbanme
 * @var string $dbusername
 * @var string $dbpassword
 */
//展开数据库参数
extract($config);
//创建连数据库的对象
$mysqli = new mysqli($host, $dbusername, $dbpassword, $dbname, $port);
// var_dump($mysqli);
//连接异常后报错
if ($mysqli->connect_errno) {
    echo $mysqli->connect_error;
    die();
}
//设置字符集
$mysqli->set_charset($charset);

4. SELECT 单条查询

<?php
//定义select命名空间
namespace php_mysqli_select;
ini_set('display_errors', 1);
error_reporting(E_ALL);
//引入数据库连接文件
require  'connect_mysqli.php';
//引入php_connect命名空间
use php_mysqli_connect;
//创建SQL语句
$sql = 'SELECT `code_goods`, `name_goods`, `num_goods`, `unit_goods`,`price_goods` FROM `goods` WHERE `code_goods`= 1101 ';
//执行查询
$stmts = $mysqli->query($sql);
//指针恢位
// $stmts->data_seek(0);
if ($stmts && $stmts->num_rows > 0) {
    while ($row = $stmts->fetch_assoc()) {
        vprintf("商品编号：%s，商品名称：%s，商品数量：%s %s，商品价格：%s元。</pre>", $row);
    }
} else {
    echo '查询失败或没有查询到满足条件的商品';
}
//释放资源
$stmts->free_result();
$mysqli->close();

结果：

5. SELECT 多条查询

<?php
//定义select命名空间
namespace php_mysqli_select;
ini_set('display_errors', 1);
error_reporting(E_ALL);
//引入数据库连接文件
require  'connect_mysqli.php';
//引入php_connect命名空间
use php_mysqli_connect;
//创建SQL语句
$sql = 'SELECT `code_goods`, `name_goods`, `num_goods`, `unit_goods`,`price_goods` FROM `goods` WHERE `price_goods` > 20 ';
//执行查询
$stmts = $mysqli->query($sql);
//指针恢位
// $stmts->data_seek(0);
if ($stmts && $stmts->num_rows > 0) {
    $rows = $stmts->fetch_all(MYSQLI_ASSOC);
    echo '<ol>';
    foreach ($rows as $row)
        vprintf("<li>商品编号：%s，商品名称：%6s，商品数量：%s %s，商品价格：%s元。</li>", $row);
    echo '</ol>';
} else {
    echo '查询失败或没有查询到满足条件的商品';
}
//释放资源
$stmts->free_result();
$mysqli->close();

结果：

6. INSERT 插入数据

<?php
//定义insert命名空间
namespace php_mysqli_insert;
ini_set('display_errors', 1);
error_reporting(E_ALL);
//引入数据库连接文件
require  'connect_mysqli.php';
//引入php_connect命名空间
use php_mysqli_connect;
//创建SQL语句
$sql = 'INSERT  `goods` SET `code_goods`=1301, `name_goods`="20斤面粉", `num_goods`=212, `unit_goods`="袋",`price_goods`=96.9';
//执行查询
$stmts = $mysqli->query($sql);
if ($stmts) {
    echo '添加商品成功';
} else {
    echo '添加商品失败';
}
//释放资源
unset($stmts, $sql);
$mysqli->close();

插入执行结果：

插入后数据表：

7. UPDATE 修改数据

<?php
//定义insert命名空间
namespace php_mysqli_update;
ini_set('display_errors', 1);
error_reporting(E_ALL);
//引入数据库连接文件
require  'connect_mysqli.php';
//引入php_connect命名空间
use php_mysqli_connect;
//创建SQL语句
$sql = 'UPDATE  `goods` SET `code_goods`=1302, `name_goods`="20斤面粉", `num_goods`=300, `unit_goods`="袋",`price_goods`=96.9 WHERE `id`="17"';
//执行查询
$stmts = $mysqli->query($sql);
if ($stmts) {
    echo '修改商品成功';
} else {
    echo '修改商品失败';
}
//释放资源
unset($stmts, $sql);
$mysqli->close();

修改前原表：

结果：

修改后表：

8. DELETE 删除数据

<?php
//定义insert命名空间
namespace php_mysqli_update;
ini_set('display_errors', 1);
error_reporting(E_ALL);
//引入数据库连接文件
require  'connect_mysqli.php';
//引入php_connect命名空间
use php_mysqli_connect;
//创建SQL语句
$sql = 'UPDATE  `goods` SET `code_goods`=1302, `name_goods`="20斤面粉", `num_goods`=300, `unit_goods`="袋",`price_goods`=96.9 WHERE `id`="16"';
//执行查询
$stmts = $mysqli->query($sql);
if ($stmts) {
    echo '修改商品成功';
} else {
    echo '修改商品失败';
}
//释放资源
unset($stmts, $sql);
$mysqli->close();

删除前原表：

执行 DELETE 的效果：

删除后的表：

9. 总结

• 使用 mysqli 连接数据库，与 PDO 类似；
• mysqli 方式要与相应方法配对使用；
• 函数不熟悉，需要继续背；