DBresultIterator.h

#pragma once

#include <libutl/DBconnection.h>
#include <libutl/DBresult.h>


UTL_NS_BEGIN;



class DBresultIterator : public Object
{
    UTL_CLASS_DECL(DBresultIterator, Object);

public:
    DBresultIterator(DBconnection* connection, const String& query, uint_t limit = uint_t_max)
    {
        init();
        initialize(connection, query, limit);
    }

    void initialize(DBconnection* connection, const String& query, uint_t limit = uint_t_max);

    bool
    ok() const
    {
        return ((_result != nullptr) && (_result->status() == dbr_ok));
    }

    uint_t
    status() const
    {
        ASSERTD(_result != nullptr);
        return _result->status();
    }

    const String&
    errorMsg() const
    {
        ASSERTD(_result != nullptr);
        return _result->errorMsg();
    }

    uint_t
    numFields() const
    {
        ASSERTD(_result != nullptr);
        return _result->numFields();
    }

    bool
    end() const
    {
        ASSERTD(_result != nullptr);
        return (_row == _result->numRows());
    }

    bool isNull(uint_t field) const;

    const uint64_t* values() const;

    uint64_t field(uint_t field) const;

    char* getString(uint_t fieldIdx) const;

    bool getBool(uint_t fieldIdx) const;

    int getInt32(uint_t fieldIdx) const;

    int64_t getInt64(uint_t fieldIdx) const;

    double getDouble(uint_t fieldIdx) const;

    time_t getDateTime(uint_t fieldIdx) const;

    uint_t row() const;

    void seek(uint_t row);

    void next();

    DBresultIterator& operator++()
    {
        next();
        return *this;
    }

private:
    void init();
    void
    deInit()
    {
    }
    void execute(uint_t page);

private:
    DBconnection* _connection;
    const DBresult* _result;
    String _query;
    uint_t _limit;
    uint_t _page;
    uint_t _row;
};


UTL_NS_END;