1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
      
    #include "ocilib.h"
    
    int main(void)
    {
        OCI_Connection *cn;
    
        if (!OCI_Initialize(ocilib_err_handler, NULL, OCI_ENV_DEFAULT))
            return EXIT_FAILURE;
    
        /* connect to db */
        cn = OCI_ConnectionCreate("db", "usr", "pwd", OCI_SESSION_DEFAULT);
    
        /* create queue table "TEST_QUEUE_TABLE" */
        OCI_QueueTableCreate(cn, "TEST_QUEUE_TABLE", "MY_MESSAGE", 
                             NULL, NULL, TRUE, 1, NULL, 
                             0, 0, NULL);
                             
         /* alter queue table "TEST_QUEUE_TABLE" - add comment on table */
        OCI_QueueTableAlter(cn, "TEST_QUEUE_TABLE", "MY_COMMENT", 0, 0);
        
        /* purge messages in  queue table "TEST_QUEUE_TABLE" */   
        OCI_QueueTablePurge(cn, "TEST_QUEUE_TABLE", NULL, FALSE, 0);
        
        /* migrate queue table "TEST_QUEUE_TABLE" to Oracle 10.1 version */   
        OCI_QueueTableMigrate(cn, "TEST_QUEUE_TABLE", "10.1");
        
        /* create queue "TEST_QUEUE" using queue table "TEST_QUEUE_TABLE" */
        OCI_QueueCreate(cn, "TEST_QUEUE",  "TEST_QUEUE_TABLE", 
                        0, 0, 0, 0, FALSE, "MY_COMMENT");   
        
        /* alter queue "TEST_QUEUE" - modify comment */
         OCI_QueueAlter(cn, "TEST_QUEUE", 0, 0, 0, "MY_NEW_COMMENT");   
       
         /* start queue "TEST_QUEUE" */  
        OCI_QueueStart(cn, "TEST_QUEUE", TRUE, TRUE);
        
        /* stop queue "TEST_QUEUE" */
        OCI_QueueStop(cn, "TEST_QUEUE", TRUE, TRUE, FALSE);
        
        /* drop queue "TEST_QUEUE" */
        OCI_QueueDrop(cn, "TEST_QUEUE");
        
        /* drop queue table "TEST_QUEUE_TABLE" */
        OCI_QueueTableDrop(cn, "TEST_QUEUE_TABLE", TRUE);
        
        /* disconnect from db */
        OCI_ConnectionFree(cn);
        
        OCI_Cleanup();
    
        return EXIT_SUCCESS;
    }