OciData.h

Go to the documentation of this file.

#ifndef __DCL_OCI_DATA_H__
#define __DCL_OCI_DATA_H__      20050222
 
__DCL_BEGIN_NAMESPACE
 
class OutputStream;
class BytesOutputStream;
 
class OciQuery;
 
#define DYNAMIC_BUFFER_SIZE 1024
 
class OciData
{
protected:
    OciQuery*   __queryHandle;
    ub4     __position;           //  1, 2, ...
    ub4     __descType;           // 0, OCI_DTYPE_XXX, OCI_DTYPE_FILE, ...
    ub4     __dynamicMode;     // OCI_DEFAULT, OCI_DYNAMIC_FETCH, OCI_DATA_AT_EXEC
 
    ub2     __dataType;           // Define, Bind datatype, SQLT_XXX
    void*   __value;         // or DataBuffer
    sb4     __valueSize;     // or BufferSize
    sb2     __indicator;     // null(-1), not null(0)
    ub2     __actualLength;       
    ub4     __callbackActualLength;
    ub2     __returnCode;
 
    BytesOutputStream* __bytesOutput; // for OCI_DYNAMIC_FETCH or OutBind of SQLT_LNG, SQLT_LBI
    size_t  __dataSize;           // for SQL::Field, SQL::Param
    size_t  __maxDataSize;     // for SQL::Field, SQL::Param
 
public:
    bool onAfterFetch();
 
protected:
    OciConnection* conn() const;
 
    OciData();
    ~OciData();
 
    bool isInteger() const;
 
    bool getDataSize(size_t* _size, bool _maxSize);
    bool getData(void* _pv, size_t* _size, SQL::DataType _dataType);
 
    bool getInteger(void* _pv, size_t* _size, SQL::DataType _dataType);
    bool getFloat(void* _pv, size_t* _size);
    bool getNumericText(char* _pv, size_t* _size);
    bool getTimeStamp(SQL::TimeStamp* _pv, size_t* _size);
    bool getInterval(SQL::Interval* _pv, size_t* _size);
    bool getBytes(byte_t* _pv, size_t* _size);
    bool writeTo(OutputStream* _pv, size_t* _size);
 
    bool getBytesFromLob(byte_t* _pv, size_t* _size);
    bool writeToFromLob(OutputStream* _pv, size_t* _size);
 
    static const wchar_t* dataTypeName(ub2 _dataType);
};
 
#ifndef __DCL_DEBUG
inline OciConnection* OciData::conn() const
{
    return __queryHandle->conn();
}
#endif
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_OCI_DATA__