#include <OciQuery.h>

Inheritance diagram for OciQuery:

Public Member Functions
	OciQuery (OciConnection *_connHandle)
virtual	~OciQuery ()
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
OCIStmt *	__stmt
ub2	__stmtType
void *	__fieldsBuffer
OciParam *	__params
OciField *	__fields
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 11 of file OciQuery.h.

Constructor & Destructor Documentation

◆ OciQuery()

OciQuery::OciQuery ( OciConnection * _connHandle )

◆ ~OciQuery()

OciQuery::~OciQuery ( )

virtual

Definition at line 74 of file OciQuery.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 OciQuery::__destroy ( )

virtual

Implements SQL::Query.

Definition at line 89 of file OciQuery.cpp.

{
    delete this;
}

◆ __execute()

bool OciQuery::__execute ( )

virtual

Implements SQL::Query.

Definition at line 353 of file OciQuery.cpp.

{
    for(size_t i = 0; i < Query::__paramCount; i++) {
        if (!__params[i].doBind())
            return false;
    }
 
    sword status = OCIStmtExecute(
        conn()->svcHandle(),        // OCISvcCtx *svchp
        __stmt,                       // OCIStmt *stmtp
        conn()->errorHandle(),      // OCIError *errhp
        (__stmtType == OCI_STMT_SELECT) ? 0 : 1,  // ub4 iters
        0,                          // ub4 rowoff
        NULL,                       // const OCISnapshot *snap_in
        NULL,                       // OCISnapshot *snap_out
        OCI_DEFAULT                 // ub4 mode
    );
    if (status != OCI_SUCCESS) {
        __SET_ERROR_NORESET(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    // OCI의 경우 stmt execute 후 fields를 결정할 수 있다.
    if (__stmtType == OCI_STMT_SELECT) {
        if (!initFields()) {
            return false;
        }
 
        Query::__eof = false;
    }
 
    for(size_t i = 0; i < Query::__paramCount; i++) {
        if (!__params[i].onAfterExecute()) {
            return false;
        }
    }
 
    if (__stmtType == OCI_STMT_UPDATE
        || __stmtType == OCI_STMT_INSERT
        || __stmtType == OCI_STMT_DELETE) {
 
        ub8 rowCount = 0;
        ub4 size = sizeof(rowCount);
        status = OCIAttrGet(
            __stmt,                   // const void *trgthndlp
            OCI_HTYPE_STMT,         // ub4 trghndltyp
            &rowCount,              // void *attributep
            &size,                  // ub4 *sizep
            OCI_ATTR_UB8_ROW_COUNT, // ub4 attrtype
            conn()->errorHandle()   // OCIError *errhp
        );
        __DCL_ASSERT(size == sizeof(rowCount));
        if (status != OCI_SUCCESS) {
            __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
            return false;
        }
        Query::__affectedRows = rowCount;
    }
    return true;
}

◆ __fetch()

bool OciQuery::__fetch ( )

virtual

Implements SQL::Query.

Definition at line 414 of file OciQuery.cpp.

{
    __DCL_ASSERT(!Query::__eof);
    sword status = OCIStmtFetch2(
        __stmt,                       // OCIStmt *stmthp
        conn()->errorHandle(),      // OCIError *errhp
        1,                          // ub4 nrows
        OCI_FETCH_NEXT,             // ub2 orientation
        0,                          // sb4 fetchOffset
        OCI_DEFAULT                 // ub4 mode
    );
    switch (status) {
        case OCI_NO_DATA: {
            Query::__eof = true;
            return true;
        }
        case OCI_SUCCESS_WITH_INFO: {
            // 2026-02-28
            // 19.30.0.0.0 버전 AIX에서 처음 발견되었다.
            // 구체적인 내용을 확인해야 한다.
            // 아마도 ODBC의 경우와 유사할 것으로 추정된다.
        }
        case OCI_SUCCESS: {
            for (size_t i = 0; i < Query::__fieldCount; i++) {
                if (!__fields[i].onAfterFetch())
                    return false;
            }
            return true;
        }
        default: {
            ;
        }
    }
 
    __SET_ERROR_NORESET(SQL::eServerError, status, conn()->errorHandle());
    return false;
}

◆ __getField()

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

virtual

Implements SQL::Query.

Definition at line 452 of file OciQuery.cpp.

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

◆ __getParam()

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

virtual

Implements SQL::Query.

Definition at line 460 of file OciQuery.cpp.

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

◆ __prepare()

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

virtual

Implements SQL::Query.

Definition at line 305 of file OciQuery.cpp.

{
    if (!reset()) {
        return false;
    }
 
     sword status = OCIStmtPrepare2(
        conn()->svcHandle(),        // OCISvcCtx *svchp
        &__stmt,                  // OCIStmt **stmthp
        conn()->errorHandle(),      // OCIError *errhp
        (const text* )_sql,         // const OraText *stmttext
        (ub4)_sqllen,               // ub4 stmt_len
        NULL,                       // const OraText  *key
        0,                          // ub4 keylen
        OCI_NTV_SYNTAX,             // ub4 language
        OCI_DEFAULT                 // ub4 mode
    );
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    ub4 size = sizeof(__stmtType);
    status = OCIAttrGet(
        __stmt,                       // const void *trgthndlp
        OCI_HTYPE_STMT,             // ub4 trghndltyp
        &__stmtType,              // void *attributep
        &size,                      // ub4 *sizep
        OCI_ATTR_STMT_TYPE,         // ub4 attrtype
        conn()->errorHandle()       // OCIError *errhp
    );
    __DCL_ASSERT(size == sizeof(__stmtType));
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    if (_paramCount > 0) {
        if (!initParams(_paramCount))
            return false;
    }
 
    return true;
}

◆ initFields()

bool OciQuery::initFields ( )

protected

Definition at line 184 of file OciQuery.cpp.

{
    __DCL_ASSERT((__stmt != NULL)
        && (Query::__fieldCount == 0)
        && (__fields == NULL)
        && (__fieldsBuffer == NULL)
    );
 
    ub4 fieldCount = 0;
    ub4 size = sizeof(fieldCount);
    sword status = OCIAttrGet(
        __stmt,                       // const void *trgthndlp
        OCI_HTYPE_STMT,             // ub4 trghndltyp
        &fieldCount,                // void *attributep
        &size,                      // ub4 *sizep
        OCI_ATTR_PARAM_COUNT,       // ub4 attrtype
        conn()->errorHandle()       // OCIError *errhp
    );
    __DCL_ASSERT(size == sizeof(fieldCount));
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
 
    TYPESIZE* ts = (TYPESIZE*)alloca(sizeof(TYPESIZE) * fieldCount);
    for (ub4 i = 0; i < fieldCount; i++) {
        OCIParam* param = NULL;
        status = OCIParamGet(
            __stmt,                   // const void *hndlp
            OCI_HTYPE_STMT,         // ub4 htype
            conn()->errorHandle(),  // OCIError *errhp
            (dvoid**)&param,        // void **parmdpp
            i + 1                   // ub4 pos
        );
        if (status != OCI_SUCCESS) {
            __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
            return false;
        }
 
        ub2 sqlt = 0;
        size = sizeof(sqlt);
        status = OCIAttrGet(
            param,                  // const void *trgthndlp
            OCI_DTYPE_PARAM,        // ub4 trghndltyp
            &sqlt,                  // void *attributep
            &size,                  // ub4 *sizep
            OCI_ATTR_DATA_TYPE,     // ub4 attrtype
            conn()->errorHandle()   // OCIError *errhp
        );
        __DCL_ASSERT(size == sizeof(sqlt));
        if (status != OCI_SUCCESS) {
            __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
            return false;
        }
 
        // ub2 dataSize 이었었는데, Assert failed 되었다.
        // 반환값의 범위는 0 ~ 4000이다.
        ub4 dataSize = 0;
        size = sizeof(dataSize);
        status = OCIAttrGet(
            param,                  // const void *trgthndlp
            OCI_DTYPE_PARAM,        // ub4 trghndltyp
            &dataSize,              // void *attributep
            &size,                  // ub4 *sizep
            OCI_ATTR_DATA_SIZE,     // ub4 attrtype
            conn()->errorHandle()   // OCIError *errhp
        );
        __DCL_ASSERT(size == sizeof(dataSize));
        if (status != OCI_SUCCESS) {
            __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
            return false;
        }
 
        ts[i].sqlt = sqlt;
        ts[i].buflen = OciData::__TYPE_SIZE(ts[i].sqlt, dataSize);
        __DCL_TRACE5_N(L"Field [%2d]   size [%6d %6d] type [%3d %ls]\n",
            i + 1, dataSize, ts[i].buflen,
            ts[i].sqlt, OciData::__TYPE_NAME(ts[i].sqlt)
        );
    }
 
    // __fieldsBuffer에 적용할, 레코드 버퍼 크기를 계산한다.
    size_t offset = 0;
    for (ub4 i = 0; i < fieldCount; i++) {
        offset = OciData::__TYPE_ALIGN(offset, ts[i].sqlt);
        __DCL_TRACE5_N(L"Field [%2d] offset [%6zd %6d] type [%3d %ls]\n",
            i + 1, offset, ts[i].buflen, ts[i].sqlt, OciData::__TYPE_NAME(ts[i].sqlt));
        offset += ts[i].buflen;
    }
 
    __DCL_TRACE1_N(L"outBuffer [%zd]\n", offset);
    // Oracle에서 __TYPE_SIZE(field) == 0인 경우는 없다.
    __fieldsBuffer = malloc(offset);
    if (__fieldsBuffer == NULL) {
        __SET_ERROR_HANDLE(SQL::eOutOfMemory, 0, NULL);
        return false;
    }
 
    Query::__fieldCount = fieldCount;
    __fields = new OciField[Query::__fieldCount];
    if (__fields == NULL) {
        __SET_ERROR_HANDLE(SQL::eOutOfMemory, 0, NULL);
        return false;
    }
 
    offset = 0;
    for (ub4 i = 0; i < Query::__fieldCount; i++) {
        offset = OciData::__TYPE_ALIGN(offset, ts[i].sqlt);
        char* buf = (char*)__fieldsBuffer + offset;
        //__DCL_TRACE3_N(L"offset [%4zd %4d] [%p]\n", offset, ts[i].buflen, buf);
        if (!(__fields[i].init(this, i + 1, ts[i].sqlt,
            buf, ts[i].buflen))
        ) {
            return false;
        }
        offset += ts[i].buflen;
    }
 
    return true;
}

◆ initParams()

bool OciQuery::initParams ( size_t _paramCount )

protected

Definition at line 137 of file OciQuery.cpp.

{
    __DCL_ASSERT((__stmt != NULL)
        && (_paramCount > 0)
        && (Query::__paramCount == 0)
        && (__params == NULL)
    );
 
#if defined(__DCL_DEBUG) && 1
    ub4 bindCount = 0;
    ub4 size = sizeof(bindCount);
    sword status = OCIAttrGet(
        __stmt,                       // const void *trgthndlp
        OCI_HTYPE_STMT,             // ub4 trghndltyp
        &bindCount,                 // void *attributep
        &size,                      // ub4 *sizep
        OCI_ATTR_BIND_COUNT,        // ub4 attrtype
        conn()->errorHandle()       // OCIError *errhp
    );
    __DCL_ASSERT(size == sizeof(bindCount));
    if (status != OCI_SUCCESS) {
        __SET_ERROR_HANDLE(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
    __DCL_ASSERT(bindCount == _paramCount);
#endif
 
    Query::__paramCount = _paramCount;
    __params = new OciParam[Query::__paramCount];
    if (__params == NULL) {
        __SET_ERROR_HANDLE(SQL::eOutOfMemory, 0, NULL);
        return false;
    }
 
    for(ub4 i = 0; i < Query::__paramCount; i++) {
        if (!__params[i].init(this, i + 1))
            return false;
    }
 
    return true;
}

◆ reset()

bool OciQuery::reset ( )

protected

Definition at line 94 of file OciQuery.cpp.

{
    Query::__eof = true;
    Query::__affectedRows = -1;
    __stmtType = __OCI_STMT_TYPE_UNKNOWN;
 
    if (__fields) {
        __DCL_ASSERT(Query::__fieldCount > 0);
        delete[] __fields;
        __fields = NULL;
        Query::__fieldCount = 0;
    }
 
    if (__params) {
        __DCL_ASSERT(Query::__paramCount > 0);
        delete[] __params;
        __params = NULL;
        Query::__paramCount = 0;
    }
 
    if (__fieldsBuffer) {
        free(__fieldsBuffer);
        __fieldsBuffer = NULL;
    }
 
    if (__stmt) {
        sword status = OCIStmtRelease(
            __stmt,                   // OCIStmt *stmthp
            conn()->errorHandle(),  // OCIError *errhp
            NULL,                   // const OraText *key
            0,                      // ub4 keylen
            OCI_DEFAULT             // ub4 mode
        );
        if (status != OCI_SUCCESS) {
            __SET_ERROR_HANDLE(SQL::eServerError, status, NULL);
            return false;
        }
        __stmt = NULL;
    }
 
    return true;
}

Member Data Documentation

◆ __fields

OciField* OciQuery::__fields

protected

Definition at line 26 of file OciQuery.h.

◆ __fieldsBuffer

void* OciQuery::__fieldsBuffer

protected

Definition at line 23 of file OciQuery.h.

◆ __params

OciParam* OciQuery::__params

protected

Definition at line 25 of file OciQuery.h.

◆ __stmt

OCIStmt* OciQuery::__stmt

protected

Definition at line 20 of file OciQuery.h.

◆ __stmtType

ub2 OciQuery::__stmtType

protected

Definition at line 21 of file OciQuery.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

◆ OciQuery()

◆ ~OciQuery()

Member Function Documentation

◆ __destroy()

◆ __execute()

◆ __fetch()

◆ __getField()

◆ __getParam()

◆ __prepare()

◆ initFields()

◆ initParams()

◆ reset()

Member Data Documentation

◆ __fields

◆ __fieldsBuffer

◆ __params

◆ __stmt

◆ __stmtType