ICRecordSet.h

#pragma once
#include "SQLStatement.h"
struct sqlite3_stmt;
struct sqlite3;

namespace ParaInfoCenter
{
    class CICDBManager;
    class DBEntity;

    class PE_CORE_DECL CICRecordSetItem
    {
    public:
        enum IC_DATA_TYPE{
            _NONE,_INT,_FLOAT, _INT64,_TEXT,_TEXT16,_BLOB
        };
        //they will return 0 or NULL if the index is not valid
        //you can get data of the same item several times without any performance penalty 
        operator int();
        operator bool();
        operator DWORD();
        operator int64();
        operator char*();
        operator char16_t*();
        operator void*();
        operator double();
        operator float();
        const char *GetNameA();
        const char16_t *GetName();
        CICRecordSetItem(int index,sqlite3_stmt *stmt);
        ~CICRecordSetItem();
        CICRecordSetItem& operator =(const CICRecordSetItem&);
        CICRecordSetItem& operator =(const int&);
        CICRecordSetItem& operator =(const int64&);
        CICRecordSetItem& operator =(const bool&);
        CICRecordSetItem& operator =(const double&);
        CICRecordSetItem& operator =(const float&);
        CICRecordSetItem& operator =(const char*);
        CICRecordSetItem& operator =(const char16_t*);
        void SetBlob(const void *value,int nlength);
        friend class CICRecordSet;
        int GetDataLength(){return m_length;};
    protected:
        void CleanOldData();
        int m_index;
        sqlite3_stmt *m_stmt;
        bool m_needInit;
        int m_type;
        char *m_sName;
        char16_t *m_wName;
        int m_length;
        union{
            void *bData;
            int iData;
            int64 nDataInt64;
            double fData;
            char *sData;
            char16_t *wData;
        };
    };

    class CICRecordSet : public CSQLStatement
    {
        friend class DBEntity;
    public:
        static int SOK;
        static int SEOF;
        static int SBOF;
        PE_CORE_DECL CICRecordSetItem& operator[](int index);
        PE_CORE_DECL void Initialize(sqlite3_stmt* stmt);
        PE_CORE_DECL void Initialize(const char* sql);
        PE_CORE_DECL void Initialize(const char16_t *sql);
        PE_CORE_DECL void Release();
        //return 0 means ok, otherwise sth is wrong, either eof or bof or other error
        PE_CORE_DECL int NextRow();
        PE_CORE_DECL int ColumnCount(){return m_columnNum;}
        PE_CORE_DECL const char* GetColumnName(int index);
        PE_CORE_DECL const char16_t* GetColumnName16(int index);

        PE_CORE_DECL int64 GetLastInsertRowID();
        PE_CORE_DECL ~CICRecordSet();
        //void operator delete(void *p);
    protected:
        /*      CICRecordSet(sqlite3_stmt* stmt);
        CICRecordSet(const char *sql);
        CICRecordSet(const char16_t* sql);*/
        CICRecordSet();
        vector<CICRecordSetItem*> m_items;

        CICRecordSetItem* m_empty;
        bool m_bUpdatable;
        int m_columnNum;//number of columns in a row

    };
}