Commit 344e5990 authored by Marko Mäkelä's avatar Marko Mäkelä

Merge 10.4 into 10.5

parents 55b3a3f4 09b03ff3
......@@ -3480,3 +3480,24 @@ Warnings:
Note 1003 select `test`.`t1`.`pk` AS `pk`,`test`.`t1`.`a` AS `a`,3 AS `d`,`test`.`t2`.`b` AS `b`,`test`.`t3`.`c` AS `c` from `test`.`t1` join `test`.`t2` join `test`.`t3` where `test`.`t1`.`a` = 3 and `test`.`t1`.`pk` <= 2
drop view v1;
drop table t1,t2,t3;
#
# MDEV-25679: view / derived table defined as ordered select with LIMIT
#
create table t1 (a int);
insert into t1 values (3), (7), (1);
create view v1 as (select a from t1 limit 2) order by a desc;
(select a from t1 limit 2) order by a desc;
a
7
3
select * from v1;
a
7
3
select * from ((select a from t1 limit 2) order by a desc) dt;
a
3
7
drop view v1;
drop table t1;
# End of 10.2 tests
......@@ -2273,3 +2273,20 @@ eval explain extended $q;
drop view v1;
drop table t1,t2,t3;
--echo #
--echo # MDEV-25679: view / derived table defined as ordered select with LIMIT
--echo #
create table t1 (a int);
insert into t1 values (3), (7), (1);
create view v1 as (select a from t1 limit 2) order by a desc;
(select a from t1 limit 2) order by a desc;
select * from v1;
select * from ((select a from t1 limit 2) order by a desc) dt;
drop view v1;
drop table t1;
--echo # End of 10.2 tests
/*****************************************************************************
Copyright (C) 2013, 2015, Google Inc. All Rights Reserved.
Copyright (C) 2014, 2020, MariaDB Corporation.
Copyright (C) 2014, 2021, MariaDB Corporation.
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
......@@ -96,6 +96,7 @@ static bool init_crypt_key(crypt_info_t* info, bool upgrade = false)
<< info->key_version << " failed (" << rc
<< "). Maybe the key or the required encryption "
"key management plugin was not found.";
info->key_version = ENCRYPTION_KEY_VERSION_INVALID;
return false;
}
......@@ -115,6 +116,7 @@ static bool init_crypt_key(crypt_info_t* info, bool upgrade = false)
if (err != MY_AES_OK || dst_len != MY_AES_BLOCK_SIZE) {
ib::error() << "Getting redo log crypto key failed: err = "
<< err << ", len = " << dst_len;
info->key_version = ENCRYPTION_KEY_VERSION_INVALID;
return false;
}
......@@ -291,6 +293,7 @@ ATTRIBUTE_COLD bool log_crypt_101_read_block(byte* buf, lsn_t start_lsn)
for (const crypt_info_t* const end = info + infos_used; info < end;
info++) {
if (info->key_version
&& info->key_version != ENCRYPTION_KEY_VERSION_INVALID
&& info->checkpoint_no == checkpoint_no) {
goto found;
}
......@@ -302,6 +305,9 @@ ATTRIBUTE_COLD bool log_crypt_101_read_block(byte* buf, lsn_t start_lsn)
/* MariaDB Server 10.1 would use the first key if it fails to
find a key for the current checkpoint. */
info = infos;
if (info->key_version == ENCRYPTION_KEY_VERSION_INVALID) {
return false;
}
found:
byte dst[OS_FILE_LOG_BLOCK_SIZE];
uint dst_len;
......
......@@ -580,6 +580,7 @@ dberr_t trx_rseg_array_init()
bool wsrep_xid_in_rseg_found = false;
#endif
mtr_t mtr;
dberr_t err = DB_SUCCESS;
for (ulint rseg_id = 0; rseg_id < TRX_SYS_N_RSEGS; rseg_id++) {
mtr.start();
......@@ -609,10 +610,11 @@ dberr_t trx_rseg_array_init()
ut_ad(rseg->id == rseg_id);
ut_ad(!trx_sys.rseg_array[rseg_id]);
trx_sys.rseg_array[rseg_id] = rseg;
if (dberr_t err = trx_rseg_mem_restore(
rseg, max_trx_id, &mtr)) {
if ((err = trx_rseg_mem_restore(
rseg, max_trx_id, &mtr))
!= DB_SUCCESS) {
mtr.commit();
return err;
break;
}
#ifdef WITH_WSREP
if (!wsrep_sys_xid.is_null() &&
......@@ -633,6 +635,21 @@ dberr_t trx_rseg_array_init()
mtr.commit();
}
if (err != DB_SUCCESS) {
for (ulint rseg_id = 0; rseg_id < TRX_SYS_N_RSEGS; rseg_id++) {
if (trx_rseg_t*& rseg = trx_sys.rseg_array[rseg_id]) {
while (trx_undo_t* u= UT_LIST_GET_FIRST(
rseg->undo_list)) {
UT_LIST_REMOVE(rseg->undo_list, u);
ut_free(u);
}
trx_rseg_mem_free(rseg);
rseg = NULL;
}
}
return err;
}
#ifdef WITH_WSREP
if (!wsrep_sys_xid.is_null()) {
/* Upgrade from a version prior to 10.3.5,
......
......@@ -852,18 +852,11 @@ trx_undo_mem_create_at_db_start(trx_rseg_t *rseg, ulint id, uint32_t page_no,
const uint16_t type = mach_read_from_2(TRX_UNDO_PAGE_HDR
+ TRX_UNDO_PAGE_TYPE
+ block->frame);
switch (type) {
case 0:
case 2: /* TRX_UNDO_UPDATE */
break;
case 1: /* TRX_UNDO_INSERT */
sql_print_error("InnoDB: upgrade from older version than"
" MariaDB 10.3 requires clean shutdown");
goto corrupted;
default:
if (UNIV_UNLIKELY(type > 2)) {
corrupted_type:
sql_print_error("InnoDB: unsupported undo header type %u",
type);
corrupted:
corrupted:
mtr.commit();
return nullptr;
}
......@@ -883,12 +876,21 @@ trx_undo_mem_create_at_db_start(trx_rseg_t *rseg, ulint id, uint32_t page_no,
switch (state) {
case TRX_UNDO_ACTIVE:
case TRX_UNDO_PREPARED:
break;
if (UNIV_LIKELY(type != 1)) {
break;
}
sql_print_error("InnoDB: upgrade from older version than"
" MariaDB 10.3 requires clean shutdown");
goto corrupted;
default:
sql_print_error("InnoDB: unsupported undo header state %u",
state);
goto corrupted;
case TRX_UNDO_TO_PURGE:
if (UNIV_UNLIKELY(type == 1)) {
goto corrupted_type;
}
/* fall through */
case TRX_UNDO_CACHED:
trx_id_t id = mach_read_from_8(TRX_UNDO_TRX_NO + undo_header);
if (id >> 48) {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment