Kùzu C++ API
|
#include <transaction.h>
Public Member Functions | |
Transaction (main::ClientContext &clientContext, TransactionType transactionType, common::transaction_t transactionID, common::transaction_t startTS) | |
Transaction (TransactionType transactionType) noexcept | |
Transaction (TransactionType transactionType, common::transaction_t ID, common::transaction_t startTS) noexcept | |
~Transaction () | |
TransactionType | getType () const |
bool | isReadOnly () const |
bool | isWriteTransaction () const |
bool | isDummy () const |
bool | isRecovery () const |
common::transaction_t | getID () const |
common::transaction_t | getStartTS () const |
common::transaction_t | getCommitTS () const |
int64_t | getCurrentTS () const |
main::ClientContext * | getClientContext () const |
void | checkForceCheckpoint (common::StatementType statementType) |
bool | shouldAppendToUndoBuffer () const |
bool | shouldLogToWAL () const |
bool | shouldForceCheckpoint () const |
KUZU_API void | commit (storage::WAL *wal) const |
void | rollback (storage::WAL *wal) const |
uint64_t | getEstimatedMemUsage () const |
storage::LocalStorage * | getLocalStorage () const |
bool | hasNewlyInsertedNodes (common::table_id_t tableID) const |
void | setMaxCommittedNodeOffset (common::table_id_t tableID, common::offset_t offset) |
bool | isUnCommitted (common::table_id_t tableID, common::offset_t nodeOffset) const |
common::row_idx_t | getLocalRowIdx (common::table_id_t tableID, common::offset_t nodeOffset) const |
common::offset_t | getUncommittedOffset (common::table_id_t tableID, common::row_idx_t localRowIdx) const |
common::offset_t | getMinUncommittedNodeOffset (common::table_id_t tableID) const |
common::offset_t | getMaxCommittedNodeOffset (common::table_id_t tableID) const |
common::offset_t | getCommittedOffsetFromUncommitted (common::table_id_t tableID, common::offset_t uncommittedOffset) const |
void | pushCreateDropCatalogEntry (catalog::CatalogSet &catalogSet, catalog::CatalogEntry &catalogEntry, bool isInternal, bool skipLoggingToWAL=false) const |
void | pushAlterCatalogEntry (catalog::CatalogSet &catalogSet, catalog::CatalogEntry &catalogEntry, const binder::BoundAlterInfo &alterInfo) const |
void | pushSequenceChange (catalog::SequenceCatalogEntry *sequenceEntry, int64_t kCount, const catalog::SequenceRollbackData &data) const |
void | pushInsertInfo (common::node_group_idx_t nodeGroupIdx, common::row_idx_t startRow, common::row_idx_t numRows, const storage::VersionRecordHandler *versionRecordHandler) const |
void | pushDeleteInfo (common::node_group_idx_t nodeGroupIdx, common::row_idx_t startRow, common::row_idx_t numRows, const storage::VersionRecordHandler *versionRecordHandler) const |
void | pushVectorUpdateInfo (storage::UpdateInfo &updateInfo, common::idx_t vectorIdx, storage::VectorUpdateInfo &vectorUpdateInfo) const |
Static Public Member Functions | |
static Transaction | getDummyTransactionFromExistingOne (const Transaction &other) |
Static Public Attributes | |
static constexpr common::transaction_t | DUMMY_TRANSACTION_ID = 0 |
static constexpr common::transaction_t | DUMMY_START_TIMESTAMP = 0 |
static constexpr common::transaction_t | START_TRANSACTION_ID |
Friends | |
class | TransactionManager |
kuzu::transaction::Transaction::Transaction | ( | main::ClientContext & | clientContext, |
TransactionType | transactionType, | ||
common::transaction_t | transactionID, | ||
common::transaction_t | startTS ) |
|
explicitnoexcept |
|
noexcept |
kuzu::transaction::Transaction::~Transaction | ( | ) |
|
inline |
KUZU_API void kuzu::transaction::Transaction::commit | ( | storage::WAL * | wal | ) | const |
|
inline |
|
inline |
|
inline |
|
inline |
|
static |
uint64_t kuzu::transaction::Transaction::getEstimatedMemUsage | ( | ) | const |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
void kuzu::transaction::Transaction::pushAlterCatalogEntry | ( | catalog::CatalogSet & | catalogSet, |
catalog::CatalogEntry & | catalogEntry, | ||
const binder::BoundAlterInfo & | alterInfo ) const |
void kuzu::transaction::Transaction::pushCreateDropCatalogEntry | ( | catalog::CatalogSet & | catalogSet, |
catalog::CatalogEntry & | catalogEntry, | ||
bool | isInternal, | ||
bool | skipLoggingToWAL = false ) const |
void kuzu::transaction::Transaction::pushDeleteInfo | ( | common::node_group_idx_t | nodeGroupIdx, |
common::row_idx_t | startRow, | ||
common::row_idx_t | numRows, | ||
const storage::VersionRecordHandler * | versionRecordHandler ) const |
void kuzu::transaction::Transaction::pushInsertInfo | ( | common::node_group_idx_t | nodeGroupIdx, |
common::row_idx_t | startRow, | ||
common::row_idx_t | numRows, | ||
const storage::VersionRecordHandler * | versionRecordHandler ) const |
void kuzu::transaction::Transaction::pushSequenceChange | ( | catalog::SequenceCatalogEntry * | sequenceEntry, |
int64_t | kCount, | ||
const catalog::SequenceRollbackData & | data ) const |
void kuzu::transaction::Transaction::pushVectorUpdateInfo | ( | storage::UpdateInfo & | updateInfo, |
common::idx_t | vectorIdx, | ||
storage::VectorUpdateInfo & | vectorUpdateInfo ) const |
void kuzu::transaction::Transaction::rollback | ( | storage::WAL * | wal | ) | const |
|
inline |
|
inline |
bool kuzu::transaction::Transaction::shouldForceCheckpoint | ( | ) | const |
bool kuzu::transaction::Transaction::shouldLogToWAL | ( | ) | const |
|
friend |
|
staticconstexpr |
|
staticconstexpr |
|
staticconstexpr |