OciConnection.h

Go to the documentation of this file.

#ifndef __DCL_OCI_CONNECTION_H__
#define __DCL_OCI_CONNECTION_H__    20020321
 
__DCL_BEGIN_NAMESPACE
 
class OciConnection;
class OciQuery;
class OciField;
class OciParam;
 
class OciConnection : public SQL::Connection
{
    DECLARE_CLASSINFO(OciConnection)
protected:
    sword       __lastStatus;       // OCI.. Call Last Status
    OCIError*   __lastError;
    ByteString  __errorMessage;     // alternative message
                                    // for Define, Bind Callback
public:
    // _priorReset setErrorMessage를 통해 설정한 메시지를 reset한다.
    // Define, Bind Callback은 OCIExecute, OCIFetch가 호출 될 때 실행된다.
    // OCIExecute, OCIFetch의 OCI_ERROR에 대한 상세 메시지는 __errorMessage에 있을 수 있다.
    // 만약, __lastStatus OCI_SUCCESS(0)이고, __lastError가 NULL 이면 독립된 오류이다.
    void setErrorHandle(
        SQL::Error _error, 
        sword _status, OCIError* _OCIError,
        bool _priorReset,
        const wchar_t* _filename, int _line
    );
 
    void setErrorMessage(
        const ByteString& _message,
        const wchar_t* _filename, int _line
    );
 
    // OCI Handle Management Helper
    sword HandleAlloc(
        void** _hndlpp,
        ub4 _type,
        size_t _xtramem_sz = 0,
        void** _usrmempp = NULL
    );
 
    sword HandleFree(
        void* _hndlp,
        ub4 _type
    );
 
    sword DescriptorAlloc(
        void** _descpp,
        ub4 _type,
        size_t _xtramem_sz = 0,
        void** _usrmempp = NULL
    );
 
    sword DescriptorFree(
        void* _descp,
        ub4 _type
    );
 
protected:
    OCIEnv*     __env;
    OCIError*   __error;
    OCIError*   __error2;
 
    OCIServer*  __server;
    OCISvcCtx*  __svcctx;
    OCISession* __session;
    OCITrans*   __trans;
 
    bool        __serverAttached;
    bool        __sessionStarted;
 
    bool        closeHelper(bool bEnableDebugInfo);
    bool        executeHelper(const char* _sql, size_t _sqllen);
public:
    OCIEnv*     envHandle() const { return __env; }
    OCIError*   errorHandle() const { return __error; }
    OCIError*   errorHandle2() const { return __error2; }
 
    OCISvcCtx*  svcHandle() const { return __svcctx; }
    OCISession* sessionHandle() const { return __session; }
 
public:
    // interface implementation
    OciConnection(const wchar_t* _serverTitle);
    virtual ~OciConnection();
    virtual void destroy();
    virtual bool __open(const char* _cons, size_t _conslen);
    virtual bool __close();
    virtual bool __execute(const char* _sql, size_t _sqllen);
    virtual bool __startTrans();
    virtual bool __commitTrans();
    virtual bool __rollbackTrans();
    virtual bool __createQueryInstance(SQL::Query** _queryHandleOut);
    virtual bool __getErrorMessage(char* _buf, size_t* _buflen);
    virtual bool __getServerInfo(char* _buf, size_t* _buflen);
 
};
 
inline void OciConnection::setErrorHandle(
        SQL::Error _error, 
        sword status, OCIError* pError,
        bool _priorReset,
        const wchar_t* _filename, int _line
    )
{
    Connection::setErrorStatus(_error, _filename, _line);
 
    __lastStatus = status;
    __lastError = pError;
 
    if (_priorReset)
        __errorMessage.clear();
}
 
inline void OciConnection::setErrorMessage(
        const ByteString& _message,
        const wchar_t* _filename, int _line
    )
{
    Connection::setErrorStatus(SQL::eServerError, _filename, _line);
 
    __errorMessage = _message;
    __lastStatus = 0;   // OCI_SUCCESS
    __lastError = NULL;
}
 
inline sword OciConnection::HandleAlloc(
        void** _hndlpp,
        ub4 _type,
        size_t _xtramem_sz,     // = 0,
        void** _usrmempp        // = NULL
    )
{
    __DCL_ASSERT(__env != NULL);
    return OCIHandleAlloc(
        __env,             // const void *parenth
        _hndlpp,            // void **hndlpp
        _type,              // ub4 type
        _xtramem_sz,        // size_t xtramem_sz
        _usrmempp           // void **usrmempp
    );
}
 
inline sword OciConnection::HandleFree(
        void* _hndlp,
        ub4 _type
    )
{
    __DCL_ASSERT(_hndlp != NULL);
    return OCIHandleFree(
        _hndlp,             // void *hndlp
        _type               // ub4 type
    );
}
 
inline sword OciConnection::DescriptorAlloc(
        void** _descpp,
        ub4 _type,
        size_t _xtramem_sz,     // = 0,
        void** _usrmempp        // = NULL
    )
{
    __DCL_ASSERT(__env != NULL);
    return OCIDescriptorAlloc(
        __env,             // const void* parenth,
        _descpp,            // void** descpp,
        _type,              // ub4 type,
        _xtramem_sz,        // size_t xtramem_sz,
        _usrmempp           // void** usrmempp
    );
}
 
inline sword OciConnection::DescriptorFree(
        void* _descp,
        ub4 _type
    )
{
    __DCL_ASSERT(_descp != NULL);
    return OCIDescriptorFree(
        _descp,             // void* descp,
        _type               // ub4 type
    );
}
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_OCI_CONNECTION_H__