Catalog_Namespace Namespace Reference

Namespaces
	anonymous_namespace{Catalog.cpp}
	anonymous_namespace{SysCatalog.cpp}

Classes
class	Catalog
	class for a per-database catalog. also includes metadata for the current database and the current user. More...
class	CommonFileOperations
struct	DBMetadata
struct	DBSummary
class	read_lock
class	SessionInfo
class	sqlite_lock
class	SysCatalog
struct	UserMetadata
class	write_lock

Typedefs
using	sys_read_lock = read_lock< SysCatalog >
using	cat_read_lock = read_lock< Catalog >
using	cat_write_lock = write_lock< Catalog >
using	cat_sqlite_lock = sqlite_lock< Catalog >
using	sys_write_lock = write_lock< SysCatalog >
using	sys_sqlite_lock = sqlite_lock< SysCatalog >
using	DBSummaryList = std::list< DBSummary >
using	TableDescriptorMap = std::map< std::string, TableDescriptor * >
using	TableDescriptorMapById = std::map< int, TableDescriptor * >
using	LogicalToPhysicalTableMapById = std::map< int32_t, std::vector< int32_t > >
using	ColumnKey = std::tuple< int, std::string >
using	ColumnDescriptorMap = std::map< ColumnKey, ColumnDescriptor * >
using	ColumnIdKey = std::tuple< int, int >
using	ColumnDescriptorMapById = std::map< ColumnIdKey, ColumnDescriptor * >
using	DictDescriptorMapById = std::map< DictRef, std::unique_ptr< DictDescriptor > >
using	DashboardDescriptorMap = std::map< std::string, std::shared_ptr< DashboardDescriptor > >
using	LinkDescriptorMap = std::map< std::string, LinkDescriptor * >
using	LinkDescriptorMapById = std::map< int, LinkDescriptor * >
using	DeletedColumnPerTableMap = std::unordered_map< const TableDescriptor *, const ColumnDescriptor * >
using	ForeignServerMap = std::map< std::string, std::shared_ptr< foreign_storage::ForeignServer > >
using	ForeignServerMapById = std::map< int, std::shared_ptr< foreign_storage::ForeignServer > >

Functions
std::ostream &	operator<< (std::ostream &os, const SessionInfo &session_info)
void	deleteObjectPrivileges (std::unique_ptr< SqliteConnector > &sqliteConnector, std::string roleName, bool userRole, DBObject &object)
void	insertOrUpdateObjectPrivileges (std::unique_ptr< SqliteConnector > &sqliteConnector, std::string roleName, bool userRole, DBObject &object)
static bool	parseUserMetadataFromSQLite (const std::unique_ptr< SqliteConnector > &conn, UserMetadata &user)

Variables
const int	DEFAULT_INITIAL_VERSION = 1
const int	MAPD_TEMP_TABLE_START_ID
const int	MAPD_TEMP_DICT_START_ID

Typedef Documentation

cat_read_lock

using Catalog_Namespace::cat_read_lock = typedef read_lock<Catalog>

Definition at line 111 of file Catalog.cpp.

cat_sqlite_lock

using Catalog_Namespace::cat_sqlite_lock = typedef sqlite_lock<Catalog>

Definition at line 113 of file Catalog.cpp.

cat_write_lock

using Catalog_Namespace::cat_write_lock = typedef write_lock<Catalog>

Definition at line 112 of file Catalog.cpp.

ColumnDescriptorMap

using Catalog_Namespace::ColumnDescriptorMap = typedef std::map<ColumnKey, ColumnDescriptor*>

Definition at line 37 of file Types.h.

ColumnDescriptorMapById

using Catalog_Namespace::ColumnDescriptorMapById = typedef std::map<ColumnIdKey, ColumnDescriptor*>

Definition at line 39 of file Types.h.

ColumnIdKey

using Catalog_Namespace::ColumnIdKey = typedef std::tuple<int, int>

Definition at line 38 of file Types.h.

ColumnKey

using Catalog_Namespace::ColumnKey = typedef std::tuple<int, std::string>

Definition at line 36 of file Types.h.

DashboardDescriptorMap

using Catalog_Namespace::DashboardDescriptorMap = typedef std::map<std::string, std::shared_ptr<DashboardDescriptor> >

Definition at line 42 of file Types.h.

DBSummaryList

using Catalog_Namespace::DBSummaryList = typedef std::list<DBSummary>

Definition at line 120 of file SysCatalog.h.

DeletedColumnPerTableMap

using Catalog_Namespace::DeletedColumnPerTableMap = typedef std::unordered_map<const TableDescriptor*, const ColumnDescriptor*>

Definition at line 46 of file Types.h.

DictDescriptorMapById

using Catalog_Namespace::DictDescriptorMapById = typedef std::map<DictRef, std::unique_ptr<DictDescriptor> >

Definition at line 40 of file Types.h.

ForeignServerMap

using Catalog_Namespace::ForeignServerMap = typedef std::map<std::string, std::shared_ptr<foreign_storage::ForeignServer> >

Definition at line 48 of file Types.h.

ForeignServerMapById

using Catalog_Namespace::ForeignServerMapById = typedef std::map<int, std::shared_ptr<foreign_storage::ForeignServer> >

Definition at line 50 of file Types.h.

LinkDescriptorMap

using Catalog_Namespace::LinkDescriptorMap = typedef std::map<std::string, LinkDescriptor*>

Definition at line 43 of file Types.h.

LinkDescriptorMapById

using Catalog_Namespace::LinkDescriptorMapById = typedef std::map<int, LinkDescriptor*>

Definition at line 44 of file Types.h.

LogicalToPhysicalTableMapById

using Catalog_Namespace::LogicalToPhysicalTableMapById = typedef std::map<int32_t, std::vector<int32_t> >

Definition at line 35 of file Types.h.

sys_read_lock

typedef read_lock< SysCatalog > Catalog_Namespace::sys_read_lock

Definition at line 110 of file Catalog.cpp.

sys_sqlite_lock

using Catalog_Namespace::sys_sqlite_lock = typedef sqlite_lock<SysCatalog>

Definition at line 81 of file SysCatalog.cpp.

sys_write_lock

using Catalog_Namespace::sys_write_lock = typedef write_lock<SysCatalog>

Definition at line 80 of file SysCatalog.cpp.

TableDescriptorMap

using Catalog_Namespace::TableDescriptorMap = typedef std::map<std::string, TableDescriptor*>

Definition at line 33 of file Types.h.

TableDescriptorMapById

using Catalog_Namespace::TableDescriptorMapById = typedef std::map<int, TableDescriptor*>

Definition at line 34 of file Types.h.

Function Documentation

deleteObjectPrivileges()

void Catalog_Namespace::deleteObjectPrivileges	(	std::unique_ptr< SqliteConnector > &	sqliteConnector,
		std::string	roleName,
		bool	userRole,
		DBObject &	object
	)

Definition at line 322 of file SysCatalog.cpp.

References DBObjectKey::dbId, DBObjectKey::objectId, DBObjectKey::permissionType, and to_string().

Referenced by Catalog_Namespace::SysCatalog::revokeDBObjectPrivileges_unsafe().

                                              {
  DBObjectKey key = object.getObjectKey();

  sqliteConnector->query_with_text_params(
      "DELETE FROM mapd_object_permissions WHERE roleName = ?1 and roleType = ?2 and "
      "objectPermissionsType = ?3 and "
      "dbId = "
      "?4 "
      "and objectId = ?5",
      std::vector<std::string>{roleName,
                               std::to_string(userRole),
                               std::to_string(key.permissionType),
                               std::to_string(key.dbId),
                               std::to_string(key.objectId)});
}

Here is the call graph for this function:

Here is the caller graph for this function:

insertOrUpdateObjectPrivileges()

void Catalog_Namespace::insertOrUpdateObjectPrivileges	(	std::unique_ptr< SqliteConnector > &	sqliteConnector,
		std::string	roleName,
		bool	userRole,
		DBObject &	object
	)

Definition at line 341 of file SysCatalog.cpp.

References DBObjectKey::dbId, DBObjectKey::objectId, DBObjectKey::permissionType, and to_string().

Referenced by Catalog_Namespace::SysCatalog::createRole_unsafe(), Catalog_Namespace::SysCatalog::grantDBObjectPrivileges_unsafe(), Catalog_Namespace::SysCatalog::migrateDBAccessPrivileges(), Catalog_Namespace::SysCatalog::migratePrivileges(), Catalog_Namespace::SysCatalog::populateRoleDbObjects(), and Catalog_Namespace::SysCatalog::revokeDBObjectPrivileges_unsafe().

                                                      {
  DBObjectKey key = object.getObjectKey();

  sqliteConnector->query_with_text_params(
      "INSERT OR REPLACE INTO mapd_object_permissions("
      "roleName, "
      "roleType, "
      "objectPermissionsType, "
      "dbId, "
      "objectId, "
      "objectPermissions, "
      "objectOwnerId,"
      "objectName) "
      "VALUES (?1, ?2, ?3, "
      "?4, ?5, ?6, ?7, ?8)",
      std::vector<std::string>{
          roleName,                                           // roleName
          userRole ? "1" : "0",                               // roleType
          std::to_string(key.permissionType),                 // permissionType
          std::to_string(key.dbId),                           // dbId
          std::to_string(key.objectId),                       // objectId
          std::to_string(object.getPrivileges().privileges),  // objectPrivileges
          std::to_string(object.getOwner()),                  // objectOwnerId
          object.getName()                                    // name
      });
}

Here is the call graph for this function:

Here is the caller graph for this function:

operator<<()

std::ostream & Catalog_Namespace::operator<<	(	std::ostream &	os,
		const SessionInfo &	session_info
	)

Definition at line 53 of file SessionInfo.cpp.

References Catalog_Namespace::SessionInfo::get_public_session_id().

                                                                        {
  os << session_info.get_public_session_id();
  return os;
}

Here is the call graph for this function:

parseUserMetadataFromSQLite()

static bool Catalog_Namespace::parseUserMetadataFromSQLite ( const std::unique_ptr< SqliteConnector > &  conn, UserMetadata &  user  )

static

Definition at line 1197 of file SysCatalog.cpp.

References Catalog_Namespace::UserMetadata::can_login, Catalog_Namespace::UserMetadata::defaultDbId, Catalog_Namespace::UserMetadata::isSuper, LOG, Catalog_Namespace::UserMetadata::passwd_hash, Catalog_Namespace::UserMetadata::userId, Catalog_Namespace::UserMetadata::userName, and logger::WARNING.

Referenced by Catalog_Namespace::SysCatalog::getMetadataForUser(), and Catalog_Namespace::SysCatalog::getMetadataForUserById().

                                                            {
  int numRows = conn->getNumRows();
  if (numRows == 0) {
    return false;
  }
  user.userId = conn->getData<int>(0, 0);
  user.userName = conn->getData<string>(0, 1);
  user.passwd_hash = conn->getData<string>(0, 2);
  user.isSuper = conn->getData<bool>(0, 3);
  user.defaultDbId = conn->isNull(0, 4) ? -1 : conn->getData<int>(0, 4);
  if (conn->isNull(0, 5)) {
    LOG(WARNING)
        << "User property 'can_login' not set for user " << user.userName
        << ". Disabling login ability. Set the users login ability with \"ALTER USER "
        << user.userName << " (can_login='true');\".";
  }
  user.can_login = conn->isNull(0, 5) ? false : conn->getData<bool>(0, 5);
  return true;
}

Here is the caller graph for this function:

Variable Documentation

DEFAULT_INITIAL_VERSION

const int Catalog_Namespace::DEFAULT_INITIAL_VERSION = 1

Definition at line 99 of file Catalog.cpp.

MAPD_TEMP_DICT_START_ID

const int Catalog_Namespace::MAPD_TEMP_DICT_START_ID

Initial value:

=
    1073741824

Definition at line 102 of file Catalog.cpp.

MAPD_TEMP_TABLE_START_ID

const int Catalog_Namespace::MAPD_TEMP_TABLE_START_ID

Initial value:

=
    1073741824

Definition at line 100 of file Catalog.cpp.