relopsmgr.h

Go to the documentation of this file.

/*
 * SwatDB
 *
 * @authors: See Contributors.doc for code contributors
 *
 * Copyright (c) 2020, 2025 Swarthmore College Computer Science Department
 * Swarthmore PA, Professors Tia Newhall, Ameet Soni
 */
 
#ifndef  _SWATDB_RELOPSMGR_H_
#define  _SWATDB_RELOPSMGR_H_
 
 
 
#include <string>
#include <vector>
#include <mutex>
#include "swatdb_types.h"
 
class FileManager;
class Catalog;
class Schema;
class File;
class RelationFile;
class HeapFile;
class HeapPage;
class Page;
class HeapFileScanner;
class Record;
class Data;
class Key;
 
extern std::string relopsdir;
 
// @@@@ SWATDB_ASSIGNMENT: NOTEMSG Do not modify this definition
 
class RelOpsManager {
 
  public:
 
    RelOpsManager(FileManager *file_mgr, BufferManager *buf_mgr, 
        Catalog *catalog, const char *result_path);
 
    HeapFile *project(FileId rel_id, std::vector<FieldId> fields);
 
    HeapFile *select(SelectType stype, 
                     FileId rel_id, std::vector<FieldId> fields, 
                     std::vector<Comp> comps, std::vector<void *> values, 
                     FileId index_id = INVALID_FILE_ID);
 
 
    HeapFile *join(JoinType jtype, FileId o_fid, FileId i_fid, 
                   std::vector<FieldId> outer_field_ids, 
                   std::vector<FieldId> inner_field_ids,  
                   std::uint32_t block_size = 0);
 
 
    HeapFile *join(JoinType jtype, FileId o_fid, FileId i_fid,
                   std::uint32_t num_buckets, 
                   std::vector<FieldId> outer_field_ids, 
                   std::vector<FieldId> inner_field_ids, 
                   std::uint32_t num_threads = 0);
 
    bool checkFilesEqual(FileId file1_id, FileId file2_id);
 
    
   private:
    /*
     * Pointer to the file manager layer of the DBMS
     */
    FileManager *file_mgr;
 
    /*
     * Pointer to the buffer manager layer of the DBMS
     */
    BufferManager *buf_mgr;
    
    /*
     * Pointer to the Catalog of the DBMS
     */
    Catalog *catalog;
 
    int result_num;
 
    FileId _createJoinRes(FileId outer_fid, FileId inner_fid, 
        std::vector<FieldId> o_fields, std::vector<FieldId> i_fields);
     
    FileId _createProjectRes(Schema *rel_schema, 
                             std::vector<FieldId> fields);
 
    FileId _createResultFile(Schema *schema);
 
};
 
#endif