Go to the documentation of this file.
16 #ifndef GRAPHSCOPE_DATABASE_INSERT_TRANSACTION_H_
17 #define GRAPHSCOPE_DATABASE_INSERT_TRANSACTION_H_
25 #include "grape/serialization/in_archive.h"
29 class MutablePropertyFragment;
36 std::string
run(
const std::string& cypher,
37 const std::map<std::string, std::string>& params);
58 char* data,
size_t length,
Allocator& alloc);
86 #endif // GRAPHSCOPE_DATABASE_INSERT_TRANSACTION_H_
static bool get_vertex_with_retries(MutablePropertyFragment &graph, label_t label, const Any &oid, vid_t &lid)
Definition: insert_transaction.cc:231
const Schema & schema() const
Definition: insert_transaction.cc:225
bool AddEdge(label_t src_label, const Any &src, label_t dst_label, const Any &dst, label_t edge_label, const Any &prop)
Definition: insert_transaction.cc:84
uint32_t timestamp_t
Definition: types.h:30
void clear()
Definition: insert_transaction.cc:217
uint32_t vid_t
Definition: types.h:31
Definition: insert_transaction.h:34
std::set< std::pair< label_t, Any > > added_vertices_
Definition: insert_transaction.h:74
timestamp_t timestamp_
Definition: insert_transaction.h:81
grape::InArchive arc_
Definition: insert_transaction.h:72
Definition: adj_list.h:23
const GraphDBSession & GetSession() const
Definition: insert_transaction.cc:227
InsertTransaction(const GraphDBSession &session, MutablePropertyFragment &graph, Allocator &alloc, IWalWriter &logger, VersionManager &vm, timestamp_t timestamp)
Definition: insert_transaction.cc:26
static void IngestWal(MutablePropertyFragment &graph, uint32_t timestamp, char *data, size_t length, Allocator &alloc)
Definition: insert_transaction.cc:184
Definition: allocators.h:29
timestamp_t timestamp() const
Definition: insert_transaction.cc:182
Definition: mutable_property_fragment.h:37
bool AddVertex(label_t label, const Any &id, const std::vector< Any > &props)
Definition: insert_transaction.cc:48
Allocator & alloc_
Definition: insert_transaction.h:78
Definition: graph_db_session.h:36
bool Commit()
Definition: insert_transaction.cc:147
Definition: version_manager.h:34
MutablePropertyFragment & graph_
Definition: insert_transaction.h:76
VersionManager & vm_
Definition: insert_transaction.h:80
std::string run(const std::string &cypher, const std::map< std::string, std::string > ¶ms)
Definition: insert_transaction.cc:42
void Abort()
Definition: insert_transaction.cc:174
IWalWriter & logger_
Definition: insert_transaction.h:79
uint8_t label_t
Definition: types.h:32
const GraphDBSession & session_
Definition: insert_transaction.h:70
~InsertTransaction()
Definition: insert_transaction.cc:40