(G_PTR*) &defaults_group, (G_PTR*) &defaults_group,

0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0},

&xb_plugin_dir, &xb_plugin_dir,

0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0 },

&xb_plugin_load, &xb_plugin_load,

0, GET_STR, REQUIRED_ARG, 0, 0, 0, 0, 0, 0 },

/* Reset the system variables in the recovery module. */

recv_sys_var_init();

trx_pool_init();

ut_crc32_init();

crc_init();

/* Extra length needed for filename if one calls my_create_backup_name */

#define MY_BACKUP_NAME_EXTRA_LENGTH 17

/* If we have our own safemalloc (for debugging) */

#if defined(SAFEMALLOC)

void sf_report_leaked_memory(my_thread_id id);

let $datadir=`select @@datadir`;

list_files $datadir mysql_upgrade_info;

list_files $datadir/mysql #sql*;

--enable_query_log

#Print the table contents in html format

<TABLE BORDER=1><TR><TH>c1</TH><TH>c2</TH><TH>c3</TH><TH>c4</TH><TH>c5</TH><TH>c6</TH><TH>c7</TH><TH>c8</TH><TH>c9</TH></TR><TR><TD>0x74696E79626C6F622D74657874207265616461626C65</TD><TD>0x626C6F622D74657874207265616461626C65</TD><TD>0x6D656469756D626C6F622D74657874207265616461626C65</TD><TD>0x6C6F6E67626C6F622D74657874207265616461626C65</TD><TD>0x74657874207265616461626C65</TD><TD>0x01</TD><TD>0x63</TD><TD>0x7661726961626C65</TD><TD>0x000000000101000000000000000000F03F000000000000F03F</TD></TR></TABLE><TABLE BORDER=1><TR><TH>id</TH><TH>col1</TH><TH>col2</TH></TR><TR><TD>1</TD><TD>0xAB123400000000000000</TD><TD>0x123ABC</TD></TR><TR><TD>2</TD><TD>0xDE123400000000000000</TD><TD>0x123DEF</TD></TR></TABLE>DROP TABLE t1, t2;

2

3

#

# MDEV-14217 [db crash] Recursive CTE when SELECT includes new field

#

CREATE TEMPORARY TABLE a_tbl (

20

disconnect con1;

connection default;

drop table t1;

drop table if exists t1;

create table t1(a int, b int, c varchar(20), primary key(a)) engine = innodb;

ALTER TABLE t1 ADD PRIMARY KEY (f2, f1);

ERROR HY000: Lost connection to MySQL server during query

# Restart mysqld after the crash and reconnect.

# Files in datadir after manual recovery.

t1.frm

t1.ibd

ALTER TABLE t2 ADD PRIMARY KEY (f2, f1);

ERROR HY000: Lost connection to MySQL server during query

# Startup the server after the crash

# Drop the orphaned rebuilt table.

SHOW TABLES;

Tables_in_test

ALTER TABLE t1 ADD INDEX (b), CHANGE c d int, ALGORITHM=INPLACE;

ERROR HY000: Lost connection to MySQL server during query

# Restart mysqld after the crash and reconnect.

FLUSH TABLES;

# Files in datadir after manual recovery.

t1.frm

t1.ibd

KEY(c3), KEY(c3,c1), KEY(c3,c2), KEY(c3,c2,c1),

KEY(c4), KEY(c4,c1), KEY(c4,c2), KEY(c4,c2,c1),

KEY(c4,c3), KEY(c4,c3,c1), KEY(c4,c3,c2), KEY(c4,c3,c2,c1)) ENGINE=InnoDB;

SET DEBUG_DBUG='+d,row_drop_table_add_to_background';

DROP TABLE t;

CREATE TABLE t (a INT) ENGINE=InnoDB;

DROP TABLE t;

KEY `i` (`i`)

) ENGINE=InnoDB AUTO_INCREMENT=401 DEFAULT CHARSET=latin1

DROP TABLE t;

--echo # Restart mysqld after the crash and reconnect.

--source include/start_mysqld.inc

perl;

EOF

--echo # Files in datadir after manual recovery.

--list_files $MYSQLD_DATADIR/test

--echo # Startup the server after the crash

--source include/start_mysqld.inc

perl;

die unless open OUT, ">$ENV{TABLENAME_INC}";

chdir "$ENV{'datadir'}/test";

source $TABLENAME_INC;

remove_file $TABLENAME_INC;

--echo # Drop the orphaned rebuilt table.

--disable_query_log

eval DROP TABLE `#mysql50#$tablename`;

--echo # Restart mysqld after the crash and reconnect.

--source include/start_mysqld.inc

perl;

EOF

FLUSH TABLES;

--echo # Files in datadir after manual recovery.

--list_files $MYSQLD_DATADIR/test

KEY(c4), KEY(c4,c1), KEY(c4,c2), KEY(c4,c2,c1),

KEY(c4,c3), KEY(c4,c3,c1), KEY(c4,c3,c2), KEY(c4,c3,c2,c1)) ENGINE=InnoDB;

let $n= 10;

SET DEBUG_DBUG='+d,row_drop_table_add_to_background';

dec $i;

}

--enable_query_log

DROP TABLE t;

--source include/restart_mysqld.inc

CREATE TABLE t (a INT) ENGINE=InnoDB;

DROP TABLE t;

SELECT * FROM t;

SHOW CREATE TABLE t;

DROP TABLE t;

select count(*) from events_statements_history where sql_text like "%...";

count(*)

2

select _utf8mb4 'васÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑвасÑ' as B;

select count(*) from events_statements_history where sql_text like "%...";

#Cleanup

DROP TABLE t1, t2;

# Wait till all disconnects are completed

--source include/wait_until_count_sessions.inc

FROM cte1;

--echo #

--echo # MDEV-14217 [db crash] Recursive CTE when SELECT includes new field

--echo #

--error ER_WRONG_NUMBER_OF_COLUMNS_IN_SELECT

WITH RECURSIVE x AS (SELECT 1,2 UNION ALL SELECT 1 FROM x) SELECT * FROM x;

xa start 'zzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzz';

select * from t1;

disconnect con1;

connection default;

drop table t1;

#

DROP TABLE t1, t2;

disconnect con2;

# Wait till all disconnects are completed

--source include/wait_until_count_sessions.inc

string.c thr_alarm.c thr_lock.c thr_mutex.c

thr_rwlock.c thr_timer.c

tree.c typelib.c base64.c my_memmem.c

lf_alloc-pin.c lf_dynarray.c lf_hash.c

safemalloc.c my_new.cc

my_getncpus.c my_safehash.c my_chmod.c my_rnd.c

DBUG_RETURN(ret);

#ifdef WITH_WSREP

error:

#endif /* WITH_WSREP */

}

}

my_decimal *Field_real::val_decimal(my_decimal *decimal_value)

{

ASSERT_COLUMN_MARKED_FOR_READ;

}

virtual double val_real(void)=0;

virtual longlong val_int(void)=0;

virtual bool val_bool(void)= 0;

virtual my_decimal *val_decimal(my_decimal *);

inline String *val_str(String *str) { return val_str(str, str); }

class Field_double :public Field_real {

public:

Field_double(uchar *ptr_arg, uint32 len_arg, uchar *null_ptr_arg,

uchar null_bit_arg,

int store(longlong nr, bool unsigned_val);

int reset(void) { bzero(ptr,sizeof(double)); return 0; }

double val_real(void);

String *val_str(String*,String *);

bool send_binary(Protocol *protocol);

int cmp(const uchar *,const uchar *);

}

/**

return the list of XID's to a client, the same way SHOW commands do.

@note

It can be easily fixed later, if necessary.

*/

{

if (xs->xa_state == XA_PREPARED)

{

protocol->store_longlong((longlong) xs->xid.formatID, FALSE);

protocol->store_longlong((longlong) xs->xid.gtrid_length, FALSE);

protocol->store_longlong((longlong) xs->xid.bqual_length, FALSE);

if (protocol->write())

return TRUE;

}

}

bool mysql_xa_recover(THD *thd)

{

List<Item> field_list;

Protocol *protocol= thd->protocol;

MEM_ROOT *mem_root= thd->mem_root;

DBUG_ENTER("mysql_xa_recover");

field_list.push_back(new (mem_root)

field_list.push_back(new (mem_root)

Item_int(thd, "bqual_length", 0,

MY_INT32_NUM_DECIMAL_DIGITS), mem_root);

if (protocol->send_result_set_metadata(&field_list,

Protocol::SEND_NUM_ROWS | Protocol::SEND_EOF))

DBUG_RETURN(1);

DBUG_RETURN(1);

my_eof(thd);

DBUG_RETURN(0);

};

typedef struct xid_t XID;

/* for recover() handlerton call */

#define MIN_XID_LIST_SIZE 128

#define MAX_XID_LIST_SIZE (1024*128)

used_fields|= (HA_CREATE_USED_CHARSET | HA_CREATE_USED_DEFAULT_CHARSET);

return false;

}

};

eng "GTID_NEXT cannot be changed by a client that owns a GTID. The client owns %s. Ownership is released on COMMIT or ROLLBACK"

ER_UNKNOWN_EXPLAIN_FORMAT

ER_CANT_EXECUTE_IN_READ_ONLY_TRANSACTION 25006

eng "Cannot execute statement in a READ ONLY transaction"

THD_STAGE_INFO(thd, stage_cleaning_up);

thd->reset_query();

/* Performance Schema Interface instrumentation, end */

MYSQL_END_STATEMENT(thd->m_statement_psi, thd->get_stmt_da());

thd->m_statement_psi= NULL;

thd->m_digest= NULL;

{

List<set_var_base> *lex_var_list= &lex->var_list;

if ((check_table_access(thd, SELECT_ACL, all_tables, FALSE, UINT_MAX, FALSE)

|| open_and_lock_tables(thd, all_tables, TRUE, 0)))

goto error;

lpt->part_info= part_info;

lpt->alter_info= alter_info;

lpt->create_info= create_info;

lpt->table= table;

lpt->key_info_buffer= 0;

lpt->key_count= 0;

set_table_default_charset(thd, create_info, (char*) db);

if (!(file= get_new_handler((TABLE_SHARE*) 0, thd->mem_root,

create_info->db_type)))

lex->link_first_table_back(view, link_to_local);

view->open_type= OT_BASE_ONLY;

if (check_dependencies_in_with_clauses(lex->with_clauses_list))

{

res= TRUE;

goto err;

}

/*

ignore lock specs for CREATE statement

*/

opt_default_time_precision

case_stmt_body opt_bin_mod

opt_if_exists_table_element opt_if_not_exists_table_element

%type <object_ddl_options>

create_or_replace

{

Lex->sql_command = SQLCOM_XA_ROLLBACK;

}

{

Lex->sql_command = SQLCOM_XA_RECOVER;

}

;

#include "sql_priv.h"

#include "sql_class.h" // set_var.h: THD

#include "sys_vars.ic"

#include "events.h"

#include <thr_alarm.h>

CMD_LINE_HELP_ONLY,

IN_SYSTEM_CHARSET, DEFAULT(SOURCE_REVISION));

static char *malloc_library;

static Sys_var_charptr Sys_malloc_library(

"version_malloc_library", "Version of the used malloc library",

whether we update the table autoinc counter or not. */

col_max_value = innobase_get_int_col_max_value(table->next_number_field);

switch (error) {

case DB_DUPLICATE_KEY:

if (field != table->found_next_number_field

|| dfield_is_null(&ufield->new_val)) {

} else {

}

}

n_changed++;

row_get_background_drop_list_len_low(void);

/*======================================*/

/*********************************************************************//**

Sets an exclusive lock on a table.

@return error code or DB_SUCCESS */

/* Drop partially created indexes. */

row_merge_drop_temp_indexes();

/* Drop any auxiliary tables that were not dropped when the

parent table was dropped. This can happen if the parent table

#include "trx0roll.h"

#include "trx0undo.h"

#include "row0ext.h"

#include "ut0new.h"

#include <algorithm>

/** Chain node of the list of tables to drop in the background. */

struct row_mysql_drop_t{

UT_LIST_NODE_T(row_mysql_drop_t)row_mysql_drop_list;

/*!< list chain node */

};

|| 0 == strcmp(name + 6, "db"));

}

#ifdef UNIV_DEBUG

/** Wait for the background drop list to become empty. */

void

error = row_drop_table_for_mysql(name, trx, FALSE, FALSE);

trx_commit_for_mysql(trx);

trx_free_for_background(trx);

mutex_enter(&row_drop_list_mutex);

ut_a(row_mysql_drop_list_inited);

drop = UT_LIST_GET_FIRST(row_mysql_drop_list);

n_tables = UT_LIST_GET_LEN(row_mysql_drop_list);

return(n_tables + n_tables_dropped);

}

}

if (!table->to_be_dropped) {

dict_table_close(table, FALSE, FALSE);

}

dict_table_close(table, FALSE, FALSE);

if (DB_SUCCESS != row_drop_table_for_mysql_in_background(

/* If the DROP fails for some table, we return, and let the

main thread retry later */

return(n_tables + n_tables_dropped);

}

goto loop;

}

return(len);

}

/*********************************************************************//**

If a table is not yet in the drop list, adds the table to the list of tables

which the master thread drops in background. We need this on Unix because in

ALTER TABLE MySQL may call drop table even if the table has running queries on

it. Also, if there are running foreign key checks on the table, we drop the

table lazily.

static

{

row_mysql_drop_t* drop;

mutex_enter(&row_drop_list_mutex);

drop != NULL;

drop = UT_LIST_GET_NEXT(row_mysql_drop_list, drop)) {

}

}

UT_LIST_ADD_LAST(row_mysql_drop_list, drop);

MONITOR_INC(MONITOR_BACKGROUND_DROP_TABLE);

mutex_exit(&row_drop_list_mutex);

}

/** Reassigns the table identifier of a table.

}

/* TODO: could we replace the counter n_foreign_key_checks_running

with lock checks on the table? Acquire here an exclusive lock on the

checks take an IS or IX lock on the table. */

if (table->n_foreign_key_checks_running > 0) {

} else {

}

goto funct_exit;

}

/* Wait on background threads to stop using table */

fil_wait_crypt_bg_threads(table);

}

/* The "to_be_dropped" marks table that is to be dropped, but

and it is free to be dropped */

table->to_be_dropped = false;

switch (trx_get_dict_operation(trx)) {

case TRX_DICT_OP_NONE:

trx_set_dict_operation(trx, TRX_DICT_OP_TABLE);

const my_core::enum_field_types type = field->real_type();

/* Handle [VAR](CHAR|BINARY) or TEXT|BLOB */

if (type == MYSQL_TYPE_VARCHAR || type == MYSQL_TYPE_STRING ||

}

return true;

}

!rdb_is_index_collation_supported(

table_arg->key_info[i].key_part[part].field) &&

!rdb_collation_exceptions->matches(tablename_sys)) {

}

}

}

// Basic sanity checking and parsing the options into a map. If this fails

// then there's no point to proceed.

if (!Rdb_cf_options::parse_cf_options(val, &option_map)) {

*reinterpret_cast<char**>(var_ptr) = nullptr;

// NO_LINT_DEBUG

// the CF options. This will results in consistent behavior and avoids

// dealing with cases when only a subset of CF-s was successfully updated.

if (val) {

*reinterpret_cast<char**>(var_ptr) = my_strdup(val, MYF(0));

} else {

*reinterpret_cast<char**>(var_ptr) = nullptr;

its name generation.

*/

struct st_mysql_storage_engine rocksdb_storage_engine = {

MYSQL_HANDLERTON_INTERFACE_VERSION};

myrocks::rocksdb_status_vars, /* status variables */

myrocks::rocksdb_system_variables, /* system variables */

"1.0", /* string version */

},

myrocks::rdb_i_s_cfstats, myrocks::rdb_i_s_dbstats,

myrocks::rdb_i_s_perf_context, myrocks::rdb_i_s_perf_context_global,

Rdb_inplace_alter_ctx(const Rdb_inplace_alter_ctx &);

Rdb_inplace_alter_ctx &operator=(const Rdb_inplace_alter_ctx &);

};

} // namespace myrocks

set @tmp_rocksdb_strict_collation_check= @@rocksdb_strict_collation_check;

set global rocksdb_strict_collation_check=1;

CREATE TABLE t1 (a INT, b TEXT);

ALTER TABLE t1 ADD KEY kb(b(10));

ALTER TABLE t1 ADD PRIMARY KEY(a);

DROP TABLE t1;

set global rocksdb_strict_collation_check= @tmp_rocksdb_strict_collation_check;

create table t1 (pk varchar(10) collate latin1_nopad_bin, primary key(pk)) engine=rocksdb;

ERROR HY000: MyRocks doesn't currently support collations with "No pad" attribute.

set global rocksdb_strict_collation_check=@tmp_rscc;

set global rocksdb_strict_collation_check=1;

CREATE TABLE t1 (a INT, b TEXT);

ALTER TABLE t1 ADD KEY kb(b(10));

ALTER TABLE t1 ADD PRIMARY KEY(a);

DROP TABLE t1;

set global rocksdb_strict_collation_check= @tmp_rocksdb_strict_collation_check;

# make sure race condition between connection close and alter on another

create table t1 (pk varchar(10) collate latin1_nopad_bin, primary key(pk)) engine=rocksdb;

set global rocksdb_strict_collation_check=@tmp_rscc;

rdb_collation_data;

mysql_mutex_t rdb_collation_data_mutex;

return cs->strxfrm_multiply==1 && cs->mbmaxlen == 1 &&

!(cs->state & (MY_CS_BINSORT | MY_CS_NOPAD));

}

uint64 m_ttl_duration = 0;

};

} // namespace myrocks

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_dbstats = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_perf_context = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_perf_context_global = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_cfoptions = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_global_info = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_compact_stats = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_ddl = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_index_file_map = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_lock_info = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

struct st_maria_plugin rdb_i_s_trx_info = {

nullptr, /* status variables */

nullptr, /* system variables */

nullptr, /* config options */

};

} // namespace myrocks

MESSAGE(STATUS "CMake 2.8.9 or higher is required by TokuDB")

ELSEIF(CMAKE_SYSTEM_PROCESSOR STREQUAL "x86_64" OR

CMAKE_SYSTEM_PROCESSOR STREQUAL "amd64")

CHECK_CXX_SOURCE_COMPILES(

"

#include <fcntl.h>

struct a {int b; int c; };

struct a d = { .b=1, .c=2 };

" TOKUDB_OK)

ENDIF()

# and probably others

[Unit]

After=network.target

After=syslog.target

# Start main service

# MYSQLD_OPTS here is for users to set in /etc/systemd/system/mariadb.service.d/MY_SPECIAL.conf

# This isn't a replacement for my.cnf.

# _WSREP_NEW_CLUSTER is for the exclusive use of the script galera_new_cluster

ExecStart=@sbindir@/mysqld $MYSQLD_OPTS $_WSREP_NEW_CLUSTER $_WSREP_START_POSITION

##

##

## by creating a file in /etc/systemd/system/mariadb.service.d/MY_SPECIAL.conf

# Useful options not previously available in [mysqld_safe]

# Inspired from https://gitweb.gentoo.org/repo/gentoo.git/tree/dev-db/mysql-init-scripts/files/mysqld_at.service

[Unit]

After=network.target

After=syslog.target

# Start main service

# MYSQLD_OPTS here is for users to set in /etc/systemd/system/mariadb@.service.d/MY_SPECIAL.conf

# This isn't a replacement for my.cnf.

# _WSREP_NEW_CLUSTER is for the exclusive use of the script galera_new_cluster

##

##

## by creating a file in /etc/systemd/system/mariadb.service.d/MY_SPECIAL.conf

# Useful options not previously available in [mysqld_safe]