MQCreateVtiReceive() 函数

语法

table_name: 必需参数。指定要创建的表的名称。由 service_name 参数指向的队列将映射到该表。
service_name: 可选参数。引用 "gbasedbt".mqiservice 表的 servicename 列中的值。如果不指定 service_name，将把 IDS.DEFAULT.SERVICE 用作服务。service_name 的最大大小为 48 个字节。
policy_name: 可选参数。引用 "gbasedbt".mqipolicy 表的 policyname 列中的值。如果不指定 policy_name，将把 IDS.DEFAULT.POLICY 用作策略。policy_name 的最大大小为 48 个字节。
maxMessage: 可选参数。指定要发送或接收的消息的最大长度。缺省值为 4000；允许的最大大小为 32628。

用途

MQCreateVtiReceive() 函数会创建绑定到由 service_name 指定的队列的 table_name（使用 policy_name 中定义的服务质量策略）。如果从该表进行选择，将返回队列中的所有可用消息，并从队列中除去这些消息。如果没有任何消息可以返回，将不返回任何行。插入到绑定表会将消息放入队列。

创建的表具有以下模式，并使用 "gbasedbt".mq 访问方法：

create table table_name (
       msg lvarchar(maxMessage),
       correlid varchar(24),
       topic varchar(40),
       qname varchar(48),
       msgid varchar(12),
       msgformat varchar(8));
               using "gbasedbt".mq (SERVICE = service_name,
                                    POLICY = policy_name,
                                    ACCESS = "RECEIVE");

绑定到队列的表之间的映射需要转换操作。对表中特定列执行的操作将转换为队列内的特定操作，如下面概述的内容：

插入操作将把以下列映射到 MQ 管理器：
- msg。将插入队列的文本。如果 msg 为 NULL，MQ 函数将向队列发送一条长度为零的消息。
- correlid。由队列管理器识别，用于从队列获取消息的密钥。
选择操作将把以下列映射到 MQ 管理器：
- msg。消息将从队列除去。
- correlid。在 WHERE 子句中，为传递到队列管理器以限定消息的值（相关标识）。执行限定时唯一应使用的运算符为等号 (=)。

下表描述 MQCreateVtiReceive() 函数自变量的解释方式。

表 1. MQCreateVtiReceive() 自变量解释
用途	自变量解释
MQCreateVtiReceive(arg1)	arg1 = table_name
MQCreateVtiReceive(arg1, arg2)	arg1 = table_name arg2 = service_name
MQCreateVtiReceive(arg1, arg2, arg3)	arg1 = table_name arg2 = service_name arg3 = policy_name
MQCreateVtiReceive(arg1, arg2, arg3, arg4)	arg1 = table_name arg2 = service_name arg3 = policy_name arg4 = maxMessage

返回码

't': 操作成功。
'f': 操作失败。

示例

使用缺省服务名称和策略名称创建表 VtiReceiveTest：

begin;
EXECUTE FUNCTION MQCreateVtiRead('VtiReceiveTest');
commit;

向队列插入消息：

INSERT INTO VtiReceiveTest(msg) values ('QMessage');

从队列读取消息：

select * from VtiReceiveTest;

如果尝试再次读取队列，将不返回任何行，因为表是使用 MQCreateVtiReceive() 函数创建的，而该函数在读取条目时便会将其除去。