Wrapper of mysql.innodb_ddl_log table. More...

#include <log0ddl.h>

Public Member Functions
	DDL_Log_Table ()
	Constructor. More...

	DDL_Log_Table (trx_t *trx)
	Constructor and it initializes transaction and query thread. More...

	~DDL_Log_Table ()
	Destructor. More...

dberr_t	insert (const DDL_Record &record)
	Insert the DDL log record into the innodb_ddl_log table. More...

dberr_t	search (ulint thread_id, DDL_Records &records)
	Search for all records of specified thread_id. More...

dberr_t	search_all (DDL_Records &records)
	Do a reverse scan on the table to fetch all the record. More...

dberr_t	remove (ulint id)
	Delete the innodb_ddl_log record of specified ID. More...

dberr_t	remove (const DDL_Records &records)
	Delete specified DDL_Records from innodb_ddl_log. More...

Private Member Functions
void	start_query_thread ()
	Set the query thread using graph. More...

void	stop_query_thread ()
	Stop the query thread. More...

void	create_tuple (const DDL_Record &record)
	Create tuple for the innodb_ddl_log table. More...

void	create_tuple (ulint id, const dict_index_t *index)
	Create tuple for the given index. More...

void	convert_to_ddl_record (bool is_clustered, rec_t rec, const ulint offsets, DDL_Record &record)
	Convert the innodb_ddl_log index record to DDL_Record. More...

ulint	parse_id (const dict_index_t index, rec_t rec, const ulint *offsets)
	Parse the index record and get 'ID'. More...

void	set_field (const byte *data, ulint offset, ulint len, DDL_Record &record)
	Set the given field of the innodb_ddl_log record from given data. More...

ulint	fetch_value (const byte *data, ulint offset)
	Fetch the value from given offset. More...

dberr_t	search_by_id (ulint id, dict_index_t *index, DDL_Records &records)
	Search specified index by specified ID. More...

Private Attributes
dict_table_t *	m_table
	innodb_ddl_log table. More...

dtuple_t *	m_tuple
	Tuple used for insert, search, delete operation. More...

trx_t *	m_trx
	Transaction used for insert, delete operation. More...

que_thr_t *	m_thr
	Dummy query thread. More...

mem_heap_t *	m_heap
	Heap to store the m_tuple, m_thr and all operation on mysql.innodb_ddl_log table. More...

Static Private Attributes
static constexpr unsigned	s_id_col_no = 0
	Column number of mysql.innodb_ddl_log.id. More...

static constexpr unsigned	s_id_col_len = 8
	Column length of mysql.innodb_ddl_log.id. More...

static constexpr unsigned	s_thread_id_col_no = 1
	Column number of mysql.innodb_ddl_log.thread_id. More...

static constexpr unsigned	s_thread_id_col_len = 8
	Column length of mysql.innodb_ddl_log.thread_id. More...

static constexpr unsigned	s_type_col_no = 2
	Column number of mysql.innodb_ddl_log.type. More...

static constexpr unsigned	s_type_col_len = 4
	Column length of mysql.innodb_ddl_log.type. More...

static constexpr unsigned	s_space_id_col_no = 3
	Column number of mysql.innodb_ddl_log.space_id. More...

static constexpr unsigned	s_space_id_col_len = 4
	Column length of mysql.innodb_ddl_log.space_id. More...

static constexpr unsigned	s_page_no_col_no = 4
	Column number of mysql.innodb_ddl_log.page_no. More...

static constexpr unsigned	s_page_no_col_len = 4
	Column length of mysql.innodb_ddl_log.page_no. More...

static constexpr unsigned	s_index_id_col_no = 5
	Column number of mysql.innodb_ddl_log.index_id. More...

static constexpr unsigned	s_index_id_col_len = 8
	Column length of mysql.innodb_ddl_log.index_id. More...

static constexpr unsigned	s_table_id_col_no = 6
	Column number of mysql.innodb_ddl_log.table_id. More...

static constexpr unsigned	s_table_id_col_len = 8
	Column length of mysql.innodb_ddl_log.table_id. More...

static constexpr unsigned	s_old_file_path_col_no = 7
	Column number of mysql.innodb_ddl_log.old_file_path. More...

static constexpr unsigned	s_new_file_path_col_no = 8
	Column number of mysql.innodb_ddl_log.new_file_path. More...

Detailed Description

Wrapper of mysql.innodb_ddl_log table.

Accessing to this table doesn't require row lock because thread could only access/modify its own ddl records.

Constructor & Destructor Documentation

◆ DDL_Log_Table() [1/2]

DDL_Log_Table::DDL_Log_Table ( )

Constructor.

◆ DDL_Log_Table() [2/2]

DDL_Log_Table::DDL_Log_Table ( trx_t * trx )

explicit

Constructor and it initializes transaction and query thread.

Once trx is passed in, make sure destructor is called before the trx commits.

Parameters

[in,out] trx Transaction

◆ ~DDL_Log_Table()

DDL_Log_Table::~DDL_Log_Table ( )

Destructor.

Member Function Documentation

◆ convert_to_ddl_record()

void DDL_Log_Table::convert_to_ddl_record	(	bool	is_clustered,
		rec_t *	rec,
		const ulint *	offsets,
		DDL_Record &	record
	)

private

Convert the innodb_ddl_log index record to DDL_Record.

Parameters

[in]	is_clustered	true if this is clustered index record, otherwise the secondary index record
[in]	rec	index record
[in]	offsets	index record offset
[in,out]	record	to store the innodb_ddl_log record.

◆ create_tuple() [1/2]

void DDL_Log_Table::create_tuple ( const DDL_Record & record )

private

Create tuple for the innodb_ddl_log table.

It is used for insert operation.

Parameters

[in] record DDL log record.

◆ create_tuple() [2/2]

void DDL_Log_Table::create_tuple	(	ulint	id,
		const dict_index_t *	index
	)

private

Create tuple for the given index.

Used for search by id (and following delete)

Parameters

[in]	id	Thread id/ id of the record
[in]	index	Clustered index or secondary index.

◆ fetch_value()

ulint DDL_Log_Table::fetch_value	(	const byte *	data,
		ulint	offset
	)

private

Fetch the value from given offset.

Parameters

[in]	data	value to be retrieved from data
[in]	offset	offset of the column

Returns: value of the given offset.

◆ insert()

dberr_t DDL_Log_Table::insert ( const DDL_Record & record )

Insert the DDL log record into the innodb_ddl_log table.

This is thread safe.

Parameters

[in] record Record to be inserted.

Returns: DB_SUCCESS or error.

◆ parse_id()

ulint DDL_Log_Table::parse_id	(	const dict_index_t *	index,
		rec_t *	rec,
		const ulint *	offsets
	)

private

Parse the index record and get 'ID'.

Parameters

[in]	index	index where the record resides
[in]	rec	index rec
[in]	offsets	offsets of the index.

Returns: id of the record.

◆ remove() [1/2]

dberr_t DDL_Log_Table::remove ( const DDL_Records & records )

Delete specified DDL_Records from innodb_ddl_log.

This is thread safe. Different threads have their own ddl records to delete. And this could be called during recovery.

Parameters

[in] records DDL_Record(s) to be deleted

Returns: DB_SUCCESS or error.

◆ remove() [2/2]

dberr_t DDL_Log_Table::remove ( ulint id )

Delete the innodb_ddl_log record of specified ID.

This is thread safe. One thread will only remove its ddl record.

Parameters

[in] id ID of the DDL_Record

Returns: DB_SUCCESS or error.

◆ search()

dberr_t DDL_Log_Table::search	(	ulint	thread_id,
		DDL_Records &	records
	)

Search for all records of specified thread_id.

The records are kept in reverse order. This is thread safe. Because different threads have different thread ids, there should not be any conflict with update.

Parameters

[in]	thread_id	thread id to search
[out]	records	DDL_Records of the specified thread id

Returns: DB_SUCCESS or error.

◆ search_all()

dberr_t DDL_Log_Table::search_all ( DDL_Records & records )

Do a reverse scan on the table to fetch all the record.

This is only called during recovery

Parameters

[out] records DDL_Records of the whole table

Returns: DB_SUCCESS or error.

Scan the index in decreasing order.

◆ search_by_id()

dberr_t DDL_Log_Table::search_by_id	(	ulint	id,
		dict_index_t *	index,
		DDL_Records &	records
	)

private

Search specified index by specified ID.

Parameters

[in]	id	ID to search
[in]	index	index to search
[in,out]	records	DDL_Record(s) got by the search

Returns: DB_SUCCESS or error

◆ set_field()

void DDL_Log_Table::set_field	(	const byte *	data,
		ulint	offset,
		ulint	len,
		DDL_Record &	record
	)

private

Set the given field of the innodb_ddl_log record from given data.

Parameters

[in]	data	data to be set
[in]	offset	column of the ddl record
[in]	len	length of the data
[in,out]	record	DDL_Record to set

◆ start_query_thread()

void DDL_Log_Table::start_query_thread ( )

private

Set the query thread using graph.

◆ stop_query_thread()

void DDL_Log_Table::stop_query_thread ( )

private

Stop the query thread.

Member Data Documentation

◆ m_heap

mem_heap_t* DDL_Log_Table::m_heap

private

Heap to store the m_tuple, m_thr and all operation on mysql.innodb_ddl_log table.

◆ m_table

dict_table_t* DDL_Log_Table::m_table

private

innodb_ddl_log table.

◆ m_thr

que_thr_t* DDL_Log_Table::m_thr

private

Dummy query thread.

◆ m_trx

trx_t* DDL_Log_Table::m_trx

private

Transaction used for insert, delete operation.

◆ m_tuple

dtuple_t* DDL_Log_Table::m_tuple

private

Tuple used for insert, search, delete operation.

◆ s_id_col_len

constexpr unsigned DDL_Log_Table::s_id_col_len = 8

staticconstexprprivate

Column length of mysql.innodb_ddl_log.id.

◆ s_id_col_no

constexpr unsigned DDL_Log_Table::s_id_col_no = 0

staticconstexprprivate

Column number of mysql.innodb_ddl_log.id.

◆ s_index_id_col_len

constexpr unsigned DDL_Log_Table::s_index_id_col_len = 8

staticconstexprprivate

Column length of mysql.innodb_ddl_log.index_id.

◆ s_index_id_col_no

constexpr unsigned DDL_Log_Table::s_index_id_col_no = 5

staticconstexprprivate

Column number of mysql.innodb_ddl_log.index_id.

◆ s_new_file_path_col_no

constexpr unsigned DDL_Log_Table::s_new_file_path_col_no = 8

staticconstexprprivate

Column number of mysql.innodb_ddl_log.new_file_path.

◆ s_old_file_path_col_no

constexpr unsigned DDL_Log_Table::s_old_file_path_col_no = 7

staticconstexprprivate

Column number of mysql.innodb_ddl_log.old_file_path.

◆ s_page_no_col_len

constexpr unsigned DDL_Log_Table::s_page_no_col_len = 4

staticconstexprprivate

Column length of mysql.innodb_ddl_log.page_no.

◆ s_page_no_col_no

constexpr unsigned DDL_Log_Table::s_page_no_col_no = 4

staticconstexprprivate

Column number of mysql.innodb_ddl_log.page_no.

◆ s_space_id_col_len

constexpr unsigned DDL_Log_Table::s_space_id_col_len = 4

staticconstexprprivate

Column length of mysql.innodb_ddl_log.space_id.

◆ s_space_id_col_no

constexpr unsigned DDL_Log_Table::s_space_id_col_no = 3

staticconstexprprivate

Column number of mysql.innodb_ddl_log.space_id.

◆ s_table_id_col_len

constexpr unsigned DDL_Log_Table::s_table_id_col_len = 8

staticconstexprprivate

Column length of mysql.innodb_ddl_log.table_id.

◆ s_table_id_col_no

constexpr unsigned DDL_Log_Table::s_table_id_col_no = 6

staticconstexprprivate

Column number of mysql.innodb_ddl_log.table_id.

◆ s_thread_id_col_len

constexpr unsigned DDL_Log_Table::s_thread_id_col_len = 8

staticconstexprprivate

Column length of mysql.innodb_ddl_log.thread_id.

◆ s_thread_id_col_no

constexpr unsigned DDL_Log_Table::s_thread_id_col_no = 1

staticconstexprprivate

Column number of mysql.innodb_ddl_log.thread_id.

◆ s_type_col_len

constexpr unsigned DDL_Log_Table::s_type_col_len = 4

staticconstexprprivate

Column length of mysql.innodb_ddl_log.type.

◆ s_type_col_no

constexpr unsigned DDL_Log_Table::s_type_col_no = 2

staticconstexprprivate

Column number of mysql.innodb_ddl_log.type.

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

storage/innobase/include/log0ddl.h
storage/innobase/log/log0ddl.cc

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ DDL_Log_Table() [1/2]

◆ DDL_Log_Table() [2/2]

◆ ~DDL_Log_Table()

Member Function Documentation

◆ convert_to_ddl_record()

◆ create_tuple() [1/2]

◆ create_tuple() [2/2]

◆ fetch_value()

◆ insert()

◆ parse_id()

◆ remove() [1/2]

◆ remove() [2/2]

◆ search()

◆ search_all()

◆ search_by_id()

◆ set_field()

◆ start_query_thread()

◆ stop_query_thread()

Member Data Documentation

◆ m_heap

◆ m_table

◆ m_thr

◆ m_trx

◆ m_tuple

◆ s_id_col_len

◆ s_id_col_no

◆ s_index_id_col_len

◆ s_index_id_col_no

◆ s_new_file_path_col_no

◆ s_old_file_path_col_no

◆ s_page_no_col_len

◆ s_page_no_col_no

◆ s_space_id_col_len

◆ s_space_id_col_no

◆ s_table_id_col_len

◆ s_table_id_col_no

◆ s_thread_id_col_len

◆ s_thread_id_col_no

◆ s_type_col_len

◆ s_type_col_no