PersistentCatCache.h

Go to the documentation of this file.

#ifndef CATALOG_PERSISTENTCATCACHE_H
#define CATALOG_PERSISTENTCATCACHE_H
 
#include "tdb.h"
 
#include "catalog/CatCacheBase.h"
#include "storage/BufferManager.h"
#include "storage/FileManager.h"
#include "storage/Record.h"
#include "storage/Table.h"
 
namespace taco {
 
class PersistentCatCache: public CatCacheBase<PersistentCatCache> {
public:
    PersistentCatCache();
 
private:
    FileId CreateCatalogFile(bool format_heapfile);
 
    struct FileHandle {
        // the file ID of the table
        FileId                  m_fid;
 
        // the heap file, this might be nullptr initially
        std::unique_ptr<Table>  m_table;
    };
 
    FileHandle OpenCatalogFile(FileId fid, const TableDesc *tabdesc);
 
    void CloseCatalogFile(FileHandle &fh);
 
    typedef ScopedBufferId PageHandle;
 
    PageHandle GetFirstPage(FileHandle &fh, char **pagebuf);
 
    void MarkPageDirty(PageHandle &pghandle);
 
    void ReleasePage(PageHandle &pghandle);
 
    void AppendRecord(FileHandle &fh, Record &rec);
 
    typedef Table::Iterator CatFileIterator;
 
    CatFileIterator IterateCatEntry(FileHandle &fh);
 
    CatFileIterator IterateCatEntryFrom(FileHandle &fh, RecordId rid);
 
    bool NextCatEntry(CatFileIterator &iter);
 
    const char *GetCurrentCatEntry(CatFileIterator &iter);
 
    RecordId GetCurrentCatEntryRecordId(CatFileIterator &iter);
 
    void UpdateCurrentCatEntry(CatFileIterator &iter, Record &rec);
 
    void EndIterateCatEntry(CatFileIterator &iter);
 
    void _CreateTableIfNullForFileHandle(FileHandle &fh, FieldOffset reclen);
 
    PageNumber  m_dbmetapg_pid;
 
    friend class CatCacheBase<PersistentCatCache>;
};
 
extern template class CatCacheBase<PersistentCatCache>;
 
}   // namespace taco
 
#endif      // CATALOG_PERSISTENTCATCACHE_H