#include <ddl0bulk.h>

Public Member Functions
void	init (const row_prebuilt_t *prebuilt)
	Initialize thread specific data. More...

dberr_t	load (const row_prebuilt_t prebuilt, Btree_multi::Btree_load sub_tree, const Rows_mysql &rows, Bulk_load::Stat_callbacks &wait_cbk)
	Load rows to a sub-tree for a specific thread. More...

dberr_t	open_blob (Btree_multi::Btree_load *sub_tree, Blob_context &blob_ctx, lob::ref_t &ref)
	Create a blob. More...

dberr_t	write_blob (Btree_multi::Btree_load sub_tree, Blob_context blob_ctx, lob::ref_t &ref, const byte data, size_t len)
	Write data into the blob. More...

dberr_t	close_blob (Btree_multi::Btree_load *sub_tree, Blob_context blob_ctx, lob::ref_t &ref)
	Indicate that the blob has been completed, so that resources can be removed, and as necessary flushing can be done. More...

void	free ()
	Free thread specific data. More...

dberr_t	get_error () const

std::string	get_error_string () const

int	get_error_code () const
	Get the client error code (eg. More...

void	add_subtree (Btree_multi::Btree_load *subtree)
	Add given subtree to the list of subtrees. More...

Btree_multi::Btree_load *	get_subtree ()
	Get the last subtree created by this thread. More...

Public Attributes
size_t	m_queue_size
	Flush queue size used by the Bulk_flusher. More...

std::list< Btree_multi::Btree_load * >	m_list_subtrees
	Each subtree needs to have a disjoint set of keys. More...

uint64_t	m_last_rowid {0}
	The last DB_ROW_ID used by this thread. More...

Private Member Functions
void	fill_system_columns (const row_prebuilt_t *prebuilt)
	Fill system columns for index entry to be loaded. More...

dberr_t	fill_tuple (const row_prebuilt_t *prebuilt, const Rows_mysql &rows, size_t row_index)
	Fill the tuple to set the column data. More...

void	fill_index_entry (const row_prebuilt_t *prebuilt)
	Fill he cluster index entry from tuple data. More...

bool	store_int_col (const Column_mysql &col, byte *data_ptr, size_t &data_len)
	Store integer column in Innodb format. More...

Private Attributes
mem_heap_t *	m_heap {}
	Heap for allocating tuple memory. More...

dtuple_t *	m_row {}
	Tuple for converting input data to table row. More...

dtuple_t *	m_entry {}
	Tuple for inserting row to cluster index. More...

unsigned char	m_trx_data [DATA_TRX_ID_LEN]
	Column data for system column transaction ID. More...

unsigned char	m_rollptr_data [DATA_ROLL_PTR_LEN]
	Column data for system column Roll pointer. More...

unsigned char	m_rowid_data [DATA_ROW_ID_LEN]
	Column data for system column DATA_ROW_ID. More...

dberr_t	m_err {DB_SUCCESS}
	Error code at thread level. More...

int	m_errcode {0}

std::ostringstream	m_sout

size_t	m_nth_index {std::numeric_limits<size_t>::max()}

Member Function Documentation

◆ add_subtree()

void ddl_bulk::Loader::Thread_data::add_subtree ( Btree_multi::Btree_load * subtree )

inline

Add given subtree to the list of subtrees.

Parameters

[in] subtree the subtree to be added.

◆ close_blob()

dberr_t ddl_bulk::Loader::Thread_data::close_blob	(	Btree_multi::Btree_load *	sub_tree,
		Blob_context	blob_ctx,
		lob::ref_t &	ref
	)

inline

Indicate that the blob has been completed, so that resources can be removed, and as necessary flushing can be done.

Parameters

[in]	sub_tree	sub tree to load data to
[in]	blob_ctx	pointer to blob which has been completely written.
[out]	ref	blob reference to be placed in the record.

Returns: DB_SUCCESS on success or a failure error code.

◆ fill_index_entry()

void ddl_bulk::Loader::Thread_data::fill_index_entry ( const row_prebuilt_t * prebuilt )

private

Fill he cluster index entry from tuple data.

Parameters

[in] prebuilt prebuilt structures from innodb table handler

◆ fill_system_columns()

void ddl_bulk::Loader::Thread_data::fill_system_columns ( const row_prebuilt_t * prebuilt )

private

Fill system columns for index entry to be loaded.

Parameters

[in] prebuilt prebuilt structures from innodb table handler

◆ fill_tuple()

dberr_t ddl_bulk::Loader::Thread_data::fill_tuple	(	const row_prebuilt_t *	prebuilt,
		const Rows_mysql &	rows,
		size_t	row_index
	)

private

Fill the tuple to set the column data.

Parameters

[in]	prebuilt	prebuilt structures from innodb table handler
[in]	rows	sql rows with column data
[in]	row_index	current row index

Returns: innodb error code.

◆ free()

void ddl_bulk::Loader::Thread_data::free ( )

Free thread specific data.

◆ get_error()

dberr_t ddl_bulk::Loader::Thread_data::get_error ( ) const

inline

◆ get_error_code()

int ddl_bulk::Loader::Thread_data::get_error_code ( ) const

inline

Get the client error code (eg.

ER_LOAD_BULK_DATA_UNSORTED).

Returns: the client error code.

◆ get_error_string()

std::string ddl_bulk::Loader::Thread_data::get_error_string ( ) const

inline

◆ get_subtree()

Btree_multi::Btree_load * ddl_bulk::Loader::Thread_data::get_subtree ( )

inline

Get the last subtree created by this thread.

◆ init()

void ddl_bulk::Loader::Thread_data::init ( const row_prebuilt_t * prebuilt )

Initialize thread specific data.

Parameters

[in] prebuilt prebuilt structures from innodb table handler

◆ load()

dberr_t ddl_bulk::Loader::Thread_data::load	(	const row_prebuilt_t *	prebuilt,
		Btree_multi::Btree_load *	sub_tree,
		const Rows_mysql &	rows,
		Bulk_load::Stat_callbacks &	wait_cbk
	)

Load rows to a sub-tree for a specific thread.

Parameters

[in]	prebuilt	prebuilt structures from innodb table handler
[in,out]	sub_tree	sub tree to load data to
[in]	rows	rows to be loaded to the cluster index sub-tree
[in]	wait_cbk	Stat callbacks

Returns: innodb error code

◆ open_blob()

dberr_t ddl_bulk::Loader::Thread_data::open_blob	(	Btree_multi::Btree_load *	sub_tree,
		Blob_context &	blob_ctx,
		lob::ref_t &	ref
	)

inline

Create a blob.

Parameters

[in]	sub_tree	sub tree to load data to
[out]	blob_ctx	pointer to an opaque object representing a blob.
[out]	ref	blob reference to be placed in the record.

Returns: DB_SUCCESS on success or a failure error code.

◆ store_int_col()

bool ddl_bulk::Loader::Thread_data::store_int_col	(	const Column_mysql &	col,
		byte *	data_ptr,
		size_t &	data_len
	)

private

Store integer column in Innodb format.

Parameters

[in]	col	sql column data
[in,out]	data_ptr	data buffer for storing converted data
[in,out]	data_len	data buffer length

Returns: true if successful.

◆ write_blob()

dberr_t ddl_bulk::Loader::Thread_data::write_blob	(	Btree_multi::Btree_load *	sub_tree,
		Blob_context	blob_ctx,
		lob::ref_t &	ref,
		const byte *	data,
		size_t	len
	)

inline

Write data into the blob.

Parameters

[in]	sub_tree	sub tree to load data to
[in]	blob_ctx	pointer to blob into which data is written.
[out]	ref	blob reference to be placed in the record.
[in]	data	buffer containing data to be written
[in]	len	length of the data to be written.

Returns: DB_SUCCESS on success or a failure error code.

Member Data Documentation

◆ m_entry

dtuple_t* ddl_bulk::Loader::Thread_data::m_entry {}

private

Tuple for inserting row to cluster index.

◆ m_err

dberr_t ddl_bulk::Loader::Thread_data::m_err {DB_SUCCESS}

private

Error code at thread level.

◆ m_errcode

int ddl_bulk::Loader::Thread_data::m_errcode {0}

private

◆ m_heap

mem_heap_t* ddl_bulk::Loader::Thread_data::m_heap {}

private

Heap for allocating tuple memory.

◆ m_last_rowid

uint64_t ddl_bulk::Loader::Thread_data::m_last_rowid {0}

The last DB_ROW_ID used by this thread.

◆ m_list_subtrees

std::list<Btree_multi::Btree_load *> ddl_bulk::Loader::Thread_data::m_list_subtrees

Each subtree needs to have a disjoint set of keys.

In the case of generated DB_ROW_ID as PK, each thread can build one subtree for one range of row ids.

◆ m_nth_index

size_t ddl_bulk::Loader::Thread_data::m_nth_index {std::numeric_limits<size_t>::max()}

private

◆ m_queue_size

size_t ddl_bulk::Loader::Thread_data::m_queue_size

Flush queue size used by the Bulk_flusher.

◆ m_rollptr_data

unsigned char ddl_bulk::Loader::Thread_data::m_rollptr_data[DATA_ROLL_PTR_LEN]

private

Column data for system column Roll pointer.

◆ m_row

dtuple_t* ddl_bulk::Loader::Thread_data::m_row {}

private

Tuple for converting input data to table row.

◆ m_rowid_data

unsigned char ddl_bulk::Loader::Thread_data::m_rowid_data[DATA_ROW_ID_LEN]

private

Column data for system column DATA_ROW_ID.

◆ m_sout

std::ostringstream ddl_bulk::Loader::Thread_data::m_sout

private

◆ m_trx_data

unsigned char ddl_bulk::Loader::Thread_data::m_trx_data[DATA_TRX_ID_LEN]

private

Column data for system column transaction ID.

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

storage/innobase/include/ddl0bulk.h
storage/innobase/ddl/ddl0bulk.cc

Public Member Functions

Public Attributes

Private Member Functions

Private Attributes

Member Function Documentation

◆ add_subtree()

◆ close_blob()

◆ fill_index_entry()

◆ fill_system_columns()

◆ fill_tuple()

◆ free()

◆ get_error()

◆ get_error_code()

◆ get_error_string()

◆ get_subtree()

◆ init()

◆ load()

◆ open_blob()

◆ store_int_col()

◆ write_blob()

Member Data Documentation

◆ m_entry

◆ m_err

◆ m_errcode

◆ m_heap

◆ m_last_rowid

◆ m_list_subtrees

◆ m_nth_index

◆ m_queue_size

◆ m_rollptr_data

◆ m_row

◆ m_rowid_data

◆ m_sout

◆ m_trx_data