summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorNikita Malyavin <nikitamalyavin@gmail.com>2022-11-29 20:40:07 +0100
committerSergei Golubchik <serg@mariadb.org>2022-11-29 20:44:05 +0100
commit5fe6ba34a6e09c887164b436d7226263bc8c41a0 (patch)
tree1594b7ef48b74e8b215679e56325e18320d3b006
parent219aedc134226ecb6024fc8c8b757551d88573b2 (diff)
downloadmariadb-git-bb-10.11-oalter.tar.gz
MDEV-29069 follow-up: improve DEFAULT rulesbb-10.11-oalter
previously, fields with DEFAULTs were allowed just when expression is deterministic. In case of online alter, we should recursively check that underlying fields of expression also either have explicit values, or have DEFAULT following this validity rule.
-rw-r--r--mysql-test/main/alter_table_online_debug.result42
-rw-r--r--mysql-test/main/alter_table_online_debug.test36
-rw-r--r--sql/field.h2
-rw-r--r--sql/log_event_server.cc59
4 files changed, 127 insertions, 12 deletions
diff --git a/mysql-test/main/alter_table_online_debug.result b/mysql-test/main/alter_table_online_debug.result
index 24c17a6feb1..fa0bec0c872 100644
--- a/mysql-test/main/alter_table_online_debug.result
+++ b/mysql-test/main/alter_table_online_debug.result
@@ -1101,6 +1101,48 @@ connection default;
Warnings:
Note 1105 Key chosen: 0
Note 1105 Key chosen: 0
+#
+# Useful UNIQUE, though a virtual column on another extra field
+#
+create or replace table t (a int primary key, b int default (a+1));
+insert into t values (10, 10),(20, 20),(30, 30);
+set debug_sync= 'alter_table_online_downgraded signal downgraded wait_for goforit';
+alter table t drop primary key, add c int default(a),
+add d int as (c) stored unique, algorithm=copy, lock=none;
+connection con2;
+set debug_sync= 'now wait_for downgraded';
+delete from t where a = 20;
+update t set a = a + 2 where a = 10;
+set debug_sync= 'now signal goforit';
+connection default;
+Warnings:
+Note 1105 Key chosen: 0
+Note 1105 Key chosen: 0
+select * from t;
+a b c d
+12 10 12 12
+30 30 30 30
+#
+# Now this index is not usable (missing DEFAULT on field c)
+#
+create or replace table t (a int primary key, b int);
+insert into t values (10, 10),(20, 20),(30, 30);
+set debug_sync= 'alter_table_online_downgraded signal downgraded wait_for goforit';
+alter table t drop primary key, add c real default(rand(a)),
+add d real as (c) stored unique, algorithm=copy, lock=none;
+connection con2;
+set debug_sync= 'now wait_for downgraded';
+delete from t where a = 20;
+update t set a = a + 2 where a = 10;
+set debug_sync= 'now signal goforit';
+connection default;
+Warnings:
+Note 1105 Key chosen: -1
+Note 1105 Key chosen: -1
+select a, b from t;
+a b
+12 10
+30 30
drop table t;
set debug_sync= reset;
set debug_dbug= @old_debug;
diff --git a/mysql-test/main/alter_table_online_debug.test b/mysql-test/main/alter_table_online_debug.test
index 663a5293903..2062f1349b0 100644
--- a/mysql-test/main/alter_table_online_debug.test
+++ b/mysql-test/main/alter_table_online_debug.test
@@ -1270,6 +1270,42 @@ set debug_sync= 'now signal goforit';
--reap
+--echo #
+--echo # Useful UNIQUE, though a virtual column on another extra field
+--echo #
+create or replace table t (a int primary key, b int default (a+1));
+insert into t values (10, 10),(20, 20),(30, 30);
+set debug_sync= 'alter_table_online_downgraded signal downgraded wait_for goforit';
+--send
+alter table t drop primary key, add c int default(a),
+ add d int as (c) stored unique, algorithm=copy, lock=none;
+--connection con2
+set debug_sync= 'now wait_for downgraded';
+delete from t where a = 20;
+update t set a = a + 2 where a = 10;
+set debug_sync= 'now signal goforit';
+--connection default
+--reap
+select * from t;
+
+--echo #
+--echo # Now this index is not usable (missing DEFAULT on field c)
+--echo #
+create or replace table t (a int primary key, b int);
+insert into t values (10, 10),(20, 20),(30, 30);
+set debug_sync= 'alter_table_online_downgraded signal downgraded wait_for goforit';
+--send
+alter table t drop primary key, add c real default(rand(a)),
+ add d real as (c) stored unique, algorithm=copy, lock=none;
+--connection con2
+set debug_sync= 'now wait_for downgraded';
+delete from t where a = 20;
+update t set a = a + 2 where a = 10;
+set debug_sync= 'now signal goforit';
+--connection default
+--reap
+select a, b from t;
+
# Cleanup
drop table t;
set debug_sync= reset;
diff --git a/sql/field.h b/sql/field.h
index 007f2ea6710..c8068124318 100644
--- a/sql/field.h
+++ b/sql/field.h
@@ -1192,7 +1192,7 @@ public:
{
bitmap_set_bit(&table->has_value_set, field_index);
}
- bool has_explicit_value()
+ bool has_explicit_value() const
{
return bitmap_is_set(&table->has_value_set, field_index);
}
diff --git a/sql/log_event_server.cc b/sql/log_event_server.cc
index 9bc06dab7c5..0aa89e1d605 100644
--- a/sql/log_event_server.cc
+++ b/sql/log_event_server.cc
@@ -8024,6 +8024,51 @@ record_compare_exit:
record_compare_differ:
return true;
}
+/**
+ Traverses default item expr of a field, and underlying field's default values.
+ If it is an extra field and has no value replicated, then its default expr
+ should be also checked.
+ */
+class Rpl_key_part_checker: public Field_enumerator
+{
+ bool online_alter;
+ Field *next_number_field;
+ bool field_usable;
+public:
+
+
+ void visit_field(Item_field *item) override
+ {
+ if (!field_usable)
+ return;
+ field_usable= check_field(item->field);
+ }
+
+ bool check_field(Field *f)
+ {
+ if (f->has_explicit_value())
+ return true;
+
+ if ((!f->vcol_info && !online_alter) || f == next_number_field)
+ return false;
+
+ Virtual_column_info *computed= f->vcol_info ? f->vcol_info
+ : f->default_value;
+
+ if (computed == NULL)
+ return true; // No DEFAULT, or constant DEFAULT
+
+ // Deterministic DEFAULT or vcol expression
+ return !(computed->flags & VCOL_NOT_STRICTLY_DETERMINISTIC)
+ && !computed->expr->walk(&Item::enumerate_field_refs_processor,
+ false, this)
+ && field_usable;
+ }
+
+ Rpl_key_part_checker(bool online_alter, Field *next_number_field):
+ online_alter(online_alter), next_number_field(next_number_field),
+ field_usable(true) {}
+};
/**
@@ -8054,19 +8099,11 @@ uint Rows_log_event::find_key_parts(const KEY *key) const
}
}
+ Rpl_key_part_checker key_part_checker(online_alter,
+ m_table->found_next_number_field);
for (p= 0; p < key->user_defined_key_parts; p++)
{
- Field *f= key->key_part[p].field;
- /*
- in the online alter case (but not in replication) we don't have
- to reject an index if it includes new columns, as long as
- their values are deterministic.
- */
- bool non_deterministic_default= f->default_value &&
- f->default_value->flags & VCOL_NOT_STRICTLY_DETERMINISTIC;
- bool next_number_field= f == f->table->next_number_field;
- if (!bitmap_is_set(&m_table->has_value_set, f->field_index) &&
- (!online_alter || non_deterministic_default || next_number_field))
+ if (!key_part_checker.check_field(key->key_part[p].field))
break;
}
return p;