Line data Source code
1 : /*
2 : * Purpose: Test retrieving compute rows
3 : * Functions: dbaltbind dbaltcolid dbaltop dbalttype dbnumalts
4 : */
5 :
6 : #include "common.h"
7 : #include <assert.h>
8 :
9 : static int got_error = 0;
10 : static int compute_supported = 1;
11 :
12 : static int
13 0 : compute_msg_handler(DBPROCESS * dbproc, DBINT msgno, int state, int severity, char *text, char *server, char *proc, int line)
14 : {
15 0 : if (strstr(text, "compute"))
16 0 : compute_supported = 0;
17 : else
18 0 : got_error = 1;
19 0 : return 0;
20 : }
21 :
22 : int
23 8 : main(int argc, char *argv[])
24 : {
25 : LOGINREC *login;
26 : DBPROCESS *dbproc;
27 : int i;
28 : DBINT rowint;
29 : DBCHAR rowchar[2];
30 : DBCHAR rowdate[32];
31 :
32 : DBINT rowtype;
33 : DBINT computeint;
34 : DBCHAR computedate[32];
35 :
36 8 : set_malloc_options();
37 8 : read_login_info(argc, argv);
38 :
39 8 : printf("Starting %s\n", argv[0]);
40 :
41 : /* Fortify_EnterScope(); */
42 8 : dbinit();
43 :
44 8 : dberrhandle(syb_err_handler);
45 8 : dbmsghandle(syb_msg_handler);
46 :
47 8 : printf("About to logon\n");
48 :
49 8 : login = dblogin();
50 8 : DBSETLPWD(login, PASSWORD);
51 8 : DBSETLUSER(login, USER);
52 8 : DBSETLAPP(login, "t0023");
53 :
54 8 : printf("About to open\n");
55 :
56 8 : dbproc = dbopen(login, SERVER);
57 8 : if (strlen(DATABASE))
58 8 : dbuse(dbproc, DATABASE);
59 8 : dbloginfree(login);
60 :
61 8 : sql_cmd(dbproc);
62 8 : dbmsghandle(compute_msg_handler);
63 8 : i = dbsqlexec(dbproc);
64 8 : dbmsghandle(syb_msg_handler);
65 8 : if (!compute_supported) {
66 0 : printf("compute clause not supported, skip test!\n");
67 0 : dbexit();
68 0 : return 0;
69 : }
70 8 : if (got_error) {
71 0 : fprintf(stderr, "Unexpected error from query.\n");
72 0 : exit(1);
73 : }
74 16 : while ((i=dbresults(dbproc)) != NO_MORE_RESULTS) {
75 16 : while (dbnextrow(dbproc) != NO_MORE_ROWS)
76 8 : continue;
77 : }
78 :
79 8 : printf("creating table\n");
80 8 : sql_cmd(dbproc);
81 8 : dbsqlexec(dbproc);
82 8 : while (dbresults(dbproc) == SUCCEED) {
83 : /* nop */
84 : }
85 :
86 8 : printf("insert\n");
87 :
88 8 : sql_cmd(dbproc);
89 8 : dbsqlexec(dbproc);
90 8 : while (dbresults(dbproc) == SUCCEED) {
91 : /* nop */
92 : }
93 8 : sql_cmd(dbproc);
94 8 : dbsqlexec(dbproc);
95 8 : while (dbresults(dbproc) == SUCCEED) {
96 : /* nop */
97 : }
98 8 : sql_cmd(dbproc);
99 8 : dbsqlexec(dbproc);
100 8 : while (dbresults(dbproc) == SUCCEED) {
101 : /* nop */
102 : }
103 8 : sql_cmd(dbproc);
104 8 : dbsqlexec(dbproc);
105 8 : while (dbresults(dbproc) == SUCCEED) {
106 : /* nop */
107 : }
108 8 : sql_cmd(dbproc);
109 8 : dbsqlexec(dbproc);
110 8 : while (dbresults(dbproc) == SUCCEED) {
111 : /* nop */
112 : }
113 :
114 8 : printf("select\n");
115 8 : sql_cmd(dbproc);
116 8 : dbsqlexec(dbproc);
117 :
118 8 : if (dbresults(dbproc) != SUCCEED) {
119 0 : fprintf(stderr, "Was expecting a result set.\n");
120 0 : exit(1);
121 : }
122 :
123 24 : for (i = 1; i <= dbnumcols(dbproc); i++)
124 24 : printf("col %d is %s\n", i, dbcolname(dbproc, i));
125 :
126 8 : printf("binding row columns\n");
127 8 : if (SUCCEED != dbbind(dbproc, 1, INTBIND, 0, (BYTE *) & rowint)) {
128 0 : fprintf(stderr, "Had problem with bind col1\n");
129 0 : abort();
130 : }
131 8 : if (SUCCEED != dbbind(dbproc, 2, STRINGBIND, 0, (BYTE *) rowchar)) {
132 0 : fprintf(stderr, "Had problem with bind col2\n");
133 0 : abort();
134 : }
135 8 : if (SUCCEED != dbbind(dbproc, 3, STRINGBIND, 0, (BYTE *) rowdate)) {
136 0 : fprintf(stderr, "Had problem with bind col3\n");
137 0 : abort();
138 : }
139 :
140 8 : printf("testing compute clause 1\n");
141 :
142 8 : if (dbnumalts(dbproc, 1) != 1) {
143 0 : fprintf(stderr, "Had problem with dbnumalts 1\n");
144 0 : abort();
145 : }
146 :
147 8 : if (dbalttype(dbproc, 1, 1) != SYBINT4) {
148 0 : fprintf(stderr, "Had problem with dbalttype 1, 1\n");
149 0 : abort();
150 : }
151 :
152 8 : if (dbaltcolid(dbproc, 1, 1) != 1) {
153 0 : fprintf(stderr, "Had problem with dbaltcolid 1, 1\n");
154 0 : abort();
155 : }
156 :
157 8 : if (dbaltop(dbproc, 1, 1) != SYBAOPSUM) {
158 0 : fprintf(stderr, "Had problem with dbaltop 1, 1\n");
159 0 : abort();
160 : }
161 :
162 8 : if (SUCCEED != dbaltbind(dbproc, 1, 1, INTBIND, 0, (BYTE *) & computeint)) {
163 0 : fprintf(stderr, "Had problem with dbaltbind 1, 1\n");
164 0 : abort();
165 : }
166 :
167 :
168 8 : printf("testing compute clause 2\n");
169 :
170 8 : if (dbnumalts(dbproc, 2) != 1) {
171 0 : fprintf(stderr, "Had problem with dbnumalts 2\n");
172 0 : abort();
173 : }
174 :
175 8 : if (dbalttype(dbproc, 2, 1) != SYBDATETIME) {
176 0 : fprintf(stderr, "Had problem with dbalttype 2, 1\n");
177 0 : abort();
178 : }
179 :
180 8 : if (dbaltcolid(dbproc, 2, 1) != 3) {
181 0 : fprintf(stderr, "Had problem with dbaltcolid 2, 1\n");
182 0 : abort();
183 : }
184 :
185 8 : if (dbaltop(dbproc, 2, 1) != SYBAOPMAX) {
186 0 : fprintf(stderr, "Had problem with dbaltop 2, 1\n");
187 0 : abort();
188 : }
189 :
190 8 : if (SUCCEED != dbaltbind(dbproc, 2, 1, STRINGBIND, -1, (BYTE *) computedate)) {
191 0 : fprintf(stderr, "Had problem with dbaltbind 2, 1\n");
192 0 : abort();
193 : }
194 :
195 72 : while ((rowtype = dbnextrow(dbproc)) != NO_MORE_ROWS) {
196 :
197 64 : if (rowtype == REG_ROW) {
198 40 : printf("gotten a regular row\n");
199 : }
200 :
201 64 : if (rowtype == 1) {
202 16 : printf("gotten a compute row for clause 1\n");
203 16 : printf("value of sum(col1) = %d\n", computeint);
204 : }
205 :
206 64 : if (rowtype == 2) {
207 8 : printf("gotten a compute row for clause 2\n");
208 8 : printf("value of max(col3) = %s\n", computedate);
209 :
210 : }
211 : }
212 :
213 8 : dbexit();
214 :
215 8 : printf("%s %s\n", __FILE__, "OK");
216 8 : return 0;
217 : }
|
