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  __errorMessageEx;       // alternative message
                                    // for Define, Bind Callback
public:
    void setErrorStatus(
            SQL::Error _error, 
            sword status, OCIError* pError,
            bool bPriorReset,
            const wchar_t* _filename, int _line
            );
    void setErrorEx(const ByteString& _message);
 
    // OCI Handle Management Helper
    sword OCIHandleAlloc(void** ppHandle, ub4 nHandleType, 
            size_t xtramem_sz = 0, void** ppvUserMem = NULL);
    sword OCIHandleFree(void* pHandle, ub4 nHandleType);
    sword OCIDescriptorAlloc(void** ppDescriptorHandle, 
            ub4 nDescriptorType, size_t xtramem_sz = 0, void** ppvUserMem = NULL);
    sword OCIDescriptorFree(void* pDescriptorHandle, ub4 nDescriptorType);
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* pszSQL, size_t n);
public:
    OCIEnv*     envHandle() const { return __env; }
    OCIError*   errorHandle() const { return __error; }
    OCIError*   errorHandle2() const { return __error2; }
 
    OCISvcCtx*  svcctxHandle() 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* _connString, size_t _connlen);
    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::setErrorStatus(
        SQL::Error _error, 
        sword status, OCIError* pError,
        bool bPriorReset,
        const wchar_t* _filename, int _line
        )
{
    Connection::setErrorStatus(_error, _filename, _line);
 
    __lastStatus = status;
    __lastError = pError;
 
    if (bPriorReset && !__errorMessageEx.isEmpty())
        __errorMessageEx.clear();
}
 
inline void OciConnection::setErrorEx(const ByteString& _message)
{
    __errorMessageEx = _message;
    __lastStatus = 0;   // OCI_SUCCESS
    __lastError = NULL;
}
 
inline sword OciConnection::OCIHandleAlloc(void** ppHandle, 
        ub4 nHandleType, 
        size_t xtramem_sz /* = 0 */, 
        void** ppvUserMem /* = NULL */)
{
    __DCL_ASSERT(__env != NULL);
    return ::OCIHandleAlloc(__env, 
            ppHandle, 
            nHandleType, 
            xtramem_sz, 
            ppvUserMem);
}
 
inline sword OciConnection::OCIHandleFree(void* pHandle, ub4 nHandleType)
{
    __DCL_ASSERT(pHandle != NULL);
    return ::OCIHandleFree(pHandle, nHandleType);
}
 
inline sword OciConnection::OCIDescriptorAlloc(void** ppDescriptorHandle, 
        ub4 nDescriptorType,
        size_t xtramem_sz /* = 0 */, 
        void** ppvUserMem /* = NULL */)
{
    __DCL_ASSERT(__env != NULL);
    return ::OCIDescriptorAlloc(__env, 
            ppDescriptorHandle, 
            nDescriptorType, 
            xtramem_sz, 
            ppvUserMem);
}
 
inline sword OciConnection::OCIDescriptorFree(
        void* pDescriptorHandle, 
        ub4 nDescriptorType)
{
    __DCL_ASSERT(pDescriptorHandle != NULL);
    return ::OCIDescriptorFree(pDescriptorHandle, nDescriptorType);
}
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_OCI_CONNECTION_H__