record_manager.h

Go to the documentation of this file.

 
#ifndef _RECORD_MANAGER_H_
#define _RECORD_MANAGER_H_
#define INF 1000000
 
#include <cstdio>
#include <iostream>
#include <string>
#include <vector>
#include <sstream>
#include "share/data_t.h"
#include "share/config.h"
#include "index/Index.h"
#include "catalog/catalog.h"
#include "share/err_type.h"
#include "buffer/buffer_manager.h"
#include "share/singleton.h"
 
 
struct record_page{
    int tuple_num;
    db_size_t record_bytes;
    DiskTuple tuples[];
 
    DiskTuple& tuple_at(int offset){
        if (offset == 0) return tuples[0];
        else{
            if (offset >= tuple_num){
                throw;
            }
            else{
                char* start = (char*)tuples;
                start = start + offset * tuples[0].getBytes();
                return *((DiskTuple*)start);
            }
        }
    }
 
    template<class T>
    DiskTuple& operator[](T offset) = delete;
};
 
 
std::vector<Index_t> Union(const std::vector<Index_t>& a, const std::vector<Index_t>& b);
 
class RecordManager {
public:
    RecordManager(BufferManager *bfm, CatalogManager *clm, IndexManager *idm): buffer_manager(bfm), catalog_manager(clm), index_manager(idm){}
    void CreateTableFile(const std::string& table_name);
    void DropTableFile(const std::string& table_name);
    void InsertRecord(std::string table_name , const MemoryTuple& tuple);
    int DeleteRecord(std::string table_name);
    int DeleteRecord(std::string table_path, std::vector<Where> where);
 
    std::vector<MemoryTuple> SelectRecord(std::string table_name);
    std::vector<MemoryTuple> SelectRecord(const std::string& table_path , const std::vector<std::string>& target_attr);
    std::vector<MemoryTuple> SelectRecord(std::string table_path , std::vector<Where> where);
    std::vector<MemoryTuple> SelectRecord(std::string table_name , const std::vector<std::string>& target_attr , std::vector<Where> where);
    void CreateIndex(std::string table_name , const std::string& target_attr);
private:
    static int getBlockNum(std::string &table_name);
    //insertRecord的辅助函数
//    static int getTupleLength(DiskTuple tuples);
    
    //判断插入的记录是否和其他记录冲突
    bool isConflict(const MemoryTuple &v, const std::string& tableName, int check_index);
    //带索引查找
    void searchWithIndex(std::string &table_name , std::string &target_attr , const Where& where , std::vector<Index_t>& record_ids);
 
//    void deleteInIndex(std::string &table_path, std::string &target_attr, std::ve)
    //在块中进行条件删除
    int conditionDeleteInBlock(const std::string& table_name , const std::vector<Index_t>& record_id);
    void DeleteInBlock(std::string table_name , int block_id , const Attribute& attr , int index , Where where, std::vector<Index_t>& record_ids);
    //在块中进行条件查询
    void conditionSelectInBlock(std::string table_name , const std::vector<Index_t>& record_id , std::vector<MemoryTuple>& v);
    void SelectInBlock(std::string table_name , int block_id , const Attribute& attr , int index , Where where , std::vector<Index_t>& record_ids);
    BufferManager *buffer_manager;
    CatalogManager *catalog_manager;
    IndexManager *index_manager;
};
 
#endif