【发布时间】：2019-08-05 14:40:20
【问题描述】：
我们整个上午都被这件事难住了。
我有一个处理一些记录的 MSSQL 存储过程。每条记录都会生成一封包含动态内容的电子邮件，并且这是从另一个存储过程中填充的。
所以第一个存储过程有一个游标，每行都被处理，导致调用另一个存储过程，它本身有一个游标循环。第一个存储过程没有输出参数或返回值等，而第二个使用输出参数将字段返回给第一个过程。
这在 Datagrip 中运行良好。
使用 PDO（或使用其他驱动程序）从 php 调用它无法完全运行。它会产生一小批记录然后停止（往往是 5、9、13 或 45 - 随着我们尝试不同的解决方案而改变）。
我们已经设法让它现在使用 PDOStatement::nextRowset 运行。我们使用第一个存储过程的查询，然后使用while ( $stmt->nextRowset() ) ; 循环遍历（不存在/不需要的）行集。
这行得通。但是由于第一个存储的过程没有返回任何东西（只是那个 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();
}
}
}
第一个存储过程（大量减少）
CREATE PROCEDURE [dbo].[queue_renewal_emails]
AS
BEGIN
DECLARE @curr_member_cursor CURSOR;
DECLARE @curr_club_cursor CURSOR;
DECLARE @g_personid INT;
DECLARE @g_emailTemplateId INT;
DECLARE @g_email_subject VARCHAR(200);
DECLARE @g_email_html VARCHAR(max);
DECLARE @g_email_plain VARCHAR(max);
DECLARE @g_personEmail VARCHAR(128);
SET @curr_club_cursor = CURSOR
LOCAL STATIC READ_ONLY FORWARD_ONLY
FOR
SELECT DISTINCT
bgemailTemplate.bgemte_name,
bgemailTemplate.bgemte_emailtemplateid,
vpersonpe.pers_emailaddress,
vpersonpe.pers_personId,
FROM company WITH(NOLOCK)
INNER JOIN complink WITH(NOLOCK) ON complink.clli_companyid = complink.Comp_CompanyId
AND complink.clli_Deleted is null
INNER JOIN vpersonpe WITH(NOLOCK) ON vpersonpe.pers_personId = complink.clli_personId
INNER JOIN bgemailTemplate WITH(NOLOCK) ON bgemailTemplate.bgemte_Deleted IS NULL
WHERE vPersonPE.pers_deleted IS NULL
AND company.comp_deleted IS NULL
AND vPersonPE.pers_parentid IS NULL
AND vpersonpe.pers_status NOT IN ('Cancelled','Expired','Suspended','Awaiting Approval','Declined','On hold','Revoked','Expelled');
-- loop through each course
OPEN @curr_club_cursor;
FETCH NEXT FROM @curr_club_cursor INTO @g_email_subject, @g_emailTemplateId, @g_personEmail, @g_personid;
WHILE @@fetch_status = 0
BEGIN
EXEC dbo.populateEmail @g_emailtemplateid /* Email template id */,
@g_email_plain OUTPUT /* Plain text email to have the placeholders replaced */,
@g_email_subject OUTPUT,
@g_personid ;
FETCH NEXT FROM @curr_club_cursor INTO @g_email_subject, @g_emailTemplateId, @g_personEmail, @g_personid;
END
CLOSE @curr_club_cursor
DEALLOCATE @curr_club_cursor
END
go
第二个存储过程（大量减少）。
CREATE PROCEDURE [dbo].[populateEmail]
@p_emailtemplateid INT,
@p_email_text VARCHAR(max) OUTPUT,
@p_email_subject VARCHAR(200) OUTPUT,
@p_person_id INT
AS
BEGIN
SET NOCOUNT ON;
-- CURSORs
DECLARE @curr_field_cursor CURSOR;
DECLARE @g_email_plain VARCHAR(MAX) = '';
DECLARE @g_email_subject VARCHAR(200) = '';
DECLARE @g_emte_emailtemplateid INT;
DECLARE @g_EmailPlaceholderId INT;
DECLARE @g_place_holder VARCHAR(128);
DECLARE @g_source_column VARCHAR(128);
DECLARE @g_prev_source_query_num INT;
DECLARE @g_source_query_num INT;
-- Variables to read results into from each query
DECLARE @g_q11_comp_name VARCHAR(180);
DECLARE @g_q11_comp_website VARCHAR(300);
DECLARE @g_q11_comp_pers_salutation VARCHAR(30);
DECLARE @g_q11_comp_pers_firstname VARCHAR(90);
DECLARE @g_q11_comp_pers_lastname VARCHAR(120);
-- Start processing
SET @p_email_text = '';
SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
SET @curr_field_cursor = CURSOR
LOCAL STATIC READ_ONLY FORWARD_ONLY
FOR
SELECT a.emte_emailtemplateid,
b.emtl_EmailPlaceholderId,
c.empl_PlaceHolder,
c.empl_SourceQueryNum,
c.empl_SourceColumn,
a.emte_plaintextemail,
a.emte_subject
FROM EmailTemplate a with (nolock)
LEFT OUTER JOIN EmailTemplateLink b with (nolock)
ON a.emte_emailtemplateid = b.emtl_EmailTemplateId
LEFT OUTER JOIN EmailPlaceholder c with (nolock)
ON b.emtl_EmailPlaceholderId = c.empl_EmailPlaceholderID
WHERE a.emte_emailtemplateid = @p_emailtemplateid
ORDER BY c.empl_SourceQueryNum;
-- Loop through each required place holder for the passed email template.
SET @g_prev_source_query_num = 0;
OPEN @curr_field_cursor
FETCH NEXT FROM @curr_field_cursor INTO @g_emte_emailtemplateid, @g_EmailPlaceholderId, @g_place_holder, @g_source_query_num, @g_source_column, @g_email_plain, @g_email_subject;
WHILE @@fetch_status = 0
BEGIN
IF @g_prev_source_query_num = 0
BEGIN
SET @p_email_text = @g_email_plain;
SET @p_email_subject = @g_email_subject;
END;
IF @g_source_query_num = 11
BEGIN
IF @g_prev_source_query_num != @g_source_query_num
BEGIN
SELECT @g_q11_comp_name = comp_name,
@g_q11_comp_website = comp_website,
@g_q11_comp_pers_salutation = Pers_Salutation,
@g_q11_comp_pers_firstname = pers_firstname,
@g_q11_comp_pers_lastname = pers_lastname
FROM company with (nolock)
LEFT OUTER JOIN vPerson with (nolock) ON company.Comp_PrimaryPersonId = vPerson.Pers_PersonId
LEFT OUTER JOIN address with (nolock) ON company.Comp_PrimaryAddressId = address.Addr_AddressId
WHERE company.Comp_CompanyId = @p_person_id;
END;
IF @g_source_column = 'comp_name'
BEGIN
SET @p_email_text = REPLACE(@p_email_text, @g_place_holder, COALESCE(@g_q11_comp_name, ''));
SET @p_email_subject = REPLACE(@p_email_subject, @g_place_holder, COALESCE(@g_q11_comp_name, ''));
END;
ELSE IF @g_source_column = 'comp_website'
BEGIN
SET @p_email_text = REPLACE(@p_email_text, @g_place_holder, COALESCE(@g_q11_comp_website, ''));
SET @p_email_subject = REPLACE(@p_email_subject, @g_place_holder, COALESCE(@g_q11_comp_website, ''));
END;
ELSE IF @g_source_column = 'comp_primary_person_firstname'
BEGIN
SET @p_email_text = REPLACE(@p_email_text, @g_place_holder, COALESCE(@g_q11_comp_pers_salutation, ''));
SET @p_email_subject = REPLACE(@p_email_subject, @g_place_holder, COALESCE(@g_q11_comp_pers_salutation, ''));
END;
ELSE IF @g_source_column = 'comp_primary_person_salutation'
BEGIN
SET @p_email_text = REPLACE(@p_email_text, @g_place_holder, COALESCE(@g_q11_comp_pers_firstname, ''));
SET @p_email_subject = REPLACE(@p_email_subject, @g_place_holder, COALESCE(@g_q11_comp_pers_firstname, ''));
END;
ELSE IF @g_source_column = 'comp_primary_person_lastname'
BEGIN
SET @p_email_text = REPLACE(@p_email_text, @g_place_holder, COALESCE(@g_q11_comp_pers_lastname, ''));
SET @p_email_subject = REPLACE(@p_email_subject, @g_place_holder, COALESCE(@g_q11_comp_pers_lastname, ''));
END;
END;
SET @g_prev_source_query_num = @g_source_query_num;
FETCH NEXT FROM @curr_field_cursor INTO @g_emte_emailtemplateid, @g_EmailPlaceholderId, @g_place_holder, @g_source_query_num, @g_source_column, @g_email_plain, @g_email_subject;
END;
CLOSE @curr_field_cursor
DEALLOCATE @curr_field_cursor
END
go
【问题讨论】：
-
你为什么在每个表上都使用 NOLOCK 并使用未提交的读取隔离级别？这是多余的。但是在任何地方都使用 NOLOCK 提示并不是一个好主意。它会做一些有趣的事情，比如随机返回丢失和/或重复的行，以及其他令人敬畏的事情。 sentryone.com/blog/aaronbertrand/bad-habits-nolock-everywhere
-
@SeanLange - 绝望的时刻！这是示例代码，但源表是相对静态的，这个过程对于这些表的任何更新都是非常次要的。
-
如果数据是静态的，那么到处乱扔 NOLOCK 提示是没有用的，因为不会有任何锁定可以忽略。 ;)
-
@SeanLange，它不是静态的，只是不会不断变化。并且这些 procs 必须对任何这些更新产生零影响（如果数据过时了，那么这对这个过程无关紧要）。
标签： php sql-server stored-procedures