PHP中MySQLi扩展库的DQL与DML操作及封装示例

准备条件

确保PHP环境已启用 mysqli 扩展，并拥有可连接的MySQL服务器（如 localhost）、用户名、密码及目标数据库（如 test）。操作前建议备份数据库，以防止误操作导致数据丢失。

DQL操作：查询数据

第1步：通过面向对象方式连接并查询

目的：建立数据库连接并执行SELECT语句。

1. 创建对象：实例化 MySQLi 类，传入主机、用户、密码和数据库名。
2. 检查连接：验证 connect_error 属性，若失败则终止程序。
3. 执行查询：调用 query() 方法发送SQL。
4. 处理结果：使用 fetch_row() 等函数遍历结果集。
5. 释放资源：调用 free() 释放结果集，close() 关闭连接。

<?php
header("Content-type: text/html;charset=utf-8");
//1、创建MySQLi对象
$mysqli = new MySQLi("localhost","root","root","test");
if($mysqli->connect_error){
    die("连接失败".$mysqli->connect_error);
}
//2、操作数据库（发送sql）
$sql="select *from user1";
//3、处理结果
$res =$mysqli->query($sql);
while($row=$res->fetch_row()){
    var_dump($row);
}
//4、关闭资源
$res->free();
$mysqli->close();
?>

第2步：通过面向过程方式连接并查询

目的：使用函数式API完成相同功能。

1. 连接：使用 mysqli_connect()。
2. 查询：使用 mysqli_query()，传入连接句柄和SQL。
3. 获取数据：使用 mysqli_fetch_row()。
4. 清理：使用 mysqli_free_result() 和 mysqli_close()。

<?php
header("Content-type: text/html;charset=utf-8");
$mysqli=mysqli_connect("localhost","root","root","test");
if(!$mysqli){
    die("连接失败".mysqli_connect_error());
}
$sql="select *from user1";
$res=mysqli_query($mysqli,$sql);
while($row=mysqli_fetch_row($res)){
    foreach ($row as $val){
        echo '-'.$val;
    }
    echo '<br/>';
}
//释放内存
mysqli_free_result($res);
mysqli_close($mysqli);
?>

DML操作：增删改数据

第1步：执行非查询类SQL

目的：处理 INSERT、UPDATE 或 DELETE 语句并判断影响行数。

1. 构建SQL：编写更新或删除语句。
2. 执行：调用 query()。
3. 判断状态：检查返回布尔值，若为假则报错；若为真，检查 affected_rows 属性。
4. 解读结果：affected_rows > 0 表示成功修改；等于0表示未受影响的行。

<?php
header("Content-type: text/html;charset=utf-8");
$mysqli = new MySQLi("localhost","root","root","test");
if($mysqli->connect_error){
    die("连接失败".$mysqli->connect_error);
}
//更新一条记录
$sql="update user1 set age=20 where id=7";
$res=$mysqli->query($sql);
if(!$res){
    echo "操作失败".$mysqli->error;
}else{
    if($mysqli->affected_rows>0){
        echo "成功";
    }else{
        echo "没有行受影响";
    }
}
//关闭资源
$mysqli->close();
?>

代码封装示例

第1步：构建SqlHelper类

目的：将连接配置和执行逻辑封装，提高复用性。

1. 配置属性：定义静态私有属性存储主机、用户、密码和数据库名。
2. 构造函数：初始化连接，设置字符集为 utf8，并处理连接错误。
3. DQL方法：执行查询，返回结果集对象。
4. DML方法：执行增删改，返回整型状态码（1成功，2无影响，0失败）。

<?php
class SqlHelper{
    private $mysqli;
    private static $host="localhost";
    private static $user="root";
    private static $pwd="root";
    private static $db="test";

    public function __construct(){
        $this->mysqli=new MySQLi(self::$host,self::$user,self::$pwd,self::$db);
        if($this->mysqli->connect_error){
            die("连接失败".$this->mysqli->connect_error);
        }
        //设置字符集
        $this->mysqli->query("set names utf8");
    }

    //dql operate
    function execute_dql($sql){
        $res =$this->mysqli->query($sql) or die($this->mysqli->error);
        return $res;
    }

    //dml operate
    function execute_dml($sql){
        $res =$this->mysqli->query($sql) or die($this->mysqli->error);
        if(!$res){
            return 0;//失败
        }else{
            if($this->mysqli->affected_rows>0){
                return 1;//成功
            }else{
                return 2;//没有行到影响
            }
        }
    }
}

以上就是在PHP中使用MySQLi扩展库进行DQL和DML操作以及简单封装的详细内容，更多关于PHP数据库操作技巧的资料请关注本站其它相关文章！