gs::InsertTransaction Class Reference

#include <insert_transaction.h>

Collaboration diagram for gs::InsertTransaction:

Public Member Functions
std::string	run (const std::string &cypher, const std::map< std::string, std::string > &params)
	InsertTransaction (const GraphDBSession &session, MutablePropertyFragment &graph, Allocator &alloc, IWalWriter &logger, VersionManager &vm, timestamp_t timestamp)
	~InsertTransaction ()
bool	AddVertex (label_t label, const Any &id, const std::vector< Any > &props)
bool	AddEdge (label_t src_label, const Any &src, label_t dst_label, const Any &dst, label_t edge_label, const Any &prop)
bool	Commit ()
void	Abort ()
timestamp_t	timestamp () const
const Schema &	schema () const
const GraphDBSession &	GetSession () const

Static Public Member Functions
static void	IngestWal (MutablePropertyFragment &graph, uint32_t timestamp, char *data, size_t length, Allocator &alloc)

Private Member Functions
void	clear ()

Static Private Member Functions
static bool	get_vertex_with_retries (MutablePropertyFragment &graph, label_t label, const Any &oid, vid_t &lid)

Private Attributes
const GraphDBSession &	session_
grape::InArchive	arc_
std::set< std::pair< label_t, Any > >	added_vertices_
MutablePropertyFragment &	graph_
Allocator &	alloc_
IWalWriter &	logger_
VersionManager &	vm_
timestamp_t	timestamp_

Constructor & Destructor Documentation

InsertTransaction()

gs::InsertTransaction::InsertTransaction	(	const GraphDBSession &	session,
		MutablePropertyFragment &	graph,
		Allocator &	alloc,
		IWalWriter &	logger,
		VersionManager &	vm,
		timestamp_t	timestamp
	)

~InsertTransaction()

gs::InsertTransaction::~InsertTransaction

(

)

Member Function Documentation

Abort()

void gs::InsertTransaction::Abort

(

)

AddEdge()

bool gs::InsertTransaction::AddEdge	(	label_t	src_label,
		const Any &	src,
		label_t	dst_label,
		const Any &	dst,
		label_t	edge_label,
		const Any &	prop
	)

AddVertex()

bool gs::InsertTransaction::AddVertex	(	label_t	label,
		const Any &	id,
		const std::vector< Any > &	props
	)

clear()

void gs::InsertTransaction::clear ( )

private

Commit()

bool gs::InsertTransaction::Commit

(

)

get_vertex_with_retries()

bool gs::InsertTransaction::get_vertex_with_retries ( MutablePropertyFragment &  graph, label_t  label, const Any &  oid, vid_t &  lid  )

staticprivate

GetSession()

const GraphDBSession & gs::InsertTransaction::GetSession

(

)

const

IngestWal()

void gs::InsertTransaction::IngestWal ( MutablePropertyFragment &  graph, uint32_t  timestamp, char *  data, size_t  length, Allocator &  alloc  )

static

run()

std::string gs::InsertTransaction::run	(	const std::string &	cypher,
		const std::map< std::string, std::string > &	params
	)

schema()

const Schema & gs::InsertTransaction::schema

(

)

const

timestamp()

timestamp_t gs::InsertTransaction::timestamp

(

)

const

Member Data Documentation

added_vertices_

std::set<std::pair<label_t, Any> > gs::InsertTransaction::added_vertices_

private

alloc_

Allocator& gs::InsertTransaction::alloc_

private

arc_

grape::InArchive gs::InsertTransaction::arc_

private

graph_

MutablePropertyFragment& gs::InsertTransaction::graph_

private

logger_

IWalWriter& gs::InsertTransaction::logger_

private

session_

const GraphDBSession& gs::InsertTransaction::session_

private

timestamp_

timestamp_t gs::InsertTransaction::timestamp_

private

vm_

VersionManager& gs::InsertTransaction::vm_

private

---

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

• /home/runner/work/GraphScope/GraphScope/flex/engines/graph_db/database/insert_transaction.h
• /home/runner/work/GraphScope/GraphScope/flex/engines/graph_db/database/insert_transaction.cc