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
|
/* File: descriptor.h
*
* Description: This file contains defines and declarations that are related to
* the entire driver.
*
* Comments: See "readme.txt" for copyright and license information.
*/
#ifndef __DESCRIPTOR_H__
#define __DESCRIPTOR_H__
#include "psqlodbc.h"
typedef struct InheritanceClass
{
UInt4 allocated;
UInt4 count;
OID cur_tableoid;
pgNAME cur_fullTable;
struct {
OID tableoid;
pgNAME fullTable;
} inf[1];
} InheritanceClass;
enum {
TI_UPDATABLE = 1L
,TI_HASOIDS_CHECKED = (1L << 1)
,TI_HASOIDS = (1L << 2)
,TI_COLATTRIBUTE = (1L << 3)
,TI_HASSUBCLASS = (1L << 4)
};
typedef struct
{
OID table_oid;
COL_INFO *col_info; /* cached SQLColumns info for this table */
pgNAME schema_name;
pgNAME table_name;
pgNAME table_alias;
pgNAME bestitem;
pgNAME bestqual;
UInt4 flags;
InheritanceClass *ih;
} TABLE_INFO;
#define TI_set_updatable(ti) (ti->flags |= TI_UPDATABLE)
#define TI_is_updatable(ti) (0 != (ti->flags & TI_UPDATABLE))
#define TI_no_updatable(ti) (ti->flags &= (~TI_UPDATABLE))
#define TI_set_hasoids_checked(ti) (ti->flags |= TI_HASOIDS_CHECKED)
#define TI_checked_hasoids(ti) (0 != (ti->flags & TI_HASOIDS))
#define TI_set_hasoids(ti) (ti->flags |= TI_HASOIDS)
#define TI_has_oids(ti) (0 != (ti->flags & TI_HASOIDS))
#define TI_set_has_no_oids(ti) (ti->flags &= (~TI_HASOIDS))
#define TI_set_hassubclass(ti) (ti->flags |= TI_HASSUBCLASS)
#define TI_has_subclass(ti) (0 != (ti->flags & TI_HASSUBCLASS))
#define TI_set_has_no_subclass(ti) (ti->flags &= (~TI_HASSUBCLASS))
void TI_Constructor(TABLE_INFO *, const ConnectionClass *);
void TI_Destructor(TABLE_INFO **, int);
void TI_ClearObject(TABLE_INFO *ti);
void TI_Create_IH(TABLE_INFO *ti);
void TI_Destroy_IH(TABLE_INFO *ti);
const pgNAME TI_From_IH(TABLE_INFO *ti, OID tableoid);
const pgNAME TI_Ins_IH(TABLE_INFO *ti, OID tableoid, const char *fullName);
enum {
FIELD_INITIALIZED = 0
,FIELD_PARSING = 1L
,FIELD_TEMP_SET = (1L << 1)
,FIELD_COL_ATTRIBUTE = (1L << 2)
,FIELD_PARSED_OK = (1L << 3)
,FIELD_PARSED_INCOMPLETE = (1L << 4)
};
typedef struct
{
char flag;
char updatable;
Int2 attnum;
pgNAME schema_name;
TABLE_INFO *ti; /* to resolve explicit table names */
pgNAME column_name;
pgNAME column_alias;
char nullable;
char auto_increment;
char func;
char columnkey;
int column_size; /* precision in 2.x */
int decimal_digits; /* scale in 2.x */
int display_size;
SQLLEN length;
OID columntype;
OID basetype; /* may be the basetype when the column type is a domain */
int typmod;
char expr;
char quote;
char dquote;
char numeric;
pgNAME before_dot;
} FIELD_INFO;
Int4 FI_precision(const FIELD_INFO *);
Int4 FI_scale(const FIELD_INFO *);
void FI_Constructor(FIELD_INFO *, BOOL reuse);
void FI_Destructor(FIELD_INFO **, int, BOOL freeFI);
#define FI_is_applicable(fi) (NULL != fi && (fi->flag & (FIELD_PARSED_OK | FIELD_COL_ATTRIBUTE)) != 0)
#define FI_type(fi) (0 == (fi)->basetype ? (fi)->columntype : (fi)->basetype)
typedef struct DescriptorHeader_
{
ConnectionClass *conn_conn;
char embedded;
char type_defined;
UInt4 desc_type;
UInt4 error_row; /* 1-based row */
UInt4 error_index; /* 1-based index */
Int4 __error_number;
char *__error_message;
PG_ErrorInfo *pgerror;
} DescriptorHeader;
/*
* ARD and APD are(must be) of the same format
*/
struct ARDFields_
{
SQLLEN size_of_rowset; /* for ODBC3 fetch operation */
SQLUINTEGER bind_size; /* size of each structure if using
* Row-wise Binding */
SQLUSMALLINT *row_operation_ptr;
SQLULEN *row_offset_ptr;
BindInfoClass *bookmark;
BindInfoClass *bindings;
SQLSMALLINT allocated;
SQLLEN size_of_rowset_odbc2; /* for SQLExtendedFetch */
};
/*
* APD must be of the same format as ARD
*/
struct APDFields_
{
SQLLEN paramset_size; /* really an SQLINTEGER type */
SQLUINTEGER param_bind_type; /* size of each structure if using
* Row-wise Parameter Binding */
SQLUSMALLINT *param_operation_ptr;
SQLULEN *param_offset_ptr;
ParameterInfoClass *bookmark; /* dummy item to fit APD to ARD */
ParameterInfoClass *parameters;
SQLSMALLINT allocated;
SQLLEN paramset_size_dummy; /* dummy item to fit APD to ARD */
};
struct IRDFields_
{
StatementClass *stmt;
SQLULEN *rowsFetched;
SQLUSMALLINT *rowStatusArray;
UInt4 nfields;
SQLSMALLINT allocated;
FIELD_INFO **fi;
};
struct IPDFields_
{
SQLULEN *param_processed_ptr;
SQLUSMALLINT *param_status_ptr;
SQLSMALLINT allocated;
ParameterImplClass *parameters;
};
/***
typedef struct
{
DescriptorHeader deschd;
ARDFields ardopts;
} ARDClass;
typedef struct
{
DescriptorHeader deschd;
APDFields apdopts;
} APDClass;
typedef struct
{
DescriptorHeader deschd;
IRDFields irdopts;
} IRDClass;
typedef struct
{
DescriptorHeader deschd;
IPDFields ipdopts;
} IPDClass;
***/
typedef struct
{
DescriptorHeader deschd;
union {
ARDFields ardf;
APDFields apdf;
IRDFields irdf;
IPDFields ipdf;
};
} DescriptorClass;
#define DC_get_conn(a) ((a)->deschd.conn_conn)
#define DC_get_desc_type(a) ((a)->deschd.desc_type)
#define DC_get_embedded(a) ((a)->deschd.embedded)
void InitializeEmbeddedDescriptor(DescriptorClass *, StatementClass *stmt,
UInt4 desc_type);
void DC_Destructor(DescriptorClass *desc);
void InitializeARDFields(ARDFields *self);
void InitializeAPDFields(APDFields *self);
/* void InitializeIRDFields(IRDFields *self);
void InitializeIPDFiedls(IPDFields *self); */
BindInfoClass *ARD_AllocBookmark(ARDFields *self);
void ARD_unbind_cols(ARDFields *self, BOOL freeall);
void APD_free_params(APDFields *self, char option);
void IPD_free_params(IPDFields *self, char option);
BOOL getCOLIfromTI(const char *, ConnectionClass *, StatementClass *, const OID, TABLE_INFO **);
RETCODE DC_set_stmt(DescriptorClass *desc, StatementClass *stmt);
void DC_clear_error(DescriptorClass *desc);
void DC_set_error(DescriptorClass *desc, int errornumber, const char * errormsg);
void DC_set_errormsg(DescriptorClass *desc, const char * errormsg);
PG_ErrorInfo *DC_get_error(DescriptorClass *self);
int DC_get_errornumber(const DescriptorClass *self);
const char *DC_get_errormsg(const DescriptorClass *self);
void DC_log_error(const char *func, const char *desc, const DescriptorClass *self);
/* Error numbers about descriptor handle */
enum {
LOWEST_DESC_ERROR = -2
/* minus means warning/notice message */
,DESC_ERROR_IN_ROW = -2
,DESC_OPTION_VALUE_CHANGED = -1
,DESC_OK = 0
,DESC_EXEC_ERROR
,DESC_STATUS_ERROR
,DESC_SEQUENCE_ERROR
,DESC_NO_MEMORY_ERROR
,DESC_COLNUM_ERROR
,DESC_NO_STMTSTRING
,DESC_ERROR_TAKEN_FROM_BACKEND
,DESC_INTERNAL_ERROR
,DESC_STILL_EXECUTING
,DESC_NOT_IMPLEMENTED_ERROR
,DESC_BAD_PARAMETER_NUMBER_ERROR
,DESC_OPTION_OUT_OF_RANGE_ERROR
,DESC_INVALID_COLUMN_NUMBER_ERROR
,DESC_RESTRICTED_DATA_TYPE_ERROR
,DESC_INVALID_CURSOR_STATE_ERROR
,DESC_CREATE_TABLE_ERROR
,DESC_NO_CURSOR_NAME
,DESC_INVALID_CURSOR_NAME
,DESC_INVALID_ARGUMENT_NO
,DESC_ROW_OUT_OF_RANGE
,DESC_OPERATION_CANCELLED
,DESC_INVALID_CURSOR_POSITION
,DESC_VALUE_OUT_OF_RANGE
,DESC_OPERATION_INVALID
,DESC_PROGRAM_TYPE_OUT_OF_RANGE
,DESC_BAD_ERROR
,DESC_INVALID_OPTION_IDENTIFIER
,DESC_RETURN_NULL_WITHOUT_INDICATOR
,DESC_INVALID_DESCRIPTOR_IDENTIFIER
,DESC_OPTION_NOT_FOR_THE_DRIVER
,DESC_FETCH_OUT_OF_RANGE
,DESC_COUNT_FIELD_INCORRECT
,DESC_STATEMENT_NOT_PREPARED
,DESC_STRING_DATA_TRUNCATED
};
#endif /* __DESCRIPTOR_H__ */
|
