aqbzdemo.tar

Generic/004077500752150001724000000000000727335521400130505ustar00rbhyravag98000000000000001Generic/sql/004077500752150001724000000000000727335521400136475ustar00rbhyravag98000000000000001Generic/sql/bz_add_subscriber.sql010064400752150001724000000027100727164424200200310ustar00rbhyravag98000000000000001REM script name: bz_add_subscriber.sql
REM This script adds a subscriber to bzcardorders_q
REM
REM version: 9i

REM =======================================================
REM cleanup section
REM =======================================================
execute dbms_aqadm.remove_subscriber ( -
	  queue_name => 'BZCARDORDERS_Q', -
	  subscriber => sys.aq$_agent('SHIPPING',null,null)-
);

execute dbms_aqadm.remove_subscriber ( -
	  queue_name => 'BZCARDORDERS_Q', -
	  subscriber => sys.aq$_agent('BILLING',null,null)-
);

execute dbms_aqadm.remove_subscriber ( -
	  queue_name => 'BZCARDORDERS_Q', -
	  subscriber => sys.aq$_agent('RUSH_ORDER',null,null)-
);
REM =======================================================
REM Add subscriber 'SHIPPING'and 'BILLING' to BZCARDORDERS_Q
REM =======================================================
execute dbms_aqadm.add_subscriber ( -
	  queue_name => 'BZCARDORDERS_Q', -
	  subscriber => sys.aq$_agent('SHIPPING',null,null)-
);

quit;

execute dbms_aqadm.add_subscriber ( -
	  queue_name => 'BZCARDORDERS_Q', -
	  subscriber => sys.aq$_agent('BILLING',null,null)-
);

REM =======================================================
REM Add a rule-based subscriber 'RUSH_ORDER' to BZCARDORDERS_Q
REM =======================================================
execute dbms_aqadm.add_subscriber ( -
	  queue_name => 'BZCARDORDERS_Q', -
	  subscriber => sys.aq$_agent('RUSH_ORDER',null,null), -
	  rule => 'tab.user_data.ord_typ = ''RUSH''' -
);
Generic/sql/bz_cr_msgtyp.sql010064400752150001724000000012030727137107500170620ustar00rbhyravag98000000000000001REM script name: bz_cr_msgtyp.sql
REM creates the bzcardorder_typ Object type
REM
REM version: 9i

REM =======================================================
REM cleanup section
REM =======================================================

DROP TYPE bzcardorder_typ;

REM =======================================================
REM Creates the bzcardorder_type. Users using this type would
REM need execute privilege on this type
REM =======================================================

CREATE OR REPLACE TYPE bzcardorder_typ AS OBJECT (
	employee_id	NUMBER(6),
	first_name	VARCHAR2(20),
	last_name	VARCHAR2(25),
	ordtyp		VARCHAR(10));	
/
Generic/sql/bz_cr_q.sql010064400752150001724000000026620727134613000160030ustar00rbhyravag98000000000000001REM script name: bz_cre.sql
REM Creates queue tables, queues - bzcardorders_q
REM Starts the queue
REM
REM version: 9i
REM

REM =======================================================
REM cleanup section
REM =======================================================
BEGIN
  dbms_aqadm.stop_queue(queue_name => 'bzcardorders_q');
  dbms_aqadm.drop_queue (
        queue_name              => 'bzcardorders_q');
  dbms_aqadm.drop_queue_table (
        queue_table => 'bzcardorders_qt');
END;
/

REM =======================================================
REM Create queue tables, queues for BZADM
REM =======================================================

 execute dbms_aqadm.create_queue_table(		 -
        queue_table => 'bzcardorders_qt', -
        comment => 'Business Card Orders queue table',	-
	multiple_consumers => true, -
        queue_payload_type => 'bzcardorder_typ',-
	primary_instance => 1,-
        secondary_instance => 2);


REM =======================================================
REM Create a queue 
REM =======================================================
BEGIN
dbms_aqadm.create_queue (
        queue_name              => 'bzcardorders_q',
        queue_table             => 'bzcardorders_qt');
END;
/

REM =======================================================
REM start queue
REM =======================================================
BEGIN
  dbms_aqadm.start_queue (
        queue_name              => 'bzcardorders_q');
END;
/
Generic/sql/bz_dequeue_eg.sql010064400752150001724000000045030727215467200171740ustar00rbhyravag98000000000000001REM script name: bz_enqueue_eg.sql
REM Shows various ways to do a dequeue
REM
REM version: 9i

REM====================================================================
REM I. Non-blocking dequeue
REM====================================================================

declare
	deqopt	dbms_aq.dequeue_options_t;
	mprop	dbms_aq.message_properties_t;
	msgid	RAW(16);
	payload bzcardorder_typ;
begin
	deqopt.consumer_name := 'BILLING';
	deqopt.navigation := DBMS_AQ.FIRST_MESSAGE;
	deqopt.wait := 0;	
	dbms_aq.dequeue(
		queue_name => 'bzcardorders_q',
		dequeue_options => deqopt,
		message_properties => mprop,
		payload => payload,
		msgid => msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/

REM====================================================================
REM II. Blocking dequeue
REM====================================================================

declare
	deqopt	dbms_aq.dequeue_options_t;
	mprop	dbms_aq.message_properties_t;
	msgid	RAW(16);
	payload bzcardorder_typ;
begin
	deqopt.consumer_name := 'SHIPPING';
	deqopt.navigation := DBMS_AQ.FIRST_MESSAGE;
	deqopt.wait := 30; -- wait for 30 seconds
	dbms_aq.dequeue(
		queue_name => 'bzcardorders_q',
		dequeue_options => deqopt,
		message_properties => mprop,
		payload => payload,
		msgid => msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/

REM====================================================================
REM III. Dequeue with dequeue_condition
REM====================================================================

declare
	deqopt	dbms_aq.dequeue_options_t;
	mprop	dbms_aq.message_properties_t;
	msgid	RAW(16);
	payload bzcardorder_typ;
begin
	deqopt.consumer_name := 'SHIPPING';
	deqopt.navigation := DBMS_AQ.FIRST_MESSAGE;
-- dequeue messages older than 30 seconds
	deqopt.deq_condition := 'sysdate - enq_time > 30/86400';
	dbms_aq.dequeue(
		queue_name => 'bzcardorders_q',
		dequeue_options => deqopt,
		message_properties => mprop,
		payload => payload,
		msgid => msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/
Generic/sql/bz_enqueue_eg.sql010064400752150001724000000052200727137155300172010ustar00rbhyravag98000000000000001REM script name: bz_enqueue_eg.sql
REM Shows various ways to do an enqueue
REM
REM version: 9i

REM====================================================================
REM I. Enqueue with a recipient list
REM====================================================================

declare
	enqopt	dbms_aq.enqueue_options_t;
	mprop	dbms_aq.message_properties_t;
	enq_msgid	RAW(16);
	rcpt_list dbms_aq.aq$_recipient_list_t;
begin
	rcpt_list(0) := sys.aq$_agent('Billing', null, null);
	rcpt_list(1) := sys.aq$_agent('Shipping', null, null);
	mprop.recipient_list := rcpt_list;
	dbms_aq.enqueue(
		queue_name => 'bzcardorders_q',
		enqueue_options => enqopt,
		message_properties => mprop,
		payload => bzcardorder_typ(101, 'Brajesh', 'Goyal','NORMAL'),
		msgid => enq_msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/


REM====================================================================
REM II. Enqueue with a delay
REM====================================================================

declare
	enqopt	dbms_aq.enqueue_options_t;
	mprop	dbms_aq.message_properties_t;
	enq_msgid	RAW(16);
	rcpt_list dbms_aq.aq$_recipient_list_t;
begin
	rcpt_list(0) := sys.aq$_agent('Billing', null, null);
	rcpt_list(1) := sys.aq$_agent('Shipping', null, null);

	mprop.delay := 30; -- 30 seconds delay
	mprop.recipient_list := rcpt_list;
	dbms_aq.enqueue(
		queue_name => 'bzcardorders_q',
		enqueue_options => enqopt,
		message_properties => mprop,
		payload => bzcardorder_typ(102, 'Shailendra','Mishra','NORMAL'),
		msgid => enq_msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/
REM====================================================================
REM III. Enqueue with an expiration 
REM====================================================================

declare
	enqopt	dbms_aq.enqueue_options_t;
	mprop	dbms_aq.message_properties_t;
	enq_msgid	RAW(16);
	rcpt_list dbms_aq.aq$_recipient_list_t;
begin
	rcpt_list(0) := sys.aq$_agent('Billing', null, null);
	rcpt_list(1) := sys.aq$_agent('Shipping', null, null);

	mprop.expiration := 30; -- expires after 30 seconds
	mprop.recipient_list := rcpt_list;
	dbms_aq.enqueue(
		queue_name => 'bzcardorders_q',
		enqueue_options => enqopt,
		message_properties => mprop,
		payload => bzcardorder_typ(101,'Brajesh','Goyal','RUSH'),
		msgid => enq_msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/
Generic/sql/bz_enqueue_eg2.sql010064400752150001724000000047060727232370400172670ustar00rbhyravag98000000000000001REM script name: bz_enqueue_eg.sql
REM Shows various ways to do an enqueue
REM
REM version: 9i

REM====================================================================
REM I. Normal Enqueue 
REM====================================================================

declare
	enqopt	dbms_aq.enqueue_options_t;
	mprop	dbms_aq.message_properties_t;
	enq_msgid	RAW(16);
begin
	dbms_aq.enqueue(
		queue_name => 'bzcardorders_q',
		enqueue_options => enqopt,
		message_properties => mprop,
		payload => bzcardorder_typ(101, 'Brajesh', 'Goyal','NORMAL'),
		msgid => enq_msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/


REM====================================================================
REM II. Enqueue with a delay
REM====================================================================

declare
	enqopt	dbms_aq.enqueue_options_t;
	mprop	dbms_aq.message_properties_t;
	enq_msgid	RAW(16);
	rcpt_list dbms_aq.aq$_recipient_list_t;
begin
	rcpt_list(0) := sys.aq$_agent('Billing', null, null);
	rcpt_list(1) := sys.aq$_agent('Shipping', null, null);

	mprop.delay := 30; -- 30 seconds delay
	mprop.recipient_list := rcpt_list;
	dbms_aq.enqueue(
		queue_name => 'bzcardorders_q',
		enqueue_options => enqopt,
		message_properties => mprop,
		payload => bzcardorder_typ(102, 'Shailendra','Mishra','NORMAL'),
		msgid => enq_msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/
REM====================================================================
REM III. Enqueue with an expiration 
REM====================================================================

declare
	enqopt	dbms_aq.enqueue_options_t;
	mprop	dbms_aq.message_properties_t;
	enq_msgid	RAW(16);
	rcpt_list dbms_aq.aq$_recipient_list_t;
begin
	rcpt_list(0) := sys.aq$_agent('Billing', null, null);
	rcpt_list(1) := sys.aq$_agent('Shipping', null, null);

	mprop.expiration := 30; -- expires after 30 seconds
	mprop.recipient_list := rcpt_list;
	dbms_aq.enqueue(
		queue_name => 'bzcardorders_q',
		enqueue_options => enqopt,
		message_properties => mprop,
		payload => bzcardorder_typ(101,'Brajesh','Goyal','RUSH'),
		msgid => enq_msgid);

--	You can perform multiple database operations in the same transaction
-- 	You need not commit here Or you can use visibility immediate to commit

	commit;
end;
/
Generic/sql/bz_main.sql010064400752150001724000000066520727134624200160120ustar00rbhyravag98000000000000001REM script name: bz_main.sql
REM creates and populates the BZ schema
REM 
REM assumes that &tbs and &temp tablespace exists locally
REM 
REM It sets up system parameters - job_queue_processes and aq_tm_processes
REM used by AQ, if not already set.
REM create bz_adm and bz users. It grants aq_administrator role to bz_adm 
REM and aq_user tole bz.
REM It creates aq queues in the schema bz_adm
REM
REM 
REM version: 9.0.1
REM change:  initial version
REM
REM =======================================================
REM cleanup section
REM =======================================================

SET VERIFY OFF

define bz_pass      = &1
define bz_adm_pass  = &2
define tbs          = &3
define ttbs         = &4
define master_pass  = &5

DROP USER bz_adm CASCADE;
DROP USER bz CASCADE;

SPOOL create_bz_schema

REM =======================================================
REM CREATE USERs
REM The user is assigned tablespaces and quota in separate
REM ALTER USER statements so that the CREATE USER statement
REM will succeed even if the &tbs and temp tablespaces do
REM not exist.
REM =======================================================

REM =======================================================
REM Create a common admin account for all AQ Demo
REM =======================================================

CREATE USER bz_adm IDENTIFIED BY &bz_adm_pass;
ALTER USER bz_adm DEFAULT TABLESPACE &tbs QUOTA UNLIMITED ON &tbs;
ALTER USER bz_adm TEMPORARY TABLESPACE &ttbs;

REM ALTER USER bz_adm DEFAULT TABLESPACE &tbs QUOTA ON &tbs UNLIMITED;
REM ALTER USER bz_adm TEMPORARY TABLESPACE &ttbs;

GRANT ALTER SESSION TO bz_adm;
GRANT CREATE CLUSTER TO bz_adm;
GRANT CREATE DATABASE LINK TO bz_adm;
GRANT CREATE SEQUENCE TO bz_adm;
GRANT CREATE SESSION TO bz_adm;
GRANT CREATE SYNONYM TO bz_adm;
GRANT CREATE TABLE TO bz_adm;
GRANT CREATE VIEW TO bz_adm;
GRANT CREATE CLUSTER TO bz_adm;
GRANT CREATE INDEXTYPE TO bz_adm;
GRANT CREATE OPERATOR TO bz_adm;
GRANT CREATE PROCEDURE TO bz_adm;
GRANT CREATE SEQUENCE TO bz_adm;
GRANT CREATE TABLE TO bz_adm;
GRANT CREATE TRIGGER TO bz_adm;
GRANT CREATE TYPE TO bz_adm;
GRANT aq_administrator_role TO bz_adm;
GRANT EXECUTE ON dbms_aq TO bz_adm;
GRANT EXECUTE ON dbms_aqadm TO bz_adm;


REM =======================================================
REM Create a user account for schema bz
REM =======================================================

CREATE USER bz IDENTIFIED BY &bz_pass;
GRANT CREATE SESSION TO bz;

GRANT EXECUTE ON dbms_aq to bz;
GRANT ExECUTE ON dbms_aqadm to bz;
GRANT aq_user_role to bz;

REM =======================================================
REM Set AQ system parameters - JOB_QUEUE_PROCESSES and
REM                            AQ_TM_PROCESSES
REM =======================================================
declare
	n number;
begin
	select value into n from v$parameter where name = 'job_queue_processes';
	if (n = 0) then
		execute immediate 'alter system set job_queue_processes = 2';
	end if;
	select value into n from v$parameter where name = 'aq_tm_processes';
	if (n = 0) then
		execute immediate 'alter system set aq_tm_processes = 2';
	end if;
end;
/
REM =======================================================
REM Create objects - message, queuetable, queue
REM =======================================================

CONNECT bz_adm/&bz_adm_pass
@@bz_cr_msgtyp.sql
@@bz_cr_q.sql

REM Grant required privileges to user bz to perform AQ operations
@@bz_priv.sql 

CONNECT bz_adm/&bz_adm_pass
@@bz_add_subscriber.sql

spool off
Generic/sql/bz_msg_clnup.sql010064400752150001724000000021520727205735100170450ustar00rbhyravag98000000000000001REM script name: bz_msg_clnup.sql
REM cleans up the messages in the queue table
REM
REM version: 9i

REM =======================================================
REM cleanup section
REM =======================================================

create or replace procedure clean_msgs (que varchar, consumer varchar) IS
	deqopt	dbms_aq.dequeue_options_t;
	mprop	dbms_aq.message_properties_t;
	msgid	RAW(16);
	more_msgs boolean := TRUE;
	payload bzcardorder_typ;
	no_messages exception;
begin
	deqopt.consumer_name := consumer;
	deqopt.navigation := DBMS_AQ.FIRST_MESSAGE;
	deqopt.wait := DBMS_AQ.NO_WAIT;	
	deqopt.dequeue_mode := DBMS_AQ.REMOVE_NODATA;

   	WHILE (more_msgs) LOOP
	BEGIN
		dbms_aq.dequeue( queue_name => que,
		  dequeue_options => deqopt,
		  message_properties => mprop,
		  payload => payload,
		  msgid => msgid);
		commit;
		deqopt.navigation := DBMS_AQ.NEXT_MESSAGE;
		
	EXCEPTION
	  WHEN no_messages then
		more_msgs := FALSE;
	  END;

	END LOOP;

end;
/

execute clean_msgs ('bzcardorders_q', 'SHIPPING');
execute clean_msgs ('bzcardorders_q', 'BILLING');
execute clean_msgs ('bzcardorders_q', 'RUSH_ORDER');
Generic/sql/bz_priv.sql010064400752150001724000000010020727134543000160240ustar00rbhyravag98000000000000001REM script name: bz_priv.sql
REM grants privileges to enqueue and dequeue to user bz
REM
REM version: 9.0.1
REM

REM ========================================================
REM Grant Enqueue and Dequeue privilege on bzcardorders_q to queue 
REM to bz user
REM ========================================================

grant execute on bzcardorder_typ to bz;

begin
dbms_aqadm.grant_queue_privilege(privilege => 'ALL', 
			 	queue_name => 'bzcardorders_q', 
				grantee => 'bz', 
				grant_option => TRUE);
end;
/
Generic/sql/tdcts.sql010064400752150001724000000014530727134625000155050ustar00rbhyravag98000000000000001REM script name:     tdcts.sql
REM purpose:         Create tablespaces for setting up Common Schema
REM version:
REM modifications:
REM **************************************************************************

connect / as sysdba

REM
REM To drop tablespaces if they exist
REM

drop tablespace smundo including contents and datafiles;
drop tablespace demo including contents and datafiles;
drop tablespace temp including contents and datafiles;

REM
REM To create new tablespaces
REM

create undo tablespace smundo
       datafile 'smundo.dbf' size 5M
       autoextend on extent management local;

create tablespace demo
       datafile 'demo.dbf' size 10M
       autoextend on extent management local autoallocate;

create temporary tablespace temp
       tempfile 'temp.dbf' size 5M
       autoextend on;

InternetAccess/004077500752150001724000000000000727335521400144065ustar00rbhyravag98000000000000001InternetAccess/README010064400752150001724000000031400727236345100152600ustar00rbhyravag98000000000000001Read instructions from the file setup_steps.txt to set up the Internet access
demo. for advanced queuing.

Activities:

Activity I - Show an Enqueue from Internet
i) Choose New Business Card Order from the scroll down menu
ii) Enter field Employeeid
iii) Generate XML
iv) Show IDAP document in the window. This is an IDAP document to enqueue a 
   message in the queue bzcardorders_q.
v) Submit Order
vi) This will pop up a window with the result. Save that file. Look at that
 file this is the response to the enqueue. 

Activity II - Show a Dequeue from Internet
i) Choose Search Business Card Order from the scroll down menu
ii) Enter field Employeeid or the messageId you got from the previous enqueue
iii) Generate XML
iv) Submit Order
v) This will pop up a window with the result. Save that file. Look at the file.
  This is the response to the dequeue.

Activity III - Transformation at Enqueue
i) Install the transformations from the directory transformation.
ii) Choose New Business Card Order from the scroll down menu
iii) Enter field EmployeeId
iv) Generate XML
v) In the window add the line 
   "<Transformation>BZ_ADM.BZCARDVERIFY</transformation>"
   in <producer_options>
vi) Submit Order
vi) Save the result in the file.
vii) To verify that transformation really happened do a dequeue as specified
   in step two. The fields First Name and Last Name will be filled in the 
   message returned.

Activity IV - Tranformation at Dequeue
i) To apply transformation at dequeue add the line 
    "<transformation>BZ_ADM.BZCARDVERIFY</transformation>" 
   in <consumer_options> before clicking on Submit Order at Dequeue.
InternetAccess/aq.conf010064400752150001724000000006220726214100400156350ustar00rbhyravag98000000000000001# Add the following to httpd.properties file for Internet Access to AQ

<Location /AQServlet/>

Options Indexes FollowSymLinks Includes

<Limit POST GET>
    AuthName "Welcome to Advanced Queuing Internet Access Demo."
    AuthType Basic
#   Replace this with location of users file
    AuthUserFile /private/bgoyal/OraHome1/Apache/Apache/AQUsers/aqpasswd
    require valid-user
  </Limit>
</Location>
InternetAccess/setup_steps.txt010064400752150001724000000103340726710555400175240ustar00rbhyravag98000000000000001Steps for setting up Internet Access to AQ
===========================================

1. Setup User Authentication for restricted access

   Non-authenticated users are not allowed to perform AQ operations. Below are
   the steps to set up basic authentication in Apache webserver.

   a. Create users file for two aq agents
        htpasswd -cd aqpasswd bob welcome
	htpasswd -d aqpasswd jane welcome
 
   b. Change apache configuration to have authenticated access to AQ servlets.
	i. Add Servlet mount point to jserv.conf

	ApJservMount /AQServlet /root

	ii. Add the following to httpds.conf to restrict access to 
            /aqserv/servlet Only the to AQ agents registered in <users>. 
            Replace /apache/htdocs/userdb/users  below with the absolute 
            location of <users> file created in step(1) above.
       
            <Location /AQServlet/>
            <Limit POST>
                AuthName "AQ restrictions for users"
                AuthType Basic
                AuthUserFile /apache/AQUsers/aqpasswd
                require valid-user
            </Limit>
            </Location>

2.  Check if the classpath for the Servlets execution has the classes required 
    AQ Internet operations

    Add the following to jserv.properties for classpath if they are not already
    there:
       wrapper.bin.parameters=-mx256M ;
       wrapper.classpath=$ORACLE_HOME/rdbms/jlib/aqapi.jar
       wrapper.classpath=$ORACLE_HOME/rdbms/jlib/jmscommon.jar
       wrapper.classpath=$ORACLE_HOME/rdbms/jlib/aqxml.jar
       wrapper.classpath=$ORACLE_HOME/rdbms/jlib/xsu12.jar
       wrapper.classpath=$ORACLE_HOME/lib/xmlparserv2.jar
       wrapper.classpath=$ORACLE_HOME/lib/xschema.jar
       wrapper.classpath=$ORACLE_HOME/lib/servlet.jar
       wrapper.classpath=$ORACLE_HOME/lib/lclasses12.zip
       wrapper.classpath=$ORACLE_HOME/jlib/jndi.jar
       wrapper.classpath=$ORACLE_HOME/jlib/jta.jar
       wrapper.classpath=$ORACLE_HOME/jdbc/lib/classes12.zip
       wrapper.classpath=$ORACLE_HOME/jdbc/lib/nls_charset12.zip
       
       replace $ORACLE_HOME appropriately.
       Also verify for env variables ORACLE_SID, ORACLE_HOME , LD_LIBRARY_PATH 
       are set in jserv.properties.

3. Make sure classpath includes the following:
     For JDK1.2.x: 
       $ORACLE_HOME/jdbc/lib/classes12.zip 
       $ORACLE_HOME/jdbc/lib/nls_charset12.zip
       $ORACLE_HOME/rdbms/jlib/aqapi.jar 
       $ORACLE_HOME/rdbms/jlib/jmscommon.jar 
       $ORACLE_HOME/rdbms/jlib/aqxml.jar 
       $ORACLE_HOME/rdbms/jlib/xsu12.jar 
       $ORACLE_HOME/jlib/jndi.jar 
       $ORACLE_HOME/jlib/jta.jar 
       $ORACLE_HOME/lib/xmlparserv2.jar 
       $ORACLE_HOME/lib/xschema.jar 
       $ORACLE_HOME/lib/servlet.jar 
       $ORACLE_HOME/lib/lclasses12.zip 
       $ORACLE_HOME/jlib/javax-ssl-1_2.jar 
       $ORACLE_HOME/lib/http_client.jar 
       $ORACLE_HOME/lib/http_server.jar 

4. Set up AQ Servlets
   
   a. Create the servlet that extends AQxmlServlet. AQxmlServlet for jdk1.1.x 
      and AQxmlServlet20 for jdk 1.2.x. Implement method init(). In this method
      setAQDataSource() to establish database connection. 

      In this example, AQDemo.java servlet is created for you. Modify sid,
      host, port in the function createAQDataSource and Compile this
      servlet.

         javac AQDemo.java

   b. Put the servlet in the directory for AQ servlets.

      In this example, put AQDemo.class in $ORACLE_HOME/Apache/Jserv/servlets

5. Database set up
   a.  Make sure init.ora file contains:
	compatible = 9.0.0 or higher
        aq_tm_processes = 1 or higher
        job_queue_processes = 2 or higher
       
   b.  Set up User Authorization for Internet access

       In this example, qs_ia_priv.sql to sets up internet users 
       "bob" and "jane".

   c.  Create and start AQ queues.

       In this example, 
       qs_ia_cr_msgtyp.sql - Creates an Oracle object type
       qs_ia_cr_q.sql - Creates a queuetable and a queue
       qs_ia_priv.sql - Grants the required privileges

6. Now you are ready to send IDAP requests and perform AQ operations.

   In this example, BizCardOrderForm.html and processBizCardOrder.js have been
   created for you. Make these files accessible through your webserver.

   Please read RunDemo.txt for instructions on how to use the demo.
InternetAccess/servlet/004077500752150001724000000000000727335521400160725ustar00rbhyravag98000000000000001InternetAccess/servlet/AQDemo.java010075500752150001724000000037140726734410500200460ustar00rbhyravag98000000000000001/* $Header: AQxmlServlet.java 12-jun-00.17:20:42 bnainani Exp $ */

/* Copyright (c) Oracle Corporation 2000. All Rights Reserved. */

/*
   DESCRIPTION
    Sample AQ servlet

*/

import java.io.*;

import javax.servlet.*;
import javax.servlet.http.*;
import oracle.AQ.*;
import oracle.AQ.xml.*;
import java.sql.*;
import java.io.*;
//import oracle.jdbc.pool.*;

/**
 * This is a sample AQ Servlet.  
 */
public class AQDemo extends oracle.AQ.xml.AQxmlServlet20
{ 


  //========================================================================
  /*
   *  getDBDrv - specify the database to which the servlet will connect
   */
  public AQxmlDataSource createAQDataSource() throws AQxmlException
  {
    AQxmlDataSource  db_drv = null;
    
    System.err.println("AQTestServlet - setting db driver");

    /* CHANGE THIS LINE 
     * Create database driver with username/password, sid, host, port */
    db_drv = new AQxmlDataSource("bz", "bz", "BGOYALDB", "bgoyal-sun",
			    "1521");

    return db_drv;
  }

    
  //========================================================================
  public void init(ServletConfig config)
  {
      AQxmlDataSource  db_drv = null;

      try
      {
	PrintStream debugFile = new PrintStream (new FileOutputStream("/tmp/aqdebuglog"));
	debugFile.println("Function Called");
	debugFile.flush();
	super.init(config);
        AQxmlDebug.setTraceLevel(5);
        AQxmlDebug.setDebug(true);
	AQxmlDebug.setLogStream(new FileOutputStream("/tmp/aqlogfile"));

        db_drv = createAQDataSource();

	setAQDataSource(db_drv);

	System.err.println("AQTestServlet - setting style sheet");

	/* CHANGE THIS LINE */
//	setStyleSheet("text/xsl", "bizCard.xsl");
      }
      catch (AQxmlException aq_ex)
      {
	System.out.println("AQ exception: " + aq_ex);
	aq_ex.printStackTrace();

	aq_ex.getNextException().printStackTrace();
      }
      catch (Exception ex)
      {
	System.out.println("Exception: " + ex);
	ex.printStackTrace();
      }
  }
      
}
 
InternetAccess/servlet/BizCardOrderForm.html010064400752150001724000000042210727205341100221010ustar00rbhyravag98000000000000001<!-- http://www.w3.org/TR/WD-xsl
http://www.w3.org/1999/XSL/Format
http://www.w3.org/1999/XSL/Transform
-->
<html>
  <HEAD>
    <!-- invoke the script to parse the url -->    
    <script src="args.js"></script>
    
    
    <!-- define the javascript function to process the user input -->
    <script src="processBizCardOrder.js"></script>

    <TITLE>Business Cards Online Order Form</TITLE>
  </HEAD>
  <BODY bgcolor= "#ccccff">
    
      <FORM NAME="request" METHOD="POST" ACTION="bob.sql">
	<table border=0 cellpadding=0 cellspacing=0 width="700">
	  <tr>
	    <th colspan=4 bgcolor="#eeeecc">
	      <font face="arial, sans-serif" size=4 color="#333333">Business Cards Order Form</font>
	    </th>
	  </tr>
	  <tr>
	    <td>
	      <SELECT Name="requestType">
		<OPTION SELECTED> New Business Card Order
		<OPTION> Search Business Card Order
		<OPTION> Remove Business Card Order
	      </SELECT>
	    </td>
	  </tr>
	  <tr>
	    <td>
	      <font face="arial, sans-serif" size=3 style="font-weight:BOLD">
		EmployeeId
	      </font>
	      <input type="text" name="employeeId" size=12 maxlength=6 value="">
	    </td>
	    <td>
	      <font face="arial, sans-serif" size=3 style="font-weight:BOLD">
		Order #
	      </font>
	      <input type="text" name="orderNo" size=12 maxlength=50 value="">
	    </td>
	  </tr>
	  <tr>
	    <td>
	      <font face="arial, sans-serif" size=3 style="font-weight:BOLD">
		First Name
	      </font>
	      <input type="text" name="firstName" size=12 maxlength=20 value="">
	    </td>
	    <td>
	      <font face="arial, sans-serif" size=3 style="font-weight:BOLD">
		Last Name
	      </font>
	      <input type="text" name="lastName" size=12 maxlength=20 value="">
	    </td>
	  </tr>
	</TABLE>
	<INPUT TYPE="BUTTON" VALUE="Generate XML" onClick="processUserInput()">
      </FORM>
     <HR WIDTH=100% SIZE=1></HR>
    <BR>
    <FORM NAME="aqxmlform" METHOD="POST" ACTION="http://bgoyal-sun:7777/AQServlet/AQDemo" ENCTYPE="text/xml">
    <TEXTAREA NAME="aqxmldoc" ENCTYPE="text/xml" ROWS="15" COLS="80"></TEXTAREA>
    <BR> <BR>
    <INPUT TYPE="SUBMIT" ENCTYPE="text/xml" VALUE="Submit Order">
    <INPUT TYPE="RESET">
    </FORM>

</BODY>
</HTML>
InternetAccess/servlet/processBizCardOrder.js010064400752150001724000000114440732732631600223410ustar00rbhyravag98000000000000001function processUserInput() {
  var aqxmldoc = '';

  // Generate IDAP Envelope
  aqxmldoc += '<?xml version="1.0"?>\n';
  aqxmldoc += '<Envelope xmlns="http://ns.oracle.com/AQ/schemas/envelope">\n';
  aqxmldoc += '<Body>\n';


  //Find the order type
  //a. New Business Card Order -- This would generate an enqueue statement
  //b. Search Business Card Order--This would generate dequeue with browse mode
  //c. Remove Business Card Order--This would generate dequeue with remove mode

  error = false;
  if (document.request.elements['requestType'].selectedIndex == 0) {
    // generate enqueue statement
    aqxmldoc += generateEnqueue();
  } else {
    // generate a dequeue statement
    aqxmldoc += generateDequeue();
  }
  if (error)
    return;
  aqxmldoc += '</Body>\n';
  aqxmldoc += '</Envelope>';
  document.aqxmlform.aqxmldoc.value = aqxmldoc;
  return;  // End of processUserInput function


  function xmlOrder () {
    aqxmldoc = '';
    aqxmldoc += '        <BZCARDORDER_TYP>\n';
    if ( (employee_id = document.request.elements['employeeId'].value) != 0)
      aqxmldoc += '          <EMPLOYEE_ID>'+employee_id + '</EMPLOYEE_ID>\n';
    else {
      firstName = document.request.elements['firstName'].value;
      lastName = document.request.elements['lastName'].value;
      if ( (firstName != null && firstName != "") || 
	   (lastName != null && lastName != ""))
	{
	  aqxmldoc += '          <FIRST_NAME> '+ firstName + 
	    ' </FIRST_NAME>\n';
	  aqxmldoc += '          <LAST_NAME> '+ lastName + 
	    ' </LAST_NAME>\n';	  
	}
      else {
	error = true;
	return '';
      }
    }
    aqxmldoc += '        </BZCARDORDER_TYP>\n';
    return aqxmldoc;
  }

  function generateEnqueue () {
    aqxmldoc = '';
    // generate an enqueue statement
    aqxmldoc += '<AQXmlSend xmlns = "http://ns.oracle.com/AQ/schemas/access">\n';
    aqxmldoc += '  <producer_options>\n';
    aqxmldoc += '     <destination>BZ_ADM.bzcardorders_q</destination>\n';
    aqxmldoc += '  </producer_options>\n';
    aqxmldoc += '  <message_set>\n';
    aqxmldoc += '    <message_count>1</message_count>\n';
    aqxmldoc += '    <message>\n';
    aqxmldoc += '      <message_number>1</message_number>\n';
    aqxmldoc += '      <message_header>\n';
    aqxmldoc += '        <correlation>1</correlation>\n';
    aqxmldoc += '        <sender_id>\n';
    aqxmldoc += '          <agent_name>'+ 'bob' + '</agent_name>\n';
    aqxmldoc += '        </sender_id>\n';
    aqxmldoc += '      </message_header>\n';
    aqxmldoc += '      <message_payload>\n';
    
    error = false;
    aqxmldoc += xmlOrder();
    if (error) {
      alert ('Must enter Employee Id or Employee Name');
      return;
    }
    
    aqxmldoc += '      </message_payload>\n';
    aqxmldoc += '    </message>\n';
    aqxmldoc += '  </message_set>\n';
    aqxmldoc += '  <AQXmlCommit>\n';
    aqxmldoc += '  </AQXmlCommit>\n';
    aqxmldoc += '</AQXmlSend>\n';   
    return aqxmldoc;
  }

  function generateDequeue() {
    aqxmldoc = '';
    
    aqxmldoc += '        <AQXmlReceive xmlns = "http://ns.oracle.com/AQ/schemas/access">\n';
    aqxmldoc += '          <consumer_options>\n';
    aqxmldoc += '            <destination>BZ_ADM.bzcardorders_q</destination>\n';
    aqxmldoc += '            <consumer_name>SHIPPING</consumer_name>\n';

    aqxmldoc += '            <selector>\n';
    orderno   = document.request.elements['orderNo'].value;
    if (orderno != null && orderno != '') {
      aqxmldoc += '              <message_id>' + orderno + '</message_id>\n';
    } else {
      aqxmldoc += '              <condition> ';
      firstName = document.request.elements['firstName'].value;
      lastName  = document.request.elements['lastName'].value;
      employeeId = document.request.elements['employeeId'].value;
      if (employeeId != null && employeeId != '')
	aqxmldoc += 'tab.user_data.employee_id= ' + employeeId;
      else if ( (firstName != null && firstName != '') ||
		(lastName != null && lastName != '')) {
	if (isFirst = (firstName != null && firstName != ''))
	  aqxmldoc += 'tab.user_data.first_Name=' + "'" + firstName + "'";
	if (lastName != null && lastName != '') {
	  aqxmldoc += isFirst ? ' AND ': '';
	  aqxmldoc += 'tab.user_data.last_Name=' + "'" + lastName + "'";
	} 
      }else {
	error = true;
	alert ('Must Enter one of EmployeeId or Order # or Name');
	return '';
      }
      aqxmldoc += '</condition>\n';
    }
    aqxmldoc += '            </selector>\n';
    if (document.request.elements['requestType'].selectedIndex == 1)
      aqxmldoc += '            <dequeue_mode>BROWSE</dequeue_mode>\n';
    else
      aqxmldoc += '            <dequeue_mode>REMOVE</dequeue_mode>\n';
    aqxmldoc += '          </consumer_options>\n';
    aqxmldoc += '          <AQXmlCommit>\n';
    aqxmldoc += '          </AQXmlCommit>\n';
    aqxmldoc += '        </AQXmlReceive>\n';
    return aqxmldoc;
  }
}
InternetAccess/servlet/bizCard.xsl010064400752150001724000000045700726340753300202020ustar00rbhyravag98000000000000001  <?xml version="1.0" ?> 
  <xsl:stylesheet xmlns:xsl="http://www.w3.org/TR/WD-xsl">
  <xsl:template match="/">
  <HTML>
  <BODY bgcolor="#ccccff">
  <xsl:for-each select="Envelope/Body">
    <xsl:for-each select="Fault">
	<TABLE border="1" cellpadding="0" cellspacing="0" width="500">
	<TR>
        <TH colspan="2" bgcolor="#eeeecc">
        <FONT face="arial, sans-serif" size="3" color="#333333">LK Error Received!</FONT>
        </TH>
        </TR>
	<TR>
	<TD>
		<FONT face="arial, sans-serif" size="3" color="#333333">Fault Code</FONT>
	</TD>
	<TD>
	        <FONT face="arial, sans-serif" size="3" color="#333333"><xsl:value-of select="faultcode"/></FONT>
	</TD>
	</TR>
	<TR>
	<TD>
	        <FONT face="arial, sans-serif" size="3" color="#333333">Fault String</FONT>
	</TD>
	<TD>
                <FONT face="arial, sans-serif" size="3" color="#333333"><xsl:value-of select="faultstring"/></FONT>
	</TD>
	</TR>
	<TR>
	<TH colspan="2">
	        <FONT face="arial, sans-serif" size="3" color="#333333">Details</FONT>
	</TH>
	</TR>
	<TR>
	<TD>
	        <FONT face="arial, sans-serif" size="3" color="#333333">Status Code</FONT>
	</TD>
	<TD>
	        <FONT face="arial, sans-serif" size="3" color="#333333"><xsl:value-of select="detail/status_response/status_code"/></FONT>
	</TD>
	</TR>
	<TR>
	<TD>
	        <FONT face="arial, sans-serif" size="3" color="#333333">Error Code</FONT>
	</TD>
	<TD>
	        <FONT face="arial, sans-serif" size="3" color="#333333"><xsl:value-of select="detail/status_response/error_code"/></FONT>
	</TD>
	</TR>
	<TR>
	<TD colspan="2">
	         <FONT face="arial, sans-serif" size="3" color="#333333">Error Message: <xsl:value-of select="detail/status_response/error_message"/></FONT>
	</TD>
	</TR>
	</TABLE>
    </xsl:for-each>
  <xsl:for-each select="AQXmlSendResponse/send_result">
  <TABLE border="0" cellpadding="0" cellspacing="0" width="700">
    <TR>
      <TD colspan="4" bgcolor="#eeeecc">
      <FONT face="arial, sans-serif" size="3" color="#333333">Order Received</FONT>
      </TD>
    </TR>
    <TR>
      <TD >
      <FONT face="arial, sans-serif" size="2" style="font-weight:BOLD">Order Id</FONT>
      </TD>
      <TD bgcolor="white">
      <FONT face="arial, sans-serif" size="2" style="font-weight:BOLD"><xsl:value-of select="message_id"/></FONT>
      </TD>
    </TR>
  </TABLE>
  </xsl:for-each>

 </xsl:for-each>
 </BODY>
  </HTML>
  </xsl:template>

  </xsl:stylesheet>
InternetAccess/sql/004077500752150001724000000000000727335521400152055ustar00rbhyravag98000000000000001InternetAccess/sql/bz_ia_main.sql010064400752150001724000000010300726734402500200040ustar00rbhyravag98000000000000001REM script name: bz_ia_main.sql
REM It creates the internet users for AQ access and grants 
REM privileges to bz for internet access 
REM 
REM Assumes the generic set up for AQ BizCard Demo has been 
REM done
REM
REM version: 9.0.1
REM change:  initial version
REM
REM =======================================================
REM cleanup section
REM =======================================================

SET VERIFY OFF

define bz_pass      = &1
define master_pass  = &5

SPOOL bz_ia

@@bz_ia_priv.sql &bz_pass &master_pass

spool off
ain.sql
REM It creates the internet users for AQ access and grants 
REM privileges to bz for internet access 
REM 
REM Assumes the generic set up for AQ BizCard Demo has been 
REM done
REM
REM version: 9.0.1
REM change:  initial version
REM
REM =======================================================
REM cleanup section
REM =======================================================

SET VERIFY OFF

define bz_pass      = &1
define master_pass  = &5

SPOOL bz_ia

@@bz_ia_priv.sql &bz_pass InternetAccess/sql/bz_ia_priv.sql010064400752150001724000000015520726734404500200530ustar00rbhyravag98000000000000001REM script name: bz_ia_priv.sql
REM grants privileges to enqueue and dequeue to user bz
REM Creates Internet users Bob and Jane
REM Grants appropriate privileges to bz for internet_access
REM
REM version: 9.0.1
REM change:  initial version
REM


define bz_pass = &1
define master_pass = &2

CONNECT bz/&bz_pass

execute dbms_aqadm.drop_aq_agent(agent_name=>'bob');
execute dbms_aqadm.drop_aq_agent(agent_name=>'jane');

REM Allows access to the queues via the servlets
execute dbms_aqadm.create_aq_agent(agent_name=>'bob', enable_http =>true);
execute dbms_aqadm.create_aq_agent(agent_name=>'jane', enable_http =>true);
execute dbms_aqadm.enable_db_access('bob', 'BZ');
execute dbms_aqadm.enable_db_access('jane', 'BZ');


REM make sure that bz already has aq_user_role and excecute on dbms_aq

CONNECT system/&master_pass as sysdba;
alter user bz grant connect through bz;
InternetAccess/sql/run.sh010075500752150001724000000001420726734547200163500ustar00rbhyravag98000000000000001sqlplus system/manager << EOF
set echo on
@tdcts.sql 
@bz_ia_main.sql bz bz_adm demo temp manager
README010064400752150001724000000024000727335545100123460ustar00rbhyravag98000000000000001This is the integrated demonstration for AQ Features. Currently, it demos the 
following features:

i) Generic - Basic AQ features
	- Multiple ways to enqueue/dequeue
		- blocking/non-blocking dequeue
		- dequeue by condition
	- Time specification functions
		- expiration and delay
	- Publish/Subscribe		 

ii) Internet Access features
	- AQ operations from the Internet
	- Internet Security

iii) Transformation
	- Transformation feature
	- Create the transformation function and use it with Internet access

iv) XML
	- Queue with XML data
	- XML mapping from an object queue to queue with XMLTYpe attribute

How to run the demo:

Scripts in directory Generic are required for all the demos. 

The demo. uses two database schema users bz and bz_adm. The schema bz_adm has
all the required message types, queuetables, queues, and tranformation 
mappings. User qz has the privileges to enqueue and dequeue from the queues in
schema bz_adm.

Each sql directory has a script run.sh. Execute this script. This will call
bz_main.sql after setting appropriate paramters. Each sql directory has a file 
bz_main.sql. bz_main.sql calls other scripts to create the schema objects and to
 give appropriate priviliges. 

Passwords used for the schemas are bz for bz and bz_Adm for bz_adm. 

Transformation/004077500752150001724000000000000727335521400145025ustar00rbhyravag98000000000000001Transformation/README010064400752150001724000000007170727236405500153640ustar00rbhyravag98000000000000001These scripts show the transformation features of AQ. This demo. uses HR
schema from shared schema. Please run the script setuphr.sh in the directory
$ORACLE_HOME/demo/human_resources, if human_resources schema has not already
been installed. This will setup HR schema that will be used to verify and fill
in missing fields the business card order in the transformation function.

These scripts creates a transformation mapping BZCARDVERIFY in the schema
bz_Adm.
Transformation/setuphr.sh010075500752150001724000000001430726442522700165260ustar00rbhyravag98000000000000001sqlplus system/manager << EOF
set echo on
@tdcts.sql 
@hr_main.sql hr demo temp change_on_install

Transformation/sql/004077500752150001724000000000000727206044000152725ustar00rbhyravag98000000000000001Transformation/sql/bz_tr_main.sql010064400752150001724000000010560727234261700201450ustar00rbhyravag98000000000000001REM script name: bz_tr_main.sql
REM Creates a transformation to verify order and fill-in missing fields
REM of bzcardorder
REM 
REM 
REM
REM version: 9.0.1
REM change:  initial version
REM
REM =======================================================
REM cleanup section
REM =======================================================

SET VERIFY OFF

define bz_adm_pass  = &1
define master_pass  = &2
define hr_pass      = &3

spool bz_tr
CONNECT system/&master_pass as sysdba;
@@bz_tr_priv.sql &hr_pass
CONNECT bz_adm/&bz_adm_pass
@@bz_tr_mapping.sql

spool off
Transformation/sql/bz_tr_priv.sql010064400752150001724000000004750727234303200201750ustar00rbhyravag98000000000000001REM script name: bz_tr_priv.sql
REM Grants execute on dbms_tranform to bz
REM Grant select on hr.employees to bz and bz_adm
REM 
REM 
REM
REM version: 9.0.1
define hr_pass = &1

grant execute on dbms_transform to bz;

connect hr/&hr_pass
grant select on hr.employees to bz;
grant select on hr.employees to bz_adm;

	
Transformation/sql/bz_tr_mapping.sql010064400752150001724000000023700727206042700206500ustar00rbhyravag98000000000000001REM This function verifies if the employee_id is correct and fills in the
REM missing information


REM =======================================================
REM cleanup section
REM =======================================================

execute dbms_transform.drop_transformation -
	(schema =>'BZ_ADM',name =>'BZCARDVERIFY');

drop function FnVerifyBzCardOrder;

create or replace function FnVerifyBzCardOrder 
	(ord BZ_ADM.BZCARDORDER_TYP)
return BZCARDORDER_TYP is
	newOrder BZ_ADM.BZCARDORDER_TYP;
BEGIN
	newOrder := BzCardOrder_typ(null, null, null, 'NORMAL');
	select employee_id, first_name, last_name into newOrder.employee_id, 
		newOrder.first_name, newOrder.last_name from hr.employees e
	where (ord.employee_id is null or ord.employee_id=e.employee_id)
 	and (ord.first_name is null or ord.first_name = e.first_name)
	and (ord.last_name is null or ord.last_name = e.last_name);

	return newOrder;
END;
/

show errors;

execute	dbms_transform.create_transformation ( -
	schema => 'BZ_ADM', name  => 'BZCARDVERIFY', -
	from_schema => 'BZ_ADM', to_schema => 'BZ_ADM', -
	from_type => 'BZCARDORDER_TYP', to_type => 'BZCARDORDER_TYP',-
	transformation => 'BZ_ADM.FNVERIFYBZCARDORDER(SOURCE.USER_DATA)');

show errors;
grant execute on FnVerifyBzCardOrder to bz;
Transformation/sql/test.sql010064400752150001724000000004410727206016100167640ustar00rbhyravag98000000000000001declare
	oorder BZCARDORDER_TYP;
	norder BZCARDORDER_typ;
begin
	oorder := BzCardOrder_typ(101, null, null);
	dbms_Transform.compute_transformation(message => oorder, 
		transformation_schema => 'BZ_ADM', 
		transformation_name => 'BZCARDVERIFY', 
		transformed_message => norder);
end;
/
Transformation/sql/run.sh010075500752150001724000000001130726734622100164330ustar00rbhyravag98000000000000001sqlplus system/manager << EOF
set echo on
@bz_tr_main.sql bz_adm master hr
XML/004077500752150001724000000000000727335521400121345ustar00rbhyravag98000000000000001XML/README010064400752150001724000000001410727236421200130000ustar00rbhyravag98000000000000001These scripts create an xml-typed queue and a transformation mapping from
an object type to XML.
XML/sql/004077500752150001724000000000000727335521400127335ustar00rbhyravag98000000000000001XML/sql/bz_xml_main.sql010064400752150001724000000017120727234361200157450ustar00rbhyravag98000000000000001REM script name: bz_xml_main.sql
REM Creates an xml-typed queue bzcardxmlo_q and an xml-tranformation
REM 
REM 
REM 
REM
REM version: 9.0.1
REM change:  initial version

define bz_adm = &1

REM =======================================================
REM cleanup section
REM =======================================================

SET VERIFY OFF

spool bz_xml

CONNECT bz_adm/&bz_adm
REM =======================================================
REM CREATE an object type with XMLType attribute
REM =======================================================

@@bz_xml_cr_msgtyp.sql

REM =======================================================
REM CREATE a queue with XMLType payload
REM =======================================================

@@bz_xml_cr_q.sql

REM =======================================================
REM CREATE a transformation from an object type to XMLType
REM =======================================================

@@bz_xml_mapping.sql

spool off
XML/sql/bz_xml_mapping.sql010064400752150001724000000025120727234400600164510ustar00rbhyravag98000000000000001REM script name: bz_xml_mapping.sql
REM Creates a mapping to convert an object type to XML: bzcarobj2xml
REM
REM version: 9i
REM change:  no connect required
REM

REM =======================================================
REM cleanup section
REM This function verifies if the employee_id is correct and fills in the
REM missing information


REM =======================================================
REM cleanup section
REM =======================================================

execute dbms_transform.drop_transformation -
	(schema =>'BZ_ADM',name =>'BZCARDOBJ2XML');

drop function FnBzCardObj2XML;

REM =======================================================
REM Creating PL/SQL Transformation function and transformation mapping
REM =======================================================

create or replace function FnBzCardOBJ2XML
	(ord BZCARDORDER_TYP)
return BZCARDXMLO_TYP is
	newOrder BzCardXMLo_typ;
BEGIN
	newOrder := BzCardXMLo_typ(null);
	select SYS_XMLGEN(ord) into newOrder.xmlo from dual;
	return newOrXML/sql/bz_xml_cr_msgtyp.sql010064400615460001147000000013430727213030700164710ustar00bgoyalg6150