#include <IBQuery.h>

Inheritance diagram for IBQuery:

Public Member Functions
	IBQuery (IBConnection *_connHandle)
virtual	~IBQuery ()
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	__nextResult ()
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Protected Attributes
isc_stmt_handle	__stmtHandle
int	__stmtType
XSQLDA *	__inSQLDA
XSQLDA *	__outSQLDA
char *	__outBuffer
IBParam *	__params
IBField *	__fields
int	__fetchCounter
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 = 0x0001 , stPrepared = 0x0002 , stExecuted = 0x0004 , stFetched = 0x0008 }

Detailed Description

Definition at line 11 of file IBQuery.h.

Constructor & Destructor Documentation

◆ IBQuery()

IBQuery::IBQuery ( IBConnection * _connHandle )

◆ ~IBQuery()

IBQuery::~IBQuery ( )

virtual

Definition at line 46 of file IBQuery.cpp.

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

Member Function Documentation

◆ __destroy()

void IBQuery::__destroy ( )

virtual

Implements SQL::Query.

Definition at line 72 of file IBQuery.cpp.

{
    delete this;
}

◆ __execute()

bool IBQuery::__execute ( )

virtual

Implements SQL::Query.

Definition at line 426 of file IBQuery.cpp.

{
    IBConnection* connHandle = conn();
    ISC_STATUS* statusVector = connHandle->statusVector();
 
    if (__stmtType == isc_info_sql_stmt_exec_procedure) {
        // 2025-07-10
        // EXECUTE PROCEDURE에 대하여 커서를 만들지 않는다.
        // 따라서, __fetch()에서 isc_dsql_fetch는 사용할 수 없다.
        if (isc_dsql_execute2(
                statusVector,
                connHandle->trHandlePtr(),
                &__stmtHandle,
                connHandle->dialect(),
                __inSQLDA,
                __outSQLDA)) {
            __SET_ERROR(SQL::eServerError);
            return false;
        }
    }
    else {
        if (isc_dsql_execute(
                statusVector,
                connHandle->trHandlePtr(),
                &__stmtHandle,
                connHandle->dialect(),
                __inSQLDA)) {
            //      __DCL_ASSERT(STATUS_FAILED(statusVector));
            __SET_ERROR(SQL::eServerError);
            return false;
        }
    }
 
    for (size_t i = 0; i < Query::__paramCount; i++) {
        __params[i].onAfterExecute();
    }
 
    // INSERT, DELETE, UPDATE statement의 실행 후
    // affected records를 구한다.
 
    unsigned char count_type = 0;
    switch(__stmtType) {
        case isc_info_sql_stmt_update: {
            count_type = isc_info_req_update_count;
            break;
        }
        case isc_info_sql_stmt_delete: {
            count_type = isc_info_req_delete_count;
            break;
        }
        case isc_info_sql_stmt_insert: {
            count_type = isc_info_req_insert_count;
            break;
        }
        case isc_info_sql_stmt_select:
        case isc_info_sql_stmt_select_for_upd: {
            Query::__eof = false;
            break;
        }
        case isc_info_sql_stmt_exec_procedure: {
            Query::__eof = false;
            for (size_t i = 0; i < Query::__fieldCount; i++) {
                if (!__fields[i].onAfterFetch())
                    return false;
            }
            break;
        }
    }
    
    if (count_type) {
        unsigned char count_is = 0;
        char count_buffer[33];
        unsigned short length;
 
        if (isc_dsql_sql_info(
                statusVector, 
                &__stmtHandle, 
                sizeof(count_info_item),
                count_info_item,
                sizeof(count_buffer),
                count_buffer)) {
//          __DCL_ASSERT(STATUS_FAILED(statusVector));
            __SET_ERROR(SQL::eServerError);
            return false;
        }
 
        for(char* p = count_buffer + 3; *p != isc_info_end; ) {
            count_is = *p++;
            length = (unsigned short)isc_vax_integer(p, 2);
            p += 2;
            Query::__affectedRows = isc_vax_integer(p, length);
            p += length;
            if (count_is == count_type)
                break;
        }
    }
 
    return true;
}

◆ __fetch()

bool IBQuery::__fetch ( )

virtual

Implements SQL::Query.

Definition at line 526 of file IBQuery.cpp.

{
    __DCL_ASSERT(!eof());
    if (__stmtType == isc_info_sql_stmt_exec_procedure) {
        // 2025-07-10
        // SQLDA 구조를 따르는 Informix, PostgreSQL과 MariaDB 모두
        // PROCEDURE 실행의 결과를 필드 접근으로 구현되었다.
        // fetch 후 필드 접근 패턴으로 맞춘다.
        __fetchCounter++;
        if (__fetchCounter > 1) {
            Query::__eof = true;
        }
        return true;
    }
 
    __DCL_ASSERT(__stmtType == isc_info_sql_stmt_select
        || __stmtType == isc_info_sql_stmt_select_for_upd);
    ISC_STATUS rs = isc_dsql_fetch(conn()->statusVector(), 
                &__stmtHandle, 
                SQLDA_CURRENT_VERSION, 
                __outSQLDA);
    if (rs == 0) {
        for(size_t i = 0; i < Query::__fieldCount; i++) {
            if (!__fields[i].onAfterFetch())
                return false;
        }
        return true;
    }
    else if (rs == 100) {
        Query::__eof = true;
        return true;
    }
 
    __DCL_TRACE1(L"[%zd]\n", (int64_t)rs);
    __SET_ERROR(SQL::eServerError);
    return false;
}

◆ __getField()

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

virtual

Implements SQL::Query.

Definition at line 564 of file IBQuery.cpp.

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

◆ __getParam()

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

virtual

Implements SQL::Query.

Definition at line 572 of file IBQuery.cpp.

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

◆ __prepare()

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

virtual

Implements SQL::Query.

Definition at line 348 of file IBQuery.cpp.

{
    if(!reset())
        return false;
 
    IBConnection* connHandle = conn();
    ISC_STATUS* statusVector = connHandle->statusVector();
 
    if (isc_dsql_allocate_statement(
            statusVector, 
            connHandle->dbHandlePtr(), 
            &__stmtHandle)
            ) {
//      __DCL_ASSERT(STATUS_FAILED(m_statusVector));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
#ifdef FIREBIRD_IBASE_H
    #undef _CONST
    #define _CONST const
#endif
 
    ISC_STATUS rs = isc_dsql_prepare(
            statusVector, 
            connHandle->trHandlePtr(), 
            &__stmtHandle, 
            0, 
            (_CONST char*)_sql,
            connHandle->dialect(), 
            NULL
            );
    if (rs) {
//      __DCL_ASSERT(STATUS_FAILED(m_statusVector));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    char res_buffer[8]; 
    if (isc_dsql_sql_info(
            statusVector,
            &__stmtHandle,
            sizeof(stmt_info_item),
            stmt_info_item,
            sizeof(res_buffer),
            res_buffer)
            ) {
//      __DCL_ASSERT(STATUS_FAILED(m_statusVector));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    if (res_buffer[0] != isc_info_sql_stmt_type) {
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    int len = isc_vax_integer(&res_buffer[1], 2);
    __stmtType = isc_vax_integer(&res_buffer[3], len);
 
    // SELECT, EXECUTE PROCEDURE 는 Row Sets을 반환한다.
    if ((__stmtType == isc_info_sql_stmt_select)
            || (__stmtType == isc_info_sql_stmt_select_for_upd)
            || (__stmtType == isc_info_sql_stmt_exec_procedure)) {
        if (!initFields())
            return false;
    }
 
    if (_paramCount > 0) {
        if (!initParams(_paramCount))
            return false;
    }
 
    return true;
//  rs = isc_dsql_set_cursor_name(statusVector, &__stmtHandle, "CURSOR1", 0);
}

◆ initFields()

bool IBQuery::initFields ( )

protected

Definition at line 185 of file IBQuery.cpp.

{
    __DCL_ASSERT((__fields == NULL) 
            && (__outBuffer == NULL)
            && (Query::__fieldCount == 0)
            );
 
    ISC_STATUS* statusVector = conn()->statusVector();
 
    __outSQLDA = (XSQLDA*)malloc(XSQLDA_LENGTH(1));
    __outSQLDA->version = SQLDA_CURRENT_VERSION;
    __outSQLDA->sqln = 1;
 
    if(isc_dsql_describe(
            statusVector, 
            &__stmtHandle, 
            SQLDA_CURRENT_VERSION,
            __outSQLDA)
            ) {
//      __DCL_ASSERT(STATUS_FAILED(statusVector));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    if (__outSQLDA->sqld == 0) {
        // 필드가 없다.
        return true;
    }
 
    if (__outSQLDA->sqln < __outSQLDA->sqld) {
        __outSQLDA = (XSQLDA*)realloc(__outSQLDA, XSQLDA_LENGTH(__outSQLDA->sqld));
        __outSQLDA->version = SQLDA_CURRENT_VERSION;
        __outSQLDA->sqln = __outSQLDA->sqld;
    
        if (isc_dsql_describe(
                statusVector, 
                &__stmtHandle, 
                SQLDA_CURRENT_VERSION,
                __outSQLDA)
                ) {
//          __DCL_ASSERT(STATUS_FAILED(statusVector));
            __SET_ERROR(SQL::eServerError);
            return false;
        }
    }
 
    Query::__fieldCount = __outSQLDA->sqld;
    __fields = new IBField[Query::__fieldCount];
    if (__fields == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    size_t offset = 0;
    XSQLVAR* sqlvar = __outSQLDA->sqlvar;
    for(size_t i = 0; i < Query::__fieldCount; i++, sqlvar++) {
        offset = __TYPE_ALIGN(offset, sqlvar->sqltype);
        switch(sqlvar->sqltype & ~1) {
            case SQL_TEXT :
                offset += sqlvar->sqllen + 1;
                break;
            case SQL_VARYING :
                offset += sqlvar->sqllen + sizeof(short) + 1;
                break;
            default :
                offset += sqlvar->sqllen;
        }
    }
 
    if (offset > 0) {
        __outBuffer = (char*)malloc(offset);
        __DCL_ASSERT((size_t)__outBuffer % sizeof(void*) == 0);
        if (!__outBuffer) {
            __SET_ERROR(SQL::eOutOfMemory);
            return false;
        }
    }
 
    sqlvar = __outSQLDA->sqlvar;
    offset = 0;
    for(size_t i = 0; i < Query::__fieldCount; i++, sqlvar++) {
        offset = __TYPE_ALIGN(offset, sqlvar->sqltype);
        sqlvar->sqldata = (char*)__outBuffer + offset;
        switch(sqlvar->sqltype & ~1) {
            case SQL_TEXT :
                offset += sqlvar->sqllen + 1;
                break;
            case SQL_VARYING :
                offset += sqlvar->sqllen + sizeof(short) + 1;
                break;
            default :
                offset += sqlvar->sqllen;
        }
 
        if (!__fields[i].init(this, sqlvar))
            return false;
    }
 
    return true;
}

◆ initParams()

bool IBQuery::initParams ( size_t _paramCount )

protected

Definition at line 286 of file IBQuery.cpp.

{
    ISC_STATUS* statusVector = conn()->statusVector();
 
    __inSQLDA = (XSQLDA*)malloc(XSQLDA_LENGTH(1));
    __inSQLDA->version = SQLDA_CURRENT_VERSION;
    __inSQLDA->sqln = 1;
 
    if (isc_dsql_describe_bind(
            statusVector, 
            &__stmtHandle, 
            SQLDA_CURRENT_VERSION, 
            __inSQLDA)
            ) {
//      __DCL_ASSERT(STATUS_FAILED(statusVector));
        __SET_ERROR(SQL::eServerError);
        return false;
    }
 
    if (__inSQLDA->sqld == 0) {
        // 파라미터가 없다. bind 할 필요가 없다.
        return true;
    }
 
    if (__inSQLDA->sqln < __inSQLDA->sqld) {
        __inSQLDA = (XSQLDA*)realloc(__inSQLDA, XSQLDA_LENGTH(__inSQLDA->sqld));
        __inSQLDA->version = SQLDA_CURRENT_VERSION;
        __inSQLDA->sqln = __inSQLDA->sqld;
    
        if (isc_dsql_describe_bind(
                statusVector, 
                &__stmtHandle, 
                SQLDA_CURRENT_VERSION, 
                __inSQLDA)
                ) {
//          __DCL_ASSERT(STATUS_FAILED(m_statusVector));
            __SET_ERROR(SQL::eServerError);
            return false;
        }
    }
    __DCL_ASSERT(__inSQLDA->sqld == _paramCount);
 
    Query::__paramCount = _paramCount;
    __params = new IBParam[Query::__paramCount];
    if (__params == NULL) {
        __SET_ERROR(SQL::eOutOfMemory);
        return false;
    }
 
    XSQLVAR* 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 IBQuery::reset ( )

protected

Definition at line 77 of file IBQuery.cpp.

{
    Query::__eof = true;
    Query::__affectedRows = -1;
    __stmtType = _IB_STMT_TYPE_UNKNOWN;
    __fetchCounter = 0;
 
    // 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) {
        free(__outSQLDA);
        __outSQLDA = NULL;
    }
 
    if (__inSQLDA) {
        free(__inSQLDA);
        __inSQLDA = NULL;
    }
 
    ISC_STATUS* statusVector = conn()->statusVector();
    bool r = true;
    if (__stmtHandle) {
        if (isc_dsql_free_statement(
                statusVector, 
                &__stmtHandle, 
                DSQL_drop)
                ) {
//          __DCL_ASSERT(STATUS_FAILED(statusVector));
            __SET_ERROR(SQL::eServerError);
            r = false;
        }
        __stmtHandle = NULL;
    }
    return r;
}

Member Data Documentation

◆ __fetchCounter

int IBQuery::__fetchCounter

protected

Definition at line 34 of file IBQuery.h.

◆ __fields

IBField* IBQuery::__fields

protected

Definition at line 31 of file IBQuery.h.

◆ __inSQLDA

XSQLDA* IBQuery::__inSQLDA

protected

Definition at line 26 of file IBQuery.h.

◆ __outBuffer

char* IBQuery::__outBuffer

protected

Definition at line 28 of file IBQuery.h.

◆ __outSQLDA

XSQLDA* IBQuery::__outSQLDA

protected

Definition at line 27 of file IBQuery.h.

◆ __params

IBParam* IBQuery::__params

protected

Definition at line 30 of file IBQuery.h.

◆ __stmtHandle

isc_stmt_handle IBQuery::__stmtHandle

protected

Definition at line 24 of file IBQuery.h.

◆ __stmtType

int IBQuery::__stmtType

protected

Definition at line 25 of file IBQuery.h.

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

Public Member Functions

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ IBQuery()

◆ ~IBQuery()

Member Function Documentation

◆ __destroy()

◆ __execute()

◆ __fetch()

◆ __getField()

◆ __getParam()

◆ __prepare()

◆ initFields()

◆ initParams()

◆ reset()

Member Data Documentation

◆ __fetchCounter

◆ __fields

◆ __inSQLDA

◆ __outBuffer

◆ __outSQLDA

◆ __params

◆ __stmtHandle

◆ __stmtType