1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
|
include "cqdef.h"
include "cq.h"
# CQ_SETCAT -- Set the current catalog by name.
int procedure cq_setcat (cq, name)
pointer cq #I the catalog descriptor
char name[ARB] #I the catalog name
int i, catno
int cq_ccrquery()
bool streq()
begin
catno = 0
do i = 1, CQ_NRECS(cq) {
if (streq (name, CQ_NAME(cq, i)))
catno = i
}
if (catno == 0)
return (0)
# Free the previous current catalog descriptor if any.
call cq_ccfree (cq)
# Allocate the new descriptor.
call cq_ccinit (cq, catno)
# Get the new catalog parameters.
if (cq_ccrquery (cq) == ERR) {
call cq_ccfree (cq)
return (0)
}
return (catno)
end
# CQ_SETCATN -- Set the current catalog by number.
int procedure cq_setcatn (cq, catno)
pointer cq #I the catalog descriptor
int catno #I the catalog number
int cq_ccrquery()
begin
if (catno < 1 || catno > CQ_NRECS(cq))
return (0)
# Free the previous current catalog descriptor if any.
call cq_ccfree (cq)
# Allocate the new descriptor.
call cq_ccinit (cq, catno)
# Get the new catalog parameters.
if (cq_ccrquery (cq) == ERR) {
call cq_ccfree (cq)
return (0)
}
return (catno)
end
# CQ_CCINIT -- Initialize the current catalog descriptor.
procedure cq_ccinit (cq, catno)
pointer cq #I the catalog database descriptor
int catno #I the current catalog number
pointer cc
begin
if (catno < 1 || catno > CQ_NRECS(cq))
return
CQ_CATNO(cq) = catno
call strcpy (CQ_NAME(cq, catno), CQ_CATNAME(cq), SZ_FNAME)
call calloc (CQ_CAT(cq), CQ_LEN_CC, TY_STRUCT)
cc = CQ_CAT(cq)
CQ_NQPARS(cc) = 0
CQ_HFMT(cc) = CQ_HNONE
call calloc (CQ_PQPNAMES(cc), SZ_LINE, TY_CHAR)
call calloc (CQ_PQPDVALUES(cc), SZ_LINE, TY_CHAR)
call calloc (CQ_PQPVALUES(cc), SZ_LINE, TY_CHAR)
call calloc (CQ_PQPUNITS(cc), SZ_LINE, TY_CHAR)
call calloc (CQ_PQPFMTS(cc), SZ_LINE, TY_CHAR)
Memc[CQ_PQPNAMES(cc)] = EOS
Memc[CQ_PQPDVALUES(cc)] = EOS
Memc[CQ_PQPVALUES(cc)] = EOS
Memc[CQ_PQPUNITS(cc)] = EOS
Memc[CQ_PQPFMTS(cc)] = EOS
CQ_ADDRESS(cc) = EOS
CQ_QUERY(cc) = EOS
end
# CQ_CCRQUERY -- Read in the query related parameters from the catalog
# database. May need to encode the field names at some point.
int procedure cq_ccrquery (cq)
pointer cq #I the catalog database descriptor
pointer cc, sp, str
int i, catno, nqpars, npars, sz1, sz2, sz3, sz4, sz5
int op1, op2, op3, op4, op5
int cq_dgeti(), cq_dscan(), nscan(), gstrcpy(), strdic()
errchk cq_dgwrd(), cq_dgeti(), cq_dscan()
begin
# If the current catalog is not defined then return.
if (CQ_CAT(cq) == NULL)
return (ERR)
if (CQ_CATNO(cq) < 1 || CQ_CATNO(cq) > CQ_NRECS(cq))
return (ERR)
cc = CQ_CAT(cq)
catno = CQ_CATNO(cq)
call smark (sp)
call salloc (str, 4 * (SZ_LINE + 1), TY_CHAR)
iferr {
# Get the catalog address and query string.
call cq_dgwrd (cq, catno, "address", CQ_ADDRESS(cc), SZ_LINE)
call cq_dgstr (cq, catno, "query", CQ_QUERY(cc), SZ_LINE)
# Get the protocol.
call cq_dgwrd (cq, catno, "protocol", Memc[str], SZ_LINE)
CQ_HFMT(cc) = strdic (Memc[str], Memc[str], SZ_LINE,
CQ_HFMTSTR)
if (CQ_HFMT(cc) <= 0)
CQ_HFMT(cc) = CQ_HNONE
# Determine the number of query parameters and position the
# file to the correct place.
nqpars = cq_dgeti (cq, catno, "nquery")
} then {
# Reinitialize and return.
CQ_ADDRESS(cc) = EOS
CQ_QUERY(cc) = EOS
call sfree (sp)
return (ERR)
}
# Open the query parameter string dictionaries.
sz1 = SZ_LINE; op1 = 2
sz2 = SZ_LINE; op2 = 2
sz3 = SZ_LINE; op3 = 2
sz4 = SZ_LINE; op4 = 2
sz5 = SZ_LINE; op5 = 2
call strcpy ("|", Memc[CQ_PQPNAMES(cc)], sz1)
call strcpy ("|", Memc[CQ_PQPDVALUES(cc)], sz2)
call strcpy ("|", Memc[CQ_PQPVALUES(cc)], sz3)
call strcpy ("|", Memc[CQ_PQPUNITS(cc)], sz4)
call strcpy ("|", Memc[CQ_PQPFMTS(cc)], sz5)
# Scan the query parameter list.
npars = 0
for (i = 1; i <= nqpars; i = i + 1) {
if (cq_dscan (cq) == EOF)
break
# Get the query parameter fields.
call gargwrd (Memc[str], SZ_LINE)
call gargwrd (Memc[str+SZ_LINE+1], SZ_LINE)
call gargwrd (Memc[str+2*(SZ_LINE+1)], SZ_LINE)
call gargwrd (Memc[str+3*(SZ_LINE+1)], SZ_LINE)
if (nscan() != 4)
break
# Get the query parameter name.
if ((sz1 - op1 + 1) < (CQ_SZ_QPNAME + 1)) {
sz1 = sz1 + SZ_LINE
call realloc (CQ_PQPNAMES(cc), sz1, TY_CHAR)
}
op1 = op1 + gstrcpy (Memc[str], Memc[CQ_PQPNAMES(cc)+op1-1],
sz1 - op1 + 1)
op1 = op1 + gstrcpy ("|", Memc[CQ_PQPNAMES(cc)+op1-1],
sz1 - op1 + 1)
# Get the default query parameter value and initialize the
# user query parameter string.
if ((sz2 - op2 + 1) < (CQ_SZ_QPVALUE + 1)) {
sz2 = sz2 + SZ_LINE
sz3 = sz3 + SZ_LINE
call realloc (CQ_PQPDVALUES(cc), sz2, TY_CHAR)
call realloc (CQ_PQPVALUES(cc), sz3, TY_CHAR)
}
op2 = op2 + gstrcpy (Memc[str+SZ_LINE+1],
Memc[CQ_PQPDVALUES(cc)+op2-1], sz2 - op2 + 1)
op2 = op2 + gstrcpy ("|", Memc[CQ_PQPDVALUES(cc)+op2-1],
sz2 - op2 + 1)
op3 = op3 + gstrcpy (Memc[str+SZ_LINE+1],
Memc[CQ_PQPVALUES(cc)+op3-1], sz3 - op3 + 1)
op3 = op3 + gstrcpy ("|", Memc[CQ_PQPVALUES(cc)+op3-1],
sz3 - op3 + 1)
# Get the query parameter units.
if ((sz4 - op4 + 1) < (CQ_SZ_QPUNITS + 1)) {
sz4 = sz4 + SZ_LINE
call realloc (CQ_PQPUNITS(cc), sz4, TY_CHAR)
}
op4 = op4 + gstrcpy (Memc[str+2*(SZ_LINE+1)],
Memc[CQ_PQPUNITS(cc)+op4-1], sz4 - op4 + 1)
op4 = op4 + gstrcpy ("|", Memc[CQ_PQPUNITS(cc)+op4-1],
sz4 - op4 + 1)
# Get the query parameter formats.
if ((sz5 - op5 + 1) < (CQ_SZ_QPFMTS + 1)) {
sz5 = sz5 + SZ_LINE
call realloc (CQ_PQPFMTS(cc), sz5, TY_CHAR)
}
op5 = op5 + gstrcpy (Memc[str+3*(SZ_LINE+1)],
Memc[CQ_PQPFMTS(cc)+op5-1], sz5 - op5 + 1)
op5 = op5 + gstrcpy ("|", Memc[CQ_PQPFMTS(cc)+op5-1],
sz5 - op5 + 1)
npars = npars + 1
}
# Return the appropriate status.
call sfree (sp)
if (npars != nqpars) {
CQ_NQPARS(cc) = 0
call realloc (CQ_PQPNAMES(cc), SZ_LINE, TY_CHAR)
call realloc (CQ_PQPDVALUES(cc), SZ_LINE, TY_CHAR)
call realloc (CQ_PQPVALUES(cc), SZ_LINE, TY_CHAR)
call realloc (CQ_PQPUNITS(cc), SZ_LINE, TY_CHAR)
call realloc (CQ_PQPFMTS(cc), SZ_LINE, TY_CHAR)
Memc[CQ_PQPNAMES(cc)] = EOS
Memc[CQ_PQPDVALUES(cc)] = EOS
Memc[CQ_PQPVALUES(cc)] = EOS
Memc[CQ_PQPUNITS(cc)] = EOS
Memc[CQ_PQPFMTS(cc)] = EOS
CQ_ADDRESS(cc) = EOS
CQ_QUERY(cc) = EOS
return (ERR)
} else {
CQ_NQPARS(cc) = npars
call realloc (CQ_PQPNAMES(cc), op1, TY_CHAR)
call realloc (CQ_PQPDVALUES(cc), op2, TY_CHAR)
call realloc (CQ_PQPVALUES(cc), op3, TY_CHAR)
call realloc (CQ_PQPUNITS(cc), op4, TY_CHAR)
call realloc (CQ_PQPFMTS(cc), op5, TY_CHAR)
Memc[CQ_PQPNAMES(cc)+op1] = EOS
Memc[CQ_PQPDVALUES(cc)+op2] = EOS
Memc[CQ_PQPVALUES(cc)+op3] = EOS
Memc[CQ_PQPUNITS(cc)+op4] = EOS
Memc[CQ_PQPFMTS(cc)+op5] = EOS
return (OK)
}
end
# CQ_CCFREE - Free the current catalog descriptor
procedure cq_ccfree (cq)
pointer cq #I the catalog database descriptor
pointer cc
begin
CQ_CATNAME(cq) = EOS
CQ_CATNO(cq) = 0
if (CQ_CAT(cq) != NULL) {
cc = CQ_CAT(cq)
call mfree (CQ_PQPNAMES(cc), TY_CHAR)
call mfree (CQ_PQPDVALUES(cc), TY_CHAR)
call mfree (CQ_PQPVALUES(cc), TY_CHAR)
call mfree (CQ_PQPUNITS(cc), TY_CHAR)
call mfree (CQ_PQPFMTS(cc), TY_CHAR)
call mfree (CQ_CAT(cq), TY_STRUCT)
}
CQ_CAT(cq) = NULL
end
|
