PqQuery.h

Go to the documentation of this file.

#ifndef __DCL_PQ_QUERY_H__
#define __DCL_PQ_QUERY_H__      20260106
 
__DCL_BEGIN_NAMESPACE
 
#define __FORMAT_TEXT               0
#define __FORMAT_BINARY             1
#define __FORMAT_DEFAULT            __FORMAT_TEXT
#define __CURSOR_FETCH_DEFAULT      100
#define __CURSOR_ENABLED(_conn) (_conn->cursor() >= 0)
 
class PqField;
class PqParam;
 
class PqQuery : public SQL::Query
{
    DECLARE_CLASSINFO(PqQuery)
public:
    PqConnection* conn() const;
 
    bool getValue(int _fieldIndex, const char*& _value, int& _length) const;
    bool setValue(int _paramIndex, Oid _type, const void* _value, unsigned _length, int _format);
 
protected:
    int         __stmtNo;
    ByteString  __stmtID;
    ByteString  __cursorID;
    ByteString  __query;
    int         __nfields;
 
    //int types[Query::__paramCount];
    //char* values[Query::__paramCount];
    //int lengths[Query::__paramCount];
    //int formats[Query::__paramCount];
    void*       __inBINDs;
    PqField* __fields;
    PqParam* __params;
 
    PGresult*   __res;
    int         __row;
 
protected:
    bool reset();
 
public:
    PqQuery(PqConnection* pConnection);
    virtual ~PqQuery();
    virtual void __destroy();
    virtual bool __prepare(
        const char* _sql, size_t _sqllen, size_t _paramCount
    );
 
    virtual bool __execute();
    virtual bool __fetch();
 
    virtual bool __getField(size_t _index, SQL::Field** _fieldHandleOut);
    virtual bool __getParam(size_t _index, SQL::Param** _paramHandleOut);
};
 
inline PqConnection* PqQuery::conn() const
{ 
    return (PqConnection*)Query::__connHandle; 
}
 
__DCL_END_NAMESPACE
 
#endif  // __DCL_PQ_QUERY_H__