Annotation of parser3/src/sql/oracle/parser3oracle.C, revision 1.1
1.1 ! parser 1: /** @file
! 2: Parser Oracle driver.
! 3:
! 4: Copyright(c) 2001 ArtLebedev Group(http://www.artlebedev.com)
! 5:
! 6: Author: Alexander Petrosyan <paf@design.ru>(http://design.ru/paf)
! 7:
! 8: 2001.07.30 using Oracle 8.1.6, tested with Oracle 7.x.x
! 9: */
! 10: static const char *RCSId="$Id: parser3pgsql.C, v 1.11 2001/08/01 09:53:00 parser Exp $";
! 11:
! 12: #include "config_includes.h"
! 13:
! 14: #include "pa_sql_driver.h"
! 15:
! 16: #include <oci.h>
! 17:
! 18: #define MAX_COLS 500
! 19: #define MAX_IN_LOBS 5
! 20: #define MAX_LOB_NAME_LENGTH 100
! 21: #define MAX_OUT_STRING_LENGTH 4000
! 22:
! 23: #define EMPTY_CLOB_FUNC_CALL "empty_clob()"
! 24:
! 25: #include "ltdl.h"
! 26:
! 27: #define MAX_STRING 0x400
! 28: #define MAX_NUMBER 20
! 29:
! 30: #if _MSC_VER
! 31: # define snprintf _snprintf
! 32: # define strcasecmp _stricmp
! 33: # define strncasecmp _strnicmp
! 34: #endif
! 35:
! 36: #ifndef max
! 37: inline int max(int a, int b) { return a>b?a:b; }
! 38: inline int min(int a, int b){ return a<b?a:b; }
! 39: #endif
! 40:
! 41: static char *lsplit(char *string, char delim) {
! 42: if(string) {
! 43: char *v=strchr(string, delim);
! 44: if(v) {
! 45: *v=0;
! 46: return v+1;
! 47: }
! 48: }
! 49: return 0;
! 50: }
! 51:
! 52: struct OracleSQL_connection_struct {
! 53: jmp_buf mark; char error[MAX_STRING];
! 54: OCIEnv *envhp;
! 55: OCIServer *srvhp;
! 56: OCIError *errhp;
! 57: OCISvcCtx *svchp;
! 58: OCISession *usrhp;
! 59: };
! 60:
! 61: struct OracleSQL_query_lobs {
! 62: struct return_rows {
! 63: struct return_row {
! 64: OCILobLocator *locator; ub4 len;
! 65: int ind;
! 66: ub2 rcode;
! 67: } *row;
! 68: int count;
! 69: };
! 70: struct cbf_context_struct {
! 71: SQL_Driver_services *services;
! 72: OracleSQL_connection_struct *cs;
! 73: return_rows *rows;
! 74: };
! 75: struct Item {
! 76: const char *name_ptr; size_t name_size;
! 77: char *data_ptr; size_t data_size;
! 78: OCILobLocator *locator;
! 79: OCIBind *bind;
! 80: return_rows rows;
! 81: } items[MAX_IN_LOBS];
! 82: int count;
! 83: };
! 84:
! 85:
! 86: // forwards
! 87: void check(
! 88: SQL_Driver_services& services, OracleSQL_connection_struct &cs,
! 89: const char *step, sword status);
! 90: static sb4 cbf_no_data(
! 91: dvoid *ctxp,
! 92: OCIBind *bindp,
! 93: ub4 iter, ub4 index,
! 94: dvoid **bufpp,
! 95: ub4 *alenpp,
! 96: ub1 *piecep,
! 97: dvoid **indpp);
! 98: static sb4 cbf_get_data(dvoid *ctxp,
! 99: OCIBind *bindp,
! 100: ub4 iter, ub4 index,
! 101: dvoid **bufpp,
! 102: ub4 **alenp,
! 103: ub1 *piecep,
! 104: dvoid **indpp,
! 105: ub2 **rcodepp);
! 106:
! 107: /**
! 108: OracleSQL server driver
! 109: */
! 110: class OracleSQL_Driver : public SQL_Driver {
! 111: public:
! 112:
! 113: OracleSQL_Driver() : SQL_Driver() {
! 114: }
! 115:
! 116: /// get api version
! 117: int api_version() { return SQL_DRIVER_API_VERSION; }
! 118: /// initialize driver by loading sql dynamic link library
! 119: const char *initialize(const char *dlopen_file_spec) {
! 120: /* const char *error=dlopen_file_spec?
! 121: dlink(dlopen_file_spec):"client library column is empty";
! 122: if(!error) {*/
! 123: OCIInitialize((ub4) OCI_THREADED /*| OCI_OBJECT*/, (dvoid *)0,
! 124: (dvoid * (*)(void *, unsigned int)) 0,
! 125: (dvoid * (*)(void*, void*, unsigned int)) 0,
! 126: (void (*)(void*, void*)) 0 );
! 127: /*}
! 128:
! 129: return error;*/
! 130: return 0;
! 131: }
! 132:
! 133: /** connect
! 134: @param used_only_in_connect_url
! 135: format: @b user:pass@host[:port]|[local]/database
! 136: */
! 137: void connect(
! 138: char *used_only_in_connect_url,
! 139: SQL_Driver_services& services,
! 140: void **connection ///< output: OracleSQL_connection_struct *
! 141: ) {
! 142: char *user=used_only_in_connect_url;
! 143: char *service=lsplit(user, '@');
! 144: char *pwd=lsplit(user, ':');
! 145:
! 146: OracleSQL_connection_struct &cs=
! 147: *(OracleSQL_connection_struct *)services.calloc(sizeof(OracleSQL_connection_struct));
! 148:
! 149: if(setjmp(cs.mark))
! 150: services._throw(cs.error);
! 151:
! 152: dvoid *tmp;
! 153:
! 154: OCIHandleAlloc( (dvoid *) NULL, (dvoid **) &cs.envhp, (ub4) OCI_HTYPE_ENV,
! 155: 52, (dvoid **) &tmp);
! 156:
! 157: OCIEnvInit( &cs.envhp, (ub4) OCI_DEFAULT, 21, (dvoid **) &tmp );
! 158:
! 159: OCIHandleAlloc( (dvoid *) cs.envhp, (dvoid **) &cs.errhp, (ub4) OCI_HTYPE_ERROR,
! 160: 52, (dvoid **) &tmp);
! 161: OCIHandleAlloc( (dvoid *) cs.envhp, (dvoid **) &cs.srvhp, (ub4) OCI_HTYPE_SERVER,
! 162: 52, (dvoid **) &tmp);
! 163:
! 164: OCIServerAttach( cs.srvhp, cs.errhp, (text *) service, (sb4) strlen(service), (ub4) OCI_DEFAULT);
! 165:
! 166: OCIHandleAlloc( (dvoid *) cs.envhp, (dvoid **) &cs.svchp, (ub4) OCI_HTYPE_SVCCTX,
! 167: 52, (dvoid **) &tmp);
! 168:
! 169: /* set attribute server context in the service context */
! 170: OCIAttrSet( (dvoid *) cs.svchp, (ub4) OCI_HTYPE_SVCCTX,
! 171: (dvoid *) cs.srvhp, (ub4) 0,
! 172: (ub4) OCI_ATTR_SERVER, (OCIError *) cs.errhp);
! 173:
! 174: /* allocate a user context handle */
! 175: OCIHandleAlloc((dvoid *)cs.envhp, (dvoid **)&cs.usrhp, (ub4) OCI_HTYPE_SESSION,
! 176: (size_t) 0, (dvoid **) 0);
! 177:
! 178: OCIAttrSet((dvoid *)cs.usrhp, (ub4)OCI_HTYPE_SESSION,
! 179: (dvoid *)user, (ub4)strlen(user),
! 180: OCI_ATTR_USERNAME, cs.errhp);
! 181:
! 182: OCIAttrSet((dvoid *)cs.usrhp, (ub4)OCI_HTYPE_SESSION,
! 183: (dvoid *)pwd, (ub4)strlen(pwd),
! 184: OCI_ATTR_PASSWORD, cs.errhp);
! 185:
! 186: check(services, cs, "OCISessionBegin", OCISessionBegin (cs.svchp, cs.errhp, cs.usrhp,
! 187: OCI_CRED_RDBMS, OCI_DEFAULT));
! 188:
! 189: OCIAttrSet((dvoid *)cs.svchp, (ub4)OCI_HTYPE_SVCCTX,
! 190: (dvoid *)cs.usrhp, (ub4)0,
! 191: OCI_ATTR_SESSION, cs.errhp);
! 192:
! 193: *(OracleSQL_connection_struct **)connection=&cs;
! 194: }
! 195: void disconnect(SQL_Driver_services& services, void *connection) {
! 196: OracleSQL_connection_struct &cs=*(OracleSQL_connection_struct *)connection;
! 197:
! 198: OCISessionEnd(cs.svchp, cs.errhp, cs.usrhp, (ub4)OCI_DEFAULT);
! 199: OCIServerDetach( cs.srvhp, cs.errhp, (ub4) OCI_DEFAULT );
! 200: check(services, cs, "OCIHandleFree2", OCIHandleFree((dvoid *) cs.srvhp, (ub4) OCI_HTYPE_SERVER));
! 201: check(services, cs, "OCIHandleFree3", OCIHandleFree((dvoid *) cs.svchp, (ub4) OCI_HTYPE_SVCCTX));
! 202: check(services, cs, "OCIHandleFree4", OCIHandleFree((dvoid *) cs.errhp, (ub4) OCI_HTYPE_ERROR));
! 203: }
! 204: void commit(SQL_Driver_services& services, void *connection) {
! 205: OracleSQL_connection_struct &cs=*(OracleSQL_connection_struct *)connection;
! 206:
! 207: check(services, cs, "commit", OCITransCommit(cs.svchp, cs.errhp, 0));
! 208: }
! 209: void rollback(SQL_Driver_services& services, void *connection) {
! 210: OracleSQL_connection_struct &cs=*(OracleSQL_connection_struct *)connection;
! 211:
! 212: check(services, cs, "rollback", OCITransRollback(cs.svchp, cs.errhp, 0));
! 213: }
! 214:
! 215: bool ping(SQL_Driver_services&, void *connection) {
! 216: return false;
! 217: }
! 218:
! 219: unsigned int quote(
! 220: SQL_Driver_services&, void *,
! 221: char *to, const char *from, unsigned int length) {
! 222: /*
! 223: it's already UNTAINT_TIMES_BIGGER
! 224: */
! 225: unsigned int result=length;
! 226: while(length--) {
! 227: switch(*from) {
! 228: case '\'': // "'" -> "''"
! 229: *to++='\'';
! 230: break;
! 231: case '\\': // "\" -> "\\"
! 232: *to++='\'';
! 233: break;
! 234: }
! 235: *to++=*from++;
! 236: }
! 237: return result;
! 238: }
! 239: void query(
! 240: SQL_Driver_services& services, void *connection,
! 241: const char *astatement, unsigned long offset, unsigned long limit,
! 242: SQL_Driver_query_event_handlers& handlers) {
! 243: // _asm int 3;
! 244: OracleSQL_connection_struct &cs=*(OracleSQL_connection_struct *)connection;
! 245: OracleSQL_query_lobs lobs={{0}, 0};
! 246: OCIStmt *stmthp=0;
! 247:
! 248: bool failed=false;
! 249: if(setjmp(cs.mark)) {
! 250: failed=true;
! 251: goto cleanup;
! 252: }
! 253: {
! 254: const char *statement=preprocess_statement(services, cs,
! 255: astatement, lobs);
! 256:
! 257: dvoid *tmp;
! 258: check(services, cs, "OCIHandleAlloc STMT", OCIHandleAlloc(
! 259: (dvoid *) cs.envhp, (dvoid **) &stmthp, (ub4) OCI_HTYPE_STMT,
! 260: 50, (dvoid **) &tmp));
! 261: check(services, cs, "syntax",
! 262: OCIStmtPrepare(stmthp, cs.errhp, (unsigned char *)statement,
! 263: (ub4) strlen((char *) statement),
! 264: (ub4) OCI_NTV_SYNTAX, (ub4) OCI_DEFAULT));
! 265: {
! 266: for(int i=0; i<lobs.count; i++) {
! 267: check(services, cs, "alloc output var desc", OCIDescriptorAlloc(
! 268: (dvoid *) cs.envhp, (dvoid **)&lobs.items[i].locator,
! 269: (ub4) OCI_DTYPE_LOB,
! 270: (size_t) 0, (dvoid **) 0));
! 271:
! 272: check(services, cs, "bind output", OCIBindByPos(stmthp,
! 273: &lobs.items[i].bind, cs.errhp,
! 274: (ub4) 1+i,
! 275: (dvoid *)&lobs.items[i].locator,
! 276: (sword)sizeof (lobs.items[i].locator), SQLT_CLOB, (dvoid *) 0,
! 277: (ub2 *) 0, (ub2 *) 0, (ub4) 0, (ub4 *) 0, OCI_DATA_AT_EXEC));
! 278:
! 279: lobs.items[i].rows.count=0;
! 280: OracleSQL_query_lobs::cbf_context_struct cbf_context={
! 281: &services, &cs, &lobs.items[i].rows};
! 282: check(services, cs, "bind dynamic", OCIBindDynamic(
! 283: lobs.items[i].bind, cs.errhp,
! 284: (dvoid *) &cbf_context, cbf_no_data,
! 285: (dvoid *) &cbf_context, cbf_get_data));
! 286: }
! 287: }
! 288:
! 289: execute_prepared(services, cs,
! 290: statement, stmthp, lobs,
! 291: offset, limit, handlers);
! 292: }
! 293: cleanup: // no check call after this point!
! 294: {
! 295: for(int i=0; i<lobs.count; i++) {
! 296: /* free var locator */
! 297: (void) OCIDescriptorFree((dvoid *) lobs.items[i].locator, (ub4) OCI_DTYPE_LOB);
! 298:
! 299: OracleSQL_query_lobs::return_rows *rows=&lobs.items[i].rows;
! 300: for(int r=0; r<rows->count; r++) {
! 301: /* free var locator */
! 302: (void) OCIDescriptorFree((dvoid *) rows->row[r].locator, (ub4) OCI_DTYPE_LOB);
! 303: }
! 304: }
! 305: }
! 306: if(stmthp)
! 307: (void) OCIHandleFree((dvoid *) stmthp, (ub4) OCI_HTYPE_STMT);
! 308:
! 309: if(failed)
! 310: services._throw(cs.error);
! 311: }
! 312:
! 313: private: // private funcs
! 314:
! 315: const char *preprocess_statement(SQL_Driver_services& services, OracleSQL_connection_struct &cs,
! 316: const char *astatement, OracleSQL_query_lobs &lobs) {
! 317: size_t statement_size=strlen(astatement);
! 318:
! 319: char *result=(char *)services.malloc(statement_size
! 320: +MAX_STRING // in case of short 'strings'
! 321: +11/* returning */+6/* into */+(MAX_LOB_NAME_LENGTH+2/*:, */)*2/*ret into*/*MAX_IN_LOBS
! 322: +1);
! 323: const char *o=astatement;
! 324:
! 325: // /**xxx**/'literal' -> EMPTY_CLOB_FUNC_CALL
! 326: char *n=result;
! 327: while(*o) {
! 328: if(
! 329: o[0]=='/' &&
! 330: o[1]=='*' &&
! 331: o[2]=='*') { // name start
! 332: o+=3;
! 333: const char *name_begin=o;
! 334: while(*o)
! 335: if(
! 336: o[0]=='*' &&
! 337: o[1]=='*' &&
! 338: o[2]=='/' &&
! 339: o[3]=='\'') { // name end
! 340: const char *name_end=o;
! 341: o+=4;
! 342: OracleSQL_query_lobs::Item &item=lobs.items[lobs.count++];
! 343: item.name_ptr=name_begin; item.name_size=name_end-name_begin;
! 344: item.data_ptr=(char *)services.malloc(statement_size/*max*/); item.data_size=0;
! 345:
! 346: const char *start=o;
! 347: bool escaped=false;
! 348: while(*o && !(o[0]=='\'' && o[1]!='\'' && !escaped)) {
! 349: escaped=*o=='\\' || (o[0]=='\'' && o[1]=='\'');
! 350: if(escaped) {
! 351: // write pending, skip "\" or "'"
! 352: if(size_t size=o-start) {
! 353: memcpy(item.data_ptr+item.data_size, start, size);
! 354: item.data_size+=size;
! 355: }
! 356: start=++o;
! 357: } else
! 358: o++;
! 359: }
! 360: if(size_t size=o-start) {
! 361: memcpy(item.data_ptr+item.data_size, start, size);
! 362: item.data_size+=size;
! 363: }
! 364: if(*o)
! 365: o++; // skip "'"
! 366:
! 367: n+=sprintf(n, EMPTY_CLOB_FUNC_CALL);
! 368: break;
! 369: } else
! 370: o++; // /**skip**/'xxx'
! 371: } else
! 372: *n++=*o++;
! 373: }
! 374: *n=0;
! 375:
! 376: if(lobs.count) {
! 377: int i;
! 378: n+=sprintf(n, " returning ");
! 379: for(i=0; i<lobs.count; i++) {
! 380: if(i)
! 381: *n++=',';
! 382: n+=sprintf(n, "%*s", lobs.items[i].name_size, lobs.items[i].name_ptr);
! 383: /*memcpy(n, lobs.items[i].name_ptr, lobs.items[i].name_size);
! 384: n+=lobs.items[i].name_size;*/
! 385: }
! 386: n+=sprintf(n, " into ");
! 387: for(i=0; i<lobs.count; i++) {
! 388: if(i)
! 389: *n++='x';
! 390: n+=sprintf(n, ":%*s", lobs.items[i].name_size, lobs.items[i].name_ptr);
! 391: /**n++=':';
! 392: memcpy(n, lobs.items[i].name_ptr, lobs.items[i].name_size);
! 393: n+=lobs.items[i].name_size;*/
! 394: }
! 395: }
! 396:
! 397: return result;
! 398: }
! 399:
! 400: void execute_prepared(
! 401: SQL_Driver_services& services, OracleSQL_connection_struct &cs,
! 402: const char *statement, OCIStmt *stmthp, OracleSQL_query_lobs &lobs,
! 403: unsigned long offset, unsigned long limit,
! 404: SQL_Driver_query_event_handlers& handlers) {
! 405:
! 406: ub2 stmt_type=-1; // UNKNOWN // OCI_STMT_SELECT;//
! 407: /*
! 408: //gpfs on sun. paf 000818
! 409: //Zanyway, this is needed before.
! 410: check(services, cs, "get stmt type", OCIAttrGet(
! 411: (dvoid *)stmthp, (ub4)OCI_HTYPE_STMT, (ub1 *)&stmt_type,
! 412: (ub4 *) 0, OCI_ATTR_STMT_TYPE, cs.errhp));
! 413: */
! 414: if(strncasecmp(statement, "select", 6)==0)
! 415: stmt_type=OCI_STMT_SELECT;
! 416: if(strncasecmp(statement, "insert", 6)==0)
! 417: stmt_type=OCI_STMT_INSERT;
! 418: if(strncasecmp(statement, "update", 6)==0)
! 419: stmt_type=OCI_STMT_UPDATE;
! 420:
! 421: int status=OCIStmtExecute(cs.svchp, stmthp, cs.errhp,
! 422: (ub4) stmt_type==OCI_STMT_SELECT?0:1, (ub4) 0,
! 423: (OCISnapshot *) NULL,
! 424: (OCISnapshot *) NULL, (ub4) OCI_DEFAULT);
! 425:
! 426: if (status != OCI_NO_DATA)
! 427: check(services, cs, "execute", status);
! 428:
! 429: {
! 430: for(int i=0; i<lobs.count; i++)
! 431: if(ub4 bytes_to_write=lobs.items[i].data_size) {
! 432: OracleSQL_query_lobs::return_rows *rows=&lobs.items[i].rows;
! 433: for(int r=0; r<rows->count; r++) {
! 434: OCILobLocator *locator=rows->row[r].locator;
! 435: check(services, cs, "lobwrite", OCILobWrite (
! 436: cs.svchp, cs.errhp,
! 437: locator, &bytes_to_write, 1,
! 438: (dvoid *) lobs.items[i].data_ptr, (ub4)bytes_to_write, OCI_ONE_PIECE,
! 439: (dvoid *)0, 0, (ub2) 0,
! 440: (ub1) SQLCS_IMPLICIT));
! 441: }
! 442: }
! 443: }
! 444:
! 445: switch(stmt_type) {
! 446: case OCI_STMT_SELECT:
! 447: fetch_table(services, cs,
! 448: stmthp, limit, offset,
! 449: handlers);
! 450: break;
! 451: case OCI_STMT_INSERT:
! 452: break;
! 453: default:/*
! 454: case OCI_STMT_UPDATE:
! 455: case OCI_STMT_DELETE:
! 456: case OCI_STMT_CREATE:
! 457: case OCI_STMT_DROP:
! 458: case OCI_STMT_ALTER:
! 459: case OCI_STMT_BEGIN:
! 460: case OCI_STMT_DECLARE:*/
! 461: break;
! 462: }
! 463: }
! 464:
! 465: void fetch_table(SQL_Driver_services& services, OracleSQL_connection_struct &cs,
! 466: OCIStmt *stmthp, int limit, int offset,
! 467: SQL_Driver_query_event_handlers& handlers) {
! 468: OCIParam *mypard;
! 469: ub2 dtype;
! 470: text *col_name;
! 471: sb4 parm_status;
! 472:
! 473: struct {
! 474: ub2 type;
! 475: char *str;
! 476: OCILobLocator *var;
! 477: OCIDefine *def;
! 478: sb2 indicator;
! 479: } cols[MAX_COLS];
! 480: int column_count;
! 481:
! 482: for(column_count=0; column_count<MAX_COLS; column_count++) {
! 483: /* get next descriptor, if there is one */
! 484: parm_status = OCIParamGet(stmthp, OCI_HTYPE_STMT, cs.errhp, (void **)&mypard,
! 485: (ub4) 1+column_count);
! 486: if(parm_status!=OCI_SUCCESS)
! 487: break;
! 488:
! 489: /* Retrieve the data type attribute */
! 490: check(services, cs, "get type", OCIAttrGet(
! 491: (dvoid*) mypard, (ub4) OCI_DTYPE_PARAM,
! 492: (dvoid*) &dtype, (ub4 *) 0, (ub4) OCI_ATTR_DATA_TYPE,
! 493: (OCIError *) cs.errhp ));
! 494:
! 495: /* Retrieve the column name attribute */
! 496: ub4 col_name_len;
! 497: check(services, cs, "get name", OCIAttrGet(
! 498: (dvoid*) mypard, (ub4) OCI_DTYPE_PARAM,
! 499: (dvoid**) &col_name, (ub4 *) &col_name_len, (ub4) OCI_ATTR_NAME,
! 500: (OCIError *) cs.errhp ));
! 501:
! 502: {
! 503: size_t size=(size_t)col_name_len;
! 504: void *ptr=services.malloc(size);
! 505: memcpy(ptr, col_name, size);
! 506: handlers.add_column(ptr, size);
! 507: }
! 508:
! 509: ub2 coerce_type=dtype;
! 510: sb4 size=0;
! 511: void *ptr;
! 512:
! 513: switch(dtype) {
! 514: case SQLT_CLOB:
! 515: {
! 516: check(services, cs, "alloc output var desc", OCIDescriptorAlloc(
! 517: (dvoid *) cs.envhp, (dvoid **)(ptr=&cols[column_count].var),
! 518: (ub4) OCI_DTYPE_LOB,
! 519: (size_t) 0, (dvoid **) 0));
! 520:
! 521: size=0;
! 522: break;
! 523: }
! 524: default:
! 525: coerce_type=SQLT_STR;
! 526: ptr=cols[column_count].str=(char *)services.malloc(MAX_OUT_STRING_LENGTH+1);
! 527: size=MAX_OUT_STRING_LENGTH;
! 528: break;
! 529: }
! 530:
! 531: cols[column_count].type=coerce_type;
! 532:
! 533: OCIDefineByPos(stmthp, &cols[column_count].def, cs.errhp,
! 534: 1+column_count, (ub1 *) ptr, size,
! 535: coerce_type, (dvoid *) &cols[column_count].indicator,
! 536: (ub2 *) 0, (ub2 *) 0, OCI_DEFAULT);
! 537: }
! 538:
! 539: handlers.before_rows();
! 540:
! 541: int i;
! 542: int status;
! 543: for (int row=0;row<limit+offset;row++) {
! 544: status = OCIStmtFetch(stmthp, cs.errhp, (ub4) 1, (ub4) OCI_FETCH_NEXT,
! 545: (ub4) OCI_DEFAULT);
! 546: if(status != 0) {
! 547: if ( status != OCI_NO_DATA )
! 548: check(services, cs, "fetch", status);
! 549: break;
! 550: }
! 551: if(row>=offset) {
! 552: handlers.add_row();
! 553: for(i=0; i<column_count; i++) {
! 554: size_t size=0;
! 555: void *ptr=0;
! 556: if(cols[i].indicator==0) switch(cols[i].type) {
! 557: case SQLT_CLOB:
! 558: {
! 559: ub4 amtp = 4096000000UL;
! 560: ub4 offset = 1;
! 561: ub4 loblen = 0;
! 562: OCILobLocator *var=(OCILobLocator *)cols[i].var;
! 563: (void) OCILobGetLength(cs.svchp, cs.errhp, var, &loblen);
! 564: if(loblen) {
! 565: size=(size_t)loblen;
! 566: ptr=services.malloc(size);
! 567: check(services, cs, "lobread", OCILobRead(cs.svchp, cs.errhp,
! 568: var, &amtp, offset, (dvoid *) ptr,
! 569: loblen, (dvoid *)0,
! 570: 0,
! 571: (ub2) 0, (ub1) SQLCS_IMPLICIT));
! 572: }
! 573: break;
! 574: }
! 575: default:
! 576: const char *str=cols[i].str;
! 577: size=strlen(str);
! 578: ptr=services.malloc(size);
! 579: memcpy(ptr, str, size);
! 580: break;
! 581: }
! 582: handlers.add_row_cell(ptr, size);
! 583: }
! 584: }
! 585: }
! 586:
! 587: for(i=0; i<column_count; i++) {
! 588: switch(cols[i].type) {
! 589: case SQLT_CLOB:
! 590: /* free var locator */
! 591: (void) OCIDescriptorFree((dvoid *) cols[i].var, (ub4) OCI_DTYPE_LOB);
! 592: break;
! 593: default:
! 594: break;
! 595: }
! 596: }
! 597: }
! 598:
! 599: private: // conn client library funcs
! 600:
! 601: // typedef void (*t_PQfinish)(PGconn *conn); t_PQfinish PQfinish;
! 602:
! 603: private: // conn client library funcs linking
! 604:
! 605: const char *dlink(const char *dlopen_file_spec) {
! 606: lt_dlhandle handle=lt_dlopen(dlopen_file_spec);
! 607: if(!handle)
! 608: return "can not open the dynamic link module";
! 609:
! 610: #define DSLINK(name, action) \
! 611: name=(t_##name)lt_dlsym(handle, #name); \
! 612: if(!name) \
! 613: action;
! 614:
! 615: #define DLINK(name) DSLINK(name, return "function " #name " was not found")
! 616:
! 617: // DLINK(PQfinish);
! 618:
! 619: return 0;
! 620: }
! 621:
! 622: };
! 623:
! 624: void check(
! 625: SQL_Driver_services& services, OracleSQL_connection_struct &cs,
! 626: const char *step, sword status) {
! 627:
! 628: // char reason[MAX_STRING/2];
! 629: const char *msg=0;
! 630:
! 631: switch (status) {
! 632: case OCI_SUCCESS:
! 633: // hurrah
! 634: return;
! 635: /*
! 636: case OCI_ERROR:
! 637: {
! 638: sb4 errcode = 0;
! 639: (void) OCIErrorGet((dvoid *)cs.errhp, (ub4) 1, (text *) NULL, &errcode,
! 640: reason, (ub4) sizeof(reason), OCI_HTYPE_ERROR);
! 641: reason[sizeof(reason)-1]=0;
! 642: msg=reason;
! 643: break;
! 644: }
! 645: case OCI_SUCCESS_WITH_INFO:
! 646: msg="OCI_SUCCESS_WITH_INFO"; break;
! 647: case OCI_NEED_DATA:
! 648: msg="OCI_NEED_DATA"; break;
! 649: case OCI_NO_DATA:
! 650: msg="OCI_NODATA"; break;
! 651: case OCI_INVALID_HANDLE:
! 652: msg="OCI_INVALID_HANDLE"; break;
! 653: case OCI_STILL_EXECUTING:
! 654: msg="OCI_STILL_EXECUTE"; break;
! 655: case OCI_CONTINUE:
! 656: msg="OCI_CONTINUE"; break;
! 657: */
! 658: }
! 659: if(!msg)
! 660: msg="UNKNOWN";
! 661:
! 662: snprintf(cs.error, sizeof(cs.error), "Error at %s - %s (%d)",
! 663: step, msg, (int)status);
! 664: longjmp(cs.mark, 1);
! 665: }
! 666:
! 667:
! 668: /* ----------------------------------------------------------------- */
! 669: /* Intbind callback that does not do any data input. */
! 670: /* ----------------------------------------------------------------- */
! 671: static sb4 cbf_no_data(
! 672: dvoid *ctxp,
! 673: OCIBind *bindp,
! 674: ub4 iter, ub4 index,
! 675: dvoid **bufpp,
! 676: ub4 *alenpp,
! 677: ub1 *piecep,
! 678: dvoid **indpp) {
! 679: *bufpp = (dvoid *) 0;
! 680: *alenpp = 0;
! 681: static sb2 null_ind = -1;
! 682: *indpp = (dvoid *) &null_ind;
! 683: *piecep = OCI_ONE_PIECE;
! 684:
! 685: return OCI_CONTINUE;
! 686: }
! 687:
! 688: /* ----------------------------------------------------------------- */
! 689: /* Outbind callback for returning data. */
! 690: /* ----------------------------------------------------------------- */
! 691: static sb4 cbf_get_data(dvoid *ctxp,
! 692: OCIBind *bindp,
! 693: ub4 iter, ub4 index,
! 694: dvoid **bufpp,
! 695: ub4 **alenp,
! 696: ub1 *piecep,
! 697: dvoid **indpp,
! 698: ub2 **rcodepp) {
! 699: OracleSQL_query_lobs::cbf_context_struct &context=
! 700: *(OracleSQL_query_lobs::cbf_context_struct *)ctxp;
! 701:
! 702: if (index == 0) {
! 703: static ub4 rows = 0;
! 704: (void) OCIAttrGet((CONST dvoid *) bindp, OCI_HTYPE_BIND, (dvoid *)&rows,
! 705: (ub4 *)sizeof(ub2), OCI_ATTR_ROWS_RETURNED, context.cs->errhp);
! 706: context.rows->count = (ub2)rows;
! 707: context.rows->row=(OracleSQL_query_lobs::return_rows::return_row*)
! 708: context.services->malloc(sizeof(OracleSQL_query_lobs::return_rows::return_row)*rows);
! 709: }
! 710:
! 711: OracleSQL_query_lobs::return_rows::return_row &var=context.rows->row[index];
! 712:
! 713: check(*context.services, *context.cs, "alloc output var desc dynamic", OCIDescriptorAlloc(
! 714: (dvoid *) context.cs->envhp, (dvoid **)&var.locator,
! 715: (ub4) OCI_DTYPE_LOB,
! 716: (size_t) 0, (dvoid **) 0));
! 717:
! 718: *bufpp = var.locator;
! 719: *alenp = &var.len;
! 720: *indpp = (dvoid *) &var.ind;
! 721: *piecep = OCI_ONE_PIECE;
! 722: *rcodepp = &var.rcode;
! 723:
! 724: return OCI_CONTINUE;
! 725: }
! 726:
! 727:
! 728: extern "C" SQL_Driver *create() {
! 729: return new OracleSQL_Driver();
! 730: }
E-mail:
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to parser3oracle.C CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [parser3project] / parser3 / src / sql / oracle