sql_insert.cc File Reference

#include "sql/sql_insert.h"
#include <errno.h>
#include <stdio.h>
#include <string.h>
#include <atomic>
#include <iterator>
#include <map>
#include <utility>
#include "field_types.h"
#include "lex_string.h"
#include "my_alloc.h"
#include "my_base.h"
#include "my_bitmap.h"
#include "my_dbug.h"
#include "my_psi_config.h"
#include "my_sys.h"
#include "my_table_map.h"
#include "my_thread_local.h"
#include "mysql/components/services/bits/psi_bits.h"
#include "mysql/mysql_lex_string.h"
#include "mysql/psi/mysql_table.h"
#include "mysql/service_mysql_alloc.h"
#include "mysql/strings/m_ctype.h"
#include "mysql/udf_registration_types.h"
#include "mysql_com.h"
#include "mysqld_error.h"
#include "pfs_table_provider.h"
#include "prealloced_array.h"
#include "sql/auth/auth_acls.h"
#include "sql/auth/auth_common.h"
#include "sql/binlog.h"
#include "sql/create_field.h"
#include "sql/dd/cache/dictionary_client.h"
#include "sql/dd/dd.h"
#include "sql/dd/dictionary.h"
#include "sql/dd_sql_view.h"
#include "sql/debug_sync.h"
#include "sql/derror.h"
#include "sql/discrete_interval.h"
#include "sql/field.h"
#include "sql/handler.h"
#include "sql/item.h"
#include "sql/key.h"
#include "sql/lock.h"
#include "sql/locked_tables_list.h"
#include "sql/mdl.h"
#include "sql/mysqld.h"
#include "sql/nested_join.h"
#include "sql/opt_explain.h"
#include "sql/opt_explain_format.h"
#include "sql/partition_info.h"
#include "sql/protocol.h"
#include "sql/query_options.h"
#include "sql/rpl_rli.h"
#include "sql/select_lex_visitor.h"
#include "sql/sql_alter.h"
#include "sql/sql_array.h"
#include "sql/sql_base.h"
#include "sql/sql_class.h"
#include "sql/sql_const.h"
#include "sql/sql_error.h"
#include "sql/sql_gipk.h"
#include "sql/sql_lex.h"
#include "sql/sql_list.h"
#include "sql/sql_resolver.h"
#include "sql/sql_select.h"
#include "sql/sql_show.h"
#include "sql/sql_table.h"
#include "sql/sql_view.h"
#include "sql/stateless_allocator.h"
#include "sql/system_variables.h"
#include "sql/table_trigger_dispatcher.h"
#include "sql/thd_raii.h"
#include "sql/transaction.h"
#include "sql/transaction_info.h"
#include "sql/trigger_def.h"
#include "sql/visible_fields.h"
#include "sql_string.h"
#include "string_with_len.h"
#include "template_utils.h"
#include "thr_lock.h"

Namespaces
namespace	dd
	The version of the current data dictionary table definitions.

Functions
static bool	check_view_insertability (THD *thd, Table_ref *view, const Table_ref *insert_table_ref)
	Additional check for insertability for VIEW. More...
static void	prepare_for_positional_update (TABLE *table, Table_ref *tables)
	Get extra info for tables we insert into. More...
static bool	check_single_table_insert (const mem_root_deque< Item * > &fields, Table_ref *view, Table_ref **insert_table_ref)
	Check that insert fields are from a single table of a multi-table view. More...
static bool	check_insert_fields (THD *thd, Table_ref *table_list, mem_root_deque< Item * > *fields)
	Check insert fields. More...
static bool	check_valid_table_refs (const Table_ref *view, const mem_root_deque< Item * > &values, table_map map)
	Check that table references are restricted to the supplied table map. More...
bool	validate_default_values_of_unset_fields (THD *thd, TABLE *table)
	Validates default value of fields which are not specified in the column list of INSERT statement. More...
void	prepare_triggers_for_insert_stmt (THD *thd, TABLE *table)
	Prepare triggers for INSERT-like statement. More...
static bool	mysql_prepare_blob_values (THD *thd, const mem_root_deque< Item * > &fields, MEM_ROOT *mem_root)
	Setup data for field BLOB/GEOMETRY field types for execution of "INSERT...UPDATE" statement. More...
static bool	fix_join_cond_for_insert (THD *thd, Table_ref *tr)
	Recursive helper function for resolving join conditions for insertion into view for prepared statements. More...
static bool	allocate_column_bitmap (THD *thd, TABLE *table, MY_BITMAP **bitmap)
static bool	last_uniq_key (TABLE *table, uint keynr)
	Check if there are more unique keys after the current one. More...
bool	write_record (THD *thd, TABLE *table, COPY_INFO *info, COPY_INFO *update)
	Write a record to table with optional deletion of conflicting records, invoke proper triggers if needed. More...
bool	check_that_all_fields_are_given_values (THD *thd, TABLE *entry, Table_ref *table_list)
	Check that all fields with aren't null_fields are used. More...
static TABLE *	create_table_from_items (THD *thd, HA_CREATE_INFO *create_info, Table_ref *create_table, Alter_info *alter_info, const mem_root_deque< Item * > &items, handlerton **post_ddl_ht)
	Create table from lists of fields and items (or just return TABLE object for pre-opened existing table). More...

Function Documentation

allocate_column_bitmap()

static bool allocate_column_bitmap ( THD *  thd, TABLE *  table, MY_BITMAP **  bitmap  )

static

check_insert_fields()

static bool check_insert_fields ( THD *  thd, Table_ref *  table_list, mem_root_deque< Item * > *  fields  )

static

Check insert fields.

Parameters

thd	The current thread.
table_list	The table for insert.
fields	The insert fields.

Returns

false if success, true if error

Resolved reference to base table is returned in lex->insert_table_leaf.

check_single_table_insert()

static bool check_single_table_insert ( const mem_root_deque< Item * > &  fields, Table_ref *  view, Table_ref **  insert_table_ref  )

static

Check that insert fields are from a single table of a multi-table view.

Parameters

	fields	The insert fields to be checked.
	view	The view for insert.
[out]	insert_table_ref	Reference to table to insert into

This function is called to check that the fields being inserted into are from a single base table. This must be checked when the table to be inserted into is a multi-table view.

Returns

false if success, true if an error was raised.

check_that_all_fields_are_given_values()

bool check_that_all_fields_are_given_values	(	THD *	thd,
		TABLE *	entry,
		Table_ref *	table_list
	)

Check that all fields with aren't null_fields are used.

Parameters

thd	thread handler
entry	table that's checked
table_list	top-level table or view, used for generating error or warning message

Return values

true	if all fields are given values

check_valid_table_refs()

static bool check_valid_table_refs ( const Table_ref *  view, const mem_root_deque< Item * > &  values, table_map  map  )

static

Check that table references are restricted to the supplied table map.

The check can be skipped if the supplied table is a base table.

Parameters

view	Table being specified
values	Values whose used tables are to be matched against table map
map	Table map to match against

Returns

false if success, true if error

check_view_insertability()

static bool check_view_insertability ( THD *  thd, Table_ref *  view, const Table_ref *  insert_table_ref  )

static

Additional check for insertability for VIEW.

A view is insertable if the following conditions are true:

• All columns being inserted into are from a single table.
• All not used columns in table have default values.
• All columns in view are distinct (not referring to the same column).
• All columns in view are insertable-into.

Parameters

	thd	thread handler
[in,out]	view	reference to view being inserted into. view->contain_auto_increment is true if and only if the view contains an auto_increment field.
	insert_table_ref	reference to underlying table being inserted into

Return values

false	if success
true	if table is not insertable-into (no error is reported)

create_table_from_items()

static TABLE * create_table_from_items ( THD *  thd, HA_CREATE_INFO *  create_info, Table_ref *  create_table, Alter_info *  alter_info, const mem_root_deque< Item * > &  items, handlerton **  post_ddl_ht  )

static

Create table from lists of fields and items (or just return TABLE object for pre-opened existing table).

Used by CREATE SELECT.

Let "source table" be the table in the SELECT part.

Let "source table columns" be the set of columns in the SELECT list.

An interesting peculiarity in the syntax CREATE TABLE (<columns>) SELECT is that function defaults are stripped from the the source table columns, but not from the additional columns defined in the CREATE TABLE part. The first TIMESTAMP column there is also subject to promotion to TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, as usual.

Parameters

[in]	thd	Thread object
[in]	create_info	Create information (like MAX_ROWS, ENGINE or temporary table flag)
[in]	create_table	Pointer to Table_ref object providing database and name for table to be created or to be open
[in,out]	alter_info	Initial list of columns and indexes for the table to be created
[in]	items	The source table columns. Corresponding column definitions (Create_field's) will be added to the end of alter_info->create_list.
[out]	post_ddl_ht	Set to handlerton for table's SE, if this SE supports atomic DDL, so caller can call SE post DDL hook after committing transaction.

Note

This function assumes that either table exists and was pre-opened and locked at open_and_lock_tables() stage (and in this case we just emit error or warning and return pre-opened TABLE object) or an exclusive metadata lock was acquired on table so we can safely create, open and lock table in it (we don't acquire metadata lock if this create is for temporary table).

Since this function contains some logic specific to CREATE TABLE ... SELECT it should be changed before it can be used in other contexts.

Return values

non-zero	Pointer to TABLE object for table created or opened
0	Error

fix_join_cond_for_insert()

static bool fix_join_cond_for_insert ( THD *  thd, Table_ref *  tr  )

static

Recursive helper function for resolving join conditions for insertion into view for prepared statements.

Parameters

thd	Thread handler
tr	Table structure which is traversed recursively

Returns

false if success, true if error

last_uniq_key()

static bool last_uniq_key ( TABLE *  table, uint  keynr  )

static

Check if there are more unique keys after the current one.

Parameters

table	table that keys are checked for
keynr	current key number

Returns

true if there are unique keys after the specified one

mysql_prepare_blob_values()

static bool mysql_prepare_blob_values ( THD *  thd, const mem_root_deque< Item * > &  fields, MEM_ROOT *  mem_root  )

static

Setup data for field BLOB/GEOMETRY field types for execution of "INSERT...UPDATE" statement.

For a expression in 'UPDATE' clause like "a= VALUES(a)", let as call Field* referring 'a' as LHS_FIELD and Field* referring field 'a' in "VALUES(a)" as RHS_FIELD

This function creates a separate copy of the blob value for RHS_FIELD, if the field is updated as well as accessed through VALUES() function in 'UPDATE' clause of "INSERT...UPDATE" statement.

Parameters

[in]	thd	Pointer to THD object.
[in]	fields	List of fields representing LHS_FIELD of all expressions in 'UPDATE' clause.
[in]	mem_root	MEM_ROOT for blob copy.

Returns

- Can fail only when we are out of memory.

Return values

false	Success
true	Failure

prepare_for_positional_update()

static void prepare_for_positional_update ( TABLE *  table, Table_ref *  tables  )

static

Get extra info for tables we insert into.

Parameters

table	table(TABLE object) we insert into, might be NULL in case of view
tables	(Table_ref object) or view we insert into

prepare_triggers_for_insert_stmt()

void prepare_triggers_for_insert_stmt	(	THD *	thd,
		TABLE *	table
	)

Prepare triggers for INSERT-like statement.

Parameters

thd	Thread handler
table	Table to which insert will happen

Note

Prepare triggers for INSERT-like statement by marking fields used by triggers and inform handlers that batching of UPDATE/DELETE cannot be done if there are BEFORE UPDATE/DELETE triggers.

validate_default_values_of_unset_fields()

bool validate_default_values_of_unset_fields	(	THD *	thd,
		TABLE *	table
	)

Validates default value of fields which are not specified in the column list of INSERT statement.

Note

table->record[0] should be be populated with default values before calling this function.

Parameters

thd	thread context
table	table to which values are inserted.

Returns

false if success, true if error

write_record()

bool write_record	(	THD *	thd,
		TABLE *	table,
		COPY_INFO *	info,
		COPY_INFO *	update
	)

Write a record to table with optional deletion of conflicting records, invoke proper triggers if needed.

Parameters

thd	thread context
table	table to which record should be written
info	COPY_INFO structure describing handling of duplicates and which is used for counting number of records inserted and deleted.
update	COPY_INFO structure describing the UPDATE part (only used for INSERT ON DUPLICATE KEY UPDATE)

Once this record is written to the table buffer, any AFTER INSERT trigger will be invoked. If instead of inserting a new record we end up updating an old one, both ON UPDATE triggers will fire instead. Similarly both ON DELETE triggers will be invoked if are to delete conflicting records.

Call thd->transaction.stmt.mark_modified_non_trans_table() if table is a non-transactional table.

Note

In ON DUPLICATE KEY UPDATE case this call may set TABLE::autoinc_field_has_explicit_non_null_value flag to true (even in case of failure) so its caller should make sure that it is reset appropriately (

See also

fill_record()).

Returns

false if success, true if error

< Flag for fatal errors