PeQuery Class Reference

#include <PeQuery.h>

Inheritance diagram for PeQuery:

Public Member Functions
	PeQuery (PeConnection *pConnection)
virtual	~PeQuery ()
virtual void	__destroy ()
virtual bool	__prepare (const char *_sql, size_t _sqllen, size_t _paramCount)
virtual bool	__execute ()
virtual bool	__fetch ()
virtual bool	__getField (size_t _index, SQL::Field **_fieldHandleOut)
virtual bool	__getParam (size_t _index, SQL::Param **_paramHandleOut)
Public Member Functions inherited from Object
virtual String	toString () const
virtual void	destroy ()
String	className () const
bool	isInstanceOf (const std::type_info &typeinfo) const
virtual const std::type_info &	typeInfo () const

Protected Member Functions
bool	reset ()
bool	initFields ()
bool	initParams (size_t _paramCount)
Protected Member Functions inherited from SQL::Query
	Query (Connection *_connHandle)
virtual	~Query ()
virtual bool	__moreResults (bool *_moreResults)
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Protected Attributes
ByteString	__statementID
ByteString	__cursorID
sqlda_t *	__outSQLDA
sqlda_t *	__inSQLDA
bool	__cursorDeclared
bool	__cursorOpened
PeField *	__fields
PeParam *	__params
Protected Attributes inherited from SQL::Query
Connection *	__connHandle
bool	__eof
int64_t	__affectedRows
size_t	__fieldCount
size_t	__paramCount
wchar_t	__placeholder
unsigned int	__states

Additional Inherited Members
Public Types inherited from SQL::Query
enum	State { stStandBy = (unsigned int) 0x0001 , stPrepared = 0x0002 , stExecuted = 0x0004 , stFetched = 0x0008 }

Detailed Description

Definition at line 9 of file PeQuery.h.

Constructor & Destructor Documentation

PeQuery()

PeQuery::PeQuery

(

PeConnection *

pConnection

)

~PeQuery()

PeQuery::~PeQuery ( )

virtual

Definition at line 66 of file PeQuery.cpp.

{
#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
}

Member Function Documentation

__destroy()

void PeQuery::__destroy ( )

virtual

Implements SQL::Query.

Definition at line 81 of file PeQuery.cpp.

{
//  cerr << "PeQuery::destory\n";
    delete this;
}

__execute()

bool PeQuery::__execute ( )

virtual

Implements SQL::Query.

Definition at line 325 of file PeQuery.cpp.

{
#ifdef __DCL_DEBUG
    for (size_t i = 0; i < Query::__paramCount; i++) {
        __params[i].onBeforeExecute();
    }
#endif
 
    /* exec sql begin declare section */
       
        
        
    
#line 286 "PeQuery.pgc"
 char * connID = conn () -> connectionID () ;
 
#line 287 "PeQuery.pgc"
 char * stmtID = ( _CONST char * ) __statementID . data () ;
 
#line 288 "PeQuery.pgc"
 char * cursorID = ( _CONST char * ) __cursorID . data () ;
/* exec sql end declare section */
#line 289 "PeQuery.pgc"
 
 
    { ECPGsetconn(__LINE__, connID);}
#line 291 "PeQuery.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    if (__outSQLDA && __outSQLDA->sqld > 0) {
        if (!__cursorDeclared) {
            ECPGset_var( 0, &( cursorID ), __LINE__);\
 /* declare $0 cursor for $1 */
#line 300 "PeQuery.pgc"
 
#line 300 "PeQuery.pgc"
 
            if (SQLCODE < 0) {
                __SET_ERROR_HANDLE(SQLCODE);
                return false;
            }
            __cursorDeclared = true;
        }
 
        if (__inSQLDA)
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "declare $0 cursor for $1", 
    ECPGt_char,&(cursorID),(long)0,(long)1,(1)*sizeof(char), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
    ECPGt_char_variable,(ECPGprepared_statement(NULL, stmtID, __LINE__)),(long)1,(long)1,(1)*sizeof(char), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
    ECPGt_sqlda, &__inSQLDA, 0L, 0L, 0L, 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 309 "PeQuery.pgc"
 
        else
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "declare $0 cursor for $1", 
    ECPGt_char,&(cursorID),(long)0,(long)1,(1)*sizeof(char), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
    ECPGt_char_variable,(ECPGprepared_statement(NULL, stmtID, __LINE__)),(long)1,(long)1,(1)*sizeof(char), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 311 "PeQuery.pgc"
 
 
        if (SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            return false;
        }
 
        __cursorOpened = true;
        __eof = false;
    }
    else {
#if 0
        // 2025.05.06 __outSQLDA 조건은 CURSOR로 처리 하므로
        // 다음 EXEC SQL EXECUTE는 의미가 없다.
        if (__outSQLDA && __inSQLDA)
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_execute, stmtID, 
    ECPGt_sqlda, &__inSQLDA, 0L, 0L, 0L, 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, 
    ECPGt_sqlda, &__outSQLDA, 0L, 0L, 0L, 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);}
#line 327 "PeQuery.pgc"
 
        else if (__outSQLDA)
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_execute, stmtID, ECPGt_EOIT, 
    ECPGt_sqlda, &__outSQLDA, 0L, 0L, 0L, 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);}
#line 329 "PeQuery.pgc"
 
        else
#endif
        if (__inSQLDA)
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_execute, stmtID, 
    ECPGt_sqlda, &__inSQLDA, 0L, 0L, 0L, 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 333 "PeQuery.pgc"
 
        else
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_execute, stmtID, ECPGt_EOIT, ECPGt_EORT);}
#line 335 "PeQuery.pgc"
 
 
        if (SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            Query::__affectedRows = -1;
            return false;
        }
 
        // INSERT, UPDATE, DELETE
        Query::__affectedRows = sqlca.sqlerrd[2];
    }
 
    for(size_t i = 0; i < Query::__paramCount; i++) {
        if (!(__params[i].onAfterExecute()))
            return false;
    }
 
    return true;
}

__fetch()

bool PeQuery::__fetch ( )

virtual

Implements SQL::Query.

Definition at line 450 of file PeQuery.cpp.

{
    // SELECT, CALL
    __DCL_ASSERT(!eof());
    __DCL_ASSERT(__outSQLDA && __outSQLDA->sqld > 0);
 
    /* exec sql begin declare section */
       
        
    
#line 362 "PeQuery.pgc"
 char * connID = conn () -> connectionID () ;
 
#line 363 "PeQuery.pgc"
 char * cursorID = ( _CONST char * ) __cursorID . data () ;
/* exec sql end declare section */
#line 364 "PeQuery.pgc"
 
 
    { ECPGsetconn(__LINE__, connID);}
#line 366 "PeQuery.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "fetch $0", 
    ECPGt_char,&(cursorID),(long)0,(long)1,(1)*sizeof(char), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, 
    ECPGt_sqlda, &__outSQLDA, 0L, 0L, 0L, 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);}
#line 373 "PeQuery.pgc"
 
 
    if (SQLCODE == ECPG_NO_ERROR) {
#if 0
        __DCL_TRACE1(L"[%p]\n", __outSQLDA);
        __DCL_TRACE4(L"[%hs] [%ld] sqln[%d] sqld[%d]\n",
            __outSQLDA->sqldaid, __outSQLDA->sqldabc,
            __outSQLDA->sqln, __outSQLDA->sqld
        );
        for (int i = 0; i < __outSQLDA->sqld; i++) {
            sqlvar_t* p = &(__outSQLDA->sqlvar[i]);
            __DCL_TRACE4(L"[%19ls] [%hd] [%p] [%p]\n",
                __dataTypeName(p), p->sqllen, p->sqldata, p->sqlind
            );
        }
#endif
        sqlvar_t* sqlvar = __outSQLDA->sqlvar;
        for (size_t i = 0; i < Query::__fieldCount; i++) {
            if (!__fields[i].onAfterFetch(sqlvar++))
                return false;
        }
        return true;
    }
    else if (SQLCODE == ECPG_NOT_FOUND) {
        Query::__eof = true;
        if (__cursorOpened) {
            __cursorOpened = false;
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "close $0", 
    ECPGt_char,&(cursorID),(long)0,(long)1,(1)*sizeof(char), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 400 "PeQuery.pgc"
 
            if (SQLCODE < 0) {
                __SET_ERROR_HANDLE(SQLCODE);
                return false;
            }
        }
        return true;
    }
 
    __SET_ERROR_HANDLE(SQLCODE);
    return false;
}

__getField()

bool PeQuery::__getField ( size_t _index, SQL::Field ** _fieldHandleOut )

virtual

Implements SQL::Query.

Definition at line 528 of file PeQuery.cpp.

{
    __DCL_ASSERT(Query::__fieldCount > 0);
    __DCL_ASSERT((0 <= _index) && (_index < Query::__fieldCount));
    *_fieldHandleOut = &__fields[_index];
    return true;
}

__getParam()

bool PeQuery::__getParam ( size_t _index, SQL::Param ** _paramHandleOut )

virtual

Implements SQL::Query.

Definition at line 536 of file PeQuery.cpp.

{
    __DCL_ASSERT(Query::__paramCount > 0);
    __DCL_ASSERT((0 <= _index) && (_index < Query::__paramCount));
    *_paramHandleOut = &__params[_index];
    return true;
}

__prepare()

bool PeQuery::__prepare ( const char * _sql, size_t _sqllen, size_t _paramCount )

virtual

Implements SQL::Query.

Definition at line 245 of file PeQuery.cpp.

{
    if(!reset())
        return false;
 
    /* exec sql begin declare section */
       
        
        
    
#line 223 "PeQuery.pgc"
 char * connID = conn () -> connectionID () ;
 
#line 224 "PeQuery.pgc"
 char * stmtID = ( _CONST char * ) __statementID . data () ;
 
#line 225 "PeQuery.pgc"
 char * sql = ( _CONST char * ) _sql ;
/* exec sql end declare section */
#line 226 "PeQuery.pgc"
 
 
    { ECPGsetconn(__LINE__, connID);}
#line 228 "PeQuery.pgc"
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    { ECPGprepare(__LINE__, NULL, 0, stmtID, sql);}
#line 235 "PeQuery.pgc"
 
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    { ECPGdescribe(__LINE__, 0, 0, NULL, stmtID,
    ECPGt_sqlda, &__outSQLDA, 0L, 0L, 0L, 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);}
#line 242 "PeQuery.pgc"
 
 
    if (SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
 
    if (__outSQLDA)   {
#if 0
        __DCL_TRACE1(L"[%p]\n", __outSQLDA);
        __DCL_TRACE4(L"[%hs] [%ld] sqln[%d] sqld[%d]\n",
            __outSQLDA->sqldaid, __outSQLDA->sqldabc,
            __outSQLDA->sqln, __outSQLDA->sqld
        );
        for (int i = 0; i < __outSQLDA->sqld; i++) {
            sqlvar_t* p = &(__outSQLDA->sqlvar[i]);
            __DCL_TRACE4(L"[%19ls] [%hd] [%p] [%p]\n",
                __dataTypeName(p), p->sqllen, p->sqldata, p->sqlind
            );
        }
#endif
        if (__outSQLDA->sqld > 0) {
            if (!initFields())
                return false;
        }
    }
 
    if (_paramCount > 0) {
        if (!initParams(_paramCount))
            return false;
    }
 
    return true;
}

initFields()

bool PeQuery::initFields ( )

protected

Definition at line 185 of file PeQuery.cpp.

{
    __DCL_ASSERT(
        (__fields == NULL) 
        && (Query::__fieldCount == 0)
        && (__outSQLDA != NULL)
        && (__outSQLDA->sqld > 0)
    );
 
    Query::__fieldCount = __outSQLDA->sqld;
    __fields = new PeField[Query::__fieldCount];
    if (__fields == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    sqlvar_t* sqlvar = __outSQLDA->sqlvar;
    for(size_t i = 0; i < Query::__fieldCount; i++, sqlvar++) {
        if (!__fields[i].init(this, sqlvar))
            return false;
    }       
 
    return true;
}

initParams()

bool PeQuery::initParams ( size_t _paramCount )

protected

Definition at line 210 of file PeQuery.cpp.

{
    __DCL_ASSERT((__params == NULL)
        && (Query::__paramCount == 0)
        && (__outSQLDA != NULL)
    );
 
    size_t nAllocSize = sizeof(sqlda_t)
        + (sizeof(sqlvar_t) * _paramCount);
    __inSQLDA = (sqlda_t*)malloc(nAllocSize);
    if (__inSQLDA == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
    memset(__inSQLDA, 0, nAllocSize);
    __inSQLDA->sqln = (short)_paramCount;
 
    Query::__paramCount = _paramCount;
    __params = new PeParam[Query::__paramCount];
    if (__params == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    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;
}

reset()

bool PeQuery::reset ( )

protected

Definition at line 87 of file PeQuery.cpp.

{
    bool r = true;
 
    /* exec sql begin declare section */
       
        
        
    
#line 84 "PeQuery.pgc"
 char * connID = conn () -> connectionID () ;
 
#line 85 "PeQuery.pgc"
 char * stmtID = ( _CONST char * ) __statementID . data () ;
 
#line 86 "PeQuery.pgc"
 char * cursorID = ( _CONST char * ) __cursorID . data () ;
/* exec sql end declare section */
#line 87 "PeQuery.pgc"
 
 
    { ECPGsetconn(__LINE__, connID);}
#line 89 "PeQuery.pgc"
 
    if (r && SQLCODE < 0) {
        __SET_ERROR_HANDLE(SQLCODE);
        return false;
    }
    __DCL_ASSERT(SQLCODE == 0);
 
    if (__cursorOpened) {
        __cursorOpened = false;
        { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "close $0", 
    ECPGt_char,&(cursorID),(long)0,(long)1,(1)*sizeof(char), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 98 "PeQuery.pgc"
 
        if (r && SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            r = false;
        }
    }
 
    if (__cursorDeclared) {
        __cursorDeclared = false;
#if 0
        { ECPGdeallocate(__LINE__, 0, NULL, cursorID);}
#line 108 "PeQuery.pgc"
 
        if (r && SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            r = false;
        }
#endif
    }
 
    if (__outSQLDA) {
        { ECPGdeallocate(__LINE__, 0, NULL, stmtID);}
#line 117 "PeQuery.pgc"
 
        if (r && SQLCODE < 0) {
            __SET_ERROR_HANDLE(SQLCODE);
            r = false;
        }
    }
 
    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 (__outSQLDA) {
        // __outSQLDA는 Informix API에서 할당됨.
        __outSQLDA = NULL;
    }
 
    if (__inSQLDA) {
        free(__inSQLDA);
        __inSQLDA = NULL;
    }
 
    return r;
}

Member Data Documentation

__cursorDeclared

bool PeQuery::__cursorDeclared

protected

Definition at line 22 of file PeQuery.h.

__cursorID

ByteString PeQuery::__cursorID

protected

Definition at line 17 of file PeQuery.h.

__cursorOpened

bool PeQuery::__cursorOpened

protected

Definition at line 23 of file PeQuery.h.

__fields

PeField* PeQuery::__fields

protected

Definition at line 25 of file PeQuery.h.

__inSQLDA

sqlda_t* PeQuery::__inSQLDA

protected

Definition at line 20 of file PeQuery.h.

__outSQLDA

sqlda_t* PeQuery::__outSQLDA

protected

Definition at line 19 of file PeQuery.h.

__params

PeParam* PeQuery::__params

protected

Definition at line 26 of file PeQuery.h.

__statementID

ByteString PeQuery::__statementID

protected

Definition at line 16 of file PeQuery.h.

---

The documentation for this class was generated from the following files:

• PeQuery.h
• PeQuery.cpp