针对thinkPHP5框架存储过程bug重写的存储过程扩展类完整实例
本文实例讲述了针对thinkPHP5框架存储过程bug重写的存储过程扩展类。分享给大家供大家参考，具体如下：
近期用tp5框架调取存储过程发现有bug，借鉴了一些官方的函数、以及找了个mysqli的类把存储过程重新写了个扩展类，下面两个类直接放置项目extend目录的stored（这个文件夹名称请按个人习惯命名）目录下，需要注意的是类增加命名空间namespacestored就OK。
1、mysqli类,此类直接在网上找的，新增一个getAllData()的函数来获取存储过程多条数据集
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();
}
//连接数据库
privatefunctiondb_connect(){
$this->link=mysqli_connect($this->host,$this->user,$this->pass);
if(!$this->link){
echo"数据库连接失败
";
echo"错误编码".mysqli_errno($this->link)."
";
echo"错误信息".mysqli_error($this->link)."
";
exit;
}
}
//设置字符集
privatefunctiondb_charset(){
mysqli_query($this->link,"setnames{$this->charset}");
}
//选择数据库
privatefunctiondb_usedb(){
mysqli_query($this->link,"use{$this->db}");
}
//私有的克隆
privatefunction__clone(){
die('cloneisnotallowed');
}
//公用的静态方法
publicstaticfunctiongetIntance(){
if(self::$dbcon==false){
self::$dbcon=newself;
}
returnself::$dbcon;
}
//执行sql语句的方法
publicfunctionquery($sql){
$res=mysqli_query($this->link,$sql);
if(!$res){
echo"sql语句执行失败
";
echo"错误编码是".mysqli_errno($this->link)."
";
echo"错误信息是".mysqli_error($this->link)."
";
}
return$res;
}
//打印数据
publicfunctionp($arr){
echo"";
print_r($arr);
echo"
";
}
publicfunctionv($arr){
echo"";
var_dump($arr);
echo"
";
}
//获得最后一条记录id
publicfunctiongetInsertid(){
returnmysqli_insert_id($this->link);
}
/**
*查询某个字段
*@param
*@returnstringorint
*/
publicfunctiongetOne($sql){
$query=$this->query($sql);
returnmysqli_free_result($query);
}
//获取一行记录,returnarray一维数组
publicfunctiongetRow($sql,$type="assoc"){
$query=$this->query($sql);
if(!in_array($type,array("assoc",'array',"row"))){
die("mysqli_queryerror");
}
$funcname="mysqli_fetch_".$type;
return$funcname($query);
}
//获取一条记录,前置条件通过资源获取一条记录
publicfunctiongetFormSource($query,$type="assoc"){
if(!in_array($type,array("assoc","array","row")))
{
die("mysqli_queryerror");
}
$funcname="mysqli_fetch_".$type;
return$funcname($query);
}
//获取多条数据，二维数组
publicfunctiongetAll($sql){
$query=$this->query($sql);
$list=array();
while($r=$this->getFormSource($query,"row")){
$list[]=$r;
}
return$list;
}
/**
*定义添加数据的方法
*@paramstring$table表名
*@paramstringorarray$data[数据]
*@returnint最新添加的id
*/
publicfunctioninsert($table,$data){
//遍历数组，得到每一个字段和字段的值
$key_str='';
$v_str='';
foreach($dataas$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="insertinto$table($key_str)values($v_str)";
$this->query($sql);
//返回上一次增加操做产生ID值
return$this->getInsertid();
}
/*
*删除一条数据方法
*@param1$table,$where=array('id'=>'1')表名条件
*@return受影响的行数
*/
publicfunctiondeleteOne($table,$where){
if(is_array($where)){
foreach($whereas$key=>$val){
$condition=$key.'='.$val;
}
}else{
$condition=$where;
}
$sql="deletefrom$tablewhere$condition";
$this->query($sql);
//返回受影响的行数
returnmysqli_affected_rows($this->link);
}
/*
*删除多条数据方法
*@param1$table,$where表名条件
*@return受影响的行数
*/
publicfunctiondeleteAll($table,$where){
if(is_array($where)){
foreach($whereas$key=>$val){
if(is_array($val)){
$condition=$key.'in('.implode(',',$val).')';
}else{
$condition=$key.'='.$val;
}
}
}else{
$condition=$where;
}
$sql="deletefrom$tablewhere$condition";
$this->query($sql);
//返回受影响的行数
returnmysqli_affected_rows($this->link);
}
/**
*[修改操作description]
*@param[type]$table[表名]
*@param[type]$data[数据]
*@param[type]$where[条件]
*@return[type]
*/
publicfunctionupdate($table,$data,$where){
//遍历数组，得到每一个字段和字段的值
$str='';
foreach($dataas$key=>$v){
$str.="$key='$v',";
}
$str=rtrim($str,',');
//修改SQL语句
$sql="update$tableset$strwhere$where";
$this->query($sql);
//返回受影响的行数
returnmysqli_affected_rows($this->link);
}
/**
*@func:获取存储过程多条数据集
*@author:bieanju
*@return:array
*@createtime:2017-12-25
*/
publicfunctiongetAllData($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{
returnfalse;
}
/*mysqli_next_result($this->link)&&mysqli_more_results($this->link)*/
}while(mysqli_next_result($this->link)&&mysqli_more_results($this->link));
}else{
returnfalse;
}
return$list;
}
}
?>
2、存储过程调用扩展类库：
mysqli=newmysqli($config);
}
/**
*根据参数绑定组装最终的SQL语句便于调试
*@accesspublic
*@paramstring$sql带参数绑定的sql语句
*@paramarray$bind参数绑定列表
*@returnstring
*/
privatefunctiongetRealSql($sql,array$bind=[])
{
foreach($bindas$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.'');
}
returnrtrim($sql);
}
/**
*@func:存储过程执行并得到数据集
*@author:bieanju
*@return:boolean
*@createtime:2017-12-22
*/
protectedfunctionprocs(){
$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);
}
returnfalse;
}
/**
*@func:存储过程数据
*@author:bieanju
*@return:array
*@createtime:2017-12-22
*/
publicfunctiondata($data=[])
{
$this->data=$data;
return$this;
}
/**
*@func:存储过程sql
*@author:bieanju
*@return:array
*@createtime:2017-12-22
*/
publicfunctionsql($sql='')
{
$this->sql=$sql;
return$this;
}
/**
*使用DEMO
*/
publicfunctiondemo(){
return$this->sql("calldemo(?,?,?,?,?,?)")->procs();
}
}
?>
3、最终项目中使用demo：
usestored\procs;
/*用use加载后第一步实例化下存储过程类*/
$this->procs=newprocs("mysqli");
/*第二步调用demo方法并获取数据*/
//$data为给存储过程占位符传递的参数必须为array|[]
$this->procs->data($data)->demo();
ok是不是调用很简单、多条存储过程的数据集就此拿到！
更多关于thinkPHP相关内容感兴趣的读者可查看本站专题：《ThinkPHP入门教程》、《thinkPHP模板操作技巧总结》、《ThinkPHP常用方法总结》、《codeigniter入门教程》、《CI(CodeIgniter)框架进阶教程》、《ZendFrameWork框架入门教程》及《PHP模板技术总结》。
希望本文所述对大家基于ThinkPHP框架的PHP程序设计有所帮助。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。