Store all the tables of the database. More...

#include <joedb/db/multi_server/Database.h>

Inheritance diagram for joedb::db::multi_server::Database:

[legend]

Collaboration diagram for joedb::db::multi_server::Database:

[legend]

Public Member Functions
void	set_max_record_id (size_t record_id)

bool	is_valid (id_of_server id) const

	Database ()

int64_t	get_schema_checkpoint () const

void	initialize_with_readonly_journal (joedb::Readonly_Journal &journal)

container_of_server	get_server_table () const

id_of_server	next (id_of_server id) const

id_of_server	previous (id_of_server id) const

template<class Comparator >
std::vector< id_of_server >	sorted_server (Comparator comparator) const

const std::string &	get_file_name (id_of_server record) const

int32_t	get_port (id_of_server record) const

int32_t	get_timeout (id_of_server record) const

const std::map< int32_t, id_of_server > &	get_index_of_server_by_port ()

id_of_server	next_server_by_port (id_of_server id)

id_of_server	previous_server_by_port (id_of_server id)

id_of_server	find_server_by_port (int32_t field_value_of_port) const

Public Member Functions inherited from joedb::Writable
virtual int64_t	get_position () const

virtual void	start_writing (int64_t position)

virtual void	soft_checkpoint_at (int64_t position)

virtual void	hard_checkpoint_at (int64_t position)

void	soft_checkpoint ()

void	hard_checkpoint ()

virtual void	drop_table (Table_Id table_id)

virtual void	rename_table (Table_Id table_id, const std::string &name)

virtual void	add_field (Table_Id table_id, const std::string &name, Type type)

virtual void	drop_field (Table_Id table_id, Field_Id field_id)

virtual void	rename_field (Table_Id table_id, Field_Id field_id, const std::string &name)

virtual void	flush ()

virtual void	insert_into (Table_Id table_id, Record_Id record_id)

virtual void	delete_from (Table_Id table_id, Record_Id record_id)

virtual void	insert_vector (Table_Id table_id, Record_Id record_id, size_t size)

virtual void	delete_vector (Table_Id table_id, Record_Id record_id, size_t size)

virtual void	on_blob (Blob blob)

virtual bool	wants_blob_data () const

virtual Blob	write_blob (const std::string &data)

virtual	~Writable ()=default

Static Public Member Functions
template<typename E = joedb::Exception>
static void	throw_exception (const std::string &message)

static id_of_server	null_server ()

Public Attributes
size_t	max_record_id

Table_Id	current_table_id = Table_Id{0}

Protected Member Functions
bool	is_valid_record_id_for_server (Record_Id record_id) const

void	remove_index_of_server_by_port (Record_Id record_id)

void	add_index_of_server_by_port (Record_Id record_id)

void	internal_delete_server (Record_Id record_id)

void	internal_insert_server (Record_Id record_id)

void	internal_vector_insert_server (Record_Id record_id, size_t size)

void	internal_update_server__file_name (Record_Id record_id, const std::string &field_value_of_file_name)

void	internal_update_vector_server__file_name (Record_Id record_id, size_t size, const std::string *value)

void	internal_update_server__port (Record_Id record_id, int32_t field_value_of_port)

void	internal_update_vector_server__port (Record_Id record_id, size_t size, const int32_t *value)

void	internal_update_server__timeout (Record_Id record_id, int32_t field_value_of_timeout)

void	internal_update_vector_server__timeout (Record_Id record_id, size_t size, const int32_t *value)

void	delete_from (Table_Id table_id, Record_Id record_id) final

void	insert_into (Table_Id table_id, Record_Id record_id) final

void	insert_vector (Table_Id table_id, Record_Id record_id, size_t size) final

void	update_string (Table_Id table_id, Record_Id record_id, Field_Id field_id, const std::string &value) final

void	update_int32 (Table_Id table_id, Record_Id record_id, Field_Id field_id, int32_t value) final

void	update_vector_string (Table_Id table_id, Record_Id record_id, Field_Id field_id, size_t size, const std::string *value) final

void	update_vector_int32 (Table_Id table_id, Record_Id record_id, Field_Id field_id, size_t size, const int32_t *value) final

std::string *	get_own_string_storage (Table_Id table_id, Record_Id record_id, Field_Id field_id, size_t &capacity) final

int32_t *	get_own_int32_storage (Table_Id table_id, Record_Id record_id, Field_Id field_id, size_t &capacity) final

void	comment (const std::string &comment) override

void	timestamp (int64_t timestamp) override

void	valid_data () final

bool	requires_schema_upgrade () const

void	check_schema ()

void	create_table (const std::string &name) override

void	drop_table (Table_Id table_id) final

void	rename_table (Table_Id table_id, const std::string &name) final

void	add_field (Table_Id table_id, const std::string &name, joedb::Type type) override

void	drop_field (Table_Id table_id, Field_Id field_id) final

void	rename_field (Table_Id table_id, Field_Id field_id, const std::string &name) final

void	custom (const std::string &name) override

Protected Attributes
detail::data_of_server	storage_of_server

std::map< int32_t, id_of_server >	index_of_server_by_port

bool	upgrading_schema = false

joedb::Memory_File	schema_file

joedb::Writable_Journal	schema_journal

Friends
class	Readable

class	id_of_server

class	container_of_server

Detailed Description

Definition at line 81 of file Database.h.

Constructor & Destructor Documentation

◆ Database()

joedb::db::multi_server::Database::Database ( )

inline

Definition at line 520 of file Database.h.

Member Function Documentation

◆ add_field()

void joedb::db::multi_server::Database::add_field	(	Table_Id	table_id,
		const std::string &	name,
		joedb::Type	type
	)

inlineoverrideprotected

Definition at line 485 of file Database.h.

◆ add_index_of_server_by_port()

void joedb::db::multi_server::Database::add_index_of_server_by_port ( Record_Id record_id )

inlineprotected

Definition at line 118 of file Database.h.

◆ check_schema()

void joedb::db::multi_server::Database::check_schema ( )

inlineprotected

Definition at line 441 of file Database.h.

◆ comment()

void joedb::db::multi_server::Database::comment ( const std::string & comment )

inlineoverrideprotectedvirtual

Reimplemented from joedb::Writable.

Definition at line 428 of file Database.h.

◆ create_table()

void joedb::db::multi_server::Database::create_table ( const std::string & name )

inlineoverrideprotectedvirtual

Reimplemented from joedb::Writable.

Definition at line 462 of file Database.h.

◆ custom()

void joedb::db::multi_server::Database::custom ( const std::string & name )

inlineoverrideprotectedvirtual

Reimplemented from joedb::Writable.

Definition at line 513 of file Database.h.

◆ delete_from()

void joedb::db::multi_server::Database::delete_from	(	Table_Id	table_id,
		Record_Id	record_id
	)

inlinefinalprotected

Definition at line 246 of file Database.h.

◆ drop_field()

void joedb::db::multi_server::Database::drop_field	(	Table_Id	table_id,
		Field_Id	field_id
	)

inlinefinalprotected

Definition at line 496 of file Database.h.

◆ drop_table()

void joedb::db::multi_server::Database::drop_table ( Table_Id table_id )

inlinefinalprotected

Definition at line 469 of file Database.h.

◆ find_server_by_port()

id_of_server joedb::db::multi_server::Database::find_server_by_port ( int32_t field_value_of_port ) const

inline

Definition at line 610 of file Database.h.

◆ get_file_name()

const std::string & joedb::db::multi_server::Database::get_file_name ( id_of_server record ) const

inline

Definition at line 568 of file Database.h.

◆ get_index_of_server_by_port()

const std::map< int32_t, id_of_server > & joedb::db::multi_server::Database::get_index_of_server_by_port ( )

inline

Definition at line 586 of file Database.h.

◆ get_own_int32_storage()

int32_t * joedb::db::multi_server::Database::get_own_int32_storage	(	Table_Id	table_id,
		Record_Id	record_id,
		Field_Id	field_id,
		size_t &	capacity
	)

inlinefinalprotected

Definition at line 403 of file Database.h.

◆ get_own_string_storage()

std::string * joedb::db::multi_server::Database::get_own_string_storage	(	Table_Id	table_id,
		Record_Id	record_id,
		Field_Id	field_id,
		size_t &	capacity
	)

inlinefinalprotected

Definition at line 382 of file Database.h.

◆ get_port()

int32_t joedb::db::multi_server::Database::get_port ( id_of_server record ) const

inline

Definition at line 574 of file Database.h.

◆ get_schema_checkpoint()

int64_t joedb::db::multi_server::Database::get_schema_checkpoint ( ) const

inline

Definition at line 525 of file Database.h.

◆ get_server_table()

container_of_server joedb::db::multi_server::Database::get_server_table ( ) const

inline

Definition at line 663 of file Database.h.

◆ get_timeout()

int32_t joedb::db::multi_server::Database::get_timeout ( id_of_server record ) const

inline

Definition at line 580 of file Database.h.

◆ initialize_with_readonly_journal()

void joedb::db::multi_server::Database::initialize_with_readonly_journal ( joedb::Readonly_Journal & journal )

inline

Definition at line 530 of file Database.h.

◆ insert_into()

void joedb::db::multi_server::Database::insert_into	(	Table_Id	table_id,
		Record_Id	record_id
	)

inlinefinalprotected

Definition at line 252 of file Database.h.

◆ insert_vector()

void joedb::db::multi_server::Database::insert_vector	(	Table_Id	table_id,
		Record_Id	record_id,
		size_t	size
	)

inlinefinalprotected

Definition at line 267 of file Database.h.

◆ internal_delete_server()

void joedb::db::multi_server::Database::internal_delete_server ( Record_Id record_id )

inlineprotected

Definition at line 140 of file Database.h.

◆ internal_insert_server()

void joedb::db::multi_server::Database::internal_insert_server ( Record_Id record_id )

inlineprotected

Definition at line 150 of file Database.h.

◆ internal_update_server__file_name()

void joedb::db::multi_server::Database::internal_update_server__file_name	(	Record_Id	record_id,
		const std::string &	field_value_of_file_name
	)

inlineprotected

Definition at line 167 of file Database.h.

◆ internal_update_server__port()

void joedb::db::multi_server::Database::internal_update_server__port	(	Record_Id	record_id,
		int32_t	field_value_of_port
	)

inlineprotected

Definition at line 191 of file Database.h.

◆ internal_update_server__timeout()

void joedb::db::multi_server::Database::internal_update_server__timeout	(	Record_Id	record_id,
		int32_t	field_value_of_timeout
	)

inlineprotected

Definition at line 221 of file Database.h.

◆ internal_update_vector_server__file_name()

void joedb::db::multi_server::Database::internal_update_vector_server__file_name	(	Record_Id	record_id,
		size_t	size,
		const std::string *	value
	)

inlineprotected

Definition at line 177 of file Database.h.

◆ internal_update_vector_server__port()

void joedb::db::multi_server::Database::internal_update_vector_server__port	(	Record_Id	record_id,
		size_t	size,
		const int32_t *	value
	)

inlineprotected

Definition at line 203 of file Database.h.

◆ internal_update_vector_server__timeout()

void joedb::db::multi_server::Database::internal_update_vector_server__timeout	(	Record_Id	record_id,
		size_t	size,
		const int32_t *	value
	)

inlineprotected

Definition at line 231 of file Database.h.

◆ internal_vector_insert_server()

void joedb::db::multi_server::Database::internal_vector_insert_server	(	Record_Id	record_id,
		size_t	size
	)

inlineprotected

Definition at line 156 of file Database.h.

◆ is_valid()

bool joedb::db::multi_server::Database::is_valid ( id_of_server id ) const

inline

Definition at line 102 of file Database.h.

◆ is_valid_record_id_for_server()

bool joedb::db::multi_server::Database::is_valid_record_id_for_server ( Record_Id record_id ) const

inlineprotected

Definition at line 106 of file Database.h.

◆ next()

id_of_server joedb::db::multi_server::Database::next ( id_of_server id ) const

inline

Definition at line 544 of file Database.h.

◆ next_server_by_port()

id_of_server joedb::db::multi_server::Database::next_server_by_port ( id_of_server id )

inline

Definition at line 591 of file Database.h.

◆ null_server()

static id_of_server joedb::db::multi_server::Database::null_server ( )

inlinestatic

Definition at line 563 of file Database.h.

◆ previous()

id_of_server joedb::db::multi_server::Database::previous ( id_of_server id ) const

inline

Definition at line 552 of file Database.h.

◆ previous_server_by_port()

id_of_server joedb::db::multi_server::Database::previous_server_by_port ( id_of_server id )

inline

Definition at line 601 of file Database.h.

◆ remove_index_of_server_by_port()

void joedb::db::multi_server::Database::remove_index_of_server_by_port ( Record_Id record_id )

inlineprotected

Definition at line 109 of file Database.h.

◆ rename_field()

void joedb::db::multi_server::Database::rename_field	(	Table_Id	table_id,
		Field_Id	field_id,
		const std::string &	name
	)

inlinefinalprotected

Definition at line 502 of file Database.h.

◆ rename_table()

void joedb::db::multi_server::Database::rename_table	(	Table_Id	table_id,
		const std::string &	name
	)

inlinefinalprotected

Definition at line 475 of file Database.h.

◆ requires_schema_upgrade()

bool joedb::db::multi_server::Database::requires_schema_upgrade ( ) const

inlineprotected

Definition at line 436 of file Database.h.

◆ set_max_record_id()

void joedb::db::multi_server::Database::set_max_record_id ( size_t record_id )

inline

Definition at line 97 of file Database.h.

◆ sorted_server()

template<class Comparator >

std::vector< id_of_server > joedb::db::multi_server::Database::sorted_server ( Comparator comparator ) const

Definition at line 669 of file Database.h.

◆ throw_exception()

template<typename E = joedb::Exception>

static void joedb::db::multi_server::Database::throw_exception ( const std::string & message )

inlinestatic

Definition at line 89 of file Database.h.

◆ timestamp()

void joedb::db::multi_server::Database::timestamp ( int64_t timestamp )

inlineoverrideprotectedvirtual

Reimplemented from joedb::Writable.

Definition at line 429 of file Database.h.

◆ update_int32()

void joedb::db::multi_server::Database::update_int32	(	Table_Id	table_id,
		Record_Id	record_id,
		Field_Id	field_id,
		int32_t	value
	)

inlinefinalprotected

Definition at line 310 of file Database.h.

◆ update_string()

void joedb::db::multi_server::Database::update_string	(	Table_Id	table_id,
		Record_Id	record_id,
		Field_Id	field_id,
		const std::string &	value
	)

inlinefinalprotected

Definition at line 290 of file Database.h.

◆ update_vector_int32()

void joedb::db::multi_server::Database::update_vector_int32	(	Table_Id	table_id,
		Record_Id	record_id,
		Field_Id	field_id,
		size_t	size,
		const int32_t *	value
	)

inlinefinalprotected

Definition at line 356 of file Database.h.

◆ update_vector_string()

void joedb::db::multi_server::Database::update_vector_string	(	Table_Id	table_id,
		Record_Id	record_id,
		Field_Id	field_id,
		size_t	size,
		const std::string *	value
	)

inlinefinalprotected

Definition at line 335 of file Database.h.

◆ valid_data()

void joedb::db::multi_server::Database::valid_data ( )

inlinefinalprotectedvirtual

Reimplemented from joedb::Writable.

Definition at line 430 of file Database.h.

Friends And Related Symbol Documentation

◆ container_of_server

friend class container_of_server

friend

Definition at line 85 of file Database.h.

◆ id_of_server

friend class id_of_server

friend

Definition at line 84 of file Database.h.

◆ Readable

friend class Readable

friend

Definition at line 83 of file Database.h.

Member Data Documentation

◆ current_table_id

Table_Id joedb::db::multi_server::Database::current_table_id = Table_Id{0}

Definition at line 95 of file Database.h.

◆ index_of_server_by_port

std::map<int32_t, id_of_server> joedb::db::multi_server::Database::index_of_server_by_port

protected

Definition at line 108 of file Database.h.

◆ max_record_id

size_t joedb::db::multi_server::Database::max_record_id

Definition at line 94 of file Database.h.

◆ schema_file

joedb::Memory_File joedb::db::multi_server::Database::schema_file

protected

Definition at line 433 of file Database.h.

◆ schema_journal

joedb::Writable_Journal joedb::db::multi_server::Database::schema_journal

protected

Definition at line 434 of file Database.h.

◆ storage_of_server

detail::data_of_server joedb::db::multi_server::Database::storage_of_server

protected

Definition at line 105 of file Database.h.

◆ upgrading_schema

bool joedb::db::multi_server::Database::upgrading_schema = false

protected

Definition at line 432 of file Database.h.

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

/home/rcoulom/repos/joedb/src/joedb/db/multi_server/Database.h

Public Member Functions

Static Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ Database()

Member Function Documentation

◆ add_field()

◆ add_index_of_server_by_port()

◆ check_schema()

◆ comment()

◆ create_table()

◆ custom()

◆ delete_from()

◆ drop_field()

◆ drop_table()

◆ find_server_by_port()

◆ get_file_name()

◆ get_index_of_server_by_port()

◆ get_own_int32_storage()

◆ get_own_string_storage()

◆ get_port()

◆ get_schema_checkpoint()

◆ get_server_table()

◆ get_timeout()

◆ initialize_with_readonly_journal()

◆ insert_into()

◆ insert_vector()

◆ internal_delete_server()

◆ internal_insert_server()

◆ internal_update_server__file_name()

◆ internal_update_server__port()

◆ internal_update_server__timeout()

◆ internal_update_vector_server__file_name()

◆ internal_update_vector_server__port()

◆ internal_update_vector_server__timeout()

◆ internal_vector_insert_server()

◆ is_valid()

◆ is_valid_record_id_for_server()

◆ next()

◆ next_server_by_port()

◆ null_server()

◆ previous()

◆ previous_server_by_port()

◆ remove_index_of_server_by_port()

◆ rename_field()

◆ rename_table()

◆ requires_schema_upgrade()

◆ set_max_record_id()

◆ sorted_server()

◆ throw_exception()

◆ timestamp()

◆ update_int32()

◆ update_string()

◆ update_vector_int32()

◆ update_vector_string()

◆ valid_data()

Friends And Related Symbol Documentation

◆ container_of_server

◆ id_of_server

◆ Readable

Member Data Documentation

◆ current_table_id

◆ index_of_server_by_port

◆ max_record_id

◆ schema_file

◆ schema_journal

◆ storage_of_server

◆ upgrading_schema