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

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

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

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

1. <?php 
2. namespace stored; 
3. /* 
4. 掌握满足单例模式的必要条件 
5. (1)私有的构造方法-为了防止在类外使用new关键字实例化对象 
6. (2)私有的成员属性-为了防止在类外引入这个存放对象的属性 
7. (3)私有的克隆方法-为了防止在类外通过clone成生另一个对象 
8. (4)公有的静态方法-为了让用户进行实例化对象的操作 
9. */ 
10. class mysqli{ 
11.   //私有的属性 
12.   private static $dbcon=false; 
13.   private $host; 
14.   private $port; 
15.   private $user; 
16.   private $pass; 
17.   private $db; 
18.   private $charset; 
19.   private $link; 
20.   //私有的构造方法 
21.   protected function __construct($config=array()){ 
22.     header('content-type:text/html;charset=utf-8'); 
23.     $this->host = $config['hostname'] ? $config['hostname'] : 'localhost'; 
24.     $this->port = $config['hostport'] ? $config['hostport'] : '3306'; 
25.     $this->user = $config['username'] ? $config['username'] : 'root'; 
26.     $this->pass = $config['password'] ? $config['password'] : 'root'; 
27.     $this->db = $config['database'] ? $config['database'] : 'zhijian'; 
28.     $this->charset=isset($config['charset']) ? $config['charset'] : 'utf8'; 
29.     //连接数据库 
30.     $this->db_connect(); 
31.     //选择数据库 
32.     $this->db_usedb(); 
33.     //设置字符集 
34.     $this->db_charset(); 
35.   } 
36.   //连接数据库 
37.   private function db_connect(){ 
38.     $this->link=mysqli_connect($this->host,$this->user,$this->pass); 
39.     if(!$this->link){ 
40.       echo "数据库连接失败<br>"; 
41.       echo "错误编码".mysqli_errno($this->link)."<br>"; 
42.       echo "错误信息".mysqli_error($this->link)."<br>"; 
43.       exit; 
44.     } 
45.   } 
46.   //设置字符集 
47.   private function db_charset(){ 
48.     mysqli_query($this->link,"set names {$this->charset}"); 
49.   } 
50.   //选择数据库 
51.   private function db_usedb(){ 
52.     mysqli_query($this->link,"use {$this->db}"); 
53.   } 
54.   //私有的克隆 
55.   private function __clone(){ 
56.     die('clone is not allowed'); 
57.   } 
58.   //公用的静态方法 
59.   public static function getIntance(){ 
60.     if(self::$dbcon==false){ 
61.       self::$dbcon=new self; 
62.     } 
63.     return self::$dbcon; 
64.   } 
65.   //执行sql语句的方法 
66.   public function query($sql){ 
67.     $res=mysqli_query($this->link,$sql); 
68.     if(!$res){ 
69.       echo "sql语句执行失败<br>"; 
70.       echo "错误编码是".mysqli_errno($this->link)."<br>"; 
71.       echo "错误信息是".mysqli_error($this->link)."<br>"; 
72.     } 
73.     return $res; 
74.   } 
75.   //打印数据 
76.   public function p($arr){ 
77.     echo "<pre>"; 
78.     print_r($arr); 
79.     echo "</pre>"; 
80.   } 
81.   public function v($arr){ 
82.     echo "<pre>"; 
83.     var_dump($arr); 
84.     echo "</pre>"; 
85.   } 
86.   //获得最后一条记录id 
87.   public function getInsertid(){ 
88.     return mysqli_insert_id($this->link); 
89.   } 
90.   /** 
91.    * 查询某个字段 
92.    * @param 
93.    * @return string or int 
94.    */ 
95.   public function getOne($sql){ 
96.     $query=$this->query($sql); 
97.     return mysqli_free_result($query); 
98.   } 
99.   //获取一行记录,return array 一维数组 
100.   public function getRow($sql,$type="assoc"){ 
101.     $query=$this->query($sql); 
102.     if(!in_array($type,array("assoc",'array',"row"))){ 
103.       die("mysqli_query error"); 
104.     } 
105.     $funcname="mysqli_fetch_".$type; 
106.     return $funcname($query); 
107.   } 
108.   //获取一条记录,前置条件通过资源获取一条记录 
109.   public function getFormSource($query,$type="assoc"){ 
110.     if(!in_array($type,array("assoc","array","row"))) 
111.     { 
112.       die("mysqli_query error"); 
113.     } 
114.     $funcname="mysqli_fetch_".$type; 
115.     return $funcname($query); 
116.   } 
117.   //获取多条数据，二维数组 
118.   public function getAll($sql){ 
119.     $query=$this->query($sql); 
120.     $list=array(); 
121.     while ($r=$this->getFormSource($query,"row")) { 
122.       $list[]=$r; 
123.     } 
124.     return $list; 
125.   } 
126.   /** 
127.    * 定义添加数据的方法 
128.    * @param string $table 表名 
129.    * @param string orarray $data [数据] 
130.    * @return int 最新添加的id 
131.    */ 
132.   public function insert($table,$data){ 
133.     //遍历数组，得到每一个字段和字段的值 
134.     $key_str=''; 
135.     $v_str=''; 
136.     foreach($data as $key=>$v){ 
137.       if(emptyempty($v)){ 
138.         die("error"); 
139.       } 
140.       //$key的值是每一个字段s一个字段所对应的值 
141.       $key_str.=$key.','; 
142.       $v_str.="'$v',"; 
143.     } 
144.     $key_str=trim($key_str,','); 
145.     $v_str=trim($v_str,','); 
146.     //判断数据是否为空 
147.     $sql="insert into $table ($key_str) values ($v_str)"; 
148.     $this->query($sql); 
149.     //返回上一次增加操做产生ID值 
150.     return $this->getInsertid(); 
151.   } 
152.   /* 
153.    * 删除一条数据方法 
154.    * @param1 $table, $where=array('id'=>'1') 表名 条件 
155.    * @return 受影响的行数 
156.    */ 
157.   public function deleteOne($table, $where){ 
158.     if(is_array($where)){ 
159.       foreach ($where as $key => $val) { 
160.         $condition = $key.'='.$val; 
161.       } 
162.     } else { 
163.       $condition = $where; 
164.     } 
165.     $sql = "delete from $table where $condition"; 
166.     $this->query($sql); 
167.     //返回受影响的行数 
168.     return mysqli_affected_rows($this->link); 
169.   } 
170.   /* 
171.   * 删除多条数据方法 
172.   * @param1 $table, $where 表名 条件 
173.   * @return 受影响的行数 
174.   */ 
175.   public function deleteAll($table, $where){ 
176.     if(is_array($where)){ 
177.       foreach ($where as $key => $val) { 
178.         if(is_array($val)){ 
179.           $condition = $key.' in ('.implode(',', $val) .')'; 
180.         } else { 
181.           $condition = $key. '=' .$val; 
182.         } 
183.       } 
184.     } else { 
185.       $condition = $where; 
186.     } 
187.     $sql = "delete from $table where $condition"; 
188.     $this->query($sql); 
189.     //返回受影响的行数 
190.     return mysqli_affected_rows($this->link); 
191.   } 
192.   /** 
193.    * [修改操作description] 
194.    * @param [type] $table [表名] 
195.    * @param [type] $data [数据] 
196.    * @param [type] $where [条件] 
197.    * @return [type] 
198.    */ 
199.   public function update($table,$data,$where){ 
200.     //遍历数组，得到每一个字段和字段的值 
201.     $str=''; 
202.     foreach($data as $key=>$v){ 
203.       $str.="$key='$v',"; 
204.     } 
205.     $str=rtrim($str,','); 
206.     //修改SQL语句 
207.     $sql="update $table set $str where $where"; 
208.     $this->query($sql); 
209.     //返回受影响的行数 
210.     return mysqli_affected_rows($this->link); 
211.   } 
212.   /** 
213.    * @func: 获取存储过程多条数据集 
214.    * @author: bieanju 
215.    * @return: array 
216.    * @createtime: 2017-12-25 
217.    */ 
218.   public function getAllData($sql){ 
219.     if (mysqli_multi_query($this->link,$sql)) { 
220.       do { 
221.         if ($result = mysqli_store_result($this->link)) { 
222.           while ($row = mysqli_fetch_assoc($result)) { 
223.             $list[] = $row; 
224.           } 
225.           /*必须释放*/ 
226.           mysqli_free_result($result); 
227.         }else{ 
228.           return false; 
229.         } 
230.         /*mysqli_next_result($this->link) && mysqli_more_results($this->link)*/ 
231.       } while (mysqli_next_result($this->link) && mysqli_more_results($this->link)); 
232.     } else { 
233.       return false; 
234.     } 
235.     return $list; 
236.   } 
237. } 
238. ?> 

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

1. <?php 
2. /** 
3.  * 针对存储过程处理类 
4.  * @author: bieanju 
5.  * @createtime: 2017-12-21 
6.  */ 
7. namespace stored; 
8. use think\Config; 
9. class procs extends mysqli{ 
10.   public $mysqli; 
11.   /* 
12.    * 存储过程数据参数 
13.    * */ 
14.   protected $data = []; 
15.   /* 
16.    * 执行语句 
17.    * */ 
18.   protected $sql = ''; 
19.   public function __construct($type = "mysqli"){ 
20.     $config = C("存储过程库配置参数"); 
21.     if($type == "mysql"){ 
22.       $config = Config::get('database'); 
23.     } 
24.     $this->mysqli = new mysqli($config); 
25.   } 
26.   /** 
27.    * 根据参数绑定组装最终的SQL语句 便于调试 
28.    * @access public 
29.    * @param string  $sql 带参数绑定的sql语句 
30.    * @param array   $bind 参数绑定列表 
31.    * @return string 
32.    */ 
33.   private function getRealSql($sql, array $bind = []) 
34.   { 
35.     foreach ($bind as $key => $val) { 
36.       $value = is_array($val) ? $val[0] : $val; 
37.       $value = is_string($val) ? "'{$val}'" : $val; 
38.       // 判断占位符 
39.       $sql = is_numeric($key) ? 
40.         substr_replace($sql, $value, strpos($sql, '?'), 1) : 
41.         str_replace( 
42.           [':' . $key . ')', ':' . $key . ',', ':' . $key . ' '], 
43.           [$value . ')', $value . ',', $value . ' '], 
44.           $sql . ' '); 
45.     } 
46.     return rtrim($sql); 
47.   } 
48.   /** 
49.    * @func:存储过程执行并得到数据集 
50.    * @author: bieanju 
51.    * @return: boolean 
52.    * @createtime: 2017-12-22 
53.    */ 
54.   protected function procs(){ 
55.     $procedure = in_array(strtolower(substr(trim($this->sql), 0, 4)), ['call', 'exec']); 
56.     // 参数绑定 
57.     if ($procedure) { 
58.       $sql = $this->getRealSql($this->sql,$this->data); 
59.       return $this->mysqli->getAllData($sql); 
60.     } 
61.     return false; 
62.   } 
63.   /** 
64.    * @func: 存储过程数据 
65.    * @author: bieanju 
66.    * @return: array 
67.    * @createtime: 2017-12-22 
68.    */ 
69.   public function data($data = []) 
70.   { 
71.     $this->data = $data; 
72.     return $this; 
73.   } 
74.   /** 
75.    * @func: 存储过程sql 
76.    * @author: bieanju 
77.    * @return: array 
78.    * @createtime: 2017-12-22 
79.    */ 
80.   public function sql($sql = '') 
81.   { 
82.     $this->sql = $sql; 
83.     return $this; 
84.   } 
85.   /** 
86.    * 使用DEMO 
87.   */ 
88.   public function demo(){ 
89.     return $this->sql("call demo(?,?,?,?,?,?)")->procs(); 
90.   } 
91. } 
92. ?> 

3、最终项目中使用demo：

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

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

Tags: thinkPHP5存储过程

分享到：