Branch data     Line data    Source code

       1                 :             : #include <stdio.h>
       2                 :             : #include <stdlib.h>
       3                 :             : #include <string.h>
       4                 :             : #include <limits.h>
       5                 :             : 
       6                 :             : exec sql include ../regression;
       7                 :             : 
       8                 :             : exec sql include pgtypes_numeric.h;
       9                 :             : 
      10                 :             : exec sql begin declare section;
      11                 :             : exec sql include struct.h;
      12                 :             : exec sql end declare section;
      13                 :             : 
      14                 :             : exec sql whenever sqlerror stop;
      15                 :             : 
      16                 :             : /* Functions for test 1 */
      17                 :             : 
      18                 :             : static void
      19                 :           2 : get_var1(MYTYPE **myvar0, MYNULLTYPE **mynullvar0)
      20                 :             : {
      21                 :             :     exec sql begin declare section;
      22                 :           2 :     MYTYPE      *myvar = malloc(sizeof(MYTYPE));
      23                 :           2 :     MYNULLTYPE  *mynullvar = malloc(sizeof(MYNULLTYPE));
      24                 :             :     exec sql end declare section;
      25                 :             : 
      26                 :             :     /* Test DECLARE ... SELECT ... INTO with pointers */
      27                 :             : 
      28                 :           2 :     exec sql declare mycur cursor for select * INTO :myvar :mynullvar from a1;
      29         [ -  + ]:           2 : 
      30         [ -  + ]:           2 :     if (sqlca.sqlcode != 0)
      31                 :           0 :         exit(1);
      32                 :             : 
      33                 :           2 :     *myvar0 = myvar;
      34                 :           2 :     *mynullvar0 = mynullvar;
      35                 :           2 : }
      36                 :             : 
      37                 :             : static void
      38                 :           2 : open_cur1(void)
      39                 :             : {
      40                 :           2 :     exec sql open mycur;
      41         [ -  + ]:           4 : }
      42                 :           2 : 
      43                 :           2 : static void
      44                 :           2 : get_record1(void)
      45                 :           2 : {
      46                 :          10 :     exec sql fetch mycur;
      47         [ -  + ]:          18 : }
      48                 :          10 : 
      49                 :          10 : static void
      50                 :          10 : close_cur1(void)
      51                 :           8 : {
      52                 :          10 :     exec sql close mycur;
      53         [ -  + ]:          10 : }
      54                 :           8 : 
      55                 :           8 : int
      56                 :           8 : main (void)
      57                 :             : {
      58                 :             :     MYTYPE      *myvar;
      59                 :             :     MYNULLTYPE  *mynullvar;
      60                 :             :     int loopcount;
      61                 :             :     char msg[128];
      62                 :             : 
      63                 :           2 :     ECPGdebug(1, stderr);
      64                 :             : 
      65                 :           2 :     strcpy(msg, "connect");
      66                 :           2 :     exec sql connect to REGRESSDB1;
      67         [ -  + ]:           2 : 
      68                 :           2 :     strcpy(msg, "set");
      69                 :           2 :     exec sql set datestyle to iso;
      70         [ -  + ]:           2 : 
      71                 :           2 :     strcpy(msg, "create");
      72                 :           2 :     exec sql create table a1(id serial primary key, t text, d1 numeric, d2 float8, c character(10));
      73         [ -  + ]:           2 : 
      74                 :           2 :     strcpy(msg, "insert");
      75                 :           2 :     exec sql insert into a1(id, t, d1, d2, c) values (default, 'a', 1.0, 2, 'a');
      76         [ -  + ]:           2 :     exec sql insert into a1(id, t, d1, d2, c) values (default, null, null, null, null);
      77         [ -  + ]:           2 :     exec sql insert into a1(id, t, d1, d2, c) values (default, 'b', 2.0, 3, 'b');
      78         [ -  + ]:           2 : 
      79                 :           2 :     strcpy(msg, "commit");
      80                 :           2 :     exec sql commit;
      81         [ -  + ]:           2 : 
      82                 :             :     /* Test out-of-scope DECLARE/OPEN/FETCH/CLOSE */
      83                 :             : 
      84                 :           2 :     get_var1(&myvar, &mynullvar);
      85                 :           2 :     open_cur1();
      86                 :             : 
      87         [ +  - ]:           8 :     for (loopcount = 0; loopcount < 100; loopcount++)
      88                 :             :     {
      89                 :           8 :         memset(myvar, 0, sizeof(MYTYPE));
      90                 :           8 :         get_record1();
      91         [ +  + ]:           8 :         if (sqlca.sqlcode == ECPG_NOT_FOUND)
      92                 :           2 :             break;
      93                 :          30 :         printf("id=%d%s t='%s'%s d1=%f%s d2=%f%s c = '%s'%s\n",
      94                 :           6 :             myvar->id, mynullvar->id ? " (NULL)" : "",
      95         [ -  + ]:           6 :             myvar->t, mynullvar->t ? " (NULL)" : "",
      96         [ +  + ]:           6 :             myvar->d1, mynullvar->d1 ? " (NULL)" : "",
      97         [ +  + ]:           6 :             myvar->d2, mynullvar->d2 ? " (NULL)" : "",
      98   [ +  +  +  + ]:          12 :             myvar->c, mynullvar->c ? " (NULL)" : "");
      99                 :             :     }
     100                 :             : 
     101                 :           2 :     close_cur1();
     102                 :             : 
     103                 :           2 :     free(myvar);
     104                 :           2 :     free(mynullvar);
     105                 :             : 
     106                 :           2 :     strcpy(msg, "drop");
     107                 :           2 :     exec sql drop table a1;
     108         [ -  + ]:           2 : 
     109                 :           2 :     strcpy(msg, "commit");
     110                 :           2 :     exec sql commit;
     111         [ -  + ]:           2 : 
     112                 :           2 :     strcpy(msg, "disconnect");
     113                 :           2 :     exec sql disconnect;
     114         [ -  + ]:           2 : 
     115                 :           2 :     return 0;
     116                 :             : }