OciParam.h

Go to the documentation of this file.

#ifndef __DCL_OCI_PARAM_H__
#define __DCL_OCI_PARAM_H__     20020321
 
#include "OciData.h"
 
__DCL_BEGIN_NAMESPACE
 
class InputStream;
 
class OciParam : public SQL::Param, public OciData
{
    DECLARE_CLASSINFO(OciParam)
protected:
    OCIBind*        __bind;
 
    union {
        OCINumber   num;
        void*       desc;   // OCILoator*, OCIDateTime*
    } __data;
 
    sb2             __inputIndicator;
 
    void*           __buffer;       //   local alloc
    InputStream* __inputStream;
 
public:
    OciQuery* query() const { return (OciQuery*)Param::__queryHandle; }
//  bool writeBlob();       // BLOB support by OciQuery
    ub2 _dataType() const { return OciData::__dataType; }
 
    OciParam();
    virtual ~OciParam();
 
    bool init(SQL::Query* _query, ub4 _position);
    bool doBind();
    bool onAfterExecute();
 
protected:
    // interfaces
 
    // out bind support
    virtual bool __setDataType(
            SQL::DataType  _dataType
            );
 
    // Field implementaion
    virtual bool isNull() const;
    virtual const wchar_t* serverDataTypeName() const;
 
    virtual bool __getDataSize(
            size_t*         _size,
            bool            _maxSize
            );
    virtual bool __getData(
            void*           _pv,
            size_t*         _size,      // IN, OUT
            SQL::DataType  _dataType
            );
 
    // Param implementaion
    virtual void setNull();
    virtual bool __setData(
            _CONST void*  _pv,
            size_t          _size,
            SQL::DataType  _dataType,
            SQL::DataType  _assignType
            );
 
 
    // implementation
    bool setTimeStamp(
            const SQL::TimeStamp* _pv,
            size_t _size,
            SQL::DataType _assignType
            );
 
    bool setInterval(
            const SQL::Interval* _pv,
            size_t _size,
            SQL::DataType _assignType
            );
 
protected:
    static sb4 CallbackInBind(
            dvoid       *ictxp,
            OCIBind     *bindp,
            ub4         iter,
            ub4         index,
            dvoid       **bufpp,
            ub4         *alenp,
            ub1         *piecep,
            dvoid       **indpp
            );
    
    static sb4 CallbackOutBind(
            dvoid       *octxp,
            OCIBind     *bindp,
            ub4         iter,
            ub4         index,
            dvoid       **bufpp,
            ub4         **alenpp,
            ub1         *piecep,
            dvoid       **indpp,
            ub2         **rcodepp
            );
    
    sb4 onCallbackInBind(
            OCIBind*    pBind,
            ub4         nIterator,
            ub4         _index,
            dvoid**     ppvBuffer,
            ub4*        pnActualLength,
            ub1*        pnPiece,
            dvoid**     ppvIndicator
            );
    
    sb4 onCallbackOutBind(
            OCIBind*    pBind,
            ub4         nIterator,
            ub4         _index,
            dvoid**     ppvBuffer,
            ub4**       ppnActualLength,
            ub1*        pnPiece,
            dvoid**     ppvIndicator,
            ub2**       ppnReturnCode
            );
};
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_OCI_PARAM_H__