php中对mysql预编译查询语句的一个封装

谁借莪１个温暖的怀抱￠ 2024-04-17 05:48 6阅读 0赞

最近在做的一个项目，因为使用原生写mysql的缘故，为了防止mysql注入，找到了另一种写法，就是mysql的预处理函数，但是由于这种写法比较繁琐，所以特意对预处理语句进行封装，可以达到基本的增删查改语句以及多条件的兼容，下面贴出代码，代码如下：

/**
     * 获取列表数据
     * @param $selfCon
     * @param $query
     * @param $params
     * @return array
     */
    function _getDataList($selfCon, $query, $params)
    {
        //初始化返回结果接收容器
        $parameters = array();
        //初始化返回结果【返回数据】
        $results = array();
        //开始查询
        $stmt = $selfCon->prepare($query);
        //回调函数传入参数
        call_user_func_array(array($stmt, 'bind_param'), _refValues($params));   //绑定参数
        //执行查询
        $stmt->execute();
        //获取结果
        $meta = $stmt->result_metadata();
        //循环塞进容器
        while ($field = $meta->fetch_field()) {
            $parameters[] = &$row[$field->name];
        }
        //塞进数据容器
        call_user_func_array(array($stmt, 'bind_result'), _refValues($parameters));  //绑定结果
        //有多行记录时将多行记录存入$results数组中.
        while ($stmt->fetch()) {
            $x = array();
            foreach ($row as $key => $val) {
                $x[$key] = $val;
            }
            $results[] = $x;
        }
        //关闭查询
        $stmt->close();
        //返回数据
        return $results;
    }
    
    /**
     * 获取单条数据
     * @param $selfCon
     * @param $query
     * @param $params
     * @return array
     */
    function _getData($selfCon, $query, $params)
    {
        //开始查询
        $stmt = $selfCon->prepare($query);
        //回调函数传入参数
        call_user_func_array(array($stmt, 'bind_param'), _refValues($params));   //绑定参数
        //执行查询
        $stmt->execute();
        //获取数据
        $result = $stmt->get_result()->fetch_array();
        //关闭连接
        $stmt->close();
        //返回
        return $result;
    }
    
    /**
     * 获取数据条数
     * @param $selfCon
     * @param $query
     * @param $params
     * @return mixed
     */
    function _getDataRow($selfCon, $query, $params)
    {
        //开始查询
        $stmt = $selfCon->prepare($query);
        //回调函数传入参数
        call_user_func_array(array($stmt, 'bind_param'), _refValues($params));   //绑定参数
        //执行查询
        $stmt->execute();
        //清除数据
        $stmt->store_result();
        //获取数据条数
        $row = $stmt->num_rows;
        //关闭连接
        $stmt->close();
        //返回
        return $row;
    }
    
    /**
     * 添加数据
     * @param $selfCon
     * @param $query
     * @param $params
     * @return mixed
     */
    function _insertData($selfCon, $query, $params)
    {
        //开始查询
        $stmt = $selfCon->prepare($query);
        //回调函数传入参数
        call_user_func_array(array($stmt, 'bind_param'), _refValues($params));   //绑定参数
        //执行查询
        $stmt->execute();
        //获取本次插入ID
        $insertId = $stmt->insert_id;
        //关闭连接
        $stmt->close();
        //返回
        return $insertId;
    }
    
    /**
     * 更新数据
     * @param $selfCon
     * @param $query
     * @param $params
     * @return mixed
     */
    function _updateData($selfCon, $query, $params)
    {
        //开始查询
        $stmt = $selfCon->prepare($query);
        //回调函数传入参数
        call_user_func_array(array($stmt, 'bind_param'), _refValues($params));   //绑定参数
        //执行查询
        $stmt->execute();
        //获取本次操作的行数
        $updateRow = $stmt->affected_rows;
        $stmt->close();
        //返回
        return $updateRow;
    }
    
    /**
     * 删除数据
     * @param $selfCon
     * @param $query
     * @param $params
     * @return mixed
     */
    function _deleteData($selfCon, $query, $params)
    {
        //开始查询
        $stmt = $selfCon->prepare($query);
        //回调函数传入参数
        call_user_func_array(array($stmt, 'bind_param'), _refValues($params));   //绑定参数
        //执行查询
        $stmt->execute();
        //获取本次操作的行数
        $deleteRow = $stmt->affected_rows;
        $stmt->close();
        //返回
        return $deleteRow;
    }
    
    
    //    内部方法    //
    
    
    /**
     * 转化引入参数
     * @param $arr
     * @return array
     */
    function _refValues($arr)
    {
        if (strnatcmp(phpversion(), '5.3') >= 0) { //Refer
            //ence is required for PHP 5.3+
            $refs = array();
            foreach ($arr as $key => $value) {
                $refs[$key] = &$arr[$key];
            }
            return $refs;
        }
        return $arr;
    }

以上就是封装预处理的整个方法，包括获取多条数据、单天数据、添加、编辑、删除数据，使用也非常方便，实例如下：

$selfCon = mysqli_connect("地址", "账户名", "密码", "数据库名");
    $sql = "INSERT INTO test (uid, content,date,time) VALUES (?,?,?,?)";
    $type = 'ssss';
    $data = array($type, '123', '测试', date('Y-m-d'), date('Y-m-d H:i:s'));
    $getData = _insertData($selfCon, $sql, $data);
    echo $getData;

记住，每次参数类型必须放在参数数组第一位，这样我们就可以使用预处理方法，代码简洁，使用也方便，同时也可以防止被注入。