Merge 10.2 into 10.3

This commit is contained in:
Marko Mäkelä 2019-03-06 16:20:13 +02:00
commit 77103e9832
13 changed files with 87 additions and 53 deletions

View File

@ -512,7 +512,8 @@ datafile_open(const char *file, datafile_cur_t *cursor, uint thread_n)
5.6+. We want to make "local" copies for the backup. */ 5.6+. We want to make "local" copies for the backup. */
strncpy(cursor->rel_path, strncpy(cursor->rel_path,
xb_get_relative_path(cursor->abs_path, FALSE), xb_get_relative_path(cursor->abs_path, FALSE),
sizeof(cursor->rel_path)); (sizeof cursor->rel_path) - 1);
cursor->rel_path[(sizeof cursor->rel_path) - 1] = '\0';
cursor->file = os_file_create_simple_no_error_handling( cursor->file = os_file_create_simple_no_error_handling(
0, cursor->abs_path, 0, cursor->abs_path,

View File

@ -123,7 +123,8 @@ void encryption_plugin_backup_init(MYSQL *mysql)
/* Required to load the plugin later.*/ /* Required to load the plugin later.*/
add_to_plugin_load_list(plugin_load.c_str()); add_to_plugin_load_list(plugin_load.c_str());
strncpy(opt_plugin_dir, dir, FN_REFLEN); strncpy(opt_plugin_dir, dir, FN_REFLEN - 1);
opt_plugin_dir[FN_REFLEN - 1] = '\0';
oss << "plugin_dir=" << '"' << dir << '"' << std::endl; oss << "plugin_dir=" << '"' << dir << '"' << std::endl;
@ -193,7 +194,10 @@ void encryption_plugin_prepare_init(int argc, char **argv)
add_to_plugin_load_list(plugin_load.c_str()); add_to_plugin_load_list(plugin_load.c_str());
if (xb_plugin_dir) if (xb_plugin_dir)
strncpy(opt_plugin_dir, xb_plugin_dir, FN_REFLEN); {
strncpy(opt_plugin_dir, xb_plugin_dir, FN_REFLEN - 1);
opt_plugin_dir[FN_REFLEN - 1] = '\0';
}
char **new_argv = new char *[argc + 1]; char **new_argv = new char *[argc + 1];
new_argv[0] = XTRABACKUP_EXE; new_argv[0] = XTRABACKUP_EXE;

View File

@ -147,7 +147,8 @@ xb_fil_cur_open(
cursor->space_id = node->space->id; cursor->space_id = node->space->id;
strncpy(cursor->abs_path, node->name, sizeof(cursor->abs_path)); strncpy(cursor->abs_path, node->name, (sizeof cursor->abs_path) - 1);
cursor->abs_path[(sizeof cursor->abs_path) - 1] = '\0';
/* Get the relative path for the destination tablespace name, i.e. the /* Get the relative path for the destination tablespace name, i.e. the
one that can be appended to the backup root directory. Non-system one that can be appended to the backup root directory. Non-system
@ -155,7 +156,8 @@ xb_fil_cur_open(
We want to make "local" copies for the backup. */ We want to make "local" copies for the backup. */
strncpy(cursor->rel_path, strncpy(cursor->rel_path,
xb_get_relative_path(cursor->abs_path, cursor->is_system()), xb_get_relative_path(cursor->abs_path, cursor->is_system()),
sizeof(cursor->rel_path)); (sizeof cursor->rel_path) - 1);
cursor->rel_path[(sizeof cursor->rel_path) - 1] = '\0';
/* In the backup mode we should already have a tablespace handle created /* In the backup mode we should already have a tablespace handle created
by fil_ibd_load() unless it is a system by fil_ibd_load() unless it is a system

View File

@ -2401,8 +2401,9 @@ check_if_skip_table(
return(FALSE); return(FALSE);
} }
strncpy(buf, dbname, FN_REFLEN); strncpy(buf, dbname, FN_REFLEN - 1);
buf[tbname - 1 - dbname] = 0; buf[FN_REFLEN - 1] = '\0';
buf[tbname - 1 - dbname] = '\0';
const skip_database_check_result skip_database = const skip_database_check_result skip_database =
check_if_skip_database(buf); check_if_skip_database(buf);
@ -2410,7 +2411,6 @@ check_if_skip_table(
return (TRUE); return (TRUE);
} }
buf[FN_REFLEN - 1] = '\0';
buf[tbname - 1 - dbname] = '.'; buf[tbname - 1 - dbname] = '.';
/* Check if there's a suffix in the table name. If so, truncate it. We /* Check if there's a suffix in the table name. If so, truncate it. We
@ -4841,7 +4841,8 @@ xtrabackup_apply_delta(
} }
dst_path[strlen(dst_path) - 6] = '\0'; dst_path[strlen(dst_path) - 6] = '\0';
strncpy(space_name, filename, FN_REFLEN); strncpy(space_name, filename, FN_REFLEN - 1);
space_name[FN_REFLEN - 1] = '\0';
space_name[strlen(space_name) - 6] = 0; space_name[strlen(space_name) - 6] = 0;
if (!get_meta_path(src_path, meta_path)) { if (!get_meta_path(src_path, meta_path)) {

View File

@ -7,3 +7,12 @@ DROP TABLE t1;
CREATE TABLE t1(a VARCHAR(2) CHARACTER SET big5 COLLATE big5_chinese_ci, CREATE TABLE t1(a VARCHAR(2) CHARACTER SET big5 COLLATE big5_chinese_ci,
FULLTEXT(a)) ENGINE=<default_engine>; FULLTEXT(a)) ENGINE=<default_engine>;
DROP TABLE t1; DROP TABLE t1;
CREATE TABLE t1 (a SERIAL, t TEXT, FULLTEXT f1(t), FULLTEXT f2(t)) ENGINE=InnoDB;
Warnings:
Note 1831 Duplicate index `f2`. This is deprecated and will be disallowed in a future release
INSERT INTO t1 (a,t) VALUES (1,'1'),(2,'1');
ALTER TABLE t1 ADD COLUMN g TEXT GENERATED ALWAYS AS (t) VIRTUAL;
DELETE FROM t1 WHERE a = 1;
ALTER TABLE t1 DROP INDEX f1;
INSERT INTO t1 (a,t) VALUES (1,'1');
DROP TABLE t1;

View File

@ -35,3 +35,12 @@ FULLTEXT(a)) ENGINE=$default_engine;
DROP TABLE t1; DROP TABLE t1;
# End of 5.1 tests # End of 5.1 tests
CREATE TABLE t1 (a SERIAL, t TEXT, FULLTEXT f1(t), FULLTEXT f2(t)) ENGINE=InnoDB;
INSERT INTO t1 (a,t) VALUES (1,'1'),(2,'1');
ALTER TABLE t1 ADD COLUMN g TEXT GENERATED ALWAYS AS (t) VIRTUAL;
DELETE FROM t1 WHERE a = 1;
ALTER TABLE t1 DROP INDEX f1;
INSERT INTO t1 (a,t) VALUES (1,'1');
DROP TABLE t1;

View File

@ -2442,6 +2442,11 @@ com_multi_end:
thd->packet.shrink(thd->variables.net_buffer_length); // Reclaim some memory thd->packet.shrink(thd->variables.net_buffer_length); // Reclaim some memory
thd->reset_kill_query(); /* Ensure that killed_errmsg is released */ thd->reset_kill_query(); /* Ensure that killed_errmsg is released */
/*
LEX::m_sql_cmd can point to Sql_cmd allocated on thd->mem_root.
Unlink it now, before freeing the root.
*/
thd->lex->m_sql_cmd= NULL;
free_root(thd->mem_root,MYF(MY_KEEP_PREALLOC)); free_root(thd->mem_root,MYF(MY_KEEP_PREALLOC));
#if defined(ENABLED_PROFILING) #if defined(ENABLED_PROFILING)

View File

@ -1572,13 +1572,8 @@ dict_table_rename_in_cache(
ut_ad(mutex_own(&dict_sys->mutex)); ut_ad(mutex_own(&dict_sys->mutex));
/* store the old/current name to an automatic variable */ /* store the old/current name to an automatic variable */
if (strlen(table->name.m_name) + 1 <= sizeof(old_name)) { ut_a(strlen(table->name.m_name) < sizeof old_name);
strcpy(old_name, table->name.m_name); strcpy(old_name, table->name.m_name);
} else {
ib::fatal() << "Too long table name: "
<< table->name
<< ", max length is " << MAX_FULL_NAME_LEN;
}
fold = ut_fold_string(new_name); fold = ut_fold_string(new_name);
@ -1768,7 +1763,7 @@ dict_table_rename_in_cache(
ulint db_len; ulint db_len;
char* old_id; char* old_id;
char old_name_cs_filename[MAX_TABLE_NAME_LEN+20]; char old_name_cs_filename[MAX_FULL_NAME_LEN+1];
uint errors = 0; uint errors = 0;
/* All table names are internally stored in charset /* All table names are internally stored in charset
@ -1785,7 +1780,8 @@ dict_table_rename_in_cache(
in old_name_cs_filename */ in old_name_cs_filename */
strncpy(old_name_cs_filename, old_name, strncpy(old_name_cs_filename, old_name,
MAX_TABLE_NAME_LEN); MAX_FULL_NAME_LEN);
old_name_cs_filename[MAX_FULL_NAME_LEN] = '\0';
if (strstr(old_name, TEMP_TABLE_PATH_PREFIX) == NULL) { if (strstr(old_name, TEMP_TABLE_PATH_PREFIX) == NULL) {
innobase_convert_to_system_charset( innobase_convert_to_system_charset(
@ -1807,7 +1803,9 @@ dict_table_rename_in_cache(
/* Old name already in /* Old name already in
my_charset_filename */ my_charset_filename */
strncpy(old_name_cs_filename, old_name, strncpy(old_name_cs_filename, old_name,
MAX_TABLE_NAME_LEN); MAX_FULL_NAME_LEN);
old_name_cs_filename[MAX_FULL_NAME_LEN]
= '\0';
} }
} }
@ -1833,7 +1831,7 @@ dict_table_rename_in_cache(
/* This is a generated >= 4.0.18 format id */ /* This is a generated >= 4.0.18 format id */
char table_name[MAX_TABLE_NAME_LEN] = ""; char table_name[MAX_TABLE_NAME_LEN + 1];
uint errors = 0; uint errors = 0;
if (strlen(table->name.m_name) if (strlen(table->name.m_name)
@ -1848,6 +1846,7 @@ dict_table_rename_in_cache(
/* Convert the table name to UTF-8 */ /* Convert the table name to UTF-8 */
strncpy(table_name, table->name.m_name, strncpy(table_name, table->name.m_name,
MAX_TABLE_NAME_LEN); MAX_TABLE_NAME_LEN);
table_name[MAX_TABLE_NAME_LEN] = '\0';
innobase_convert_to_system_charset( innobase_convert_to_system_charset(
strchr(table_name, '/') + 1, strchr(table_name, '/') + 1,
strchr(table->name.m_name, '/') + 1, strchr(table->name.m_name, '/') + 1,
@ -1857,9 +1856,10 @@ dict_table_rename_in_cache(
/* Table name could not be converted /* Table name could not be converted
from charset my_charset_filename to from charset my_charset_filename to
UTF-8. This means that the table name UTF-8. This means that the table name
is already in UTF-8 (#mysql#50). */ is already in UTF-8 (#mysql50#). */
strncpy(table_name, table->name.m_name, strncpy(table_name, table->name.m_name,
MAX_TABLE_NAME_LEN); MAX_TABLE_NAME_LEN);
table_name[MAX_TABLE_NAME_LEN] = '\0';
} }
/* Replace the prefix 'databasename/tablename' /* Replace the prefix 'databasename/tablename'

View File

@ -1,7 +1,7 @@
/***************************************************************************** /*****************************************************************************
Copyright (c) 2011, 2018, Oracle and/or its affiliates. All Rights Reserved. Copyright (c) 2011, 2018, Oracle and/or its affiliates. All Rights Reserved.
Copyright (c) 2016, 2018, MariaDB Corporation. Copyright (c) 2016, 2019, MariaDB Corporation.
This program is free software; you can redistribute it and/or modify it under This program is free software; you can redistribute it and/or modify it under
the terms of the GNU General Public License as published by the Free Software the terms of the GNU General Public License as published by the Free Software
@ -726,6 +726,7 @@ fts_reset_get_doc(
memset(get_doc, 0x0, sizeof(*get_doc)); memset(get_doc, 0x0, sizeof(*get_doc));
get_doc->index_cache = ind_cache; get_doc->index_cache = ind_cache;
get_doc->cache = cache;
} }
ut_ad(ib_vector_size(cache->get_docs) ut_ad(ib_vector_size(cache->get_docs)
@ -4783,12 +4784,12 @@ fts_tokenize_document(
ut_a(!doc->tokens); ut_a(!doc->tokens);
ut_a(doc->charset); ut_a(doc->charset);
doc->tokens = rbt_create_arg_cmp( doc->tokens = rbt_create_arg_cmp(sizeof(fts_token_t),
sizeof(fts_token_t), innobase_fts_text_cmp, (void*) doc->charset); innobase_fts_text_cmp,
(void*) doc->charset);
if (parser != NULL) { if (parser != NULL) {
fts_tokenize_param_t fts_param; fts_tokenize_param_t fts_param;
fts_param.result_doc = (result != NULL) ? result : doc; fts_param.result_doc = (result != NULL) ? result : doc;
fts_param.add_pos = 0; fts_param.add_pos = 0;

View File

@ -1,7 +1,7 @@
/***************************************************************************** /*****************************************************************************
Copyright (c) 2007, 2018, Oracle and/or its affiliates. All Rights Reserved. Copyright (c) 2007, 2018, Oracle and/or its affiliates. All Rights Reserved.
Copyright (c) 2016, 2018, MariaDB Corporation. Copyright (c) 2016, 2019, MariaDB Corporation.
This program is free software; you can redistribute it and/or modify it under This program is free software; you can redistribute it and/or modify it under
the terms of the GNU General Public License as published by the Free Software the terms of the GNU General Public License as published by the Free Software
@ -674,25 +674,27 @@ fts_fetch_index_words(
fts_zip_t* zip = static_cast<fts_zip_t*>(user_arg); fts_zip_t* zip = static_cast<fts_zip_t*>(user_arg);
que_node_t* exp = sel_node->select_list; que_node_t* exp = sel_node->select_list;
dfield_t* dfield = que_node_get_val(exp); dfield_t* dfield = que_node_get_val(exp);
short len = static_cast<short>(dfield_get_len(dfield));
ut_a(dfield_get_len(dfield) <= FTS_MAX_WORD_LEN);
uint16 len = uint16(dfield_get_len(dfield));
void* data = dfield_get_data(dfield); void* data = dfield_get_data(dfield);
/* Skip the duplicate words. */ /* Skip the duplicate words. */
if (zip->word.f_len == static_cast<ulint>(len) if (zip->word.f_len == len && !memcmp(zip->word.f_str, data, len)) {
&& !memcmp(zip->word.f_str, data, zip->word.f_len)) {
return(TRUE); return(TRUE);
} }
ut_a(len <= FTS_MAX_WORD_LEN); memcpy(zip->word.f_str, data, len);
zip->word.f_len = len;
zip->word.f_len = ulint(len);
memcpy(zip->word.f_str, data, zip->word.f_len);
ut_a(zip->zp->avail_in == 0); ut_a(zip->zp->avail_in == 0);
ut_a(zip->zp->next_in == NULL); ut_a(zip->zp->next_in == NULL);
/* The string is prefixed by len. */ /* The string is prefixed by len. */
/* FIXME: This is not byte order agnostic (InnoDB data files
with FULLTEXT INDEX are not portable between little-endian and
big-endian systems!) */
zip->zp->next_in = reinterpret_cast<byte*>(&len); zip->zp->next_in = reinterpret_cast<byte*>(&len);
zip->zp->avail_in = sizeof(len); zip->zp->avail_in = sizeof(len);
@ -720,14 +722,13 @@ fts_fetch_index_words(
ut_a(len <= FTS_MAX_WORD_LEN); ut_a(len <= FTS_MAX_WORD_LEN);
len = 0; len = 0;
} }
break; continue;
case Z_STREAM_END: case Z_STREAM_END:
case Z_BUF_ERROR: case Z_BUF_ERROR:
case Z_STREAM_ERROR: case Z_STREAM_ERROR:
default: default:
ut_error; ut_error;
break;
} }
} }

View File

@ -1,6 +1,7 @@
/***************************************************************************** /*****************************************************************************
Copyright (c) 1996, 2016, Oracle and/or its affiliates. All Rights Reserved. Copyright (c) 1996, 2016, Oracle and/or its affiliates. All Rights Reserved.
Copyright (c) 2019, MariaDB Corporation.
This program is free software; you can redistribute it and/or modify it under This program is free software; you can redistribute it and/or modify it under
the terms of the GNU General Public License as published by the Free Software the terms of the GNU General Public License as published by the Free Software
@ -68,11 +69,11 @@ dict_create_add_foreign_id(
sprintf(id, "%s_ibfk_%lu", name, sprintf(id, "%s_ibfk_%lu", name,
(ulong) (*id_nr)++); (ulong) (*id_nr)++);
} else { } else {
char table_name[MAX_TABLE_NAME_LEN + 20] = ""; char table_name[MAX_TABLE_NAME_LEN + 21];
uint errors = 0; uint errors = 0;
strncpy(table_name, name, strncpy(table_name, name, (sizeof table_name) - 1);
MAX_TABLE_NAME_LEN + 20); table_name[(sizeof table_name) - 1] = '\0';
innobase_convert_to_system_charset( innobase_convert_to_system_charset(
strchr(table_name, '/') + 1, strchr(table_name, '/') + 1,
@ -81,7 +82,8 @@ dict_create_add_foreign_id(
if (errors) { if (errors) {
strncpy(table_name, name, strncpy(table_name, name,
MAX_TABLE_NAME_LEN + 20); (sizeof table_name) - 1);
table_name[(sizeof table_name) - 1] = '\0';
} }
/* no overflow if number < 1e13 */ /* no overflow if number < 1e13 */

View File

@ -96,8 +96,8 @@ row_merge_create_fts_sort_index(
field = dict_index_get_nth_field(new_index, 0); field = dict_index_get_nth_field(new_index, 0);
field->name = NULL; field->name = NULL;
field->prefix_len = 0; field->prefix_len = 0;
field->col = static_cast<dict_col_t*>( field->col = new(mem_heap_zalloc(new_index->heap, sizeof(dict_col_t)))
mem_heap_alloc(new_index->heap, sizeof(dict_col_t))); dict_col_t();
field->col->prtype = idx_field->col->prtype | DATA_NOT_NULL; field->col->prtype = idx_field->col->prtype | DATA_NOT_NULL;
field->col->mtype = charset == &my_charset_latin1 field->col->mtype = charset == &my_charset_latin1
? DATA_VARCHAR : DATA_VARMYSQL; ? DATA_VARCHAR : DATA_VARMYSQL;
@ -111,8 +111,8 @@ row_merge_create_fts_sort_index(
field = dict_index_get_nth_field(new_index, 1); field = dict_index_get_nth_field(new_index, 1);
field->name = NULL; field->name = NULL;
field->prefix_len = 0; field->prefix_len = 0;
field->col = static_cast<dict_col_t*>( field->col = new(mem_heap_zalloc(new_index->heap, sizeof(dict_col_t)))
mem_heap_alloc(new_index->heap, sizeof(dict_col_t))); dict_col_t();
field->col->mtype = DATA_INT; field->col->mtype = DATA_INT;
*opt_doc_id_size = FALSE; *opt_doc_id_size = FALSE;
@ -146,21 +146,16 @@ row_merge_create_fts_sort_index(
field->col->prtype = DATA_NOT_NULL | DATA_BINARY_TYPE; field->col->prtype = DATA_NOT_NULL | DATA_BINARY_TYPE;
field->col->mbminlen = 0;
field->col->mbmaxlen = 0;
/* The third field is on the word's position in the original doc */ /* The third field is on the word's position in the original doc */
field = dict_index_get_nth_field(new_index, 2); field = dict_index_get_nth_field(new_index, 2);
field->name = NULL; field->name = NULL;
field->prefix_len = 0; field->prefix_len = 0;
field->col = static_cast<dict_col_t*>( field->col = new(mem_heap_zalloc(new_index->heap, sizeof(dict_col_t)))
mem_heap_alloc(new_index->heap, sizeof(dict_col_t))); dict_col_t();
field->col->mtype = DATA_INT; field->col->mtype = DATA_INT;
field->col->len = 4 ; field->col->len = 4 ;
field->fixed_len = 4; field->fixed_len = 4;
field->col->prtype = DATA_NOT_NULL; field->col->prtype = DATA_NOT_NULL;
field->col->mbminlen = 0;
field->col->mbmaxlen = 0;
return(new_index); return(new_index);
} }

View File

@ -4358,11 +4358,12 @@ row_rename_table_for_mysql(
if (!new_is_tmp) { if (!new_is_tmp) {
/* Rename all constraints. */ /* Rename all constraints. */
char new_table_name[MAX_TABLE_NAME_LEN] = ""; char new_table_name[MAX_TABLE_NAME_LEN + 1];
char old_table_utf8[MAX_TABLE_NAME_LEN] = ""; char old_table_utf8[MAX_TABLE_NAME_LEN + 1];
uint errors = 0; uint errors = 0;
strncpy(old_table_utf8, old_name, MAX_TABLE_NAME_LEN); strncpy(old_table_utf8, old_name, MAX_TABLE_NAME_LEN);
old_table_utf8[MAX_TABLE_NAME_LEN] = '\0';
innobase_convert_to_system_charset( innobase_convert_to_system_charset(
strchr(old_table_utf8, '/') + 1, strchr(old_table_utf8, '/') + 1,
strchr(old_name, '/') +1, strchr(old_name, '/') +1,
@ -4373,6 +4374,7 @@ row_rename_table_for_mysql(
my_charset_filename to UTF-8. This means that the my_charset_filename to UTF-8. This means that the
table name is already in UTF-8 (#mysql#50). */ table name is already in UTF-8 (#mysql#50). */
strncpy(old_table_utf8, old_name, MAX_TABLE_NAME_LEN); strncpy(old_table_utf8, old_name, MAX_TABLE_NAME_LEN);
old_table_utf8[MAX_TABLE_NAME_LEN] = '\0';
} }
info = pars_info_create(); info = pars_info_create();
@ -4383,6 +4385,7 @@ row_rename_table_for_mysql(
old_table_utf8); old_table_utf8);
strncpy(new_table_name, new_name, MAX_TABLE_NAME_LEN); strncpy(new_table_name, new_name, MAX_TABLE_NAME_LEN);
new_table_name[MAX_TABLE_NAME_LEN] = '\0';
innobase_convert_to_system_charset( innobase_convert_to_system_charset(
strchr(new_table_name, '/') + 1, strchr(new_table_name, '/') + 1,
strchr(new_name, '/') +1, strchr(new_name, '/') +1,
@ -4393,6 +4396,7 @@ row_rename_table_for_mysql(
my_charset_filename to UTF-8. This means that the my_charset_filename to UTF-8. This means that the
table name is already in UTF-8 (#mysql#50). */ table name is already in UTF-8 (#mysql#50). */
strncpy(new_table_name, new_name, MAX_TABLE_NAME_LEN); strncpy(new_table_name, new_name, MAX_TABLE_NAME_LEN);
new_table_name[MAX_TABLE_NAME_LEN] = '\0';
} }
pars_info_add_str_literal(info, "new_table_utf8", new_table_name); pars_info_add_str_literal(info, "new_table_utf8", new_table_name);