我们整个上午都被这件事难住了。
我有一个处理一些记录的 MSSQL 存储过程。每条记录都会生成一封带有动态内容的电子邮件,这是从另一个存储过程填充的。
所以第一个存储过程有一个游标,每一行都被处理导致调用另一个存储过程,它本身有一个游标可以循环。第一个存储过程没有输出参数或返回值等,而第二个使用输出参数将字段返回给第一个过程。
这在 Datagrip 中运行良好。
使用 PDO(或使用其他驱动程序)从 php 调用它无法完全运行。它会产生一小批记录然后停止(往往是 5、9、13 或 45 - 随着我们对不同解决方案的试验而改变)。
我们已经设法让它现在使用 PDOStatement::nextRowset 运行。我们使用第一个存储过程的查询,然后使用while ( $stmt->nextRowset() ) ; 循环遍历(不存在/不需要的)行集。
这有效。但是由于第一个存储的 proc 没有返回任何内容(只是 pdo 似乎想要处理某种内部结果集),这似乎非常脏且效率低下。
有替代方案吗?可能是要传递给 pdo 的参数,还是存储过程中的设置?
下面有一些简化的代码来展示事物是如何交互的。
PHP调用脚本。
<?php
$emailRepository = new EmailRepository(hostname, port, dbname, username, password);
$ret = $emailRepository->sendRenewalEmails();
class EmailRepository
{
public function __construct($hostname, $port, $dbname, $username, $password)
{
$this->hostname = $hostname;
$this->port = $port;
$this->dbname = $dbname;
$this->username = $username;
$this->password = $password;
$this->connect();
}
private function connect()
{
try {
$this->db = new PDO ("sqlsrv:Server=$this->hostname,$this->port;Database=$this->dbname", $this->username, $this->password);
$this->db->setAttribute( PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION );
} catch (PDOException $e) {
var_dump("Failed to get DB handle: " . $e->getMessage());
}
}
public function sendRenewalEmails()
{
try {
$stmt = $this->db->prepare("EXEC membership_queue_renewal_emails");
$stmt->execute();
do {
echo '>';
} while($stmt->nextRowset());
return true;
} catch (Exception $e) {
echo $e->getMessage();
}
}
}
温温酱