Parser::CreateDBStmt Class Reference

#include <ParserNode.h>

Inheritance diagram for Parser::CreateDBStmt:

Collaboration diagram for Parser::CreateDBStmt:

Public Member Functions
	CreateDBStmt (const rapidjson::Value &payload)
	CreateDBStmt (std::string *n, std::list< NameValueAssign * > *l, const bool if_not_exists)
void	execute (const Catalog_Namespace::SessionInfo &session, bool read_only_mode) override
Public Member Functions inherited from Parser::DDLStmt
void	setColumnDescriptor (ColumnDescriptor &cd, const ColumnDef *coldef)
Public Member Functions inherited from Parser::Node
virtual	~Node ()

Private Attributes
std::unique_ptr< std::string >	db_name_
std::list< std::unique_ptr < NameValueAssign > >	options_
bool	if_not_exists_

Detailed Description

Definition at line 1927 of file ParserNode.h.

Constructor & Destructor Documentation

Parser::CreateDBStmt::CreateDBStmt

(

const rapidjson::Value &

payload

)

Definition at line 6545 of file ParserNode.cpp.

References CHECK, db_name_, if_not_exists_, json_bool(), json_str(), options_, and Parser::anonymous_namespace{ParserNode.cpp}::parse_options().

                                                        {
  CHECK(payload.HasMember("name"));
  db_name_ = std::make_unique<std::string>(json_str(payload["name"]));

  if_not_exists_ = false;
  if (payload.HasMember("ifNotExists")) {
    if_not_exists_ = json_bool(payload["ifNotExists"]);
  }

  parse_options(payload, options_);
}

Here is the call graph for this function:

Parser::CreateDBStmt::CreateDBStmt ( std::string *  n, std::list< NameValueAssign * > *  l, const bool  if_not_exists  )

inline

Definition at line 1931 of file ParserNode.h.

References options_.

      : db_name_(n), if_not_exists_(if_not_exists) {
    if (l) {
      for (const auto e : *l) {
        options_.emplace_back(e);
      }
      delete l;
    }
  }

Member Function Documentation

void Parser::CreateDBStmt::execute ( const Catalog_Namespace::SessionInfo &  session, bool  read_only_mode  )

overridevirtual

Implements Parser::DDLStmt.

Definition at line 6557 of file ParserNode.cpp.

References Parser::checkStringLiteral(), db_name_, legacylockmgr::ExecutorOuterLock, Catalog_Namespace::SessionInfo::get_currentUser(), legacylockmgr::LockMgr< MutexType, KeyType >::getMutex(), if_not_exists_, Catalog_Namespace::UserMetadata::isSuper, options_, and Catalog_Namespace::UserMetadata::userId.

Referenced by heavydb.cursor.Cursor::executemany().

                                                {
  if (read_only_mode) {
    throw std::runtime_error("CREATE DATABASE invalid in read only mode.");
  }
  if (!session.get_currentUser().isSuper) {
    throw std::runtime_error(
        "CREATE DATABASE command can only be executed by super user.");
  }

  const auto execute_write_lock =
      heavyai::unique_lock<legacylockmgr::WrapperType<heavyai::shared_mutex>>(
          *legacylockmgr::LockMgr<heavyai::shared_mutex, bool>::getMutex(
              legacylockmgr::ExecutorOuterLock, true));

  Catalog_Namespace::DBMetadata db_meta;
  if (SysCatalog::instance().getMetadataForDB(*db_name_, db_meta) && if_not_exists_) {
    return;
  }
  int ownerId = session.get_currentUser().userId;
  if (!options_.empty()) {
    for (auto& p : options_) {
      if (boost::iequals(*p->get_name(), "owner")) {
        checkStringLiteral("Owner name", p);
        const std::string* str =
            static_cast<const StringLiteral*>(p->get_value())->get_stringval();
        Catalog_Namespace::UserMetadata user;
        if (!SysCatalog::instance().getMetadataForUser(*str, user)) {
          throw std::runtime_error("User " + *str + " does not exist.");
        }
        ownerId = user.userId;
      } else {
        throw std::runtime_error("Invalid CREATE DATABASE option " + *p->get_name() +
                                 ". Only OWNER supported.");
      }
    }
  }
  SysCatalog::instance().createDatabase(*db_name_, ownerId);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

std::unique_ptr<std::string> Parser::CreateDBStmt::db_name_

private

Definition at line 1944 of file ParserNode.h.

Referenced by CreateDBStmt(), and execute().

bool Parser::CreateDBStmt::if_not_exists_

private

Definition at line 1946 of file ParserNode.h.

Referenced by CreateDBStmt(), and execute().

std::list<std::unique_ptr<NameValueAssign> > Parser::CreateDBStmt::options_

private

Definition at line 1945 of file ParserNode.h.

Referenced by CreateDBStmt(), and execute().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/Parser/ParserNode.h
• /home/jenkins-slave/workspace/core-os-doxygen/Parser/ParserNode.cpp