针对thinkPHP5框架存储过程bug重写的存储过程扩展类完整实例

php开发 得得之家
这篇文章主要介绍了针对thinkPHP5框架存储过程bug重写的存储过程扩展类,结合完整实例形式给出了修复thinkPHP5存储过程原有bug的扩展类定义与使用方法,需要的朋友可以参考下

本文实例讲述了针对thinkPHP5框架存储过程bug重写的存储过程扩展类。分享给大家供大家参考，具体如下：

近期用tp5框架调取存储过程发现有bug，借鉴了一些官方的函数、以及找了个mysqli的类把存储过程重新写了个扩展类，下面两个类直接放置项目extend目录的stored（这个文件夹名称请按个人习惯命名）目录下，需要注意的是类增加命名空间namespace stored就OK。

1、mysqli类,此类直接在网上找的，新增一个getAllData()的函数来获取存储过程多条数据集


<?php
namespace stored;
/*
掌握满足单例模式的必要条件
(1)私有的构造方法-为了防止在类外使用new关键字实例化对象
(2)私有的成员属性-为了防止在类外引入这个存放对象的属性
(3)私有的克隆方法-为了防止在类外通过clone成生另一个对象
(4)公有的静态方法-为了让用户进行实例化对象的操作
*/
class mysqli{
  //私有的属性
  private static $dbcon=false;
  private $host;
  private $port;
  private $user;
  private $pass;
  private $db;
  private $charset;
  private $link;
  //私有的构造方法
  protected function __construct($config=array()){
    header('content-type:text/html;charset=utf-8');
    $this->host = $config['hostname'] ? $config['hostname'] : 'localhost';
    $this->port = $config['hostport'] ? $config['hostport'] : '3306';
    $this->user = $config['username'] ? $config['username'] : 'root';
    $this->pass = $config['password'] ? $config['password'] : 'root';
    $this->db = $config['database'] ? $config['database'] : 'zhijian';
    $this->charset=isset($config['charset']) ? $config['charset'] : 'utf8';
    //连接数据库
    $this->db_connect();
    //选择数据库
    $this->db_usedb();
    //设置字符集
    $this->db_charset();
  }
  //连接数据库
  private function db_connect(){
    $this->link=mysqli_connect($this->host,$this->user,$this->pass);
    if(!$this->link){
      echo "数据库连接失败<br>";
      echo "错误编码".mysqli_errno($this->link)."<br>";
      echo "错误信息".mysqli_error($this->link)."<br>";
      exit;
    }
  }
  //设置字符集
  private function db_charset(){
    mysqli_query($this->link,"set names {$this->charset}");
  }
  //选择数据库
  private function db_usedb(){
    mysqli_query($this->link,"use {$this->db}");
  }
  //私有的克隆
  private function __clone(){
    die('clone is not allowed');
  }
  //公用的静态方法
  public static function getIntance(){
    if(self::$dbcon==false){
      self::$dbcon=new self;
    }
    return self::$dbcon;
  }
  //执行sql语句的方法
  public function query($sql){
    $res=mysqli_query($this->link,$sql);
    if(!$res){
      echo "sql语句执行失败<br>";
      echo "错误编码是".mysqli_errno($this->link)."<br>";
      echo "错误信息是".mysqli_error($this->link)."<br>";
    }
    return $res;
  }
  //打印数据
  public function p($arr){
    echo "<pre>";
    print_r($arr);
    echo "</pre>";
  }
  public function v($arr){
    echo "<pre>";
    var_dump($arr);
    echo "</pre>";
  }
  //获得最后一条记录id
  public function getInsertid(){
    return mysqli_insert_id($this->link);
  }
  /**
   * 查询某个字段
   * @param
   * @return string or int
   */
  public function getOne($sql){
    $query=$this->query($sql);
    return mysqli_free_result($query);
  }
  //获取一行记录,return array 一维数组
  public function getRow($sql,$type="assoc"){
    $query=$this->query($sql);
    if(!in_array($type,array("assoc",'array',"row"))){
      die("mysqli_query error");
    }
    $funcname="mysqli_fetch_".$type;
    return $funcname($query);
  }
  //获取一条记录,前置条件通过资源获取一条记录
  public function getFormSource($query,$type="assoc"){
    if(!in_array($type,array("assoc","array","row")))
    {
      die("mysqli_query error");
    }
    $funcname="mysqli_fetch_".$type;
    return $funcname($query);
  }
  //获取多条数据，二维数组
  public function getAll($sql){
    $query=$this->query($sql);
    $list=array();
    while ($r=$this->getFormSource($query,"row")) {
      $list[]=$r;
    }
    return $list;
  }
  /**
   * 定义添加数据的方法
   * @param string $table 表名
   * @param string orarray $data [数据]
   * @return int 最新添加的id
   */
  public function insert($table,$data){
    //遍历数组，得到每一个字段和字段的值
    $key_str='';
    $v_str='';
    foreach($data as $key=>$v){
      if(empty($v)){
        die("error");
      }
      //$key的值是每一个字段s一个字段所对应的值
      $key_str.=$key.',';
      $v_str.="'$v',";
    }
    $key_str=trim($key_str,',');
    $v_str=trim($v_str,',');
    //判断数据是否为空
    $sql="insert into $table ($key_str) values ($v_str)";
    $this->query($sql);
    //返回上一次增加操做产生ID值
    return $this->getInsertid();
  }
  /*
   * 删除一条数据方法
   * @param1 $table, $where=array('id'=>'1') 表名 条件
   * @return 受影响的行数
   */
  public function deleteOne($table, $where){
    if(is_array($where)){
      foreach ($where as $key => $val) {
        $condition = $key.'='.$val;
      }
    } else {
      $condition = $where;
    }
    $sql = "delete from $table where $condition";
    $this->query($sql);
    //返回受影响的行数
    return mysqli_affected_rows($this->link);
  }
  /*
  * 删除多条数据方法
  * @param1 $table, $where 表名 条件
  * @return 受影响的行数
  */
  public function deleteAll($table, $where){
    if(is_array($where)){
      foreach ($where as $key => $val) {
        if(is_array($val)){
          $condition = $key.' in ('.implode(',', $val) .')';
        } else {
          $condition = $key. '=' .$val;
        }
      }
    } else {
      $condition = $where;
    }
    $sql = "delete from $table where $condition";
    $this->query($sql);
    //返回受影响的行数
    return mysqli_affected_rows($this->link);
  }
  /**
   * [修改操作description]
   * @param [type] $table [表名]
   * @param [type] $data [数据]
   * @param [type] $where [条件]
   * @return [type]
   */
  public function update($table,$data,$where){
    //遍历数组，得到每一个字段和字段的值
    $str='';
    foreach($data as $key=>$v){
      $str.="$key='$v',";
    }
    $str=rtrim($str,',');
    //修改SQL语句
    $sql="update $table set $str where $where";
    $this->query($sql);
    //返回受影响的行数
    return mysqli_affected_rows($this->link);
  }
  /**
   * @func: 获取存储过程多条数据集
   * @author: bieanju
   * @return: array
   * @createtime: 2017-12-25
   */
  public function getAllData($sql){
    if (mysqli_multi_query($this->link,$sql)) {
      do {
        if ($result = mysqli_store_result($this->link)) {
          while ($row = mysqli_fetch_assoc($result)) {
            $list[] = $row;
          }
          /*必须释放*/
          mysqli_free_result($result);
        }else{
          return false;
        }
        /*mysqli_next_result($this->link) && mysqli_more_results($this->link)*/
      } while (mysqli_next_result($this->link) && mysqli_more_results($this->link));
    } else {
      return false;
    }
    return $list;
  }
}
?>

2、存储过程调用扩展类库：


<?php
/**
 * 针对存储过程处理类
 * @author: bieanju
 * @createtime: 2017-12-21
 */
namespace stored;
use think\Config;
class procs extends mysqli{
  public $mysqli;
  /*
   * 存储过程数据参数
   * */
  protected $data = [];
  /*
   * 执行语句
   * */
  protected $sql = '';
  public function __construct($type = "mysqli"){
    $config = C("存储过程库配置参数");
    if($type == "mysql"){
      $config = Config::get('database');
    }
    $this->mysqli = new mysqli($config);
  }
  /**
   * 根据参数绑定组装最终的SQL语句 便于调试
   * @access public
   * @param string  $sql 带参数绑定的sql语句
   * @param array   $bind 参数绑定列表
   * @return string
   */
  private function getRealSql($sql, array $bind = [])
  {
    foreach ($bind as $key => $val) {
      $value = is_array($val) ? $val[0] : $val;
      $value = is_string($val) ? "'{$val}'" : $val;
      // 判断占位符
      $sql = is_numeric($key) ?
        substr_replace($sql, $value, strpos($sql, '?'), 1) :
        str_replace(
          [':' . $key . ')', ':' . $key . ',', ':' . $key . ' '],
          [$value . ')', $value . ',', $value . ' '],
          $sql . ' ');
    }
    return rtrim($sql);
  }
  /**
   * @func:存储过程执行并得到数据集
   * @author: bieanju
   * @return: boolean
   * @createtime: 2017-12-22
   */
  protected function procs(){
    $procedure = in_array(strtolower(substr(trim($this->sql), 0, 4)), ['call', 'exec']);
    // 参数绑定
    if ($procedure) {
      $sql = $this->getRealSql($this->sql,$this->data);
      return $this->mysqli->getAllData($sql);
    }
    return false;
  }
  /**
   * @func: 存储过程数据
   * @author: bieanju
   * @return: array
   * @createtime: 2017-12-22
   */
  public function data($data = [])
  {
    $this->data = $data;
    return $this;
  }
  /**
   * @func: 存储过程sql
   * @author: bieanju
   * @return: array
   * @createtime: 2017-12-22
   */
  public function sql($sql = '')
  {
    $this->sql = $sql;
    return $this;
  }
  /**
   * 使用DEMO
  */
  public function demo(){
    return $this->sql("call demo(?,?,?,?,?,?)")->procs();
  }
}
?>

3、最终项目中使用demo：


use stored\procs;
/*用use加载后第一步实例化下存储过程类*/
 $this->procs = new procs("mysqli");
/*第二步调用demo方法并获取数据*/
//$data为给存储过程占位符传递的参数必须为array|[ ]
$this->procs->data($data)->demo();

ok是不是调用很简单、多条存储过程的数据集就此拿到！

更多关于thinkPHP相关内容感兴趣的读者可查看本站专题：《ThinkPHP入门教程》、《thinkPHP模板操作技巧总结》、《ThinkPHP常用方法总结》、《codeigniter入门教程》、《CI(CodeIgniter)框架进阶教程》、《Zend FrameWork框架入门教程》及《PHP模板技术总结》。

希望本文所述对大家基于ThinkPHP框架的PHP程序设计有所帮助。

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！

相关文档推荐

PHP堆栈调试操作简单示例
这篇文章主要介绍了PHP堆栈调试操作,结合简单实例形式分析了php使用debug_backtrace()函数进行堆栈调试操作方法,需要的朋友可以参考下
Phpstorm+Xdebug断点调试PHP的方法
这篇文章主要介绍了Phpstorm+Xdebug断点调试PHP的方法，本教程将通过配置Xdebug扩展进行断点调试，目的在于提高大家的开发效率，感兴趣的小伙伴们可以参考一下
PHP排序算法之冒泡排序(Bubble Sort)实现方法详解
这篇文章主要介绍了PHP排序算法之冒泡排序(Bubble Sort)实现方法,参照大话数据结构中的算法,结合实例形式较为详细的分析了冒泡排序的原理与相关实现技巧,需要的朋友可以参考下
Mac系统下安装PHP Xdebug
本文给大家详细讲述了在Mac系统下安装PHP Xdebug的详细步骤和流程，一起学习下吧。
thinkPHP5框架实现分页查询功能的方法示例
这篇文章主要介绍了thinkPHP5框架实现分页查询功能的方法,结合实例形式分析了thinkPHP5实现分页查询功能的相关控制器、模板等操作技巧,需要的朋友可以参考下
Ubuntu上安装yaf扩展的方法
下面小编就为大家分享一篇Ubuntu上安装yaf扩展的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
php开发Java开发Python开发C/C++开发C#/.NET开发其他开发语言
html vue validate adobe dreamweaver hbuilder vscode aptana editor dedecms ckeditor 编辑器 过滤 规则 织梦 图片本地化 模板 缩略图 图集 图片删除 ajax 瀑布流 无限下拉 cms 判断 sql 清除 tag 文档数 angularjs2 按钮 切换效果 vue3 thinkphp yii2 css 项目列表 li go Beego Buffalo Echo Gin Iris Revel 百度云 虚拟主机 pbootcms 伪静态 框架 排序 数据库 对象 字段 sql语句 php 字符串 分割 D3.js bootstrap 函数 svg selectAll 织梦cms 关键词 解析 采集 长度限制 日期 正则表达式