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