pqxxcursor.h

/* This file is part of the KDE project
   Copyright (C) 2003 Adam Pigg <adam@piggz.co.uk>
 
   This program is free software; you can redistribute it and/or
   modify it under the terms of the GNU Library General Public
   License as published by the Free Software Foundation; either
   version 2 of the License, or (at your option) any later version.
 
   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   Library General Public License for more details.
 
   You should have received a copy of the GNU Library General Public License
   along with this program; see the file COPYING.  If not, write to
   the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
 * Boston, MA 02110-1301, USA.
*/
 
#ifndef KEXIDB_CURSOR_PQXX_H
#define KEXIDB_CURSOR_PQXX_H
 
#include "config.h"
 
#include <kexidb/cursor.h>
#include <kexidb/connection.h>
#include <kexidb/utils.h>
 
#if 0
#include <pqxx/all.h>
#else
#include <pqxx/pqxx>
#endif
 
#include <pqxx/binarystring>
#include <migration/pqxx/pg_type.h>
 
namespace KexiDB {
 
class pqxxSqlCursor: public Cursor {
public:
    virtual ~pqxxSqlCursor();
 
    virtual TQVariant value(uint i);
    virtual const char** rowData() const;
    virtual void storeCurrentRow(RowData &data) const;
 
//TODO      virtual const char *** bufferData()
        
//TODO  virtual int serverResult() const;
        
//TODO  virtual TQString serverResultName() const;
 
//TODO  virtual TQString serverErrorMsg() const;
        
protected:
    pqxxSqlCursor(Connection* conn, const TQString& statement = TQString(), uint options = NoOptions );
    pqxxSqlCursor(Connection* conn, QuerySchema& query, uint options = NoOptions );
    virtual void drv_clearServerResult();
    virtual void drv_appendCurrentRecordToBuffer();
    virtual void drv_bufferMovePointerNext();
    virtual void drv_bufferMovePointerPrev();
    virtual void drv_bufferMovePointerTo(TQ_LLONG to);
    virtual bool drv_open();
    virtual bool drv_close();
    virtual void drv_getNextRecord();
    virtual void drv_getPrevRecord();
 
private:
    pqxx::result* m_res;
//  pqxx::nontransaction* m_tran;
    pqxx::connection* my_conn;
    TQVariant pValue(uint pos)const;
    bool m_implicityStarted : 1;
    //TQByteArray processBinaryData(pqxx::binarystring*) const;
    friend class pqxxSqlConnection;
};
 
inline TQVariant pgsqlCStrToVariant(const PQXX_FIELD_CLASS& r)
{
    switch(r.type())
    {
        case BOOLOID:
            return TQString::fromLatin1(r.c_str(), r.size())=="true"; //TODO check formatting
        case INT2OID:
        case INT4OID:
        case INT8OID:
            return r.as(int());
        case FLOAT4OID:
        case FLOAT8OID:
        case NUMERICOID:
            return r.as(double());
        case DATEOID:
            return TQString::fromUtf8(r.c_str(), r.size()); //TODO check formatting
        case TIMEOID:
            return TQString::fromUtf8(r.c_str(), r.size()); //TODO check formatting
        case TIMESTAMPOID:
            return TQString::fromUtf8(r.c_str(), r.size()); //TODO check formatting
        case BYTEAOID:
            return KexiDB::pgsqlByteaToByteArray(r.c_str(), r.size());
        case BPCHAROID:
        case VARCHAROID:
        case TEXTOID:
            return TQString::fromUtf8(r.c_str(), r.size()); //utf8?
        default:
            return TQString::fromUtf8(r.c_str(), r.size()); //utf8?
    }
}
 
}
 
#endif