Catalog_Namespace::SessionInfo Class Reference

#include <SessionInfo.h>

Collaboration diagram for Catalog_Namespace::SessionInfo:

Public Member Functions
	SessionInfo (std::shared_ptr< MapDHandler > mapdHandler, std::shared_ptr< Catalog > cat, const UserMetadata &user, const ExecutorDeviceType t, const std::string &sid)
	SessionInfo (std::shared_ptr< Catalog > cat, const UserMetadata &user, const ExecutorDeviceType t, const std::string &sid)
	SessionInfo (const SessionInfo &s)
MapDHandler *	get_mapdHandler () const
Catalog &	getCatalog () const
std::shared_ptr< Catalog >	get_catalog_ptr () const
void	set_catalog_ptr (std::shared_ptr< Catalog > c)
const UserMetadata &	get_currentUser () const
const ExecutorDeviceType	get_executor_device_type () const
void	set_executor_device_type (ExecutorDeviceType t)
std::string	get_session_id () const
time_t	get_last_used_time () const
void	update_last_used_time ()
bool	checkDBAccessPrivileges (const DBObjectType &permissionType, const AccessPrivileges &privs, const std::string &objectName="") const
time_t	get_start_time () const
std::string const &	get_public_session_id () const
	operator std::string () const

Private Member Functions
std::string	public_session_id () const

Private Attributes
std::shared_ptr< MapDHandler >	mapdHandler_
std::shared_ptr< Catalog >	catalog_
UserMetadata	currentUser_
std::atomic< ExecutorDeviceType >	executor_device_type_
const std::string	session_id_
std::atomic< time_t >	last_used_time_
std::atomic< time_t >	start_time_
const std::string	public_session_id_

Detailed Description

Definition at line 62 of file SessionInfo.h.

Constructor & Destructor Documentation

SessionInfo() [1/3]

Catalog_Namespace::SessionInfo::SessionInfo ( std::shared_ptr< MapDHandler >  mapdHandler, std::shared_ptr< Catalog >  cat, const UserMetadata &  user, const ExecutorDeviceType  t, const std::string &  sid  )

inline

Definition at line 64 of file SessionInfo.h.

      : mapdHandler_(mapdHandler)
      , catalog_(cat)
      , currentUser_(user)
      , executor_device_type_(t)
      , session_id_(sid)
      , last_used_time_(time(0))
      , start_time_(time(0))
      , public_session_id_(public_session_id()) {}

SessionInfo() [2/3]

Catalog_Namespace::SessionInfo::SessionInfo ( std::shared_ptr< Catalog >  cat, const UserMetadata &  user, const ExecutorDeviceType  t, const std::string &  sid  )

inline

Definition at line 77 of file SessionInfo.h.

      : SessionInfo(std::make_shared<MapDHandler>(), cat, user, t, sid) {}

SessionInfo() [3/3]

Catalog_Namespace::SessionInfo::SessionInfo ( const SessionInfo &  s )

inline

Definition at line 82 of file SessionInfo.h.

      : mapdHandler_(s.mapdHandler_)
      , catalog_(s.catalog_)
      , currentUser_(s.currentUser_)
      , executor_device_type_(static_cast<ExecutorDeviceType>(s.executor_device_type_))
      , session_id_(s.session_id_)
      , public_session_id_(s.public_session_id_) {}

Member Function Documentation

checkDBAccessPrivileges()

bool Catalog_Namespace::SessionInfo::checkDBAccessPrivileges	(	const DBObjectType &	permissionType,
		const AccessPrivileges &	privs,
		const std::string &	objectName = ""
	)		const

Definition at line 24 of file SessionInfo.cpp.

References Catalog_Namespace::SysCatalog::checkPrivileges(), DatabaseDBObjectType, get_currentUser(), getCatalog(), and Catalog_Namespace::SysCatalog::instance().

Referenced by Parser::CreateTableStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Parser::DropTableStmt::execute(), Parser::DumpTableStmt::execute(), Parser::RestoreTableStmt::execute(), Parser::CreateViewStmt::execute(), and Parser::DropViewStmt::execute().

                                                                             {
  auto& cat = getCatalog();
  // run flow with DB object level access permission checks
  DBObject object(objectName, permissionType);
  if (permissionType == DBObjectType::DatabaseDBObjectType) {
    object.setName(cat.getCurrentDB().dbName);
  }
  object.loadKey(cat);
  object.setPrivileges(privs);
  std::vector<DBObject> privObjects;
  privObjects.push_back(object);
  return SysCatalog::instance().checkPrivileges(get_currentUser(), privObjects);
}

Here is the call graph for this function:

Here is the caller graph for this function:

get_catalog_ptr()

std::shared_ptr<Catalog> Catalog_Namespace::SessionInfo::get_catalog_ptr ( ) const

inline

Definition at line 91 of file SessionInfo.h.

{ return catalog_; }

get_currentUser()

const UserMetadata& Catalog_Namespace::SessionInfo::get_currentUser ( ) const

inline

Definition at line 93 of file SessionInfo.h.

Referenced by Parser::check_alter_table_privilege(), MapDHandler::check_table_load_privileges(), checkDBAccessPrivileges(), checkPermissionForTables(), Executor::execute(), Parser::CreateTableStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Parser::TruncateTableStmt::execute(), Parser::RenameDatabaseStmt::execute(), Parser::RenameUserStmt::execute(), Parser::CopyTableStmt::execute(), Parser::CreateRoleStmt::execute(), Parser::DropRoleStmt::execute(), Parser::GrantPrivilegesStmt::execute(), Parser::RevokePrivilegesStmt::execute(), Parser::ShowPrivilegesStmt::execute(), Parser::GrantRoleStmt::execute(), Parser::RevokeRoleStmt::execute(), Parser::CreateViewStmt::execute(), Parser::CreateDBStmt::execute(), Parser::DropDBStmt::execute(), Parser::CreateUserStmt::execute(), Parser::AlterUserStmt::execute(), Parser::DropUserStmt::execute(), Calcite::getCompletionHints(), MapDHandler::hasTableAccessPrivileges(), is_allowed_on_dashboard(), query_state::operator<<(), MapDHandler::set_execution_mode_nolock(), and MapDHandler::user_can_access_table().

{ return currentUser_; }

Here is the caller graph for this function:

get_executor_device_type()

const ExecutorDeviceType Catalog_Namespace::SessionInfo::get_executor_device_type ( ) const

inline

Definition at line 94 of file SessionInfo.h.

Referenced by MapDHandler::execute_rel_alg_df().

                                                            {
    return executor_device_type_;
  }

Here is the caller graph for this function:

get_last_used_time()

time_t Catalog_Namespace::SessionInfo::get_last_used_time ( ) const

inline

Definition at line 99 of file SessionInfo.h.

{ return last_used_time_; }

get_mapdHandler()

MapDHandler* Catalog_Namespace::SessionInfo::get_mapdHandler ( ) const

inline

Definition at line 89 of file SessionInfo.h.

Referenced by Parser::AddColumnStmt::execute().

{ return mapdHandler_.get(); }

Here is the caller graph for this function:

get_public_session_id()

std::string const& Catalog_Namespace::SessionInfo::get_public_session_id ( ) const

inline

Definition at line 105 of file SessionInfo.h.

Referenced by Catalog_Namespace::operator<<(), and query_state::operator<<().

{ return public_session_id_; }

Here is the caller graph for this function:

get_session_id()

std::string Catalog_Namespace::SessionInfo::get_session_id ( ) const

inline

Definition at line 98 of file SessionInfo.h.

Referenced by Parser::AddColumnStmt::execute(), Parser::ExportQueryStmt::execute(), and Calcite::getCompletionHints().

{ return session_id_; }

Here is the caller graph for this function:

get_start_time()

time_t Catalog_Namespace::SessionInfo::get_start_time ( ) const

inline

Definition at line 104 of file SessionInfo.h.

Referenced by public_session_id().

{ return start_time_; }

Here is the caller graph for this function:

getCatalog()

Catalog& Catalog_Namespace::SessionInfo::getCatalog ( ) const

inline

Definition at line 90 of file SessionInfo.h.

Referenced by Parser::check_alter_table_privilege(), Parser::AddColumnStmt::check_executable(), MapDHandler::check_table_load_privileges(), checkDBAccessPrivileges(), checkPermissionForTables(), Parser::InsertIntoTableAsSelectStmt::LocalConnector::checkpoint(), Executor::execute(), Parser::CreateTableStmt::execute(), Parser::CreateTableAsSelectStmt::execute(), Parser::DropTableStmt::execute(), Parser::TruncateTableStmt::execute(), Parser::RenameTableStmt::execute(), Parser::RenameColumnStmt::execute(), Parser::AddColumnStmt::execute(), Parser::DumpTableStmt::execute(), Parser::RestoreTableStmt::execute(), Parser::CopyTableStmt::execute(), Parser::GrantPrivilegesStmt::execute(), Parser::RevokePrivilegesStmt::execute(), Parser::ShowPrivilegesStmt::execute(), Parser::ExportQueryStmt::execute(), Parser::CreateViewStmt::execute(), Parser::DropViewStmt::execute(), MapDHandler::execute_rel_alg_df(), Parser::CreateTableStmt::executeDryRun(), MapDHandler::get_tables_impl(), Calcite::getCompletionHints(), MapDHandler::hasTableAccessPrivileges(), Fragmenter_Namespace::InsertDataLoader::insertData(), Parser::InsertIntoTableAsSelectStmt::LocalConnector::insertDataToLeaf(), is_allowed_on_dashboard(), query_state::operator<<(), MapDHandler::parse_to_plan_legacy(), MapDHandler::prepare_columnar_loader(), Parser::InsertIntoTableAsSelectStmt::LocalConnector::rollback(), and MapDHandler::user_can_access_table().

{ return *catalog_; }

Here is the caller graph for this function:

operator std::string()

Catalog_Namespace::SessionInfo::operator std::string ( ) const

inline

Definition at line 106 of file SessionInfo.h.

{ return public_session_id_; }

public_session_id()

std::string Catalog_Namespace::SessionInfo::public_session_id ( ) const

private

Definition at line 43 of file SessionInfo.cpp.

References get_start_time(), session_id_, and run_benchmark_import::start_time.

                                               {
  const time_t start_time = get_start_time();
  struct tm st;
  localtime_r(&start_time, &st);
  std::ostringstream ss;
  ss << (st.tm_min % 10) << std::setfill('0') << std::setw(2) << st.tm_sec << '-'
     << session_id_.substr(0, 4);
  return ss.str();
}

Here is the call graph for this function:

set_catalog_ptr()

void Catalog_Namespace::SessionInfo::set_catalog_ptr ( std::shared_ptr< Catalog >  c )

inline

Definition at line 92 of file SessionInfo.h.

{ catalog_ = c; }

set_executor_device_type()

void Catalog_Namespace::SessionInfo::set_executor_device_type ( ExecutorDeviceType  t )

inline

Definition at line 97 of file SessionInfo.h.

Referenced by MapDHandler::set_execution_mode_nolock().

{ executor_device_type_ = t; }

Here is the caller graph for this function:

update_last_used_time()

void Catalog_Namespace::SessionInfo::update_last_used_time ( )

inline

Definition at line 100 of file SessionInfo.h.

{ last_used_time_ = time(0); }

Member Data Documentation

catalog_

std::shared_ptr<Catalog> Catalog_Namespace::SessionInfo::catalog_

private

Definition at line 110 of file SessionInfo.h.

currentUser_

UserMetadata Catalog_Namespace::SessionInfo::currentUser_

private

Definition at line 111 of file SessionInfo.h.

executor_device_type_

std::atomic<ExecutorDeviceType> Catalog_Namespace::SessionInfo::executor_device_type_

private

Definition at line 112 of file SessionInfo.h.

last_used_time_

std::atomic<time_t> Catalog_Namespace::SessionInfo::last_used_time_

private

Definition at line 114 of file SessionInfo.h.

mapdHandler_

std::shared_ptr<MapDHandler> Catalog_Namespace::SessionInfo::mapdHandler_

private

Definition at line 109 of file SessionInfo.h.

public_session_id_

const std::string Catalog_Namespace::SessionInfo::public_session_id_

private

Definition at line 116 of file SessionInfo.h.

session_id_

const std::string Catalog_Namespace::SessionInfo::session_id_

private

Definition at line 113 of file SessionInfo.h.

Referenced by public_session_id().

start_time_

std::atomic<time_t> Catalog_Namespace::SessionInfo::start_time_

private

Definition at line 115 of file SessionInfo.h.

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/Catalog/SessionInfo.h
• /home/jenkins-slave/workspace/core-os-doxygen/Catalog/SessionInfo.cpp