IFXQuery.cpp

Go to the documentation of this file.

#line 1 "ifxquery.ec"
#include <dcl/Config.h>
 
#include <sqlhdr.h>
#include <sqliapi.h>
 
#include <sqlda.h>
#include <sqlstype.h>
#include <sqltypes.h>
 
#include <stdlib.h>     // malloc, free
#include <string.h>     // memset
 
#include <dcl/Object.h>
#if __DCL_HAVE_ALLOC_DEBUG
#undef __DCL_ALLOC_LEVEL
#define __DCL_ALLOC_LEVEL   __DCL_ALLOC_INTERNAL
#endif
 
#include <dcl/Numeric.h>
#include <dcl/SQLCore.h>
 
#include "IFXConnection.h"
#include "IFXQuery.h"
#include "IFXField.h"
#include "IFXParam.h"
#include "IFXUtils.h" // for void ndebug_free(void* _pv)
 
#define __TRACE_THIS    0
#if __TRACE_THIS
#define __DCL_TRACE0_N  __DCL_TRACE0
#define __DCL_TRACE1_N  __DCL_TRACE1
#define __DCL_TRACE2_N  __DCL_TRACE2
#define __DCL_TRACE3_N  __DCL_TRACE3
#define __DCL_TRACE4_N  __DCL_TRACE4
#else
#define __DCL_TRACE0_N(fmt)
#define __DCL_TRACE1_N(fmt, arg)
#define __DCL_TRACE2_N(fmt, arg1, arg2)
#define __DCL_TRACE3_N(fmt, arg1, arg2, arg3)
#define __DCL_TRACE4_N(fmt, arg1, arg2, arg3, arg4)
#endif
 
#undef __THIS_FILE__
static const wchar_t __THIS_FILE__[] = __T("dcl/sql/IFXQuery.ec");
 
__DCL_BEGIN_NAMESPACE
 
IMPLEMENT_CLASSINFO(IFXQuery, SQL::Query)
 
#ifdef __DCL_DEBUG
#define __SQ_NAME(_sq)  case _sq: return L ## #_sq;
 
static const wchar_t* __STMT_STRING(int _sq)
{
    switch (_sq) {
        __SQ_NAME(SQ_SELECT)
        __SQ_NAME(SQ_UPDATE)
        __SQ_NAME(SQ_DELETE)
        __SQ_NAME(SQ_INSERT)
        __SQ_NAME(SQ_EXECPROC)
    }
    return L"SQ_OTHER..";
}
#endif
 
IFXQuery::IFXQuery(IFXConnection* pConnection)
    : Query(pConnection)
{
    ByteString strID;
    strID = ByteString::format("%p", this);
 
    __statementID = "stmt_" + strID;
    __cursorID = "cursor_" + strID;
 
#if __USE_STMT_TYPE
    __stmtType = __SQ_UNKNOWN;
#endif
    __inSQLDA = NULL;
    __outSQLDA = NULL;
    __outBuffer = NULL;
 
    __cursorOpened = false;
    __cursorDeclared = false;
 
    __fields = NULL;
    __params = NULL;
}
 
IFXQuery::~IFXQuery()
{
#ifdef __DCL_DEBUG
    if (!reset()) {
        ByteString s;
        size_t n = 512;
        ByteBuffer* buf = ByteBuffer::create(n);
        bool b = conn()->__getErrorMessage(buf->data(), &n);
        if (b) {
            buf->__dataLength = n;
            s = buf;
        }
        buf->release();
 
        if (b) {
            __DCL_TRACE1(__T("Warning! %s\n"), s.data());
        }
        else {
            __DCL_TRACE0(__T("Warning! Query reset error\n"));
        }
    }
#else
    (void)reset();
#endif
}
 
void IFXQuery::__destroy()
{
//  cerr << "IFXQuery::destory\n";
    delete this;
}
 
bool IFXQuery::reset()
{
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 120 "ifxquery.ec"
#line 121 "ifxquery.ec"
  char *pszConnectionID = conn()->connectionID();
  char *pszStatementID = (_CONST char*)__statementID.data();
  char *pszCursorID = (_CONST char*)__cursorID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 124 "ifxquery.ec"
 
    
/*
 *  EXEC SQL SET CONNECTION :pszConnectionID;
 */
#line 126 "ifxquery.ec"
  {
#line 126 "ifxquery.ec"
  sqli_connect_set(0, pszConnectionID, 0);
#line 126 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    if (__cursorOpened) {
/*
 *      EXEC SQL CLOSE :pszCursorID;
 */
#line 134 "ifxquery.ec"
  {
#line 134 "ifxquery.ec"
  sqli_curs_close(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszCursorID, 256));
#line 134 "ifxquery.ec"
  }
        __cursorOpened = false;
    }
 
    if (__cursorDeclared) {
/*
 *      EXEC SQL FREE :pszCursorID;
 */
#line 139 "ifxquery.ec"
  {
#line 139 "ifxquery.ec"
  sqli_mt_free(pszCursorID);
#line 139 "ifxquery.ec"
  }
        __cursorDeclared = false;
    }
    
#if __USE_STMT_TYPE
    if (__stmtType != __SQ_UNKNOWN) {
/*
 *      EXEC SQL FREE :pszStatementID;
 */
#line 145 "ifxquery.ec"
  {
#line 145 "ifxquery.ec"
  sqli_mt_free(pszStatementID);
#line 145 "ifxquery.ec"
  }
        __stmtType = __SQ_UNKNOWN;
    }
#else
    if (__outSQLDA || __inSQLDA) {
/*
 *      EXEC SQL FREE : pszStatementID;
 */
#line 150 "ifxquery.ec"
  {
#line 150 "ifxquery.ec"
  sqli_mt_free(pszStatementID);
#line 150 "ifxquery.ec"
  }
    }
#endif
 
    Query::__eof = true;
    Query::__affectedRows = -1;
 
    // clear fields
    if (__fields) {
        __DCL_ASSERT(Query::__fieldCount > 0);
        delete[] __fields;
        __fields = NULL;
        Query::__fieldCount = 0;
    }
 
    // clear binds
    if (__params) {
        __DCL_ASSERT(Query::__paramCount > 0);
        delete[] __params;
        __params = NULL;
        Query::__paramCount = 0;
    }
 
    if (__outBuffer) {
        free(__outBuffer);
        __outBuffer = NULL;
    }
 
    if (__outSQLDA) {
        // __outSQLDA는 Informix API에서 할당됨.
        ndebug_free(__outSQLDA);
        __outSQLDA = NULL;
    }
 
    if (__inSQLDA) {
        ndebug_free(__inSQLDA);
        __inSQLDA = NULL;
    }
 
    return true;
}
 
bool IFXQuery::initFields()
{
    __DCL_ASSERT((Query::__fieldCount == 0)
        && (__fields == NULL)
        && (__outBuffer == NULL)
        && (__outSQLDA != NULL)
        && (__outSQLDA->sqld > 0));
 
    Query::__fieldCount = __outSQLDA->sqld;
    __fields = new IFXField[Query::__fieldCount];
    if (__fields == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    mintptr offset = 0;
    // 레코드 버퍼 크기 계산
    ifx_sqlvar_t* sqlvar = __outSQLDA->sqlvar;
    for(size_t i = 0; i < Query::__fieldCount; i++, sqlvar++) {
        offset = rtypalign(offset, sqlvar->sqltype);
        mint msize = rtypmsize(sqlvar->sqltype, sqlvar->sqllen);
        __DCL_TRACE4_N(L"[%10hs] sqllen[%4d] msize[%4d] offset[%4d]\n",
            rtypname(sqlvar->sqltype), sqlvar->sqllen,
            msize, offset);
        switch (sqlvar->sqltype & SQLTYPE) {
            case SQLDECIMAL:
            case SQLMONEY:
            case SQLDTIME:
            case SQLINTERVAL:
                break;
            default:
                sqlvar->sqllen = msize;
        }
        offset += msize;
        /*
        SQLTYPE     sqllen              rtypmsize
        ===========================================
        SQLCHAR     서버컬럼최대길이    sqllen + 1
        SQLVCHAR                        '\0'을 포함한 버퍼의 크기
        SQLNCHAR
        SQLNVCHAR
        -------------------------------------------
        SQLDECIMAL  DECIMAL(p,s)        sizeof(dec_t)
        SQLMONEY    의 p,s의미
        -------------------------------------------
        SQLDTIME    qualifier           sizeof(dtime_t)
        SQLINTERVAL qualifier           sizeof(intrvl_t)
        */
    }
 
    if (offset > 0) {
        __outBuffer = (char*)malloc(offset);
        __DCL_ASSERT((size_t)__outBuffer % sizeof(void*) == 0);
        if (__outBuffer == NULL) {
            __SET_ERROR(SQL::eOutOfMemory);
            return false;
        }
        memset(__outBuffer, 0, offset);
    }
 
    sqlvar = __outSQLDA->sqlvar;
    offset = 0;
    for(size_t i = 0; i < Query::__fieldCount; i++, sqlvar++) {
        offset = rtypalign(offset, sqlvar->sqltype);
        sqlvar->sqldata = (char*)__outBuffer + offset;
        offset += rtypmsize(sqlvar->sqltype, sqlvar->sqllen);
 
        if (!__fields[i].init(this, sqlvar))
            return false;
    }       
 
    return true;
}
 
bool IFXQuery::initParams(size_t _paramCount)
{
    __DCL_ASSERT((__params == NULL)
        && (Query::__paramCount == 0)
        && (__inSQLDA != NULL));
#if 0
    size_t nAllocSize = sizeof(ifx_sqlda_t) + (sizeof(ifx_sqlvar_t) * _paramCount);
    __inSQLDA = (ifx_sqlda_t*)malloc(nAllocSize);
    if (__inSQLDA == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
    memset(__inSQLDA, 0, nAllocSize);
    __inSQLDA->sqld = _paramCount;
    __inSQLDA->sqlvar = (ifx_sqlvar_t*)((char*)__inSQLDA + sizeof(ifx_sqlda_t));
    __inSQLDA->desc_occ = sizeof(ifx_sqlda_t);
#endif
    Query::__paramCount = _paramCount;
    __params = new IFXParam[Query::__paramCount];
    if (__params == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    ifx_sqlvar_t* sqlvar = __inSQLDA->sqlvar;
    for(size_t i = 0; i < Query::__paramCount; i++, sqlvar++) {
        if (!__params[i].init(this, sqlvar))
            return false;
    }
 
    return true;
}
 
bool IFXQuery::__prepare(const char* _sql, size_t _sqllen,
    size_t _paramCount)
{
    if (!reset())
        return false;
 
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 305 "ifxquery.ec"
#line 306 "ifxquery.ec"
  char *pszConnectionID = conn()->connectionID();
  char *pszStatementID = (_CONST char*)__statementID.data();
  char *pszSQL = (_CONST char*)_sql;
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 309 "ifxquery.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION : pszConnectionID;
 */
#line 311 "ifxquery.ec"
  {
#line 311 "ifxquery.ec"
  sqli_connect_set(0, pszConnectionID, 0);
#line 311 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
/*
 *  EXEC SQL PREPARE : pszStatementID FROM : pszSQL;
 */
#line 318 "ifxquery.ec"
  {
#line 318 "ifxquery.ec"
  sqli_prep(ESQLINTVERSION, pszStatementID, pszSQL,(ifx_literal_t *)0, (ifx_namelist_t *)0, -1, 0, 0); 
#line 318 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
/*
 *  EXEC SQL DESCRIBE INPUT : pszStatementID INTO __inSQLDA;
 */
#line 324 "ifxquery.ec"
  {
#line 324 "ifxquery.ec"
  sqli_describe_input_stmt(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszStatementID, 257), &__inSQLDA, 0);
#line 324 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
#if __TRACE_THIS && 1
    if (__inSQLDA) {
        __DCL_TRACE2_N(L"__inSQLDA[%p] sqld[%d]]\n",
            __inSQLDA, __inSQLDA->sqld);
        ifx_sqlvar_t* sqlvar = __inSQLDA->sqlvar;
        for (int2 i = 0; i < __inSQLDA->sqld; i++, sqlvar++) {
            __DCL_TRACE3_N(L"[%10hs][%2d] sqllen[%4d]\n",
                rtypname(sqlvar->sqltype), sqlvar->sqltype, sqlvar->sqllen);
        }
    }
#endif
 
/*
 *  EXEC SQL DESCRIBE OUTPUT :pszStatementID INTO __outSQLDA;
 */
#line 341 "ifxquery.ec"
  {
#line 341 "ifxquery.ec"
  sqli_describe_output_stmt(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszStatementID, 257), &__outSQLDA, 0);
#line 341 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
 
    __DCL_TRACE1_N(L"stmtType[%ls]\n",
        __STMT_STRING(SQLCODE == 0 ? SQ_SELECT : SQLCODE));
#if __USE_STMT_TYPE
    __stmtType = sqlca.sqlcode;
    if (__stmtType == 0)
        __stmtType = SQ_SELECT;
 
    switch (__stmtType) {
        case SQ_SELECT:
        case SQ_EXECPROC: {
            break;
        }
        default: {
            if (__outSQLDA) {
                ndebug_free(__outSQLDA);
                __outSQLDA = NULL;
            }
        }
    }
#endif
 
    if (__outSQLDA) {
        __DCL_TRACE2_N(L"__outSQLDA[%p] sqld[%d]\n", __outSQLDA, __outSQLDA->sqld);
        if (__outSQLDA->sqld > 0) {
            if (!initFields())
                return false;
        }
    }
 
    if (_paramCount > 0) {
        if (!initParams(_paramCount))
            return false;
    }
 
    return true;
}
 
bool IFXQuery::__execute()
{
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 386 "ifxquery.ec"
#line 387 "ifxquery.ec"
  char *pszConnectionID = conn()->connectionID();
  char *pszStatementID = (_CONST char*)__statementID.data();
  char *pszCursorID = (_CONST char*)__cursorID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 390 "ifxquery.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :pszConnectionID;
 */
#line 392 "ifxquery.ec"
  {
#line 392 "ifxquery.ec"
  sqli_connect_set(0, pszConnectionID, 0);
#line 392 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_SQLCODE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    //if (__stmtType == SQ_SELECT) {
    if (__outSQLDA && __outSQLDA->sqld > 0) {
        if (!__cursorDeclared) {
/*
 *          EXEC SQL DECLARE :pszCursorID CURSOR FOR :pszStatementID;
 */
#line 402 "ifxquery.ec"
  {
#line 402 "ifxquery.ec"
  sqli_curs_decl_dynm(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszCursorID, 0), pszCursorID, sqli_curs_locate(ESQLINTVERSION, pszStatementID, 1), 0, 0);
#line 402 "ifxquery.ec"
  }
            if (SQLCODE < 0) {
                __SET_ERROR_SQLCODE(SQLCODE);
                return false;
            }
            __cursorDeclared = true;
        }
 
        if (__cursorOpened) {
/*
 *          EXEC SQL CLOSE :pszCursorID;
 */
#line 411 "ifxquery.ec"
  {
#line 411 "ifxquery.ec"
  sqli_curs_close(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszCursorID, 256));
#line 411 "ifxquery.ec"
  }
            if (SQLCODE < 0) {
                __SET_ERROR_SQLCODE(SQLCODE);
                return false;
            }
            __cursorOpened = false;
        }
 
        if (__inSQLDA)
/*
 *          EXEC SQL OPEN :pszCursorID USING DESCRIPTOR __inSQLDA;
 */
#line 420 "ifxquery.ec"
  {
#line 420 "ifxquery.ec"
  sqli_curs_open(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszCursorID, 256), __inSQLDA, (char *)0, (struct value *)0, 1, 0);
#line 420 "ifxquery.ec"
  }
        else
/*
 *          EXEC SQL OPEN :pszCursorID;
 */
#line 422 "ifxquery.ec"
  {
#line 422 "ifxquery.ec"
  sqli_curs_open(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszCursorID, 256), (ifx_sqlda_t *)0, (char *)0, (struct value *)0, 0, 0);
#line 422 "ifxquery.ec"
  }
 
        if (SQLCODE < 0) {
            __SET_ERROR_SQLCODE(SQLCODE);
            return false;
        }
 
        __cursorOpened = true;
        __eof = false;
    }
    else {
#if __USE_STMT_TYPE
        // 2025.05.06 __outSQLDA 조건은 CURSOR로 처리 하므로
        // 다음 EXEC SQL EXECUTE는 의미가 없다.
        if (__outSQLDA && __inSQLDA)
/*
 *          EXEC SQL EXECUTE :pszStatementID INTO DESCRIPTOR __outSQLDA
 *                  USING DESCRIPTOR __inSQLDA;
 */
#line 437 "ifxquery.ec"
  {
#line 438 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszStatementID, 257), __inSQLDA, (char *)0, (struct value *)0, __outSQLDA, (char *)0, (struct value *)0, 0);
#line 438 "ifxquery.ec"
  }
        else if (__outSQLDA)
/*
 *          EXEC SQL EXECUTE :pszStatementID INTO DESCRIPTOR __outSQLDA;
 */
#line 440 "ifxquery.ec"
  {
#line 440 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszStatementID, 257), (ifx_sqlda_t *)0, (char *)0, (struct value *)0, __outSQLDA, (char *)0, (struct value *)0, 0);
#line 440 "ifxquery.ec"
  }
        else
#endif
        if (__inSQLDA)
/*
 *          EXEC SQL EXECUTE : pszStatementID USING DESCRIPTOR __inSQLDA;
 */
#line 444 "ifxquery.ec"
  {
#line 444 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszStatementID, 257), __inSQLDA, (char *)0, (struct value *)0, (ifx_sqlda_t *)0, (char *)0, (struct value *)0, 0);
#line 444 "ifxquery.ec"
  }
        else
/*
 *          EXEC SQL EXECUTE :pszStatementID;
 */
#line 446 "ifxquery.ec"
  {
#line 446 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszStatementID, 257), (ifx_sqlda_t *)0, (char *)0, (struct value *)0, (ifx_sqlda_t *)0, (char *)0, (struct value *)0, 0);
#line 446 "ifxquery.ec"
  }
 
        if (SQLCODE < 0) {
            __SET_ERROR_SQLCODE(SQLCODE);
            Query::__affectedRows = -1;
            return false;
        }
 
#if __USE_STMT_TYPE
        if (__stmtType == SQ_EXECPROC) {
            for(size_t i = 0; i < Query::__fieldCount; i++) {
                if (!__fields[i].onAfterFetch())
                    return false;
            }
        }
        else {
            // INSERT, UPDATE, DELETE
            Query::__affectedRows = sqlca.sqlerrd[2];
        }
#else
        // INSERT, UPDATE, DELETE
        Query::__affectedRows = sqlca.sqlerrd[2];
#endif
    }
 
    for(size_t i = 0; i < Query::__paramCount; i++) {
        if (!(__params[i].onAfterExecute()))
            return false;
    }
 
    return true;
}
 
bool IFXQuery::__fetch()
{
    // SELECT, EXECUTE PROCEDURE
    __DCL_ASSERT(!eof());
    __DCL_ASSERT(__outSQLDA && __outSQLDA->sqld > 0);
 
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 485 "ifxquery.ec"
#line 486 "ifxquery.ec"
  char *pszCursorID = (_CONST char*)__cursorID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 487 "ifxquery.ec"
 
 
/*
 *  EXEC SQL FETCH :pszCursorID USING DESCRIPTOR __outSQLDA;
 */
#line 489 "ifxquery.ec"
  {
#line 489 "ifxquery.ec"
  static _FetchSpec _FS0 = { 0, 1, 0 };
  sqli_curs_fetch(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, pszCursorID, 256), (ifx_sqlda_t *)0, __outSQLDA, (char *)0, &_FS0);
#line 489 "ifxquery.ec"
  }
 
    if (SQLCODE == 0) {
        for (size_t i = 0; i < Query::__fieldCount; i++) {
            if (!__fields[i].onAfterFetch())
                return false;
        }
        return true;
    }
    else if (SQLCODE == SQLNOTFOUND) {
        Query::__eof = true;
        return true;
    }
 
    __SET_ERROR_SQLCODE(SQLCODE);
    return false;
}
 
bool IFXQuery::__getField(size_t _index, SQL::Field** _fieldHandleOut)
{
    __DCL_ASSERT(Query::__fieldCount > 0);
    __DCL_ASSERT((0 <= _index) && (_index < Query::__fieldCount));
    *_fieldHandleOut = &__fields[_index];
    return true;
}
 
bool IFXQuery::__getParam(size_t _index, SQL::Param** _paramHandleOut)
{
    __DCL_ASSERT(Query::__paramCount > 0);
    __DCL_ASSERT((0 <= _index) && (_index < Query::__paramCount));
    *_paramHandleOut = &__params[_index];
    return true;
}
 
__DCL_END_NAMESPACE
 
#line 523 "ifxquery.ec"