GET CONVERSATION GROUP (Transact-SQL)

  • 项目

适用于：SQL ServerAzure SQL 托管实例

为下一个要收到的消息返回会话组标识符，并锁定包含消息的会话的会话组。 会话组标识符可用于在检索消息本身之前检索会话状态信息。

Transact-SQL 语法约定

语法

[ WAITFOR ( ]  
   GET CONVERSATION GROUP @conversation_group_id  
      FROM <queue>  
[ ) ] [ , TIMEOUT timeout ]  
[ ; ]  
  
<queue> ::=  
{ database_name.schema_name.queue_name | schema_name.queue_name | queue_name }

注意

若要查看 SQL Server 2014 (12.x) 及更早版本的 Transact-SQL 语法，请参阅早期版本文档。

参数

WAITFOR
指定如果当前没有消息，则 GET CONVERSATION GROUP 语句将等待消息到达队列。

@conversation_group_id
用于存储 GET CONVERSATION GROUP 语句返回的会话组 ID 的变量。 该变量的类型必须为 uniqueidentifier。 如果没有可用的会话组，则该变量设置为 NULL。

FROM
指定要从中获取会话组的队列。

database_name
包含从中获取会话组的队列的数据库的名称。 如果未提供 database_name，则默认为当前数据库。

schema_name
拥有从中获取会话组的队列的架构的名称。 如果未提供 schema_name，则默认为当前用户的默认架构。

queue_name
要从中获取会话组的队列的名称。

TIMEOUT timeout
指定 Service Broker 等待消息到达队列的时间（毫秒）。 该子句只能与 WAITFOR 子句一起使用。 如果使用 WAITFOR 的语句不包括该子句，或者 timeout 为 -1，则等待时间没有限制。 如果超时时间已到，则 GET CONVERSATION GROUP 将 @conversation_group_id 变量设置为 NULL。

注解

重要

如果 GET CONVERSATION GROUP 语句不是批处理或存储过程中的第一个语句，则必须使用 Transact-SQL 语句终止符分号 (;) 终止前面的语句。

如果 GET CONVERSATION GROUP 语句中指定的队列不可用，则该语句将失败，并返回一个 Transact-SQL 错误。

该语句返回满足以下所有条件的下一个会话组：

  • 可以成功锁定该会话组。

  • 该会话组在队列中有可用的消息。

  • 在满足上述条件的所有会话组中，该会话组具有最高的优先级。 会话组的优先级是分配给属于该组的成员并且在队列中具有消息的任何会话的最高优先级。

在相同事务中连续调用 GET CONVERSATION GROUP 可锁定多个会话组。 如果没有可用的会话组，则该语句返回 NULL 作为会话组标识符。

指定 WAITFOR 子句后，该语句将等待指定的超时时间，或等到会话组可用为止。 如果在语句等待期间删除队列，则语句会立即返回一个错误。

GET CONVERSATION GROUP 在用户定义函数中无效。

权限

若要从队列中获取会话组标识符，则当前用户必须具有对队列的 RECEIVE 权限。

示例

A. 获取会话组，无限期等待

下例将 @conversation_group_id 设置为 ExpenseQueue 中下一个可用消息的会话组标识符。 该命令将等到消息变得可用为止。

DECLARE @conversation_group_id UNIQUEIDENTIFIER ;  
  
WAITFOR (  
 GET CONVERSATION GROUP @conversation_group_id  
     FROM ExpenseQueue  
) ;

B. 获取会话组，等待一分钟

下例将 @conversation_group_id 设置为 ExpenseQueue 中下一个可用消息的会话组标识符。 如果在一分钟内没有出现任何可用消息，GET CONVERSATION GROUP 将直接返回而不更改 @conversation_group_id 的值。

DECLARE @conversation_group_id UNIQUEIDENTIFIER  
  
WAITFOR (  
    GET CONVERSATION GROUP @conversation_group_id   
    FROM ExpenseQueue ),  
TIMEOUT 60000 ;

C. 获取会话组，立即返回

下例将 @conversation_group_id 设置为 ExpenseQueue 中下一个可用消息的会话组标识符。 如果没有任何可用的消息，GET CONVERSATION GROUP 将立即返回而不更改 @conversation_group_id。

DECLARE @conversation_group_id UNIQUEIDENTIFIER ;  
  
GET CONVERSATION GROUP @conversation_group_id  
FROM AdventureWorks.dbo.ExpenseQueue ;

另请参阅

BEGIN DIALOG CONVERSATION (Transact-SQL)
MOVE CONVERSATION (Transact-SQL)