Kùzu C++ API
|
Contain client side configuration. We make profiler associated per query, so profiler is not maintained in client context. More...
#include <client_context.h>
Public Member Functions | |
ClientContext (Database *database) | |
~ClientContext () | |
const ClientConfig * | getClientConfig () const |
ClientConfig * | getClientConfigUnsafe () |
const DBConfig * | getDBConfig () const |
DBConfig * | getDBConfigUnsafe () |
common::Value | getCurrentSetting (const std::string &optionName) |
bool | isOptionSet (const std::string &optionName) const |
void | interrupt () |
bool | interrupted () const |
bool | hasTimeout () const |
void | setQueryTimeOut (uint64_t timeoutInMS) |
uint64_t | getQueryTimeOut () const |
void | startTimer () |
uint64_t | getTimeoutRemainingInMS () const |
void | resetActiveQuery () |
void | setMaxNumThreadForExec (uint64_t numThreads) |
uint64_t | getMaxNumThreadForExec () const |
transaction::Transaction * | getTx () const |
transaction::TransactionContext * | getTransactionContext () const |
common::ProgressBar * | getProgressBar () const |
void | addScanReplace (function::ScanReplacement scanReplacement) |
std::unique_ptr< function::ScanReplacementData > | tryReplace (const std::string &objectName) const |
void | setExtensionOption (std::string name, common::Value value) |
extension::ExtensionOptions * | getExtensionOptions () const |
std::string | getExtensionDir () const |
std::string | getEnvVariable (const std::string &name) |
std::string | getDatabasePath () const |
Database * | getDatabase () const |
common::TaskScheduler * | getTaskScheduler () const |
DatabaseManager * | getDatabaseManager () const |
storage::StorageManager * | getStorageManager () const |
storage::MemoryManager * | getMemoryManager () |
storage::WAL * | getWAL () const |
catalog::Catalog * | getCatalog () const |
transaction::TransactionManager * | getTransactionManagerUnsafe () const |
common::VirtualFileSystem * | getVFSUnsafe () const |
common::RandomEngine * | getRandomEngine () |
std::unique_ptr< PreparedStatement > | prepare (std::string_view query) |
std::unique_ptr< QueryResult > | executeWithParams (PreparedStatement *preparedStatement, std::unordered_map< std::string, std::unique_ptr< common::Value > > inputParams, std::optional< uint64_t > queryID=std::nullopt) |
std::unique_ptr< QueryResult > | query (std::string_view queryStatement, std::optional< uint64_t > queryID=std::nullopt) |
std::vector< std::shared_ptr< parser::Statement > > | parseQuery (std::string_view query) |
void | setDefaultDatabase (AttachedKuzuDatabase *defaultDatabase_) |
bool | hasDefaultDatabase () |
void | addScalarFunction (std::string name, function::function_set definitions) |
void | removeScalarFunction (std::string name) |
processor::WarningContext & | getWarningContextUnsafe () |
const processor::WarningContext & | getWarningContext () const |
graph::GraphEntrySet & | getGraphEntrySetUnsafe () |
void | cleanUP () |
std::unique_ptr< QueryResult > | queryInternal (std::string_view query, std::string_view encodedJoin, bool enumerateAllPlans=true, std::optional< uint64_t > queryID=std::nullopt) |
Friends | |
class | Connection |
class | binder::Binder |
class | binder::ExpressionBinder |
class | processor::ImportDB |
struct | main::SpillToDiskSetting |
Contain client side configuration. We make profiler associated per query, so profiler is not maintained in client context.
|
explicit |
kuzu::main::ClientContext::~ClientContext | ( | ) |
void kuzu::main::ClientContext::addScalarFunction | ( | std::string | name, |
function::function_set | definitions ) |
void kuzu::main::ClientContext::addScanReplace | ( | function::ScanReplacement | scanReplacement | ) |
void kuzu::main::ClientContext::cleanUP | ( | ) |
std::unique_ptr< QueryResult > kuzu::main::ClientContext::executeWithParams | ( | PreparedStatement * | preparedStatement, |
std::unordered_map< std::string, std::unique_ptr< common::Value > > | inputParams, | ||
std::optional< uint64_t > | queryID = std::nullopt ) |
catalog::Catalog * kuzu::main::ClientContext::getCatalog | ( | ) | const |
|
inline |
|
inline |
common::Value kuzu::main::ClientContext::getCurrentSetting | ( | const std::string & | optionName | ) |
|
inline |
DatabaseManager * kuzu::main::ClientContext::getDatabaseManager | ( | ) | const |
std::string kuzu::main::ClientContext::getDatabasePath | ( | ) | const |
|
inline |
|
inline |
std::string kuzu::main::ClientContext::getEnvVariable | ( | const std::string & | name | ) |
std::string kuzu::main::ClientContext::getExtensionDir | ( | ) | const |
extension::ExtensionOptions * kuzu::main::ClientContext::getExtensionOptions | ( | ) | const |
graph::GraphEntrySet & kuzu::main::ClientContext::getGraphEntrySetUnsafe | ( | ) |
uint64_t kuzu::main::ClientContext::getMaxNumThreadForExec | ( | ) | const |
storage::MemoryManager * kuzu::main::ClientContext::getMemoryManager | ( | ) |
common::ProgressBar * kuzu::main::ClientContext::getProgressBar | ( | ) | const |
uint64_t kuzu::main::ClientContext::getQueryTimeOut | ( | ) | const |
common::RandomEngine * kuzu::main::ClientContext::getRandomEngine | ( | ) |
storage::StorageManager * kuzu::main::ClientContext::getStorageManager | ( | ) | const |
common::TaskScheduler * kuzu::main::ClientContext::getTaskScheduler | ( | ) | const |
uint64_t kuzu::main::ClientContext::getTimeoutRemainingInMS | ( | ) | const |
transaction::TransactionContext * kuzu::main::ClientContext::getTransactionContext | ( | ) | const |
transaction::TransactionManager * kuzu::main::ClientContext::getTransactionManagerUnsafe | ( | ) | const |
transaction::Transaction * kuzu::main::ClientContext::getTx | ( | ) | const |
common::VirtualFileSystem * kuzu::main::ClientContext::getVFSUnsafe | ( | ) | const |
storage::WAL * kuzu::main::ClientContext::getWAL | ( | ) | const |
const processor::WarningContext & kuzu::main::ClientContext::getWarningContext | ( | ) | const |
processor::WarningContext & kuzu::main::ClientContext::getWarningContextUnsafe | ( | ) |
bool kuzu::main::ClientContext::hasDefaultDatabase | ( | ) |
|
inline |
|
inline |
|
inline |
bool kuzu::main::ClientContext::isOptionSet | ( | const std::string & | optionName | ) | const |
std::vector< std::shared_ptr< parser::Statement > > kuzu::main::ClientContext::parseQuery | ( | std::string_view | query | ) |
std::unique_ptr< PreparedStatement > kuzu::main::ClientContext::prepare | ( | std::string_view | query | ) |
std::unique_ptr< QueryResult > kuzu::main::ClientContext::query | ( | std::string_view | queryStatement, |
std::optional< uint64_t > | queryID = std::nullopt ) |
std::unique_ptr< QueryResult > kuzu::main::ClientContext::queryInternal | ( | std::string_view | query, |
std::string_view | encodedJoin, | ||
bool | enumerateAllPlans = true, | ||
std::optional< uint64_t > | queryID = std::nullopt ) |
void kuzu::main::ClientContext::removeScalarFunction | ( | std::string | name | ) |
|
inline |
void kuzu::main::ClientContext::setDefaultDatabase | ( | AttachedKuzuDatabase * | defaultDatabase_ | ) |
void kuzu::main::ClientContext::setExtensionOption | ( | std::string | name, |
common::Value | value ) |
void kuzu::main::ClientContext::setMaxNumThreadForExec | ( | uint64_t | numThreads | ) |
void kuzu::main::ClientContext::setQueryTimeOut | ( | uint64_t | timeoutInMS | ) |
void kuzu::main::ClientContext::startTimer | ( | ) |
std::unique_ptr< function::ScanReplacementData > kuzu::main::ClientContext::tryReplace | ( | const std::string & | objectName | ) | const |
|
friend |
|
friend |
|
friend |
|
friend |
|
friend |