MySQL 9.1.0
Source Code Documentation
Typedefs | Functions
Bulk_data_load Namespace Reference

Typedefs

using Blob_context = void *
 

Functions

void * begin (THD *thd, const TABLE *table, size_t data_size, size_t memory, size_t num_threads) noexcept
 
bool load (THD *thd, void *ctx, const TABLE *table, const Rows_mysql &sql_rows, size_t thread, Bulk_load::Stat_callbacks &wait_cbks) noexcept
 
bool open_blob (THD *thd, void *load_ctx, const TABLE *table, Blob_context &blob_ctx, unsigned char *blobref, size_t thread) noexcept
 
bool write_blob (THD *thd, void *load_ctx, const TABLE *table, Blob_context blob_ctx, unsigned char *blobref, size_t thread, const unsigned char *data, size_t data_len) noexcept
 
bool close_blob (THD *thd, void *load_ctx, const TABLE *table, Blob_context blob_ctx, unsigned char *blobref, size_t thread) noexcept
 
bool end (THD *thd, void *ctx, const TABLE *table, bool error) noexcept
 
bool check_for_deprecated_use (Field_float *field)
 
bool check_for_deprecated_use (Field_double *field)
 
bool check_for_deprecated_use (Field_new_decimal *field)
 
bool check_for_deprecated_use (Field *field)
 
size_t get_se_memory_size (THD *thd, const TABLE *table) noexcept
 
bool is_table_supported (THD *thd, const TABLE *table) noexcept
 

Typedef Documentation

◆ Blob_context

using Bulk_data_load::Blob_context = typedef void *

Function Documentation

◆ begin()

void * Bulk_data_load::begin ( THD *  thd,
const TABLE *  table,
size_t  data_size,
size_t  memory,
size_t  num_threads 
)
noexcept

◆ check_for_deprecated_use() [1/4]

bool Bulk_data_load::check_for_deprecated_use ( Field *  field)

◆ check_for_deprecated_use() [2/4]

bool Bulk_data_load::check_for_deprecated_use ( Field_double *  field)

◆ check_for_deprecated_use() [3/4]

bool Bulk_data_load::check_for_deprecated_use ( Field_float *  field)

◆ check_for_deprecated_use() [4/4]

bool Bulk_data_load::check_for_deprecated_use ( Field_new_decimal *  field)

◆ close_blob()

bool Bulk_data_load::close_blob ( THD *  thd,
void *  load_ctx,
const TABLE *  table,
Blob_context  blob_ctx,
unsigned char *  blobref,
size_t  thread 
)
noexcept

◆ end()

bool Bulk_data_load::end ( THD *  thd,
void *  ctx,
const TABLE *  table,
bool  error 
)
noexcept

◆ get_se_memory_size()

size_t Bulk_data_load::get_se_memory_size ( THD *  thd,
const TABLE *  table 
)
noexcept

◆ is_table_supported()

bool Bulk_data_load::is_table_supported ( THD *  thd,
const TABLE *  table 
)
noexcept

◆ load()

bool Bulk_data_load::load ( THD *  thd,
void *  ctx,
const TABLE *  table,
const Rows_mysql &  sql_rows,
size_t  thread,
Bulk_load::Stat_callbacks &  wait_cbks 
)
noexcept

◆ open_blob()

bool Bulk_data_load::open_blob ( THD *  thd,
void *  load_ctx,
const TABLE *  table,
Blob_context &  blob_ctx,
unsigned char *  blobref,
size_t  thread 
)
noexcept

◆ write_blob()

bool Bulk_data_load::write_blob ( THD *  thd,
void *  load_ctx,
const TABLE *  table,
Blob_context  blob_ctx,
unsigned char *  blobref,
size_t  thread,
const unsigned char *  data,
size_t  data_len 
)
noexcept