PgParam.h

Go to the documentation of this file.

#ifndef __DCL_PG_PARAM_H__
#define __DCL_PG_PARAM_H__      20250403
 
__DCL_BEGIN_NAMESPACE
 
class PgParam : public SQL::Param
{
    DECLARE_CLASSINFO(PgParam)
protected:
    sqlvar_t*       __sqlvar;
    short           __indicator;
    union {
        int32_t     i32;
        int64_t     i64;
        uint32_t    u32;
        uint64_t    u64;
        float       f32;
        double      f64;
        numeric     nu;
        date        dt;
        timestamp   ts;
        interval    ival;
    } __data;
    ByteString __bytes;
 
protected:
    void setErrorStatus(SQL::Error _error, long _SQLCODE,   
                const wchar_t* _filename, int _line);
    void setErrorStatus(const ByteString& _message,
                const wchar_t* _filename, int _line);
 
    PgQuery* query() const;
 
public:
    bool init(SQL::Query* _query, sqlvar_t* _sqlvar);
#if __DCL_DEBUG
    void onBeforeExecute();
#endif
    bool onAfterExecute();
 
    PgParam();
    virtual ~PgParam();
 
    // interfaces
    virtual const wchar_t* serverDataTypeName() const;
    virtual void setNull();
    virtual bool __setData(
            _CONST void* _pv,
            size_t _size,
            SQL::DataType _dataType,
            SQL::DataType _assignType
            );
};
 
inline void PgParam::setErrorStatus(SQL::Error _error, long _SQLCODE,  
                const wchar_t* _filename, int _line)
{
    ((PgConnection*)Param::connection())->setErrorStatus(
                _error,
                _SQLCODE,
                _filename, 
                _line
                );
}
 
inline void PgParam::setErrorStatus(const ByteString& _message,
                        const wchar_t* _filename, int _line)
{
    ((PgConnection*)Param::connection())->setErrorStatus(
                _message,
                _filename,
                _line
                );
}
 
inline PgQuery* PgParam::query() const
{
    return (PgQuery*)Param::__queryHandle;
}
 
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_PG_PARAM_H__