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