00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035 #include "ocilib_internal.h"
00036
00037
00038
00039
00040
00041
00042
00043
00044
00045 OCI_Long * OCI_LongInit
00046 (
00047 OCI_Statement *stmt,
00048 OCI_Long **plg,
00049 OCI_Define *def,
00050 unsigned int type
00051 )
00052 {
00053 boolean res = TRUE;
00054 OCI_Long *lg = NULL;
00055
00056 OCI_CHECK(plg == NULL, NULL);
00057
00058 if (*plg == NULL)
00059 *plg = (OCI_Long *) OCI_MemAlloc(OCI_IPC_LONG, sizeof(*lg),
00060 (size_t) 1, TRUE);
00061
00062 if (*plg != NULL)
00063 {
00064 lg = *plg;
00065
00066 lg->size = 0;
00067 lg->stmt = stmt;
00068 lg->def = def;
00069 lg->type = type;
00070 lg->offset = 0;
00071
00072 if (def != NULL)
00073 lg->hstate = OCI_OBJECT_FETCHED_CLEAN;
00074 else
00075 lg->hstate = OCI_OBJECT_ALLOCATED;
00076 }
00077 else
00078 res = FALSE;
00079
00080 OCI_RESULT(res);
00081
00082 return lg;
00083 }
00084
00085
00086
00087
00088
00089
00090
00091
00092
00093 OCI_Long * OCI_API OCI_LongCreate
00094 (
00095 OCI_Statement *stmt,
00096 unsigned int type
00097 )
00098 {
00099 OCI_Long *lg = NULL;
00100
00101 OCI_CHECK_INITIALIZED(NULL);
00102
00103 OCI_CHECK_PTR(OCI_IPC_STATEMENT, stmt, NULL);
00104
00105 lg = OCI_LongInit(stmt, &lg, NULL, type);
00106
00107 OCI_RESULT(lg != NULL);
00108
00109 return lg;
00110 }
00111
00112
00113
00114
00115
00116 boolean OCI_API OCI_LongFree
00117 (
00118 OCI_Long *lg
00119 )
00120 {
00121 OCI_CHECK_PTR(OCI_IPC_LONG, lg, FALSE);
00122
00123 OCI_CHECK_OBJECT_FETCHED(lg, FALSE);
00124
00125 OCI_FREE(lg->buffer);
00126 OCI_FREE(lg);
00127
00128 OCI_RESULT(TRUE);
00129
00130 return TRUE;
00131 }
00132
00133
00134
00135
00136
00137 unsigned int OCI_API OCI_LongGetType
00138 (
00139 OCI_Long *lg
00140 )
00141 {
00142 OCI_CHECK_PTR(OCI_IPC_LONG, lg, OCI_UNKNOWN);
00143
00144 OCI_RESULT(TRUE);
00145
00146 return lg->type;
00147 }
00148
00149
00150
00151
00152
00153 unsigned int OCI_API OCI_LongRead
00154 (
00155 OCI_Long *lg,
00156 void *buffer,
00157 unsigned int len
00158 )
00159 {
00160 unsigned int size = len;
00161 unsigned int fact = 1;
00162
00163 OCI_CHECK_PTR(OCI_IPC_LONG, lg, 0);
00164 OCI_CHECK_PTR(OCI_IPC_VOID, buffer, 0);
00165
00166 OCI_CHECK_MIN(lg->stmt->con, lg->stmt, size, 1, 0);
00167
00168 OCI_CHECK(lg->offset >= lg->size, 0);
00169
00170
00171
00172
00173
00174 if (lg->type == OCI_CLONG)
00175 len *= (unsigned int) sizeof(odtext);
00176
00177
00178
00179 if ((size + lg->offset) > lg->size)
00180 {
00181 size = lg->size - lg->offset;
00182 }
00183
00184
00185
00186 memcpy(buffer, lg->buffer + (size_t) lg->offset*fact, (size_t) (size*fact));
00187
00188 lg->offset += size;
00189
00190 if (lg->type == OCI_CLONG)
00191 {
00192 ((dtext *) buffer)[size] = 0;
00193 size /= (unsigned int) sizeof(dtext);
00194 }
00195
00196 OCI_RESULT(TRUE);
00197
00198 return size;
00199 }
00200
00201
00202
00203
00204
00205 unsigned int OCI_API OCI_LongWrite
00206 (
00207 OCI_Long *lg,
00208 void *buffer,
00209 unsigned int len
00210 )
00211 {
00212 boolean res = TRUE;
00213 sword code = OCI_SUCCESS;
00214 void *obuf = NULL;
00215 void *handle = NULL;
00216 ub1 in_out = OCI_PARAM_IN;
00217 ub1 piece = OCI_ONE_PIECE;
00218 ub4 type = 0;
00219 ub4 iter = 0;
00220 ub4 dx = 0;
00221 ub4 count = len;
00222
00223 OCI_CHECK_PTR(OCI_IPC_VOID, buffer, 0);
00224 OCI_CHECK_PTR(OCI_IPC_LONG, lg, 0);
00225
00226 OCI_CHECK_MIN(lg->stmt->con, lg->stmt, len, 1, 0);
00227
00228 if (lg->type == OCI_CLONG)
00229 len *= (unsigned int) sizeof(dtext);
00230
00231 if (lg->type == OCI_CLONG)
00232 obuf = OCI_GetInputDataString(buffer, (int *) &len);
00233 else
00234 obuf = buffer;
00235
00236
00237
00238 OCI_CALL1
00239 (
00240 res, lg->stmt->con, lg->stmt,
00241
00242 OCIStmtGetPieceInfo(lg->stmt->stmt, lg->stmt->con->err, &handle,
00243 &type, &in_out, &iter, &dx, &piece)
00244 )
00245
00246
00247
00248 if (len > 0)
00249 piece = (ub1) ((lg->size > 0) ? OCI_NEXT_PIECE : OCI_FIRST_PIECE);
00250 else
00251 piece = (ub1) OCI_LAST_PIECE;
00252
00253
00254
00255 if ((lg->size + len) >= lg->stmt->long_size)
00256 {
00257 piece = OCI_LAST_PIECE;
00258 count = lg->stmt->long_size - lg->size;
00259 }
00260
00261
00262
00263 OCI_CALL1
00264 (
00265 res, lg->stmt->con, lg->stmt,
00266
00267 OCIStmtSetPieceInfo(handle, type, lg->stmt->con->err, (dvoid *) obuf,
00268 &count, piece, (dvoid *) NULL, (ub2 *) NULL)
00269 )
00270
00271
00272
00273 if (res == TRUE)
00274 {
00275 code = OCIStmtExecute(lg->stmt->con->cxt, lg->stmt->stmt,
00276 lg->stmt->con->err, (ub4) 1, (ub4) 0,
00277 (OCISnapshot *) NULL, (OCISnapshot *) NULL,
00278 (ub4) 0);
00279 }
00280
00281 if ((code != OCI_SUCCESS) && (code != OCI_NEED_DATA))
00282 {
00283 if (code == OCI_SUCCESS_WITH_INFO)
00284 {
00285 OCI_ExceptionOCI(lg->stmt->con->err, lg->stmt->con, lg->stmt, TRUE);
00286 }
00287 else
00288 {
00289 OCI_ExceptionOCI(lg->stmt->con->err, lg->stmt->con, lg->stmt, FALSE);
00290 res = FALSE;
00291 }
00292 }
00293
00294 if (lg->type == OCI_CLONG)
00295 OCI_ReleaseDataString(obuf);
00296
00297
00298
00299 if (res == TRUE)
00300 {
00301 lg->size += count;
00302
00303
00304
00305
00306 if (lg->type == OCI_CLONG)
00307 count /= (unsigned int) sizeof(odtext);
00308
00309 }
00310
00311 OCI_RESULT(res);
00312
00313 return count;
00314 }
00315
00316
00317
00318
00319
00320 unsigned int OCI_API OCI_LongGetSize
00321 (
00322 OCI_Long *lg
00323 )
00324 {
00325 unsigned int size = 0;
00326
00327 OCI_CHECK_PTR(OCI_IPC_LONG, lg, 0);
00328
00329 size = lg->size;
00330
00331 if (lg->type == OCI_CLONG)
00332 size /= (unsigned int) sizeof(odtext);
00333
00334 OCI_RESULT(TRUE);
00335
00336 return size;
00337 }
00338
00339
00340
00341
00342
00343 void * OCI_API OCI_LongGetBuffer
00344 (
00345 OCI_Long *lg
00346 )
00347 {
00348 OCI_CHECK_PTR(OCI_IPC_LONG, lg, NULL);
00349
00350 OCI_RESULT(TRUE);
00351
00352 return (void *) lg->buffer;
00353 }