OciQuery Class Reference

#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	__nextResult ()
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Protected Attributes
OCIStmt *	__stmt
ub2	__stmtType
OciField *	__fields
OciParam *	__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 = 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 62 of file OciQuery.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 OciQuery::__destroy ( )

virtual

Implements SQL::Query.

Definition at line 88 of file OciQuery.cpp.

{
    delete this;
}

__execute()

bool OciQuery::__execute ( )

virtual

Implements SQL::Query.

Definition at line 252 of file OciQuery.cpp.

{
    for(size_t i = 0; i < Query::__paramCount; i++) {
        if (!__params[i].doBind())
            return false;
    }
 
    OciConnection* pConnection = conn();
    OCIError*   pError = pConnection->errorHandle();
 
    sword status = OCI_SUCCESS;
    status = ::OCIStmtExecute(
            pConnection->svcctxHandle(),
            __stmt,
            pError,
            (__stmtType == OCI_STMT_SELECT) ? 0 : 1,
            0,
            NULL,
            NULL,
            OCI_DEFAULT);
    if (status != OCI_SUCCESS) {
        __SET_ERROR_NORESET(SQL::eServerError, status, pError);
        return false;
    }
 
    // OCI의 경우 stmt execute 후 fields를 결정할 수 있다.
    if (__stmtType == OCI_STMT_SELECT) {
        if (!__fields) {
            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 nAffectedRows = 0;
        status = ::OCIAttrGet(__stmt,
                OCI_HTYPE_STMT, 
                &nAffectedRows,
                NULL, 
                OCI_ATTR_UB8_ROW_COUNT,
                pError);
        if (status != OCI_SUCCESS) {
            __SET_ERROR(SQL::eServerError, status, pError);
            return false;
        }
        Query::__affectedRows = nAffectedRows;
    }
    return true;
}

__fetch()

bool OciQuery::__fetch ( )

virtual

Implements SQL::Query.

Definition at line 312 of file OciQuery.cpp.

{
    __DCL_ASSERT(!eof());
    OCIError* pError = conn()->errorHandle();
    sword status = ::OCIStmtFetch2(
            __stmt,
            pError,
            1,
            OCI_FETCH_NEXT, 0,
            OCI_DEFAULT);
    if (status == OCI_SUCCESS) {
        for(size_t i = 0; i < Query::__fieldCount; i++) {
            if (!__fields[i].onAfterFetch())
                return false;
        }
        return true;
    }
    else if (status == OCI_NO_DATA) {
        Query::__eof = true;
        return true;
    }
 
    __SET_ERROR_NORESET(SQL::eServerError, status, pError);
    return false;
}

__getField()

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

virtual

Implements SQL::Query.

Definition at line 338 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 346 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 175 of file OciQuery.cpp.

{
    OciConnection* pConnection = conn();
    OCIError* pError = pConnection->errorHandle();
 
    if (!reset())
        return false;
 
    sword status = OCI_SUCCESS;
 
    status = ::OCIStmtPrepare2(
            pConnection->svcctxHandle(),
            &__stmt,
            pError,
            (const text* )_sql,
            _sqllen,
            NULL, 0,
            OCI_NTV_SYNTAX,
            OCI_DEFAULT);
    if (status != OCI_SUCCESS) {
        __SET_ERROR(SQL::eServerError, status, pError);
        return false;
    }
 
    status = ::OCIAttrGet(__stmt, 
            OCI_HTYPE_STMT, 
            &__stmtType,
            NULL, 
            OCI_ATTR_STMT_TYPE, 
            pError);
    if (status != OCI_SUCCESS) {
        __SET_ERROR(SQL::eServerError, status, pError);
        return false;
    }
 
    if (_paramCount > 0) {
        if (!initParams(_paramCount))
            return false;
    }
 
    return true;
}

initFields()

bool OciQuery::initFields ( )

protected

Definition at line 219 of file OciQuery.cpp.

{
    OciConnection* pConnection = conn();
    OCIError* pError = pConnection->errorHandle();
    sword status = OCI_SUCCESS;
 
    ub4 nFieldCount = 0;
    status = ::OCIAttrGet(__stmt, 
            OCI_HTYPE_STMT, 
            &nFieldCount, 
            NULL, 
            OCI_ATTR_PARAM_COUNT, 
            pError);
    if (status != OCI_SUCCESS) {
        __SET_ERROR(SQL::eServerError, status, pError);
        return false;
    }
 
    Query::__fieldCount = nFieldCount;
    __fields = new OciField[Query::__fieldCount];
    if (__fields == NULL) {
        __SET_ERROR(SQL::eOutOfMemory, 0, NULL);
        return false;
    }
 
    for(size_t i = 0; i < Query::__fieldCount; i++) {
        if (!__fields[i].init(this, i + 1))
            return false;
    }
 
    return true;
}

initParams()

bool OciQuery::initParams ( size_t _paramCount )

protected

Definition at line 132 of file OciQuery.cpp.

{
#if defined(__DCL_DEBUG) && 1
    ub4 size = 0;
    ub4 startloc = 1;
    sb4 found = 0;
    text* bvnp; ub1 bvnl;
    text* invp; ub1 inpl;
    ub1 dupl; OCIBind* hndl;
 
    sword status = ::OCIStmtGetBindInfo(
            __stmt,
            conn()->errorHandle(),
            size, startloc, &found,
            &bvnp, &bvnl, &invp, &inpl,
            &dupl, &hndl);
    __DCL_TRACE2_N(L"[%d][%d]\n", status, found);
    if (status != OCI_SUCCESS) {
        if (status == OCI_NO_DATA) {
            return true;
        }
        // 그렇다면 에러다.
        __SET_ERROR(SQL::eServerError, status, conn()->errorHandle());
        return false;
    }
    __DCL_ASSERT(abs(found) == _paramCount);
#endif
 
    Query::__paramCount = _paramCount;
    __params = new OciParam[Query::__paramCount];
    if (__params == NULL) {
        __SET_ERROR(SQL::eOutOfMemory, 0, NULL);
        return false;
    }
 
    for(size_t 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 93 of file OciQuery.cpp.

{
    Query::__eof = true;
    Query::__affectedRows = -1;
    __stmtType = _OCI_STMT_TYPE_UNKNOWN;
    
    // 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 (__stmt) {
        sword status = ::OCIStmtRelease(
                __stmt,
                conn()->errorHandle(),
                NULL, 0,
                OCI_DEFAULT
                );
        if (status != OCI_SUCCESS) {
            __SET_ERROR(SQL::eServerError, status, NULL);
            return false;
        }
        __stmt = NULL;
    }
 
    return true;
}

Member Data Documentation

__fields

OciField* OciQuery::__fields

protected

Definition at line 23 of file OciQuery.h.

__params

OciParam* OciQuery::__params

protected

Definition at line 24 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:

• OciQuery.h
• OciQuery.cpp