OmniSciDB
a5dc49c757
|
Functions for database metadata access. More...
#include "Catalog/Catalog.h"
#include <algorithm>
#include <boost/algorithm/string/predicate.hpp>
#include <boost/filesystem.hpp>
#include <boost/range/adaptor/map.hpp>
#include <boost/version.hpp>
#include <cassert>
#include <cerrno>
#include <cstdio>
#include <cstring>
#include <exception>
#include <fstream>
#include <list>
#include <memory>
#include <random>
#include <regex>
#include <sstream>
#include <boost/uuid/sha1.hpp>
#include <rapidjson/document.h>
#include <rapidjson/istreamwrapper.h>
#include <rapidjson/ostreamwrapper.h>
#include <rapidjson/writer.h>
#include "Catalog/SysCatalog.h"
#include "QueryEngine/Execute.h"
#include "QueryEngine/TableOptimizer.h"
#include "DataMgr/FileMgr/FileMgr.h"
#include "DataMgr/FileMgr/GlobalFileMgr.h"
#include "DataMgr/ForeignStorage/AbstractFileStorageDataWrapper.h"
#include "DataMgr/ForeignStorage/ForeignStorageInterface.h"
#include "DataMgr/ForeignStorage/FsiChunkUtils.h"
#include "DataMgr/ForeignStorage/RegexParserDataWrapper.h"
#include "Fragmenter/Fragmenter.h"
#include "Fragmenter/SortedOrderFragmenter.h"
#include "LockMgr/LockMgr.h"
#include "MigrationMgr/MigrationMgr.h"
#include "OSDependent/heavyai_path.h"
#include "Parser/ParserNode.h"
#include "RefreshTimeCalculator.h"
#include "Shared/DateTimeParser.h"
#include "Shared/File.h"
#include "Shared/StringTransform.h"
#include "Shared/SysDefinitions.h"
#include "Shared/measure.h"
#include "Shared/misc.h"
#include "StringDictionary/StringDictionaryClient.h"
#include "MapDRelease.h"
#include "RWLocks.h"
#include "SharedDictionaryValidator.h"
#include "Shared/distributed.h"
#include "Parser/ReservedKeywords.h"
Go to the source code of this file.
Namespaces | |
Catalog_Namespace | |
Catalog_Namespace::anonymous_namespace{Catalog.cpp} | |
Typedefs | |
using | Catalog_Namespace::sys_read_lock = read_lock< SysCatalog > |
using | Catalog_Namespace::cat_read_lock = read_lock< Catalog > |
using | Catalog_Namespace::cat_write_lock = write_lock< Catalog > |
using | Catalog_Namespace::cat_sqlite_lock = sqlite_lock< Catalog > |
Variables | |
bool | g_enable_fsi {true} |
bool | g_enable_s3_fsi {false} |
int32_t | g_distributed_leaf_idx {-1} |
int32_t | g_distributed_num_leaves {0} |
bool | g_enable_logs_system_tables {true} |
bool | g_enable_logs_system_tables_auto_refresh {false} |
std::string | g_logs_system_tables_refresh_interval {"600S"} |
bool | g_cache_string_hash |
bool | g_enable_system_tables |
bool | g_serialize_temp_tables {false} |
const int | Catalog_Namespace::DEFAULT_INITIAL_VERSION = 1 |
const int | Catalog_Namespace::MAPD_TEMP_TABLE_START_ID |
const int | Catalog_Namespace::MAPD_TEMP_DICT_START_ID |
Functions for database metadata access.
Definition in file Catalog.cpp.
bool g_cache_string_hash |
Definition at line 55 of file StringDictionary.cpp.
Referenced by CommandLineOptions::fillOptions(), Catalog_Namespace::Catalog::getMetadataForDict(), and RowSetMemoryOwner::getOrAddStringDictProxy().
int32_t g_distributed_leaf_idx {-1} |
Definition at line 98 of file Catalog.cpp.
Referenced by foreign_storage::fragment_maps_to_leaf(), foreign_storage::anonymous_namespace{LogFileBufferParser.cpp}::get_node_name(), dist::is_aggregator(), dist::is_first_leaf(), dist::is_leaf_node(), DBHandler::set_leaf_info(), and foreign_storage::set_node_name().
int32_t g_distributed_num_leaves {0} |
Definition at line 99 of file Catalog.cpp.
Referenced by foreign_storage::fragment_maps_to_leaf(), and DBHandler::set_leaf_info().
bool g_enable_fsi {true} |
Definition at line 96 of file Catalog.cpp.
Referenced by AlterForeignServerCommand::AlterForeignServerCommand(), AlterForeignTableCommand::AlterForeignTableCommand(), Catalog_Namespace::Catalog::buildForeignServerMapUnlocked(), Catalog_Namespace::Catalog::buildMaps(), Catalog_Namespace::Catalog::CheckAndExecuteMigrations(), Catalog_Namespace::SysCatalog::createDatabase(), Catalog_Namespace::Catalog::createDefaultServersIfNotExists(), CreateForeignServerCommand::CreateForeignServerCommand(), CreateForeignTableCommand::CreateForeignTableCommand(), Catalog_Namespace::Catalog::createTable(), import_export::Detector::Detector(), DropForeignServerCommand::DropForeignServerCommand(), DropForeignTableCommand::DropForeignTableCommand(), Parser::GrantPrivilegesStmt::execute(), Parser::RevokePrivilegesStmt::execute(), CommandLineOptions::fillOptions(), Catalog_Namespace::SysCatalog::grantAllOnDatabase_unsafe(), Catalog_Namespace::Catalog::reassignOwners(), RefreshForeignTablesCommand::RefreshForeignTablesCommand(), Catalog_Namespace::Catalog::reloadCatalogMetadataUnlocked(), Catalog_Namespace::Catalog::reloadForeignTableUnlocked(), Catalog_Namespace::Catalog::restoreOldOwners(), ShowCreateServerCommand::ShowCreateServerCommand(), ShowForeignServersCommand::ShowForeignServersCommand(), Catalog_Namespace::thread_holding_write_lock(), Catalog_Namespace::Catalog::updateForeignTablesInMapUnlocked(), and CommandLineOptions::validate().
bool g_enable_logs_system_tables {true} |
Definition at line 100 of file Catalog.cpp.
Referenced by CommandLineOptions::fillOptions(), Catalog_Namespace::Catalog::initializeSystemServers(), Catalog_Namespace::Catalog::initializeSystemTables(), and CommandLineOptions::validate().
bool g_enable_logs_system_tables_auto_refresh {false} |
Definition at line 101 of file Catalog.cpp.
Referenced by CommandLineOptions::fillOptions(), Catalog_Namespace::anonymous_namespace{Catalog.cpp}::set_common_log_system_table_options(), and CommandLineOptions::validate().
bool g_enable_s3_fsi {false} |
Definition at line 97 of file Catalog.cpp.
Referenced by Catalog_Namespace::thread_holding_write_lock(), CommandLineOptions::validate(), and foreign_storage::AbstractFileStorageDataWrapper::validateServerOptions().
bool g_enable_system_tables |
Definition at line 64 of file SysCatalog.cpp.
Referenced by anonymous_namespace{DBHandler.cpp}::check_and_reset_in_memory_system_table(), Catalog_Namespace::Catalog::conditionallyInitializeSystemObjects(), CommandLineOptions::fillOptions(), Catalog_Namespace::SysCatalog::initializeInformationSchemaDb(), anonymous_namespace{RelAlgExecutor.cpp}::prepare_for_system_table_execution(), Catalog_Namespace::thread_holding_write_lock(), and CommandLineOptions::validate().
std::string g_logs_system_tables_refresh_interval {"600S"} |
Definition at line 103 of file Catalog.cpp.
Referenced by CommandLineOptions::fillOptions(), Catalog_Namespace::anonymous_namespace{Catalog.cpp}::set_common_log_system_table_options(), and CommandLineOptions::validate().
bool g_serialize_temp_tables {false} |
Definition at line 109 of file Catalog.cpp.
Referenced by Catalog_Namespace::Catalog::createTable(), Catalog_Namespace::Catalog::eraseTableMetadata(), EmbeddedDatabase::DBEngineImpl::init(), QueryRunner::QueryRunner::QueryRunner(), Catalog_Namespace::thread_holding_write_lock(), and Catalog_Namespace::Catalog::~Catalog().