Fix schema, table and tablespace. More...

Public Member Functions
	Fixup_data (bool concurrent, bool is_drop)
	Constructor. More...

template<typename T >
bool	fix (THD *thd, const DD_Objs< T > &dd_objects)
	Fix tables for which data is not cloned. More...

bool	fix_config_tables (THD *thd)
	Remove data cloned from configuration tables which are not relevant in recipient. More...

template<>
bool	fix_one_object (THD thd, const dd::Table table, size_t thread_number)

template<>
bool	fix_one_object (THD thd, const dd::Schema schema, size_t thread_number)

template<>
bool	fix_one_object (THD thd, const dd::Tablespace tablespace, size_t thread_number)

Static Public Attributes
static const size_t	S_NUM_CONFIG_TABLES = 0
	Number of system configuration tables. More...

static const std::array< const char *, S_NUM_CONFIG_TABLES >	s_config_tables = {}
	Array of configuration tables. More...

Private Member Functions
template<typename T >
bool	fix_one_object (THD thd, const T object, size_t thread_number)
	Check and fix specific DD object. More...

template<typename T >
void	fix_objects (THD *thd, const DD_Objs_Iter< T > &begin, const DD_Objs_Iter< T > &end, size_t thread_number)
	Check and fix a rangle of DD objects. More...

size_t	get_num_tasks () const

void	set_num_tasks (size_t num_entries)
	Calculate and set number of new tasks to spawn. More...

bool	is_drop () const

bool	allow_concurrent () const

const char *	sql_operation ()
	Get the table operation string. More...

bool	skip_se_tables (enum legacy_db_type type)
	Check if the current SE type should be skipped. More...

bool	is_performance_schema (const char *schema_name) const
	Check if the schema is performance schema. More...

bool	is_system_schema (const char *schema_name) const
	Check if the current schema is system schema. More...

bool	skip_schema_tables (const dd::Table table, const char table_name, const char *schema_name)
	Check if the current schema tables needs to be skipped. More...

bool	skip_schema (const char *schema_name)
	Check if the current schema needs to be skipped. More...

bool	skip_tablespace (THD thd, const dd::Tablespace dd_space)
	Check if the current tablespace needs to be skipped. More...

bool	execute_sql (THD thd, const char schema_name, const char table_name, const char tablespace_name, size_t thread_number)
	Form and execute sql command. More...

bool	failed () const

Private Attributes
std::atomic_size_t	m_num_errors
	Number of tasks failed. More...

size_t	m_num_tasks
	Number of tasks. More...

bool	m_concurrent
	Allow concurrent threads. More...

bool	m_drop
	If the objects need to be dropped. More...

Detailed Description

Fix schema, table and tablespace.

Used for two different purposes.

After recovery from cloned database: A. Create empty data file for non-Innodb tables that are not cloned. B. Create any schema directory that is not present.
Before cloning into current data directory: A. Drop all user tables. B. Drop all user schema C. Drop all user tablespaces.

Constructor & Destructor Documentation

◆ Fixup_data()

anonymous_namespace{clone0api.cc}::Fixup_data::Fixup_data	(	bool	concurrent,
		bool	is_drop
	)

inline

Constructor.

Parameters

[in]	concurrent	spawn multiple threads
[in]	is_drop	the operation is drop

Member Function Documentation

◆ allow_concurrent()

bool anonymous_namespace{clone0api.cc}::Fixup_data::allow_concurrent ( ) const

inlineprivate

Returns: true, if concurrency is allowed.

◆ execute_sql()

bool anonymous_namespace{clone0api.cc}::Fixup_data::execute_sql	(	THD *	thd,
		const char *	schema_name,
		const char *	table_name,
		const char *	tablespace_name,
		size_t	thread_number
	)

private

Form and execute sql command.

Parameters

[in,out]	thd	current THD
[in]	schema_name	schema name
[in]	table_name	table name
[in]	tablespace_name	tablespace name
[in]	thread_number	current thread number.

◆ failed()

bool anonymous_namespace{clone0api.cc}::Fixup_data::failed ( ) const

inlineprivate

Returns: true, if any thread has failed.

◆ fix()

template<typename T >

bool anonymous_namespace{clone0api.cc}::Fixup_data::fix	(	THD *	thd,
		const DD_Objs< T > &	dd_objects
	)

inline

Fix tables for which data is not cloned.

Parameters

[in,out]	thd	current THD
[in]	dd_objects	table/schema/tablespace from DD

Returns: true if error

◆ fix_config_tables()

bool anonymous_namespace{clone0api.cc}::Fixup_data::fix_config_tables ( THD * thd )

Remove data cloned from configuration tables which are not relevant in recipient.

Parameters

[in,out] thd current THD

Returns: true if error

◆ fix_objects()

template<typename T >

void anonymous_namespace{clone0api.cc}::Fixup_data::fix_objects	(	THD *	thd,
		const DD_Objs_Iter< T > &	begin,
		const DD_Objs_Iter< T > &	end,
		size_t	thread_number
	)

private

Check and fix a rangle of DD objects.

Parameters

[in,out]	thd	current THD
[in]	begin	first element in current slice
[in]	end	last element in current slice
[in]	thread_number	current thread number.

◆ fix_one_object() [1/4]

template<>

bool anonymous_namespace{clone0api.cc}::Fixup_data::fix_one_object	(	THD *	thd,
		const dd::Schema *	schema,
		size_t	thread_number
	)

◆ fix_one_object() [2/4]

template<>

bool anonymous_namespace{clone0api.cc}::Fixup_data::fix_one_object	(	THD *	thd,
		const dd::Table *	table,
		size_t	thread_number
	)

◆ fix_one_object() [3/4]

template<>

bool anonymous_namespace{clone0api.cc}::Fixup_data::fix_one_object	(	THD *	thd,
		const dd::Tablespace *	tablespace,
		size_t	thread_number
	)

◆ fix_one_object() [4/4]

template<typename T >

bool anonymous_namespace{clone0api.cc}::Fixup_data::fix_one_object	(	THD *	thd,
		const T *	object,
		size_t	thread_number
	)

private

Check and fix specific DD object.

Parameters

[in,out]	thd	current THD
[in]	object	DD object
[in]	thread_number	current thread number.

◆ get_num_tasks()

size_t anonymous_namespace{clone0api.cc}::Fixup_data::get_num_tasks ( ) const

inlineprivate

Returns: number of tasks.

◆ is_drop()

bool anonymous_namespace{clone0api.cc}::Fixup_data::is_drop ( ) const

inlineprivate

Returns: true, if current operation is drop.

◆ is_performance_schema()

bool anonymous_namespace{clone0api.cc}::Fixup_data::is_performance_schema ( const char * schema_name ) const

inlineprivate

Check if the schema is performance schema.

Parameters

[in] schema_name schema name

Returns: true iff performance schema.

◆ is_system_schema()

bool anonymous_namespace{clone0api.cc}::Fixup_data::is_system_schema ( const char * schema_name ) const

inlineprivate

Check if the current schema is system schema.

Parameters

[in] schema_name schema name

Returns: true iff system schema.

◆ set_num_tasks()

void anonymous_namespace{clone0api.cc}::Fixup_data::set_num_tasks ( size_t num_entries )

inlineprivate

Calculate and set number of new tasks to spawn.

Parameters

[in] num_entries number of entries to handle

◆ skip_schema()

bool anonymous_namespace{clone0api.cc}::Fixup_data::skip_schema ( const char * schema_name )

inlineprivate

Check if the current schema needs to be skipped.

Parameters

[in] schema_name schema name

Returns: true iff schema needs to be skipped.

◆ skip_schema_tables()

bool anonymous_namespace{clone0api.cc}::Fixup_data::skip_schema_tables	(	const dd::Table *	table,
		const char *	table_name,
		const char *	schema_name
	)

inlineprivate

Check if the current schema tables needs to be skipped.

Parameters

[in]	table	DD table
[in]	table_name	table name
[in]	schema_name	schema name

Returns: true iff table needs to be skipped.

◆ skip_se_tables()

bool anonymous_namespace{clone0api.cc}::Fixup_data::skip_se_tables ( enum legacy_db_type type )

inlineprivate

Check if the current SE type should be skipped.

Parameters

[in] type SE type

Returns: true iff the SE needs to be skipped.

◆ skip_tablespace()

bool anonymous_namespace{clone0api.cc}::Fixup_data::skip_tablespace	(	THD *	thd,
		const dd::Tablespace *	dd_space
	)

inlineprivate

Check if the current tablespace needs to be skipped.

Parameters

[in,out]	thd	current THD
[in]	dd_space	dd tablespace

Returns: true iff tablespace needs to be skipped.

◆ sql_operation()

const char * anonymous_namespace{clone0api.cc}::Fixup_data::sql_operation ( )

inlineprivate

Get the table operation string.

Returns: sql key word for the operation.

Member Data Documentation

◆ m_concurrent

bool anonymous_namespace{clone0api.cc}::Fixup_data::m_concurrent

private

Allow concurrent threads.

◆ m_drop

bool anonymous_namespace{clone0api.cc}::Fixup_data::m_drop

private

If the objects need to be dropped.

◆ m_num_errors

std::atomic_size_t anonymous_namespace{clone0api.cc}::Fixup_data::m_num_errors

private

Number of tasks failed.

◆ m_num_tasks

size_t anonymous_namespace{clone0api.cc}::Fixup_data::m_num_tasks

private

Number of tasks.

◆ s_config_tables

const std::array< const char *, Fixup_data::S_NUM_CONFIG_TABLES > anonymous_namespace{clone0api.cc}::Fixup_data::s_config_tables = {}

static

Array of configuration tables.

◆ S_NUM_CONFIG_TABLES

const size_t anonymous_namespace{clone0api.cc}::Fixup_data::S_NUM_CONFIG_TABLES = 0

static

Number of system configuration tables.

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

storage/innobase/clone/clone0api.cc

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Fixup_data()

Member Function Documentation

◆ allow_concurrent()

◆ execute_sql()

◆ failed()

◆ fix()

◆ fix_config_tables()

◆ fix_objects()

◆ fix_one_object() [1/4]

◆ fix_one_object() [2/4]

◆ fix_one_object() [3/4]

◆ fix_one_object() [4/4]

◆ get_num_tasks()

◆ is_drop()

◆ is_performance_schema()

◆ is_system_schema()

◆ set_num_tasks()

◆ skip_schema()

◆ skip_schema_tables()

◆ skip_se_tables()

◆ skip_tablespace()

◆ sql_operation()

Member Data Documentation

◆ m_concurrent

◆ m_drop

◆ m_num_errors

◆ m_num_tasks

◆ s_config_tables

◆ S_NUM_CONFIG_TABLES