OmniSciDB  085a039ca4
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
EmbeddedDatabase::DBEngineImpl Class Reference
+ Inheritance diagram for EmbeddedDatabase::DBEngineImpl:
+ Collaboration diagram for EmbeddedDatabase::DBEngineImpl:

Public Member Functions

 DBEngineImpl ()
 
 ~DBEngineImpl ()
 
bool init (const std::string &cmd_line)
 
std::shared_ptr< CursorImplsql_execute_dbe (const TSessionId &session_id, const std::string &query_str, const bool column_format, const int32_t first_n, const int32_t at_most_n)
 
void executeDDL (const std::string &query)
 
void importArrowTable (const std::string &name, std::shared_ptr< arrow::Table > &table, uint64_t fragment_size)
 
std::shared_ptr< CursorImplexecuteDML (const std::string &query)
 
std::shared_ptr< CursorImplexecuteRA (const std::string &query)
 
std::vector< std::string > getTables ()
 
std::vector< ColumnDetailsgetTableDetails (const std::string &table_name)
 
bool setDatabase (std::string &db_name)
 
bool login (std::string &db_name, std::string &user_name, const std::string &password)
 
- Public Member Functions inherited from EmbeddedDatabase::DBEngine
virtual ~DBEngine ()
 
void executeDDL (const std::string &query)
 
std::shared_ptr< CursorexecuteDML (const std::string &query)
 
std::shared_ptr< CursorexecuteRA (const std::string &query)
 
void importArrowTable (const std::string &name, std::shared_ptr< arrow::Table > &table, uint64_t fragment_size=0)
 
std::vector< std::string > getTables ()
 
std::vector< ColumnDetailsgetTableDetails (const std::string &table_name)
 
bool setDatabase (std::string &db_name)
 
bool login (std::string &db_name, std::string &user_name, const std::string &password)
 

Protected Member Functions

void reset ()
 
bool catalogExists (const std::string &base_path)
 
void cleanCatalog (const std::string &base_path)
 
std::string createCatalog (const std::string &base_path)
 
- Protected Member Functions inherited from EmbeddedDatabase::DBEngine
 DBEngine ()
 
 DBEngine (const DBEngine &)=delete
 
DBEngineoperator= (const DBEngine &)=delete
 

Private Attributes

std::string base_path_
 
std::string session_id_
 
std::shared_ptr< DBHandlerdb_handler_
 
bool is_temp_db_
 
std::string udf_filename_
 
std::vector< std::string > system_folders_
 

Additional Inherited Members

- Static Public Member Functions inherited from EmbeddedDatabase::DBEngine
static std::shared_ptr< DBEnginecreate (const std::string &cmd_line)
 

Detailed Description

DBEngine internal implementation

Definition at line 99 of file DBEngine.cpp.

Constructor & Destructor Documentation

EmbeddedDatabase::DBEngineImpl::DBEngineImpl ( )
inline

Definition at line 101 of file DBEngine.cpp.

101 : is_temp_db_(false) {}
EmbeddedDatabase::DBEngineImpl::~DBEngineImpl ( )
inline

Definition at line 103 of file DBEngine.cpp.

References reset().

103 { reset(); }

+ Here is the call graph for this function:

Member Function Documentation

bool EmbeddedDatabase::DBEngineImpl::catalogExists ( const std::string &  base_path)
inlineprotected

Definition at line 368 of file DBEngine.cpp.

References system_folders_.

Referenced by init().

368  {
369  if (!boost::filesystem::exists(base_path)) {
370  return false;
371  }
372  for (auto& subdir : system_folders_) {
373  std::string path = base_path + "/" + subdir;
374  if (!boost::filesystem::exists(path)) {
375  return false;
376  }
377  }
378  return true;
379  }
std::vector< std::string > system_folders_
Definition: DBEngine.cpp:441

+ Here is the caller graph for this function:

void EmbeddedDatabase::DBEngineImpl::cleanCatalog ( const std::string &  base_path)
inlineprotected

Definition at line 381 of file DBEngine.cpp.

References system_folders_.

381  {
382  if (boost::filesystem::exists(base_path)) {
383  for (auto& subdir : system_folders_) {
384  std::string path = base_path + "/" + subdir;
385  if (boost::filesystem::exists(path)) {
386  boost::filesystem::remove_all(path);
387  }
388  }
389  }
390  }
std::vector< std::string > system_folders_
Definition: DBEngine.cpp:441
std::string EmbeddedDatabase::DBEngineImpl::createCatalog ( const std::string &  base_path)
inlineprotected

Definition at line 392 of file DBEngine.cpp.

References is_temp_db_, and system_folders_.

Referenced by init().

392  {
393  std::string root_dir = base_path;
394  if (base_path.empty()) {
395  boost::system::error_code error;
396  auto tmp_path = boost::filesystem::temp_directory_path(error);
397  if (boost::system::errc::success != error.value()) {
398  std::cerr << error.message() << std::endl;
399  return "";
400  }
401  tmp_path /= "omnidbe_%%%%-%%%%-%%%%";
402  auto uniq_path = boost::filesystem::unique_path(tmp_path, error);
403  if (boost::system::errc::success != error.value()) {
404  std::cerr << error.message() << std::endl;
405  return "";
406  }
407  root_dir = uniq_path.string();
408  is_temp_db_ = true;
409  }
410  if (!boost::filesystem::exists(root_dir)) {
411  if (!boost::filesystem::create_directory(root_dir)) {
412  std::cerr << "Cannot create database directory: " << root_dir << std::endl;
413  return "";
414  }
415  }
416  size_t absent_count = 0;
417  for (auto& sub_dir : system_folders_) {
418  std::string path = root_dir + "/" + sub_dir;
419  if (!boost::filesystem::exists(path)) {
420  if (!boost::filesystem::create_directory(path)) {
421  std::cerr << "Cannot create database subdirectory: " << path << std::endl;
422  return "";
423  }
424  ++absent_count;
425  }
426  }
427  if ((absent_count > 0) && (absent_count < system_folders_.size())) {
428  std::cerr << "Database directory structure is broken: " << root_dir << std::endl;
429  return "";
430  }
431  return root_dir;
432  }
std::vector< std::string > system_folders_
Definition: DBEngine.cpp:441

+ Here is the caller graph for this function:

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

Definition at line 223 of file DBEngine.cpp.

References run_benchmark_import::res, session_id_, and sql_execute_dbe().

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

223  {
224  auto res = sql_execute_dbe(session_id_, query, false, -1, -1);
225  }
std::shared_ptr< CursorImpl > sql_execute_dbe(const TSessionId &session_id, const std::string &query_str, const bool column_format, const int32_t first_n, const int32_t at_most_n)
Definition: DBEngine.cpp:200

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::shared_ptr<CursorImpl> EmbeddedDatabase::DBEngineImpl::executeDML ( const std::string &  query)
inline

Definition at line 261 of file DBEngine.cpp.

References session_id_, and sql_execute_dbe().

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

261  {
262  return sql_execute_dbe(session_id_, query, false, -1, -1);
263  }
std::shared_ptr< CursorImpl > sql_execute_dbe(const TSessionId &session_id, const std::string &query_str, const bool column_format, const int32_t first_n, const int32_t at_most_n)
Definition: DBEngine.cpp:200

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::shared_ptr<CursorImpl> EmbeddedDatabase::DBEngineImpl::executeRA ( const std::string &  query)
inline

Definition at line 265 of file DBEngine.cpp.

References session_id_, and sql_execute_dbe().

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

265  {
266  return sql_execute_dbe(session_id_, query, false, -1, -1);
267  }
std::shared_ptr< CursorImpl > sql_execute_dbe(const TSessionId &session_id, const std::string &query_str, const bool column_format, const int32_t first_n, const int32_t at_most_n)
Definition: DBEngine.cpp:200

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::vector<ColumnDetails> EmbeddedDatabase::DBEngineImpl::getTableDetails ( const std::string &  table_name)
inline

Definition at line 287 of file DBEngine.cpp.

References EmbeddedDatabase::ColumnDetails::col_name, EmbeddedDatabase::ColumnDetails::col_type, EmbeddedDatabase::ColumnDetails::comp_param, db_handler_, EmbeddedDatabase::DICT, EmbeddedDatabase::ColumnDetails::encoding, EmbeddedDatabase::ColumnDetails::is_array, IS_GEO, kARRAY, EmbeddedDatabase::ColumnDetails::nullable, EmbeddedDatabase::ColumnDetails::precision, run_benchmark_import::result, EmbeddedDatabase::ColumnDetails::scale, session_id_, EmbeddedDatabase::sqlToColumnEncoding(), and EmbeddedDatabase::sqlToColumnType().

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

287  {
288  std::vector<ColumnDetails> result;
289  auto catalog = db_handler_->get_session_copy(session_id_).get_catalog_ptr();
290  if (catalog) {
291  auto metadata = catalog->getMetadataForTable(table_name, false);
292  if (metadata) {
293  const auto col_descriptors =
294  catalog->getAllColumnMetadataForTable(metadata->tableId, false, true, false);
295  const auto deleted_cd = catalog->getDeletedColumn(metadata);
296  for (const auto cd : col_descriptors) {
297  if (cd == deleted_cd) {
298  continue;
299  }
300  ColumnDetails col_details;
301  col_details.col_name = cd->columnName;
302  auto ct = cd->columnType;
303  SQLTypes sql_type = ct.get_type();
304  EncodingType sql_enc = ct.get_compression();
305  col_details.col_type = sqlToColumnType(sql_type);
306  col_details.encoding = sqlToColumnEncoding(sql_enc);
307  col_details.nullable = !ct.get_notnull();
308  col_details.is_array = (sql_type == kARRAY);
309  if (IS_GEO(sql_type)) {
310  col_details.precision = static_cast<int>(ct.get_subtype());
311  col_details.scale = ct.get_output_srid();
312  } else {
313  col_details.precision = ct.get_precision();
314  col_details.scale = ct.get_scale();
315  }
316  if (col_details.encoding == ColumnEncoding::DICT) {
317  // have to get the actual size of the encoding from the dictionary
318  // definition
319  const int dict_id = ct.get_comp_param();
320  auto dd = catalog->getMetadataForDict(dict_id, false);
321  if (dd) {
322  col_details.comp_param = dd->dictNBits;
323  } else {
324  throw std::runtime_error("Dictionary definition for column doesn't exist");
325  }
326  } else {
327  col_details.comp_param = ct.get_comp_param();
328  if (ct.is_date_in_days() && col_details.comp_param == 0) {
329  col_details.comp_param = 32;
330  }
331  }
332  result.push_back(col_details);
333  }
334  }
335  }
336  return result;
337  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437
SQLTypes
Definition: sqltypes.h:38
ColumnType sqlToColumnType(const SQLTypes &type)
Definition: DBETypes.cpp:111
EncodingType
Definition: sqltypes.h:233
tuple ColumnDetails
Definition: _parsers.py:23
ColumnEncoding sqlToColumnEncoding(const EncodingType &type)
Definition: DBETypes.cpp:162
#define IS_GEO(T)
Definition: sqltypes.h:251

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::vector<std::string> EmbeddedDatabase::DBEngineImpl::getTables ( )
inline

Definition at line 269 of file DBEngine.cpp.

References db_handler_, session_id_, and run_benchmark_import::tables.

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

269  {
270  std::vector<std::string> table_names;
271  auto catalog = db_handler_->get_session_copy(session_id_).get_catalog_ptr();
272  if (catalog) {
273  const auto tables = catalog->getAllTableMetadata();
274  for (const auto td : tables) {
275  if (td->shard >= 0) {
276  // skip shards, they're not standalone tables
277  continue;
278  }
279  table_names.push_back(td->tableName);
280  }
281  } else {
282  throw std::runtime_error("System catalog uninitialized");
283  }
284  return table_names;
285  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437

+ Here is the caller graph for this function:

void EmbeddedDatabase::DBEngineImpl::importArrowTable ( const std::string &  name,
std::shared_ptr< arrow::Table > &  table,
uint64_t  fragment_size 
)
inline

Definition at line 227 of file DBEngine.cpp.

References Data_Namespace::CPU_LEVEL, Catalog_Namespace::SysCatalog::createDBObject(), db_handler_, DEFAULT_FRAGMENT_ROWS, DEFAULT_MAX_CHUNK_SIZE, DEFAULT_MAX_ROWS, DEFAULT_PAGE_SIZE, TableDescriptor::fragmenter, TableDescriptor::fragPageSize, TableDescriptor::fragType, Fragmenter_Namespace::INSERT_ORDER, Catalog_Namespace::SysCatalog::instance(), TableDescriptor::isView, TableDescriptor::keyMetainfo, TableDescriptor::maxChunkSize, TableDescriptor::maxFragRows, TableDescriptor::maxRows, setup::name, TableDescriptor::persistenceLevel, releaseArrowTable(), session_id_, setArrowTable(), TableDescriptor::storageType, TableDBObjectType, TableDescriptor::tableName, and TableDescriptor::userId.

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

229  {
230  setArrowTable(name, table);
231  try {
232  auto session = db_handler_->get_session_copy(session_id_);
233  TableDescriptor td;
234  td.tableName = name;
235  td.userId = session.get_currentUser().userId;
236  td.storageType = "ARROW:" + name;
238  td.isView = false;
239  td.fragmenter = nullptr;
241  td.maxFragRows = fragment_size > 0 ? fragment_size : DEFAULT_FRAGMENT_ROWS;
245  td.keyMetainfo = "[]";
246 
247  std::list<ColumnDescriptor> cols;
248  std::vector<Parser::SharedDictionaryDef> dictionaries;
249  auto catalog = session.get_catalog_ptr();
250  // nColumns
251  catalog->createTable(td, cols, dictionaries, false);
253  session.get_currentUser(), td.tableName, TableDBObjectType, *catalog);
254  } catch (...) {
256  throw;
257  }
259  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437
std::string tableName
std::string storageType
#define DEFAULT_MAX_CHUNK_SIZE
void setArrowTable(std::string name, std::shared_ptr< arrow::Table > table)
void createDBObject(const UserMetadata &user, const std::string &objectName, DBObjectType type, const Catalog_Namespace::Catalog &catalog, int32_t objectId=-1)
void releaseArrowTable(std::string name)
#define DEFAULT_MAX_ROWS
static SysCatalog & instance()
Definition: SysCatalog.h:337
std::string keyMetainfo
std::shared_ptr< Fragmenter_Namespace::AbstractFragmenter > fragmenter
#define DEFAULT_PAGE_SIZE
#define DEFAULT_FRAGMENT_ROWS
Fragmenter_Namespace::FragmenterType fragType
Data_Namespace::MemoryLevel persistenceLevel
string name
Definition: setup.in.py:72

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

bool EmbeddedDatabase::DBEngineImpl::init ( const std::string &  cmd_line)
inline

Definition at line 105 of file DBEngine.cpp.

References CommandLineOptions::allow_loop_joins, CommandLineOptions::allow_multifrag, CommandLineOptions::authMetadata, CommandLineOptions::base_path, base_path_, SystemParameters::calcite_keepalive, catalogExists(), createCatalog(), db_handler_, CommandLineOptions::db_leaves, CommandLineOptions::disk_cache_config, CommandLineOptions::enable_auto_clear_render_mem, CommandLineOptions::enable_legacy_syntax, CommandLineOptions::enable_rendering, logger::FATAL, g_enable_thrift_logs, g_serialize_temp_tables, CommandLineOptions::idle_session_duration, CommandLineOptions::init_logging(), CommandLineOptions::intel_jit_profile, CommandLineOptions::jit_debug, shared::kDefaultDbName, shared::kDefaultRootPasswd, shared::kRootUsername, LOG, CommandLineOptions::max_concurrent_render_sessions, CommandLineOptions::max_session_duration, CommandLineOptions::num_reader_threads, SystemParameters::omnisci_server_port, CommandLineOptions::parse_command_line(), CommandLineOptions::read_only, CommandLineOptions::render_compositor_use_last_gpu, CommandLineOptions::render_mem_bytes, CommandLineOptions::render_oom_retry_threshold, CommandLineOptions::renderer_prefer_igpu, CommandLineOptions::renderer_use_ppll_polys, CommandLineOptions::renderer_vulkan_timeout_ms, CommandLineOptions::reserved_gpu_mem, session_id_, CommandLineOptions::string_leaves, CommandLineOptions::system_parameters, CommandLineOptions::udf_compiler_options, CommandLineOptions::udf_compiler_path, and CommandLineOptions::udf_file_name.

105  {
106  static bool initialized{false};
107  if (initialized) {
108  throw std::runtime_error("Database engine already initialized");
109  }
110 
112 
113  // Split the command line into parameters
114  std::vector<std::string> parameters;
115  if (!cmd_line.empty()) {
116  parameters = boost::program_options::split_unix(cmd_line);
117  }
118 
119  // Generate command line to initialize CommandLineOptions for DBHandler
120  const char* log_option = "omnisci_dbe";
121  std::vector<const char*> cstrings;
122  cstrings.push_back(log_option);
123  for (auto& param : parameters) {
124  cstrings.push_back(param.c_str());
125  }
126  int argc = cstrings.size();
127  const char** argv = cstrings.data();
128 
129  CommandLineOptions prog_config_opts(log_option);
130  if (prog_config_opts.parse_command_line(argc, argv, false)) {
131  throw std::runtime_error("DBE paramerameters parsing failed");
132  }
133 
134  if (!g_enable_thrift_logs) {
135  apache::thrift::GlobalOutput.setOutputFunction([](const char* msg) {});
136  }
137 
138  auto base_path = prog_config_opts.base_path;
139 
140  // Check path to the database
141  bool is_new_db = base_path.empty() || !catalogExists(base_path);
142  if (is_new_db) {
143  base_path = createCatalog(base_path);
144  if (base_path.empty()) {
145  throw std::runtime_error("Database directory could not be created");
146  }
147  }
148  prog_config_opts.base_path = base_path;
149  prog_config_opts.init_logging();
150 
151  prog_config_opts.system_parameters.omnisci_server_port = -1;
152  prog_config_opts.system_parameters.calcite_keepalive = true;
153 
154  try {
155  db_handler_ =
156  std::make_shared<DBHandler>(prog_config_opts.db_leaves,
157  prog_config_opts.string_leaves,
158  prog_config_opts.base_path,
159  prog_config_opts.allow_multifrag,
160  prog_config_opts.jit_debug,
161  prog_config_opts.intel_jit_profile,
162  prog_config_opts.read_only,
163  prog_config_opts.allow_loop_joins,
164  prog_config_opts.enable_rendering,
165  prog_config_opts.renderer_use_ppll_polys,
166  prog_config_opts.renderer_prefer_igpu,
167  prog_config_opts.renderer_vulkan_timeout_ms,
168  prog_config_opts.enable_auto_clear_render_mem,
169  prog_config_opts.render_oom_retry_threshold,
170  prog_config_opts.render_mem_bytes,
171  prog_config_opts.max_concurrent_render_sessions,
172  prog_config_opts.reserved_gpu_mem,
173  prog_config_opts.render_compositor_use_last_gpu,
174  prog_config_opts.num_reader_threads,
175  prog_config_opts.authMetadata,
176  prog_config_opts.system_parameters,
177  prog_config_opts.enable_legacy_syntax,
178  prog_config_opts.idle_session_duration,
179  prog_config_opts.max_session_duration,
180  prog_config_opts.udf_file_name,
181  prog_config_opts.udf_compiler_path,
182  prog_config_opts.udf_compiler_options,
183 #ifdef ENABLE_GEOS
184  prog_config_opts.libgeos_so_filename,
185 #endif
186  prog_config_opts.disk_cache_config,
187  is_new_db);
188  } catch (const std::exception& e) {
189  LOG(FATAL) << "Failed to initialize database handler: " << e.what();
190  }
191  db_handler_->connect(session_id_,
195  base_path_ = base_path;
196  initialized = true;
197  return true;
198  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437
#define LOG(tag)
Definition: Logger.h:217
bool catalogExists(const std::string &base_path)
Definition: DBEngine.cpp:368
const std::string kDefaultDbName
std::string createCatalog(const std::string &base_path)
Definition: DBEngine.cpp:392
bool g_serialize_temp_tables
Definition: Catalog.cpp:106
const std::string kRootUsername
const std::string kDefaultRootPasswd
bool g_enable_thrift_logs
Definition: HeavyDB.cpp:288

+ Here is the call graph for this function:

bool EmbeddedDatabase::DBEngineImpl::login ( std::string &  db_name,
std::string &  user_name,
const std::string &  password 
)
inline

Definition at line 346 of file DBEngine.cpp.

References db_handler_, and session_id_.

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

346  {
347  db_handler_->disconnect(session_id_);
348  db_handler_->connect(session_id_, user_name, password, db_name);
349  return true;
350  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437

+ Here is the caller graph for this function:

void EmbeddedDatabase::DBEngineImpl::reset ( )
inlineprotected

Definition at line 353 of file DBEngine.cpp.

References base_path_, db_handler_, Catalog_Namespace::SysCatalog::destroy(), is_temp_db_, session_id_, and logger::shutdown().

Referenced by ~DBEngineImpl().

353  {
354  if (db_handler_) {
355  db_handler_->disconnect(session_id_);
356  db_handler_->shutdown();
357  }
359  db_handler_.reset();
360 
362  if (is_temp_db_) {
363  boost::filesystem::remove_all(base_path_);
364  }
365  base_path_.clear();
366  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437
void shutdown()
Definition: Logger.cpp:341

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

bool EmbeddedDatabase::DBEngineImpl::setDatabase ( std::string &  db_name)
inline

Definition at line 339 of file DBEngine.cpp.

References db_handler_, Catalog_Namespace::SysCatalog::instance(), and session_id_.

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

339  {
340  auto& sys_cat = Catalog_Namespace::SysCatalog::instance();
341  auto& user = db_handler_->get_session_copy(session_id_).get_currentUser();
342  sys_cat.switchDatabase(db_name, user.userName);
343  return true;
344  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437
static SysCatalog & instance()
Definition: SysCatalog.h:337

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::shared_ptr<CursorImpl> EmbeddedDatabase::DBEngineImpl::sql_execute_dbe ( const TSessionId &  session_id,
const std::string &  query_str,
const bool  column_format,
const int32_t  first_n,
const int32_t  at_most_n 
)
inline

Definition at line 200 of file DBEngine.cpp.

References CPU, db_handler_, and run_benchmark_import::result.

Referenced by executeDDL(), executeDML(), and executeRA().

204  {
205  ExecutionResult result{std::make_shared<ResultSet>(std::vector<TargetInfo>{},
208  nullptr,
209  nullptr,
210  0,
211  0),
212  {}};
213  db_handler_->sql_execute(
214  result, session_id, query_str, column_format, first_n, at_most_n);
215  auto& targets = result.getTargetsMeta();
216  std::vector<std::string> col_names;
217  for (const auto target : targets) {
218  col_names.push_back(target.get_resname());
219  }
220  return std::make_shared<CursorImpl>(result.getRows(), col_names);
221  }
std::shared_ptr< DBHandler > db_handler_
Definition: DBEngine.cpp:437

+ Here is the caller graph for this function:

Member Data Documentation

std::string EmbeddedDatabase::DBEngineImpl::base_path_
private

Definition at line 435 of file DBEngine.cpp.

Referenced by init(), and reset().

std::shared_ptr<DBHandler> EmbeddedDatabase::DBEngineImpl::db_handler_
private
bool EmbeddedDatabase::DBEngineImpl::is_temp_db_
private

Definition at line 438 of file DBEngine.cpp.

Referenced by createCatalog(), and reset().

std::string EmbeddedDatabase::DBEngineImpl::session_id_
private
std::vector<std::string> EmbeddedDatabase::DBEngineImpl::system_folders_
private
std::string EmbeddedDatabase::DBEngineImpl::udf_filename_
private

Definition at line 439 of file DBEngine.cpp.


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