LCOV - code coverage report
Current view: top level - src/interfaces/ecpg/test/sql - declare.pgc (source / functions) Hit Total Coverage
Test: PostgreSQL 15devel Lines: 108 108 100.0 %
Date: 2021-12-04 22:09:09 Functions: 5 5 100.0 %
Legend: Lines: hit not hit

          Line data    Source code
       1             : #include <locale.h>
       2             : #include <string.h>
       3             : #include <stdlib.h>
       4             : 
       5             : EXEC SQL WHENEVER SQLERROR SQLPRINT;
       6             : 
       7             : EXEC SQL INCLUDE sqlca;
       8             : EXEC SQL INCLUDE ../regression;
       9             : 
      10             : #define ARRAY_SIZE 2
      11             : 
      12             : void execute_test(void);
      13             : void commitTable(void);
      14             : void reset(void);
      15             : void printResult(char *tc_name, int loop);
      16             : 
      17             : EXEC SQL BEGIN DECLARE SECTION;
      18             : int f1[ARRAY_SIZE];
      19             : int f2[ARRAY_SIZE];
      20             : char f3[ARRAY_SIZE][20];
      21             : EXEC SQL END DECLARE SECTION;
      22             : 
      23           4 : int main(void)
      24             : {
      25           4 :     setlocale(LC_ALL, "C");
      26             : 
      27           4 :     ECPGdebug(1, stderr);
      28             : 
      29           4 :     EXEC SQL CONNECT TO REGRESSDB1 AS con1;
      30           4 :     EXEC SQL CONNECT TO REGRESSDB2 AS con2;
      31           4 : 
      32           4 :     EXEC SQL AT con1 CREATE TABLE source(f1 integer, f2 integer, f3 varchar(20));
      33           4 :     EXEC SQL AT con2 CREATE TABLE source(f1 integer, f2 integer, f3 varchar(20));
      34           4 : 
      35           4 :     EXEC SQL AT con1 INSERT INTO source VALUES(1, 10, 'db on con1');
      36           4 :     EXEC SQL AT con1 INSERT INTO source VALUES(2, 20, 'db on con1');
      37           4 : 
      38           4 :     EXEC SQL AT con2 INSERT INTO source VALUES(1, 10, 'db on con2');
      39           4 :     EXEC SQL AT con2 INSERT INTO source VALUES(2, 20, 'db on con2');
      40           4 : 
      41           4 :     commitTable();
      42             : 
      43           4 :     execute_test();
      44             : 
      45           4 :     EXEC SQL AT con1 DROP TABLE IF EXISTS source;
      46           4 :     EXEC SQL AT con2 DROP TABLE IF EXISTS source;
      47           4 : 
      48           4 :     commitTable();
      49             : 
      50           4 :     EXEC SQL DISCONNECT ALL;
      51           4 : 
      52           4 :     return 0;
      53             : }
      54             : 
      55             : /*
      56             :  * default connection: con2
      57             :  * Non-default connection: con1
      58             :  *
      59             :  */
      60           4 : void execute_test(void)
      61             : {
      62             :     EXEC SQL BEGIN DECLARE SECTION;
      63             :     int i, count, length;
      64           4 :     char *selectString = "SELECT f1,f2,f3 FROM source";
      65             :     EXEC SQL END DECLARE SECTION;
      66             : 
      67             :     /*
      68             :      * testcase1. using DECLARE STATEMENT without using AT clause,
      69             :      * using PREPARE and CURSOR statement without using AT clause
      70             :      */
      71           4 :     reset();
      72             : 
      73             :     EXEC SQL DECLARE stmt_1 STATEMENT;
      74           4 :     EXEC SQL PREPARE stmt_1 FROM :selectString;
      75           4 :     EXEC SQL DECLARE cur_1 CURSOR FOR stmt_1;
      76           4 :     EXEC SQL OPEN cur_1;
      77           4 : 
      78             :     EXEC SQL WHENEVER NOT FOUND DO BREAK;
      79           4 :     i = 0;
      80             :     while (1)
      81             :     {
      82          12 :         EXEC SQL FETCH cur_1 INTO :f1[i], :f2[i], :f3[i];
      83          12 :         i++;
      84             :     }
      85           4 :     EXEC SQL CLOSE cur_1;
      86           4 :     EXEC SQL DEALLOCATE PREPARE stmt_1;
      87          16 :     EXEC SQL WHENEVER NOT FOUND CONTINUE;
      88             : 
      89           4 :     printResult("testcase1", 2);
      90             : 
      91             : 
      92             :     /*
      93             :      * testcase2. using DECLARE STATEMENT at con1,
      94             :      * using PREPARE and CURSOR statement without using AT clause
      95             :      */
      96           4 :     reset();
      97             : 
      98             :     EXEC SQL AT con1 DECLARE stmt_2 STATEMENT;
      99           4 :     EXEC SQL PREPARE stmt_2 FROM :selectString;
     100           4 :     EXEC SQL DECLARE cur_2 CURSOR FOR stmt_2;
     101           4 :     EXEC SQL OPEN cur_2;
     102           4 : 
     103             :     EXEC SQL WHENEVER NOT FOUND DO BREAK;
     104           4 :     i = 0;
     105             :     while (1)
     106             :     {
     107          12 :         EXEC SQL FETCH cur_2 INTO :f1[i], :f2[i], :f3[i];
     108          12 :         i++;
     109             :     }
     110           4 :     EXEC SQL CLOSE cur_2;
     111           4 :     EXEC SQL DEALLOCATE PREPARE stmt_2;
     112          16 :     EXEC SQL WHENEVER NOT FOUND CONTINUE;
     113             : 
     114           4 :     printResult("testcase2", 2);
     115             : 
     116             :     /*
     117             :      * testcase3. using DECLARE STATEMENT without using AT clause,
     118             :      * using PREPARE and EXECUTE statement without using AT clause
     119             :      */
     120           4 :     reset();
     121             : 
     122             :     EXEC SQL DECLARE stmt_3 STATEMENT;
     123           4 :     EXEC SQL PREPARE stmt_3 FROM :selectString;
     124           4 :     EXEC SQL EXECUTE stmt_3 INTO :f1, :f2, :f3;
     125           4 : 
     126           4 :     EXEC SQL DEALLOCATE PREPARE stmt_3;
     127           4 : 
     128           4 :     printResult("testcase3", 2);
     129             : 
     130             :     /*
     131             :      * testcase4. using DECLARE STATEMENT without using AT clause,
     132             :      * using PREPARE and CURSOR statement at con2
     133             :      */
     134           4 :     reset();
     135             : 
     136             :     EXEC SQL DECLARE stmt_4 STATEMENT;
     137           4 :     EXEC SQL AT con2 PREPARE stmt_4 FROM :selectString;
     138           4 :     EXEC SQL AT con2 DECLARE cur_4 CURSOR FOR stmt_4;
     139           4 :     EXEC SQL AT con2 OPEN cur_4;
     140           4 : 
     141             :     EXEC SQL WHENEVER NOT FOUND DO BREAK;
     142           4 :     i = 0;
     143             :     while (1)
     144             :     {
     145          12 :         EXEC SQL AT con2 FETCH cur_4 INTO :f1[i], :f2[i], :f3[i];
     146          12 :         i++;
     147             :     }
     148           4 :     EXEC SQL AT con2 CLOSE cur_4;
     149           4 :     EXEC SQL AT con2 DEALLOCATE PREPARE stmt_4;
     150          16 :     EXEC SQL WHENEVER NOT FOUND CONTINUE;
     151             : 
     152           4 :     printResult("testcase4", 2);
     153             : 
     154             :     /*
     155             :      * DESCRIBE statement is also supported.
     156             :      */
     157             :     EXEC SQL AT con1 DECLARE stmt_desc STATEMENT;
     158           4 :     EXEC SQL PREPARE stmt_desc FROM :selectString;
     159           4 :     EXEC SQL DECLARE cur_desc CURSOR FOR stmt_desc;
     160           4 :     EXEC SQL OPEN cur_desc;
     161           4 : 
     162             :     /* descriptor can be used for describe statement */
     163           4 :     EXEC SQL AT con1 ALLOCATE DESCRIPTOR desc_for_describe;
     164           4 :     EXEC SQL DESCRIBE stmt_desc INTO SQL DESCRIPTOR desc_for_describe;
     165             : 
     166           4 :     EXEC SQL AT con1 GET DESCRIPTOR desc_for_describe :count = COUNT;
     167           4 :     EXEC SQL AT con1 GET DESCRIPTOR desc_for_describe VALUE 3 :length = LENGTH;
     168           4 : 
     169           4 :     EXEC SQL AT con1 DEALLOCATE DESCRIPTOR desc_for_describe;
     170           4 : 
     171             :     /* for fetch statement */
     172           4 :     EXEC SQL AT con1 ALLOCATE DESCRIPTOR desc_for_fetch;
     173           4 :     EXEC SQL FETCH cur_desc INTO SQL DESCRIPTOR desc_for_fetch;
     174           4 : 
     175           4 :     EXEC SQL AT con1 GET DESCRIPTOR desc_for_fetch VALUE 3 :f3[0] = DATA;
     176           4 : 
     177           4 :     EXEC SQL AT con1 DEALLOCATE DESCRIPTOR desc_for_fetch;
     178           4 :     EXEC SQL CLOSE cur_desc;
     179           4 :     EXEC SQL DEALLOCATE stmt_desc;
     180           4 : 
     181           4 :     printf("****descriptor results****\n");
     182           4 :     printf("count: %d, length: %d, data: %s\n", count, length, f3[0]);
     183           4 : }
     184             : 
     185           8 : void commitTable()
     186             : {
     187           8 :     EXEC SQL AT con1 COMMIT;
     188           8 :     EXEC SQL AT con2 COMMIT;
     189           8 : }
     190             : 
     191             : /*
     192             :  * reset all the output variables
     193             :  */
     194          16 : void reset()
     195             : {
     196          16 :     memset(f1, 0, sizeof(f1));
     197          16 :     memset(f2, 0, sizeof(f2));
     198          16 :     memset(f3, 0, sizeof(f3));
     199          16 : }
     200             : 
     201          16 : void printResult(char *tc_name, int loop)
     202             : {
     203             :     int i;
     204             : 
     205          16 :     if (tc_name)
     206          16 :         printf("****%s test results:****\n", tc_name);
     207             : 
     208          48 :     for (i = 0; i < loop; i++)
     209          32 :         printf("f1=%d, f2=%d, f3=%s\n", f1[i], f2[i], f3[i]);
     210             : 
     211          16 :     printf("\n");
     212          16 : }

Generated by: LCOV version 1.14