42.5.1.1 MQPUBLISH42.5.1.1 MQPUBLISH>>-MQPUBLISH--(------------------------------------------------->
>--+---------------------------------------------+--msg-data---->
'-publisher-service--,--+-------------------+-'
'-service-policy--,-'
>--+---------------------------------+--)----------------------><
'-,--topic--+-------------------+-'
| (1) |
'-,--correl-id------'
주:
스키마는 DB2MQ입니다.
MQPUBLISH 함수는 데이터를 MQSeries에 발행합니다. 이 함수를 사용하려면 MQSeries Publish/Subscribe나 MQSeries Integrator 중 하나를 설치해야 합니다. 자세한 정보는 www.ibm.com/software/MQSeries를 참조하십시오.
MQPUBLISH 함수는 service-policy가 정의한 서비스 규정 품질을 사용하여 msg-data에 포함된 데이터를 publisher-service에 지정된 MQSeries 발행자에 발행합니다. 선택적으로 메시지에 주제를 지정할 수 있고, 사용자 정의 메시지 상관 ID를 지정할 수도 있습니다. 이 함수는 성공할 경우 "1"값을 리턴하고, 성공하지 못할 경우 "0"값을 리턴합니다.
예
예 1: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 문자열 "Testing 123"을 기본 publisher 서비스(DB2.DEFAULT.PUBLISHER)에 발행합니다. 메시지에 상관 ID나 주제는 지정되지 않습니다.
VALUES MQPUBLISH('Testing 123')
예 2: 이 예에서는 "TESTS"라는 주제 하에 문자열 "Testing 345"를 "MYPUBLISHER" publisher 서비스에 발행합니다. 기본 규정이 사용되고 상관 ID는 지정되지 않습니다.
VALUES MQPUBLISH('MYPUBLISHER','Testing 345', 'TESTS')
예 3: 이 예에서는 상관 ID를 "TEST1"로 지정하고 "MYPOLOCY" 규정을 사용하여 문자열 "Testing 678"을 "MYPUBLISHER" publisher 서비스에 발행합니다. 이 메시지는 "TESTS"라는 주제로 발행됩니다.
VALUES MQPUBLISH('MYPUBLISHER','MYPOLICY','Testing 678','TESTS','TEST1')
예 4: 이 예에서는 상관 ID는 지정하지 않고 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 "TESTS"라는 주제 하에 문자열 "Testing 901"을 "MYPUBLISHER" publisher 서비스에 발행합니다.
VALUES MQPUBLISH('Testing 901','TESTS')
성공할 경우, 모든 예는 '1'값을 리턴합니다.
42.5.1.2 MQREADCLOB>>-MQREADCLOB--(--+----------------------------------------+---->
'-receive-service--+-------------------+-'
'-,--service-policy-'
>--)-----------------------------------------------------------><
스키마는 DB2MQ입니다.
MQREADCLOB 함수는 service-policy가 정의한 서비스 규정 품질을 사용하여 receive-service가 지정한 MQSeries 위치에서 메시지를 리턴합니다. 이 작업을 실행하면 대기행렬에서 receive-service와 연관된 메시지가 제거되지 않고, 대기행렬 헤드에 있는 메시지가 리턴됩니다. 리턴값은 메시지를 포함하는, 최대 길이가 IMB인 CLOB입니다. 리턴할 메시지가 없을 때는 널(NULL)이 리턴됩니다.
예:
예 1: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 기본 서비스(DB2.DEFAULT.SERVICE)가 지정한 대기행렬 헤드에 있는 메시지를 읽습니다.
VALUES MQREADCLOB()
예 2: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 "MYSERVICE" 서비스가 지정한 대기행렬 헤드에 있는 메시지를 읽습니다.
VALUES MQREADCLOB('MYSERVICE')
예 3: 이 예에서는 "MYPOLOCY" 규정을 사용하여 "MYSERVICE" 서비스가 지정한 대기행렬 헤드에 있는 메시지를 읽습니다.
VALUES MQREADCLOB('MYSERVICE','MYPOLICY')
성공할 경우, 모든 예는 메시지 내용을 최대 크기가 1MB인 CLOB으로 리턴합니다.
리턴할 메시지가 없을 때는 널(NULL)이 리턴됩니다.
42.5.1.3 MQRECEIVECLOB>>-MQRECEIVECLOB------------------------------------------------>
>--(--+----------------------------------------------------------+--)-><
'-receive-service--+-------------------------------------+-'
'-,--service-policy--+--------------+-'
'-,--correl-id-'
스키마는 DB2MQ입니다.
MQRECEIVECLOB 함수는 service-policy가 정의한 서비스 규정 품질을 사용하여 receive-service가 지정한 MQSeries 위치에서 메시지를 리턴합니다. 이 작업을 수행하면 receive-service와 연관된 대기행렬에서 메시지가 제거됩니다. correl-id가 지정되어 있으면 일치하는 상관 ID가 있는 첫 번째 메시지가 리턴됩니다. correl-id가 지정되어 있지 않으면 대기행렬 헤드에 있는 메시지가 리턴됩니다. 리턴값은 메시지를 포함하는, 최대 길이가 IMB인 CLOB입니다. 리턴할 메시지가 없을 때는 널(NULL)이 리턴됩니다.
예:
예 1: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 기본 서비스(DB2.DEFAULT.SERVICE)가 지정한 대기행렬 헤드에 있는 메시지를 수신합니다.
VALUES MQRECEIVECLOB()
예 2: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 "MYSERVICE" 서비스가 지정한 대기행렬 헤드에 있는 메시지를 수신합니다.
VALUES MQRECEIVECLOB('MYSERVICE')
예 3: 이 예에서는 "MYPOLOCY" 규정을 사용하여 "MYSERVICE" 서비스가 지정한 대기행렬 헤드에 있는 메시지를 수신합니다.
VALUES MQRECEIVECLOB('MYSERVICE','MYPOLICY')
예 4: 이 예에서는 "MYPOLOCY" 규정을 사용하여 "MYSERVICE" 서비스가 지정한 대기행렬 헤드에서 '1234'와 일치하는 상관 ID가 있는 첫 번째 메시지를 수신합니다.
VALUES MQRECEIVECLOB('MYSERVICE',MYPOLICY','1234')
성공할 경우, 모든 예는 메시지 내용을 최대 크기가 1MB인 CLOB으로 리턴합니다.
리턴할
메시지가 없을 때는 널(NULL)이 리턴됩니다.
42.5.1.4 MQSEND
>>-MQSEND--(--+----------------------------------------+-------->
'-send-service--,--+-------------------+-'
'-service-policy--,-'
>--msg-data--+-------------------+--)--------------------------><
| (1) |
'-,--correl-id------'
주:
스키마는 DB2MQ입니다.
MQSEND 함수는 service-policy가 정의한 서비스 규정 품질을 사용하여 msg-data에 포함된 데이터를 send-service가 지정한 MQSeries로 송신합니다. correl-id로 선택적 사용자 정의 메시지 상관 ID를 지정할 수도 있습니다. 이 함수는 성공할 경우 "1"값을 리턴하고, 성공하지 못할 경우 "0"값을 리턴합니다.
예:
예 1: 이 예에서는 상관 ID를 지정하지 않고 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 문자열 "Testing 123"을 기본 서비스(DB2.DEFAULT.SERVICE)에 송신합니다.
VALUES MQSEND('Testing 123')
예 2: 이 예에서는 상관 ID를 지정하지 않고 "MYPOLOCY" 규정을 사용하여 문자열 "Testing "345"를 "MYSERVICE" 서비스에 송신합니다.
VALUES MQSEND('MYSERVICE','MYPOLICY','Testing 345')
예 3: 이 예에서는 상관 ID를 "TEST3"으로 지정하고 "MYPOLOCY" 규정을 사용하여 문자열 "Testing 678"을 "MYSERVICE" 서비스에 송신합니다.
VALUES MQSEND('MYSERVICE','MYPOLICY','Testing 678','TEST3')
예 4: 이 예에서는 상관 ID를 지정하지 않고 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 문자열 "TESTING 901"을 "MYSERVICE" 서비스에 송신합니다.
VALUES MQSEND('MYSERVICE','Testing 901')
성공할 경우, 모든 예는 '1' 스칼라 값을 리턴합니다.
42.5.2.1 MQREADALLCLOB>>-MQREADALLCLOB--(--------------------------------------------->
>--+----------------------------------------+--+----------+----->
'-receive-service--+-------------------+-' '-num-rows-'
'-,--service-policy-'
>--)-----------------------------------------------------------><
스키마는 DB2MQ입니다.
MQREADALLCLOB 함수는 service-policy 서비스 규정 품질을 사용하여 receive-service가 지정한 MQSeries 위치에서 메시지와 메시지 메타데이터가 포함된 테이블을 리턴합니다. 이 작업을 수행하면 대기행렬에서 receive-service와 연관된 메시지가 제거되지 않습니다.
num-rows가 지정되어 있으면 num-rows 메시지의 최대 크기가 리턴됩니다. num-rows가 지정되어 있지 않으면 사용 가능한 모든 메시지가 리턴됩니다. 리턴된 테이블에는 다음 컬럼이 포함됩니다.
예:
예 1: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 기본 서비스(DB2.DEFAULT.SERVICE)가 지정한 대기행렬에서 모든 메시지를 수신합니다. 메시지와 모든 메타데이터가 테이블로 리턴됩니다.
SELECT * FROM table (MQREADALLCLOB()) T
예 2: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 MYSERVICE 서비스가 지정한 대기행렬의 헤드에서 모든 메시지를 수신합니다. MSG와 CORRELID 컬럼만 리턴됩니다.
SELECT T.MSG, T.CORRELID
FROM table (MQREADALLCLOB('MYSERVICE')) T
예 3: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 기본 서비스(DB2.DEFAULT.SERVICE)가 지정한 대기행렬의 헤드를 읽습니다. CORRELID가 '1234'인 메시지와 모든 컬럼이 리턴됩니다.
SELECT * FROM table (MQREADALLCLOB()) T WHERE T.CORRELID = '1234'
예 4: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 기본 서비스(DB2.DEFAULT.SERVICE)가 지정한 대기행렬 헤드에 있는 처음 10개의 메시지를 수신합니다. 모든 컬럼이 리턴됩니다.
SELECT * FROM table (MQREADALLCLOB(10)) T
42.5.2.2 MQRECEIVEALLCLOB>>-MQRECEIVEALLCLOB--(------------------------------------------>
>--+----------------------------------------------------------+-->
'-receive-service--+-------------------------------------+-'
'-,--service-policy--+--------------+-'
'-,--correl-id-'
>--+-----------------+--)--------------------------------------><
'-+---+--num-rows-'
'-,-'
스키마는 DB2MQ입니다.
MQRECEIVEALLCLOB 함수는 service-policy 서비스 규정 품질을 사용하여 receive-service가 지정한 MQSeries 위치에서 메시지와 메시지 메타데이터가 포함된 테이블을 리턴합니다. 이 작업을 수행하면 receive-service와 연관된 대기행렬에서 메시지가 제거됩니다.
correl-id가 지정되어 있으면 일치하는 상관 ID가 있는 메시지만 리턴됩니다. correl-id가 지정되어 있지 않으면 대기행렬 헤드에 있는 메시지가 리턴됩니다.
num-rows가 지정되어 있으면 num-rows 메시지의 최대 크기가 리턴됩니다. num-rows가 지정되어 있지 않으면 사용 가능한 모든 메시지가 리턴됩니다. 리턴된 테이블에는 다음 컬럼이 포함됩니다.
예:
예 1: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 기본 서비스(DB2.DEFAULT.SERVICE)가 지정한 대기행렬에서 모든 메시지를 수신합니다. 메시지와 모든 메타데이터가 테이블로 리턴됩니다.
SELECT * FROM table (MQRECEIVEALLCLOB()) T
예 2: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 MYSERVICE 서비스가 지정한 대기행렬의 헤드에서 모든 메시지를 수신합니다. MSG와 CORRELID 컬럼만 리턴됩니다.
SELECT T.MSG, T.CORRELID
FROM table (MQRECEIVEALLCLOB('MYSERVICE')) T
예 3: 이 예에서는 "MYPOLOCY" 규정을 사용하여 "MYSERVICE" 서비스가 지정한 대기행렬 헤드에서 모든 메시지를 수신합니다. CORRELID가 '1234'인 메시지와 MSG와 CORRELID 컬럼만 리턴됩니다.
SELECT T.MSG, T.CORRELID
FROM table (MQRECEIVEALLCLOB('MYSERVICE','MYPOLICY','1234')) T
예 4: 이 예에서는 기본 규정(DB2.DEFAULT.POLICY)을 사용하여 기본 서비스(DB2.DEFAULT.SERVICE)가 지정한 대기행렬 헤드에 있는 처음 10개의 메시지를 수신합니다. 모든 컬럼이 리턴됩니다.
SELECT * FROM table (MQRECEIVEALLCLOB(10)) T
42.5.3 MQSeries 함수에서의 CLOB 데이터 지원 추가MQSeries 함수(DB2MQ 스키마에 정의되어 있음)에는 현재 VARCHAR 뿐만 아니라 CLOB 데이터와 함께 사용할 수 있는 함수가 포함되어 있습니다. 일부 상황에서는 새 함수가 CLOB 데이터 유형을 다루고 또 다른 일부 상황에서는 기존 함수가 CLOB 및 VARCHAR 데이터 유형을 다룹니다. 어떤 경우든 간에, CLOB 함수 구문은 VARCHAR 함수 구문과 일치합니다. 다음 테이블에 CLOB 데이터 사용을 지원하는 함수와 이에 상응하는 VARCHAR 함수를 나열해 놓았습니다.
표 17. CLOB 데이터 유형을 지원하는 MQSeries 함수
| VARCHAR 데이터에 사용할 수 있는 함수
| CLOB 데이터에 사용할 수 있는 함수
|
|---|---|
| MQPUBLISH
| MQPUBLISH
|
| MQREAD
| MQREADCLOB
|
| MQRECEIVE
| MQRECEIVECLOB
|
| MQSEND
| MQSEND
|
| MQREADALL
| MQREADALLCLOB
|
| MQRECEIVEALL
| MQRECEIVEALLCLOB
|
MQSeries 함수(DB2MQ 스키마에 정의되어 있음) 사용에 대한 자세한 정보는 MQSeries를 참조하십시오.
1