php执行多个存储过程的方法【基于thinkPHP】

2024-05-04 23:51:57

字体：大中小

来源：转载

供稿：网友

本文实例讲述了php执行多个存储过程的方法。分享给大家供大家参考，具体如下：

从以前的使用原生代码来看，只需要将结果集关闭即可，即

$this -> queryID -> close();

使用mysqli方式，修改DbMysqli.class.php，将query函数改为：

public function query($str) {    $this -> initConnect(false);    if (!$this -> _linkID) {      return false;    }    $this -> queryStr = $str;    //释放前次的查询结果    if ($this -> queryID)      $this -> free();    N('db_query', 1);    // 记录开始执行时间    G('queryStartTime');    $this -> queryID = $this -> _linkID -> query($str);    // 对存储过程改进    $ret = array();    $this -> debug();    if (false === $this -> queryID) {      $this -> error();      return false;    } else {      $this -> numRows = $this -> queryID -> num_rows;      $this -> numCols = $this -> queryID -> field_count;      $ret = $this -> getAll();    }    //主要将这段移动了一下，关闭结果集    if ($this -> _linkID -> more_results()) {      while (($res = $this -> _linkID -> next_result()) != NULL) {        $this -> queryID -> close();      }    }    return $ret ;}

下面就可以调用多个存储过程，或许执行其他SQL操作，可以直接使用M函数

在使用thinkphp的时候发现执行多个存储过程只能执行第一个，看了一下源码Driver/Db/DbMysql.class，已经对存储过程进行了一定处理，但是不知道为什么运行不了。

用原生代码解决了问题（下面是部分代码）：

$db = new mysqli(C("DB_HOST"), C("DB_USER"), C("DB_PWD"), C("DB_NAME"));if (mysqli_connect_errno())throw_exception(mysqli_connect_error());$t2 = microtime(true);echo "数据库连接用时：" . (($t2 - $t1)) . "s <br />";$arr = array();// 1st Query$procedure = "call p1()";$result = $db->query($procedure);if ($result) {// Cycle through resultswhile ($row = $result->fetch_object()) {//添加到对象数组$arr[] = $row;}// 这里是最重要的，需要将游标移动下一个结果集$result->close();$db->next_result();}$procedure = "call p2()";$result = $db->query($procedure);if ($result) {// Cycle through resultswhile ($row = $result->fetch_object()) {//添加到对象数组$arr[] = $row;}// 这里是最重要的，需要将游标移动下一个结果集$result->close();$db->next_result();}

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

注：相关教程知识阅读请移步到PHP教程频道。

上一篇：php curl中gzip的压缩性能测试实例分析

下一篇：php实现的http请求封装示例