DefaultDatabase.h

Go to the documentation of this file.

/*****************************************************************************
 *                                                                           *
 *  Copyright 2018 Rice University                                           *
 *                                                                           *
 *  Licensed under the Apache License, Version 2.0 (the "License");          *
 *  you may not use this file except in compliance with the License.         *
 *  You may obtain a copy of the License at                                  *
 *                                                                           *
 *      http://www.apache.org/licenses/LICENSE-2.0                           *
 *                                                                           *
 *  Unless required by applicable law or agreed to in writing, software      *
 *  distributed under the License is distributed on an "AS IS" BASIS,        *
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. *
 *  See the License for the specific language governing permissions and      *
 *  limitations under the License.                                           *
 *                                                                           *
 *****************************************************************************/

#ifndef DEFAULTDATABASE_H
#define DEFAULTDATABASE_H

#include "Configuration.h"
#include "DataTypes.h"
#include "PDBLogger.h"
#include "UserType.h"
#include "SharedMem.h"
#include "PageCache.h"
#include "PageCircularBuffer.h"

#include <map>
#include <pthread.h>
#include <boost/filesystem.hpp>
using namespace std;

// create a smart pointer for DummyDatabase objects
class DefaultDatabase;
typedef shared_ptr<DefaultDatabase> DefaultDatabasePtr;
;

class DefaultDatabase {

public:
    DefaultDatabase(NodeID nodeId,
                    DatabaseID dbId,
                    string dbName,
                    ConfigurationPtr conf,
                    pdb::PDBLoggerPtr logger,
                    SharedMemPtr shm,
                    string metaDBPath,
                    vector<string>* dataDBPaths,
                    PageCachePtr cache,
                    PageCircularBufferPtr flushBuffer);
    ~DefaultDatabase();


    bool initializeFromDBDir(boost::filesystem::path dbDir);

    bool initializeFromMetaDBDir(boost::filesystem::path metaDBDir);

    bool addType(TypePtr type);

    bool addType(string name, UserTypeID id);


    TypePtr getType(UserTypeID typeId);


    bool removeType(UserTypeID typeID);

    DatabaseID getDatabaseID();

    string getDatabaseName();

    void flush();

    map<UserTypeID, TypePtr>* getTypes();


protected:
    void addTypeBySequenceFiles(string name, UserTypeID id, boost::filesystem::path typeDir);

    void addTypeByPartitionedFiles(string name, UserTypeID id, boost::filesystem::path metaTypeDir);

    void clearType(UserTypeID typeId, string typeName);

    string encodeTypePath(string dbPath, UserTypeID typeId, string typeName);

private:
    ConfigurationPtr conf;
    map<UserTypeID, TypePtr>* types;
    string dbName;
    DatabaseID dbId;
    NodeID nodeId;
    pdb::PDBLoggerPtr logger;
    pthread_mutex_t typeOpLock;
    string metaDBPath;
    vector<string>* dataDBPaths;
    SharedMemPtr shm;
    PageCachePtr cache;
    PageCircularBufferPtr flushBuffer;
};


#endif /* DEFAULTDATABASE_H */