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 char_t __THIS_FILE__[] = __T("dcl/sql/IFXQuery.ec");
 
__DCL_BEGIN_NAMESPACE
 
#define __SET_ERROR(_error) \
    conn()->setErrorHandle(_error, 0L, __THIS_FILE__, __LINE__)
#define __SET_ERROR_HANDLE(_SQLCODE) \
    conn()->setErrorHandle(SQL::eServerError, _SQLCODE, __THIS_FILE__, __LINE__)
#define __SET_ERROR_MSG(_message) \
    conn()->setErrorMessage(_message, __THIS_FILE__, __LINE__)
 
IMPLEMENT_CLASSINFO(IFXQuery, SQL::Query)
 
#if defined(__DCL_DEBUG) && __TRACE_THIS
#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* _connection)
    : Query(_connection)
{
    ByteString strID;
    strID = ByteString::format("%zx", (size_t)this);
    __statementID = "stmt_" + strID;
    __cursorID = "curs_" + 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()) {
        char buf[256];
        size_t buflen = sizeof(buf) - 1;
        bool b = conn()->__getErrorMessage(buf, &buflen);
        buf[b ? buflen : 0] = '\0';
        __DCL_TRACE1(L"Warning! Query reset error! %hs\n", buf);
    }
#else
    (void)reset();
#endif
}
 
void IFXQuery::__destroy()
{
//  cerr << "IFXQuery::destory\n";
    delete this;
}
 
bool IFXQuery::reset()
{
    bool r = true;
 
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 116 "ifxquery.ec"
#line 117 "ifxquery.ec"
  char *connID = conn()->connectionID();
  char *stmtID = (_CONST char*)__statementID.data();
  char *cursorID = (_CONST char*)__cursorID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 120 "ifxquery.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :connID;
 */
#line 122 "ifxquery.ec"
  {
#line 122 "ifxquery.ec"
  sqli_connect_set(0, connID, 0);
#line 122 "ifxquery.ec"
  }
    if (r && SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        r = false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    if (__cursorOpened) {
        __cursorOpened = false;
/*
 *      EXEC SQL CLOSE :cursorID;
 */
#line 131 "ifxquery.ec"
  {
#line 131 "ifxquery.ec"
  sqli_curs_close(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cursorID, 256));
#line 131 "ifxquery.ec"
  }
        if (r && SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            r = false;
        }
    }
 
    if (__cursorDeclared) {
        __cursorDeclared = false;
/*
 *      EXEC SQL FREE :cursorID;
 */
#line 140 "ifxquery.ec"
  {
#line 140 "ifxquery.ec"
  sqli_mt_free(cursorID);
#line 140 "ifxquery.ec"
  }
        if (r && SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            r = false;
        }
    }
 
#if __USE_STMT_TYPE
    if (__stmtType != __SQ_UNKNOWN) {
/*
 *      EXEC SQL FREE :stmtID;
 */
#line 149 "ifxquery.ec"
  {
#line 149 "ifxquery.ec"
  sqli_mt_free(stmtID);
#line 149 "ifxquery.ec"
  }
        __stmtType = __SQ_UNKNOWN;
    }
#else
    if (__outSQLDA || __inSQLDA) {
/*
 *      EXEC SQL FREE :stmtID;
 */
#line 154 "ifxquery.ec"
  {
#line 154 "ifxquery.ec"
  sqli_mt_free(stmtID);
#line 154 "ifxquery.ec"
  }
        if (r && SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            r = false;
        }
    }
#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 r;
}
 
bool IFXQuery::initFields()
{
    __DCL_ASSERT(
        (Query::__fieldCount == 0)
        && (__fields == NULL)
        && (__outBuffer == NULL)
        && (__outSQLDA != NULL)
        && (__outSQLDA->sqld > 0)
    );
 
    // __outSQLDA에 적용할, 레코드 버퍼 크기를 계산한다.
    mintptr offset = 0;
    ifx_sqlvar_t* sqlvar = __outSQLDA->sqlvar;
    for(int2 i = 0; i < __outSQLDA->sqld; 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
        SQLLVARCHAR
        -------------------------------------------
        SQLDECIMAL  DECIMAL(p,s)        sizeof(dec_t)
        SQLMONEY    의 p,s의미
        -------------------------------------------
        SQLDTIME    qualifier           sizeof(dtime_t)
        SQLINTERVAL qualifier           sizeof(intrvl_t)
        */
    }
 
    __DCL_TRACE1_N(L"outBuffer [%zd]\n", offset);
    if (offset > 0) {
        __outBuffer = (char*)malloc(offset);
        __DCL_ASSERT((size_t)__outBuffer % sizeof(void*) == 0);
        if (__outBuffer == NULL) {
            __SET_ERROR(SQL::eOutOfMemory);
            return false;
        }
    }
 
    sqlvar = __outSQLDA->sqlvar;
    offset = 0;
    for(int2 i = 0; i < __outSQLDA->sqld; i++, sqlvar++) {
        offset = rtypalign(offset, sqlvar->sqltype);
        sqlvar->sqldata = __outBuffer + offset;
        offset += rtypmsize(sqlvar->sqltype, sqlvar->sqllen);
    }       
 
    Query::__fieldCount = __outSQLDA->sqld;
    __fields = new IFXField[Query::__fieldCount];
    if (__fields == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    sqlvar = __outSQLDA->sqlvar;
    for (size_t i = 0; i < Query::__fieldCount; i++, sqlvar++) {
        if (!__fields[i].init(this, sqlvar))
            return false;
    }
 
    return true;
}
 
bool IFXQuery::initParams(size_t _paramCount)
{
    __DCL_ASSERT((Query::__paramCount == 0)
        && (__params == NULL)
        && (__inSQLDA != NULL)
        && (__inSQLDA->sqld > 0)
    );
 
    __DCL_ASSERT(__inSQLDA->sqld == (int2)_paramCount);
 
    Query::__paramCount = __inSQLDA->sqld;
    __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 313 "ifxquery.ec"
#line 314 "ifxquery.ec"
  char *connID = conn()->connectionID();
  char *stmtID = (_CONST char*)__statementID.data();
  char *sql = (_CONST char*)_sql;
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 317 "ifxquery.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION : connID;
 */
#line 319 "ifxquery.ec"
  {
#line 319 "ifxquery.ec"
  sqli_connect_set(0, connID, 0);
#line 319 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
/*
 *  EXEC SQL PREPARE : stmtID FROM : sql;
 */
#line 326 "ifxquery.ec"
  {
#line 326 "ifxquery.ec"
  sqli_prep(ESQLINTVERSION, stmtID, sql,(ifx_literal_t *)0, (ifx_namelist_t *)0, -1, 0, 0); 
#line 326 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
/*
 *  EXEC SQL DESCRIBE INPUT : stmtID INTO __inSQLDA;
 */
#line 332 "ifxquery.ec"
  {
#line 332 "ifxquery.ec"
  sqli_describe_input_stmt(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, stmtID, 257), &__inSQLDA, 0);
#line 332 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(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 :stmtID INTO __outSQLDA;
 */
#line 349 "ifxquery.ec"
  {
#line 349 "ifxquery.ec"
  sqli_describe_output_stmt(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, stmtID, 257), &__outSQLDA, 0);
#line 349 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(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
 
    __DCL_TRACE2_N(L"__outSQLDA[%p] sqld[%d]\n",
        __outSQLDA, __outSQLDA ? __outSQLDA->sqld : -1);
    if (__outSQLDA && __outSQLDA->sqld > 0) {
        if (!initFields())
            return false;
    }
 
    __DCL_TRACE2_N(L"__inSQLDA[%p] sqld[%d]\n",
        __inSQLDA, __inSQLDA ? __inSQLDA->sqld : -1);
    if (_paramCount > 0) {
        if (!initParams(_paramCount))
            return false;
    }
 
    return true;
}
 
bool IFXQuery::__execute()
{
/*
 *  EXEC SQL BEGIN DECLARE SECTION;
 */
#line 395 "ifxquery.ec"
#line 396 "ifxquery.ec"
  char *connID = conn()->connectionID();
  char *stmtID = (_CONST char*)__statementID.data();
  char *cursorID = (_CONST char*)__cursorID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 399 "ifxquery.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :connID;
 */
#line 401 "ifxquery.ec"
  {
#line 401 "ifxquery.ec"
  sqli_connect_set(0, connID, 0);
#line 401 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    //if (__stmtType == SQ_SELECT) {
    if (__outSQLDA && __outSQLDA->sqld > 0) {
        if (!__cursorDeclared) {
/*
 *          EXEC SQL DECLARE :cursorID CURSOR FOR :stmtID;
 */
#line 411 "ifxquery.ec"
  {
#line 411 "ifxquery.ec"
  sqli_curs_decl_dynm(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cursorID, 0), cursorID, sqli_curs_locate(ESQLINTVERSION, stmtID, 1), 0, 0);
#line 411 "ifxquery.ec"
  }
            if (SQLCODE < 0) {
                __SET_ERROR_HANDLE(SQLCODE);
                return false;
            }
            __cursorDeclared = true;
        }
 
        if (__cursorOpened) {
/*
 *          EXEC SQL CLOSE :cursorID;
 */
#line 420 "ifxquery.ec"
  {
#line 420 "ifxquery.ec"
  sqli_curs_close(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cursorID, 256));
#line 420 "ifxquery.ec"
  }
            if (SQLCODE < 0) {
                __SET_ERROR_HANDLE(SQLCODE);
                return false;
            }
            __cursorOpened = false;
        }
 
        if (__inSQLDA)
/*
 *          EXEC SQL OPEN :cursorID USING DESCRIPTOR __inSQLDA;
 */
#line 429 "ifxquery.ec"
  {
#line 429 "ifxquery.ec"
  sqli_curs_open(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cursorID, 256), __inSQLDA, (char *)0, (struct value *)0, 1, 0);
#line 429 "ifxquery.ec"
  }
        else
/*
 *          EXEC SQL OPEN :cursorID;
 */
#line 431 "ifxquery.ec"
  {
#line 431 "ifxquery.ec"
  sqli_curs_open(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cursorID, 256), (ifx_sqlda_t *)0, (char *)0, (struct value *)0, 0, 0);
#line 431 "ifxquery.ec"
  }
 
        if (SQLCODE < 0) {
            __SET_ERROR_HANDLE(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 :stmtID INTO DESCRIPTOR __outSQLDA
 *                  USING DESCRIPTOR __inSQLDA;
 */
#line 446 "ifxquery.ec"
  {
#line 447 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, stmtID, 257), __inSQLDA, (char *)0, (struct value *)0, __outSQLDA, (char *)0, (struct value *)0, 0);
#line 447 "ifxquery.ec"
  }
        else if (__outSQLDA)
/*
 *          EXEC SQL EXECUTE :stmtID INTO DESCRIPTOR __outSQLDA;
 */
#line 449 "ifxquery.ec"
  {
#line 449 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, stmtID, 257), (ifx_sqlda_t *)0, (char *)0, (struct value *)0, __outSQLDA, (char *)0, (struct value *)0, 0);
#line 449 "ifxquery.ec"
  }
        else
#endif
        if (__inSQLDA)
/*
 *          EXEC SQL EXECUTE : stmtID USING DESCRIPTOR __inSQLDA;
 */
#line 453 "ifxquery.ec"
  {
#line 453 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, stmtID, 257), __inSQLDA, (char *)0, (struct value *)0, (ifx_sqlda_t *)0, (char *)0, (struct value *)0, 0);
#line 453 "ifxquery.ec"
  }
        else
/*
 *          EXEC SQL EXECUTE :stmtID;
 */
#line 455 "ifxquery.ec"
  {
#line 455 "ifxquery.ec"
  sqli_exec(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, stmtID, 257), (ifx_sqlda_t *)0, (char *)0, (struct value *)0, (ifx_sqlda_t *)0, (char *)0, (struct value *)0, 0);
#line 455 "ifxquery.ec"
  }
 
        if (SQLCODE < 0) {
            __SET_ERROR_HANDLE(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 494 "ifxquery.ec"
#line 495 "ifxquery.ec"
  char *connID = conn()->connectionID();
  char *cursorID = (_CONST char*)__cursorID.data();
/*
 *  EXEC SQL END DECLARE SECTION;
 */
#line 497 "ifxquery.ec"
 
 
/*
 *  EXEC SQL SET CONNECTION :connID;
 */
#line 499 "ifxquery.ec"
  {
#line 499 "ifxquery.ec"
  sqli_connect_set(0, connID, 0);
#line 499 "ifxquery.ec"
  }
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
/*
 *  EXEC SQL FETCH :cursorID USING DESCRIPTOR __outSQLDA;
 */
#line 506 "ifxquery.ec"
  {
#line 506 "ifxquery.ec"
  static _FetchSpec _FS0 = { 0, 1, 0 };
  sqli_curs_fetch(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cursorID, 256), (ifx_sqlda_t *)0, __outSQLDA, (char *)0, &_FS0);
#line 506 "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;
        if (__cursorOpened) {
            __cursorOpened = false;
/*
 *          EXEC SQL CLOSE :cursorID;
 */
#line 519 "ifxquery.ec"
  {
#line 519 "ifxquery.ec"
  sqli_curs_close(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cursorID, 256));
#line 519 "ifxquery.ec"
  }
            if (SQLCODE < 0) {
                __SET_ERROR_HANDLE(SQLCODE);
                return false;
            }
        }
        return true;
    }
 
    __SET_ERROR_HANDLE(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 548 "ifxquery.ec"