如何使用 Zend 框架在 MySql 数据库中使用存储过程？答案

【问题标题】：How can I use a stored procedure in a MySql database with Zend Framework?如何使用 Zend 框架在 MySql 数据库中使用存储过程？
【发布时间】：2010-11-21 04:39:19
【问题描述】：

我最近学会了使用 Zend Framework。我做了一个简单的 CRUD 应用程序。但现在我想将现有数据库用于更复杂的应用程序，我想知道如何在模型中调用存储过程，如何发送参数，如何读取结果并将它们存储在 PHP 中的数组中。请。我感谢任何形式的帮助:)

【问题讨论】：

如果您想在托管 MySQL 数据库的 GoDaddy 中使用存储过程，请检查您是否可以将其与数据库备份一起备份。根据我的经验，他们不允许备份存储过程。使用它们让我无法接受。

标签： zend-framework stored-procedures

【解决方案1】：

这并不难。下面是一个带有IN 参数、OUT 参数和结果集的 MySQL 存储过程示例：

CREATE PROCEDURE MyProc(IN i INTEGER, OUT o INTEGER)
BEGIN
  SELECT i+10 INTO o;
  SELECT i, o;
END

您可以使用query() 方法调用它，并传递一个参数：

$stmt = $db->query("CALL MyProc(?, @output)", array(25));
print_r( $stmt->fetchAll() );

诀窍在于 MySQL 存储的过程可能会返回多个结果集（例如，如果过程有多个 SELECT 查询）。因此，API 必须先遍历所有结果集，然后才能执行另一个 SQL 查询。否则您会收到“Commands out of sync”错误。

如果您使用 PDO_MySQL 适配器：

while ($stmt->nextRowset()) { }

如果你使用MySQLi适配器，你会发现Zend_Db_Statement_Mysqli没有实现nextRowset()，所以你必须调用内部的mysqli连接对象：

while ($db->getConnection()->next_result()) { }

清除结果集后，您可以运行后续 SQL 查询，例如获取过程的 OUT 参数的值：

$stmt = $db->query("SELECT @output");
print_r( $stmt->fetchAll() );

【讨论】：

我没有测试过在MySQL以外的其他品牌数据库中调用存储过程。
谢谢比尔.. 我会尽快尝试 :)

【解决方案2】：

比尔的回答很好。仅出于完整性考虑，如果您遇到：

SQLSTATE[HY000]: General error: 2053

当使用此方法从您的过程中获取结果集时，请检查您的参数。我重构了一个方法，并将 NULL 作为参数传递给过程，因为我使用的变量超出了范围。一旦我解决了这个愚蠢的错误，问题就消失了（被另一个取代）：

SQLSTATE[HY000]: General error: 2014 Cannot execute queries while other 
unbuffered queries are active.  Consider using PDOStatement::fetchAll().

不过，我正在使用$stmt->fetchAll()。我改用prepare() 和execute() 代替query()。在我的 Zend_Db 配置中从 pdo_mysql 切换到 mysqli 终于让我工作了。我从以下 SO 问题中找到了这些信息：

Call Multiple Stored Procedures with the Zend Framework

【讨论】：

【解决方案3】：

    $db = Zend_Db_Table::getDefaultAdapter();    
    $stmt = $db->query("CALL procedure()");
    $data = $stmt->fetchAll();

【讨论】：

欢迎来到 StackOverflow。为了提供一个好的答案，你应该用你提供的代码写一个解释。

【解决方案4】：

如果有人正在寻找ZendFramework 2 \ Zend Expressive 使用Zend\Db：

还有另一种方法可以使用createStatement() 方法。

// prepare create statement from adapter
$stmt = $this->getAdapter()->createStatement();

$stmt->prepare('CALL myproc("myVal")');
// execute sql query
$records = $stmt->execute();
// manipulate results
if ($records instanceof ResultInterface && $records->isQueryResult()) {
    $resultSet = new ResultSet;
    $resultSet->initialize($records);
    // return records if found
    if (count($resultSet)) {
       // return array of result set
       return $resultSet->toArray();
    }
   // if no records found
   return array()

}

【讨论】：