EmbeddedDatabase::DBEngineImpl Class Reference

Inheritance diagram for EmbeddedDatabase::DBEngineImpl:

Collaboration diagram for EmbeddedDatabase::DBEngineImpl:

Public Member Functions
void	reset ()
void	executeDDL (const std::string &query)
Cursor *	executeDML (const std::string &query)
	DBEngineImpl (const std::string &base_path)
Public Member Functions inherited from EmbeddedDatabase::DBEngine
void	reset ()
void	executeDDL (std::string query)
Cursor *	executeDML (std::string query)

Public Attributes
const int	CALCITEPORT = 3279
const std::string	OMNISCI_DEFAULT_DB = "omnisci"
const std::string	OMNISCI_ROOT_USER = "admin"
const std::string	OMNISCI_DATA_PATH = "//mapd_data"

Private Attributes
std::string	base_path_
std::shared_ptr< Data_Namespace::DataMgr >	data_mgr_
Catalog_Namespace::DBMetadata	database_
Catalog_Namespace::UserMetadata	user_
QueryRunner::QueryRunner *	query_runner_
std::vector< CursorImpl * >	cursors_

Additional Inherited Members
Static Public Member Functions inherited from EmbeddedDatabase::DBEngine
static DBEngine *	create (std::string path)
Protected Member Functions inherited from EmbeddedDatabase::DBEngine
	DBEngine ()

Detailed Description

DBEngine internal implementation

Definition at line 91 of file DBEngine.cpp.

Constructor & Destructor Documentation

DBEngineImpl()

EmbeddedDatabase::DBEngineImpl::DBEngineImpl ( const std::string &  base_path )

inline

Definition at line 121 of file DBEngine.cpp.

References CALCITEPORT, CPU, Catalog_Namespace::Catalog::get(), QueryRunner::QueryRunner::init(), and Catalog_Namespace::SysCatalog::instance().

      : base_path_(base_path), query_runner_(nullptr) {
    if (!boost::filesystem::exists(base_path_)) {
      std::cerr << "Catalog basepath " + base_path_ + " does not exist.\n";
      // TODO: Create database if it does not exist
    } else {
      SystemParameters system_parameters;
      std::string data_path = base_path_ + OMNISCI_DATA_PATH;
      data_mgr_ = std::make_shared<Data_Namespace::DataMgr>(
          data_path, system_parameters, false, 0);
      auto calcite = std::make_shared<Calcite>(-1, CALCITEPORT, base_path_, 1024, 5000);
      auto& sys_cat = Catalog_Namespace::SysCatalog::instance();
      sys_cat.init(base_path_, data_mgr_, {}, calcite, false, false, {});
      if (!sys_cat.getSqliteConnector()) {
        std::cerr << "SqliteConnector is null " << std::endl;
      } else {
        sys_cat.getMetadataForDB(OMNISCI_DEFAULT_DB, database_);  // TODO: Check
        auto catalog = Catalog_Namespace::Catalog::get(base_path_,
                                                       database_,
                                                       data_mgr_,
                                                       std::vector<LeafHostInfo>(),
                                                       calcite,
                                                       false);
        sys_cat.getMetadataForUser(OMNISCI_ROOT_USER, user_);
        auto session = std::make_unique<Catalog_Namespace::SessionInfo>(
            catalog, user_, ExecutorDeviceType::CPU, "");
        query_runner_ = QueryRunner::QueryRunner::init(session);
      }
    }
  }

Here is the call graph for this function:

Member Function Documentation

executeDDL()

void EmbeddedDatabase::DBEngineImpl::executeDDL ( const std::string &  query )

inline

Definition at line 106 of file DBEngine.cpp.

Referenced by EmbeddedDatabase::DBEngine::executeDDL().

                                          {
    if (query_runner_ != nullptr) {
      query_runner_->runDDLStatement(query);
    }
  }

Here is the caller graph for this function:

executeDML()

Cursor* EmbeddedDatabase::DBEngineImpl::executeDML ( const std::string &  query )

inline

Definition at line 112 of file DBEngine.cpp.

References CPU.

Referenced by EmbeddedDatabase::DBEngine::executeDML().

                                             {
    if (query_runner_ != nullptr) {
      auto rs = query_runner_->runSQL(query, ExecutorDeviceType::CPU);
      cursors_.emplace_back(new CursorImpl(rs, data_mgr_));
      return cursors_.back();
    }
    return nullptr;
  }

Here is the caller graph for this function:

reset()

void EmbeddedDatabase::DBEngineImpl::reset ( )

inline

Definition at line 99 of file DBEngine.cpp.

Referenced by EmbeddedDatabase::DBEngine::reset().

               {
    // TODO: Destroy all cursors in the cursors_
    if (query_runner_ != nullptr) {
      query_runner_->reset();
    }
  }

Here is the caller graph for this function:

Member Data Documentation

base_path_

std::string EmbeddedDatabase::DBEngineImpl::base_path_

private

Definition at line 153 of file DBEngine.cpp.

CALCITEPORT

const int EmbeddedDatabase::DBEngineImpl::CALCITEPORT = 3279

Definition at line 94 of file DBEngine.cpp.

cursors_

std::vector<CursorImpl*> EmbeddedDatabase::DBEngineImpl::cursors_

private

Definition at line 158 of file DBEngine.cpp.

data_mgr_

std::shared_ptr<Data_Namespace::DataMgr> EmbeddedDatabase::DBEngineImpl::data_mgr_

private

Definition at line 154 of file DBEngine.cpp.

database_

Catalog_Namespace::DBMetadata EmbeddedDatabase::DBEngineImpl::database_

private

Definition at line 155 of file DBEngine.cpp.

OMNISCI_DATA_PATH

const std::string EmbeddedDatabase::DBEngineImpl::OMNISCI_DATA_PATH = "//mapd_data"

Definition at line 97 of file DBEngine.cpp.

OMNISCI_DEFAULT_DB

const std::string EmbeddedDatabase::DBEngineImpl::OMNISCI_DEFAULT_DB = "omnisci"

Definition at line 95 of file DBEngine.cpp.

OMNISCI_ROOT_USER

const std::string EmbeddedDatabase::DBEngineImpl::OMNISCI_ROOT_USER = "admin"

Definition at line 96 of file DBEngine.cpp.

query_runner_

QueryRunner::QueryRunner* EmbeddedDatabase::DBEngineImpl::query_runner_

private

Definition at line 157 of file DBEngine.cpp.

user_

Catalog_Namespace::UserMetadata EmbeddedDatabase::DBEngineImpl::user_

private

Definition at line 156 of file DBEngine.cpp.

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/Embedded/DBEngine.cpp