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:
    ub4     __position;           // 1, 2, ...
    ub4     __dynamicMode;     // OCI_DEFAULT, OCI_DYNAMIC_FETCH, OCI_DATA_AT_EXEC
 
    ub4     __descType;           // 0, OCI_DTYPE_XXX, OCI_DTYPE_FILE, OCI_DTYPE_LOB, ...
    void*   __valuePtr;           // valuep or NULL
    sb4     __valueSize;     // value_sz
    ub2     __valueType;     // Define, Bind SQLT_XXX
 
    sb2     __indicator;     // indp, null(-1), not null(0)
    ub2     __actualLength;       // rlenp,alenp, areported in bytes for OUT binds
    ub2     __returnCode;       // rcodep, column-level return codes
    ub4     __callbackActualLength;
 
    BytesOutputStream* __bytesOutput; // for OCI_DYNAMIC_FETCH or OutBind for SQLT_LNG, SQLT_LBI
    size_t  __dataSize;           // for SQL::Field, SQL::Param
    size_t  __maxDataSize;     // for SQL::Field, SQL::Param
 
public:
    bool onAfterFetch();
 
protected:
    virtual OciQuery* query() const = 0;
    OciConnection* conn() const;
 
    OciData();
    ~OciData();
 
    const wchar_t* serverDataTypeName() const;
 
    bool getDataSize(size_t* _size, bool _maxsize);
    bool getData(void* _buf, size_t* _size, SQL::DataType _bufType);
 
    bool getInteger(void* _buf, size_t* _size, SQL::DataType _bufType);
    bool getFloat(void* _buf, size_t* _size);
    bool getNumericText(char* _buf, size_t* _size);
    bool getDate(SQL::Date* _buf, size_t* _size);
    bool getTime(SQL::Time* _buf, size_t* _size);
    bool getTimeStamp(SQL::TimeStamp* _buf);
    bool getInterval(SQL::Interval* _buf);
    bool getBytes(byte_t* _buf, size_t* _size);
    bool writeTo(OutputStream* _buf, size_t* _size);
 
    bool getBytesFromLob(byte_t* _buf, size_t* _size);
    bool writeToFromLob(OutputStream* _output, size_t* _size);
 
public:
    static const wchar_t* __TYPE_NAME(ub2 _sqlt);
    static ub4 __TYPE_SIZE(ub2 _sqlt, ub4 _size);
    static size_t __TYPE_ALIGN(size_t _offset, ub2 _sqlt);
};
 
inline OciConnection* OciData::conn() const
{
    return query()->conn();
}
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_OCI_DATA__