sqlite3database.h

Go to the documentation of this file.

#pragma once
#ifndef DB_SQLITE3DATABASE_H
#define DB_SQLITE3DATABASE_H
//------------------------------------------------------------------------------
#include "core/config.h"
#include "attr/attribute.h"
#include "db/database.h"
#include "sqlite3.h"
 
//------------------------------------------------------------------------------
namespace Attr
{
    // some SQLite-internal names
    DeclareAttrString(name);
    DeclareAttrString(type);
    DeclareAttrInt(cid);
    DeclareAttrInt(notnull);
    DeclareAttrBlob(dflt_value);
    DeclareAttrBool(pk);
    DeclareAttrInt(seq);
    DeclareAttrBool(unique);
    DeclareAttrInt(seqno);
}
 
//------------------------------------------------------------------------------
namespace Db
{
class Sqlite3Database : public Database
{
    __DeclareClass(Sqlite3Database);
public:
    enum TempStore
    {
        File,
        Memory,
    };

    Sqlite3Database();
    virtual ~Sqlite3Database();

    void SetCacheNumPages(SizeT numCachePages);
    SizeT GetCacheNumPages() const;
    void SetTempStore(TempStore s);
    TempStore GetTempStore() const;
    void SetSynchronousMode(bool b);
    bool GetSynchronousMode() const;
    void SetBusyTimeout(int ms);
    int GetBusyTimeout() const;

    virtual bool Open();
    virtual void Close();

    virtual bool AttachDatabase(const IO::URI& uri, const Util::String& dbName);
    virtual void DetachDatabase(const Util::String& dbName);
    virtual void BeginTransaction();
    virtual void EndTransaction();
    virtual bool IsInTransaction() const;

    sqlite3* GetSqliteHandle() const;
    
    virtual void CopyInMemoryDatabaseToFile(const IO::URI& fileUri);
 
private:
    void ReadTableLayouts();
    void RegisterAttributes(Ptr<Table>& attrTable);
 
    SizeT cacheNumPages;
    TempStore tempStore;
    bool syncMode;
    bool inTransaction;
    int busyTimeout;
    sqlite3* sqliteHandle;
    Ptr<Command> beginTransactionCmd;
    Ptr<Command> endTransactionCmd;
};
 
//------------------------------------------------------------------------------
inline sqlite3*
Sqlite3Database::GetSqliteHandle() const
{
    n_assert(0 != this->sqliteHandle);
    return this->sqliteHandle;
}
 
//------------------------------------------------------------------------------
inline void
Sqlite3Database::SetCacheNumPages(SizeT p)
{
    n_assert(!this->IsOpen());
    n_assert(p > 0);
    this->cacheNumPages = p;
}
 
//------------------------------------------------------------------------------
inline SizeT
Sqlite3Database::GetCacheNumPages() const
{
    return this->cacheNumPages;
}
 
//------------------------------------------------------------------------------
inline void
Sqlite3Database::SetTempStore(TempStore s)
{
    this->tempStore = s;
}
 
//------------------------------------------------------------------------------
inline Sqlite3Database::TempStore
Sqlite3Database::GetTempStore() const
{
    return this->tempStore;
}
 
//------------------------------------------------------------------------------
inline void
Sqlite3Database::SetSynchronousMode(bool b)
{
    this->syncMode = b;
}
 
//------------------------------------------------------------------------------
inline bool
Sqlite3Database::GetSynchronousMode() const
{
    return this->syncMode;
}
 
//------------------------------------------------------------------------------
inline void
Sqlite3Database::SetBusyTimeout(int ms)
{
    this->busyTimeout = ms;
}
 
//------------------------------------------------------------------------------
inline int
Sqlite3Database::GetBusyTimeout() const
{
    return this->busyTimeout;
}
 
//------------------------------------------------------------------------------
inline bool
Sqlite3Database::IsInTransaction() const
{
    return this->inTransaction;
}
 
} // namespace Db
//------------------------------------------------------------------------------
#endif