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              : }