Branch data Line data Source code
1 : : #include <stdlib.h>
2 : : #include <string.h>
3 : : #include <limits.h>
4 : : #include "ecpg_config.h"
5 : :
6 : : exec sql include ../regression;
7 : : exec sql include sqlda.h;
8 : : exec sql include pgtypes_numeric.h;
9 : :
10 : : exec sql whenever sqlerror stop;
11 : :
12 : : /* These shouldn't be under DECLARE SECTION */
13 : : sqlda_t *inp_sqlda, *outp_sqlda, *outp_sqlda1;
14 : :
15 : : static void
16 : 24 : dump_sqlda(sqlda_t *sqlda)
17 : : {
18 : : int i;
19 : :
20 [ - + ]: 24 : if (sqlda == NULL)
21 : : {
22 : 0 : printf("dump_sqlda called with NULL sqlda\n");
23 : 0 : return;
24 : : }
25 : :
26 [ + + ]: 168 : for (i = 0; i < sqlda->sqld; i++)
27 : : {
28 [ + - + + ]: 144 : if (sqlda->sqlvar[i].sqlind && *(sqlda->sqlvar[i].sqlind) == -1)
29 : 20 : printf("name sqlda descriptor: '%s' value NULL'\n", sqlda->sqlvar[i].sqlname.data);
30 : : else
31 [ + + + - : 124 : switch (sqlda->sqlvar[i].sqltype)
+ + - ]
32 : : {
33 : 40 : case ECPGt_char:
34 : 40 : printf("name sqlda descriptor: '%s' value '%s'\n", sqlda->sqlvar[i].sqlname.data, sqlda->sqlvar[i].sqldata);
35 : 40 : break;
36 : 24 : case ECPGt_int:
37 : 24 : printf("name sqlda descriptor: '%s' value %d\n", sqlda->sqlvar[i].sqlname.data, *(int *)sqlda->sqlvar[i].sqldata);
38 : 24 : break;
39 : 20 : case ECPGt_long:
40 : 20 : printf("name sqlda descriptor: '%s' value %ld\n", sqlda->sqlvar[i].sqlname.data, *(long int *)sqlda->sqlvar[i].sqldata);
41 : 20 : break;
42 : 0 : case ECPGt_long_long:
43 : 0 : printf("name sqlda descriptor: '%s' value %lld\n",
44 : 0 : sqlda->sqlvar[i].sqlname.data, *(long long int *)sqlda->sqlvar[i].sqldata);
45 : 0 : break;
46 : 20 : case ECPGt_double:
47 : 20 : printf("name sqlda descriptor: '%s' value %f\n", sqlda->sqlvar[i].sqlname.data, *(double *)sqlda->sqlvar[i].sqldata);
48 : 20 : break;
49 : 20 : case ECPGt_numeric:
50 : : {
51 : : char *val;
52 : :
53 : 20 : val = PGTYPESnumeric_to_asc((numeric*)sqlda->sqlvar[i].sqldata, -1);
54 : 20 : printf("name sqlda descriptor: '%s' value NUMERIC '%s'\n", sqlda->sqlvar[i].sqlname.data, val);
55 : 20 : PGTYPESchar_free(val);
56 : 20 : break;
57 : : }
58 : : }
59 : : }
60 : : }
61 : :
62 : : int
63 : 2 : main (void)
64 : : {
65 : : exec sql begin declare section;
66 : 2 : char *stmt1 = "SELECT * FROM t1";
67 : 2 : char *stmt2 = "SELECT * FROM t1 WHERE id = ?";
68 : : int rec;
69 : : int id;
70 : : exec sql end declare section;
71 : :
72 : : char msg[128];
73 : :
74 : 2 : ECPGdebug(1, stderr);
75 : :
76 : 2 : strcpy(msg, "connect");
77 : 2 : exec sql connect to REGRESSDB1 as regress1;
78 [ - + ]: 2 :
79 : 2 : strcpy(msg, "set");
80 : 2 : exec sql set datestyle to iso;
81 [ - + ]: 2 :
82 : 2 : strcpy(msg, "create");
83 : 2 : exec sql create table t1(
84 : : id integer,
85 : : t text,
86 : : d1 numeric,
87 : : d2 float8,
88 : : c char(10),
89 : : big bigint
90 : : );
91 [ - + ]: 2 :
92 : 2 : strcpy(msg, "insert");
93 : 2 : exec sql insert into t1 values
94 : : (1, 'a', 1.0, 1, 'a',1111111111111111111),
95 : : (2, null, null, null, null,null),
96 : : (3, 'c', 0.0, 3, 'c',3333333333333333333),
97 : : (4, 'd', 'NaN', 4, 'd',4444444444444444444),
98 : : (5, 'e', 0.001234, 5, 'e',5555555555555555555);
99 [ - + ]: 2 :
100 : 2 : strcpy(msg, "commit");
101 : 2 : exec sql commit;
102 [ - + ]: 2 :
103 : : /* SQLDA test for getting all records from a table */
104 : :
105 : 2 : outp_sqlda = NULL;
106 : :
107 : 2 : strcpy(msg, "prepare");
108 : 2 : exec sql prepare st_id1 from :stmt1;
109 [ - + ]: 2 :
110 : 2 : strcpy(msg, "declare");
111 : : exec sql declare mycur1 cursor for st_id1;
112 : :
113 : 2 : strcpy(msg, "open");
114 : 2 : exec sql open mycur1;
115 [ - + ]: 2 :
116 : : exec sql whenever not found do break;
117 : :
118 : 2 : rec = 0;
119 : : while (1)
120 : : {
121 : 12 : strcpy(msg, "fetch");
122 : 12 : exec sql fetch 1 from mycur1 into descriptor outp_sqlda;
123 [ + + - + ]: 12 :
124 : 10 : printf("FETCH RECORD %d\n", ++rec);
125 : 10 : dump_sqlda(outp_sqlda);
126 : : }
127 : :
128 : : exec sql whenever not found continue;
129 : :
130 : 2 : strcpy(msg, "close");
131 : 2 : exec sql close mycur1;
132 [ - + ]: 2 :
133 : 2 : strcpy(msg, "deallocate");
134 : 2 : exec sql deallocate prepare st_id1;
135 [ - + ]: 2 :
136 : 2 : free(outp_sqlda);
137 : :
138 : : /* SQLDA test for getting ALL records into the sqlda list */
139 : :
140 : 2 : outp_sqlda = NULL;
141 : :
142 : 2 : strcpy(msg, "prepare");
143 : 2 : exec sql prepare st_id2 from :stmt1;
144 [ - + ]: 2 :
145 : 2 : strcpy(msg, "declare");
146 : : exec sql declare mycur2 cursor for st_id2;
147 : :
148 : 2 : strcpy(msg, "open");
149 : 2 : exec sql open mycur2;
150 [ - + ]: 2 :
151 : 2 : strcpy(msg, "fetch");
152 : 2 : exec sql fetch all from mycur2 into descriptor outp_sqlda;
153 [ - + ]: 2 :
154 : 2 : outp_sqlda1 = outp_sqlda;
155 : 2 : rec = 0;
156 [ + + ]: 12 : while (outp_sqlda1)
157 : : {
158 : : sqlda_t *ptr;
159 : 10 : printf("FETCH RECORD %d\n", ++rec);
160 : 10 : dump_sqlda(outp_sqlda1);
161 : :
162 : 10 : ptr = outp_sqlda1;
163 : 10 : outp_sqlda1 = outp_sqlda1->desc_next;
164 : 10 : free(ptr);
165 : : }
166 : :
167 : 2 : strcpy(msg, "close");
168 : 2 : exec sql close mycur2;
169 [ - + ]: 2 :
170 : 2 : strcpy(msg, "deallocate");
171 : 2 : exec sql deallocate prepare st_id2;
172 [ - + ]: 2 :
173 : : /* SQLDA test for getting one record using an input descriptor */
174 : :
175 : : /*
176 : : * Input sqlda has to be built manually
177 : : * sqlda_t contains 1 sqlvar_t structure already.
178 : : */
179 : 2 : inp_sqlda = (sqlda_t *)malloc(sizeof(sqlda_t));
180 : 2 : memset(inp_sqlda, 0, sizeof(sqlda_t));
181 : 2 : inp_sqlda->sqln = 1;
182 : :
183 : 2 : inp_sqlda->sqlvar[0].sqltype = ECPGt_int;
184 : 2 : inp_sqlda->sqlvar[0].sqldata = (char *)&id;
185 : :
186 : 2 : printf("EXECUTE RECORD 4\n");
187 : :
188 : 2 : id = 4;
189 : :
190 : 2 : outp_sqlda = NULL;
191 : :
192 : 2 : strcpy(msg, "prepare");
193 : 2 : exec sql prepare st_id3 FROM :stmt2;
194 [ - + ]: 2 :
195 : 2 : strcpy(msg, "execute");
196 : 2 : exec sql execute st_id3 using descriptor inp_sqlda into descriptor outp_sqlda;
197 [ - + ]: 2 :
198 : 2 : dump_sqlda(outp_sqlda);
199 : :
200 : 2 : strcpy(msg, "deallocate");
201 : 2 : exec sql deallocate prepare st_id3;
202 [ - + ]: 2 :
203 : 2 : free(inp_sqlda);
204 : 2 : free(outp_sqlda);
205 : :
206 : : /* SQLDA test for getting one record using an input descriptor
207 : : * on a named connection
208 : : */
209 : :
210 : 2 : exec sql connect to REGRESSDB1 as con2;
211 [ - + ]: 2 :
212 : : /*
213 : : * Input sqlda has to be built manually
214 : : * sqlda_t contains 1 sqlvar_t structure already.
215 : : */
216 : 2 : inp_sqlda = (sqlda_t *)malloc(sizeof(sqlda_t));
217 : 2 : memset(inp_sqlda, 0, sizeof(sqlda_t));
218 : 2 : inp_sqlda->sqln = 1;
219 : :
220 : 2 : inp_sqlda->sqlvar[0].sqltype = ECPGt_int;
221 : 2 : inp_sqlda->sqlvar[0].sqldata = (char *)&id;
222 : :
223 : 2 : printf("EXECUTE RECORD 4\n");
224 : :
225 : 2 : id = 4;
226 : :
227 : 2 : outp_sqlda = NULL;
228 : :
229 : 2 : strcpy(msg, "prepare");
230 : 2 : exec sql at con2 prepare st_id4 FROM :stmt2;
231 [ - + ]: 2 :
232 : 2 : strcpy(msg, "execute");
233 : 2 : exec sql at con2 execute st_id4 using descriptor inp_sqlda into descriptor outp_sqlda;
234 [ - + ]: 2 :
235 : 2 : dump_sqlda(outp_sqlda);
236 : :
237 : 2 : strcpy(msg, "commit");
238 : 2 : exec sql at con2 commit;
239 [ - + ]: 2 :
240 : 2 : strcpy(msg, "deallocate");
241 : 2 : exec sql deallocate prepare st_id4;
242 [ - + ]: 2 :
243 : 2 : free(inp_sqlda);
244 : 2 : free(outp_sqlda);
245 : :
246 : 2 : strcpy(msg, "disconnect");
247 : 2 : exec sql disconnect con2;
248 [ - + ]: 2 :
249 : : /* End test */
250 : :
251 : 2 : strcpy(msg, "drop");
252 : 2 : exec sql drop table t1;
253 [ - + ]: 2 :
254 : 2 : strcpy(msg, "commit");
255 : 2 : exec sql commit;
256 [ - + ]: 2 :
257 : 2 : strcpy(msg, "disconnect");
258 : 2 : exec sql disconnect;
259 [ - + ]: 2 :
260 : 2 : return 0;
261 : : }
|
