// Copyright 2016 PingCAP, Inc. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package executor_test import ( "bytes" "context" "errors" "fmt" "io" "io/ioutil" "net/http" "strconv" "testing" "github.com/pingcap/failpoint" "github.com/pingcap/tidb/config" "github.com/pingcap/tidb/errno" "github.com/pingcap/tidb/executor" "github.com/pingcap/tidb/expression" "github.com/pingcap/tidb/infoschema" "github.com/pingcap/tidb/parser/mysql" "github.com/pingcap/tidb/parser/terror" "github.com/pingcap/tidb/sessionctx" "github.com/pingcap/tidb/sessionctx/variable" "github.com/pingcap/tidb/testkit" "github.com/pingcap/tidb/types" "github.com/pingcap/tidb/util/mock" topsqlstate "github.com/pingcap/tidb/util/topsql/state" "github.com/stretchr/testify/require" ) func TestSetVar(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("SET @a = 1;") tk.MustExec(`SET @a = "1";`) tk.MustExec("SET @a = null;") tk.MustExec("SET @@global.autocommit = 1;") // TODO: this test case should returns error. // err := tk.ExecToErr("SET @@global.autocommit = null;") // c.Assert(err, NotNil) tk.MustExec("SET @@autocommit = 1;") require.Error(t, tk.ExecToErr("SET @@autocommit = null;")) require.Error(t, tk.ExecToErr("SET @@date_format = 1;")) require.Error(t, tk.ExecToErr("SET @@rewriter_enabled = 1;")) require.Error(t, tk.ExecToErr("SET xxx = abcd;")) require.Error(t, tk.ExecToErr("SET @@global.a = 1;")) require.Error(t, tk.ExecToErr("SET @@global.timestamp = 1;")) // For issue 998 tk.MustExec("SET @issue998a=1, @issue998b=5;") tk.MustQuery(`select @issue998a, @issue998b;`).Check(testkit.Rows("1 5")) tk.MustExec("SET @@autocommit=0, @issue998a=2;") tk.MustQuery(`select @issue998a, @@autocommit;`).Check(testkit.Rows("2 0")) tk.MustExec("SET @@global.autocommit=1, @issue998b=6;") tk.MustQuery(`select @issue998b, @@global.autocommit;`).Check(testkit.Rows("6 1")) // For issue 4302 tk.MustExec("use test;drop table if exists x;create table x(a int);insert into x value(1);") tk.MustExec("SET @issue4302=(select a from x limit 1);") tk.MustQuery(`select @issue4302;`).Check(testkit.Rows("1")) // Set default // {ScopeGlobal | ScopeSession, "low_priority_updates", "OFF"}, // For global var tk.MustQuery(`select @@global.low_priority_updates;`).Check(testkit.Rows("0")) tk.MustExec(`set @@global.low_priority_updates="ON";`) tk.MustQuery(`select @@global.low_priority_updates;`).Check(testkit.Rows("1")) tk.MustExec(`set @@global.low_priority_updates=DEFAULT;`) // It will be set to default var value. tk.MustQuery(`select @@global.low_priority_updates;`).Check(testkit.Rows("0")) // For session tk.MustQuery(`select @@session.low_priority_updates;`).Check(testkit.Rows("0")) tk.MustExec(`set @@global.low_priority_updates="ON";`) tk.MustExec(`set @@session.low_priority_updates=DEFAULT;`) // It will be set to global var value. tk.MustQuery(`select @@session.low_priority_updates;`).Check(testkit.Rows("1")) // For mysql jdbc driver issue. tk.MustQuery(`select @@session.tx_read_only;`).Check(testkit.Rows("0")) // Test session variable states. vars := tk.Session().(sessionctx.Context).GetSessionVars() require.NoError(t, tk.Session().CommitTxn(context.TODO())) tk.MustExec("set @@autocommit = 1") require.False(t, vars.InTxn()) require.True(t, vars.IsAutocommit()) tk.MustExec("set @@autocommit = 0") require.False(t, vars.IsAutocommit()) tk.MustExec("set @@sql_mode = 'strict_trans_tables'") require.True(t, vars.StrictSQLMode) tk.MustExec("set @@sql_mode = ''") require.False(t, vars.StrictSQLMode) tk.MustExec("set names utf8") charset, collation := vars.GetCharsetInfo() require.Equal(t, "utf8", charset) require.Equal(t, "utf8_bin", collation) tk.MustExec("set names latin1 collate latin1_bin") charset, collation = vars.GetCharsetInfo() require.Equal(t, "latin1", charset) require.Equal(t, "latin1_bin", collation) tk.MustExec("set names utf8 collate default") charset, collation = vars.GetCharsetInfo() require.Equal(t, "utf8", charset) require.Equal(t, "utf8_bin", collation) expectErrMsg := "[ddl:1273]Unknown collation: 'non_exist_collation'" tk.MustGetErrMsg("set names utf8 collate non_exist_collation", expectErrMsg) tk.MustGetErrMsg("set @@session.collation_server='non_exist_collation'", expectErrMsg) tk.MustGetErrMsg("set @@session.collation_database='non_exist_collation'", expectErrMsg) tk.MustGetErrMsg("set @@session.collation_connection='non_exist_collation'", expectErrMsg) tk.MustGetErrMsg("set @@global.collation_server='non_exist_collation'", expectErrMsg) tk.MustGetErrMsg("set @@global.collation_database='non_exist_collation'", expectErrMsg) tk.MustGetErrMsg("set @@global.collation_connection='non_exist_collation'", expectErrMsg) expectErrMsg = "[parser:1115]Unknown character set: 'boguscharsetname'" tk.MustGetErrMsg("set names boguscharsetname", expectErrMsg) tk.MustExec("set character_set_results = NULL") tk.MustQuery("select @@character_set_results").Check(testkit.Rows("")) tk.MustExec("set @@global.ddl_slow_threshold=12345") tk.MustQuery("select @@global.ddl_slow_threshold").Check(testkit.Rows("12345")) require.Equal(t, uint32(12345), variable.DDLSlowOprThreshold) tk.MustExec("set session ddl_slow_threshold=\"54321\"") tk.MustQuery("show variables like 'ddl_slow_threshold'").Check(testkit.Rows("ddl_slow_threshold 54321")) require.Equal(t, uint32(54321), variable.DDLSlowOprThreshold) tk.MustExec("set @@global.ddl_slow_threshold=-1") tk.MustQuery("select @@global.ddl_slow_threshold").Check(testkit.Rows(strconv.Itoa(variable.DefTiDBDDLSlowOprThreshold))) require.Equal(t, uint32(variable.DefTiDBDDLSlowOprThreshold), variable.DDLSlowOprThreshold) require.Error(t, tk.ExecToErr("set @@global.ddl_slow_threshold=abc")) tk.MustQuery("select @@global.ddl_slow_threshold").Check(testkit.Rows(strconv.Itoa(variable.DefTiDBDDLSlowOprThreshold))) require.Equal(t, uint32(variable.DefTiDBDDLSlowOprThreshold), variable.DDLSlowOprThreshold) // Test set transaction isolation level, which is equivalent to setting variable "tx_isolation". tk.MustExec("SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED") tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) // error err := tk.ExecToErr("SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) // Fails err = tk.ExecToErr("SET GLOBAL TRANSACTION ISOLATION LEVEL SERIALIZABLE") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@global.tx_isolation").Check(testkit.Rows("REPEATABLE-READ")) tk.MustQuery("select @@global.transaction_isolation").Check(testkit.Rows("REPEATABLE-READ")) // test synonyms variables tk.MustExec("SET SESSION tx_isolation = 'READ-COMMITTED'") tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) err = tk.ExecToErr("SET SESSION tx_isolation = 'READ-UNCOMMITTED'") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) // fails err = tk.ExecToErr("SET SESSION transaction_isolation = 'SERIALIZABLE'") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) // fails err = tk.ExecToErr("SET GLOBAL transaction_isolation = 'SERIALIZABLE'") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@global.tx_isolation").Check(testkit.Rows("REPEATABLE-READ")) tk.MustQuery("select @@global.transaction_isolation").Check(testkit.Rows("REPEATABLE-READ")) err = tk.ExecToErr("SET GLOBAL transaction_isolation = 'READ-UNCOMMITTED'") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@global.tx_isolation").Check(testkit.Rows("REPEATABLE-READ")) tk.MustQuery("select @@global.transaction_isolation").Check(testkit.Rows("REPEATABLE-READ")) err = tk.ExecToErr("SET GLOBAL tx_isolation = 'SERIALIZABLE'") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@global.tx_isolation").Check(testkit.Rows("REPEATABLE-READ")) tk.MustQuery("select @@global.transaction_isolation").Check(testkit.Rows("REPEATABLE-READ")) // Even the transaction fail, set session variable would success. tk.MustExec("BEGIN") tk.MustExec("SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED") require.Error(t, tk.ExecToErr(`INSERT INTO t VALUES ("sdfsdf")`)) tk.MustExec("COMMIT") tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustExec("set global avoid_temporal_upgrade = on") tk.MustQuery(`select @@global.avoid_temporal_upgrade;`).Check(testkit.Rows("1")) tk.MustExec("set @@global.avoid_temporal_upgrade = off") tk.MustQuery(`select @@global.avoid_temporal_upgrade;`).Check(testkit.Rows("0")) tk.MustExec("set session sql_log_bin = on") tk.MustQuery(`select @@session.sql_log_bin;`).Check(testkit.Rows("1")) tk.MustExec("set sql_log_bin = off") tk.MustQuery(`select @@session.sql_log_bin;`).Check(testkit.Rows("0")) tk.MustExec("set @@sql_log_bin = on") tk.MustQuery(`select @@session.sql_log_bin;`).Check(testkit.Rows("1")) binlogValue := "0" if config.GetGlobalConfig().Binlog.Enable { binlogValue = "1" } tk.MustQuery(`select @@global.log_bin;`).Check(testkit.Rows(binlogValue)) tk.MustQuery(`select @@log_bin;`).Check(testkit.Rows(binlogValue)) tk.MustExec("set @@tidb_general_log = 1") tk.MustExec("set @@tidb_general_log = 0") tk.MustExec("set @@tidb_pprof_sql_cpu = 1") tk.MustExec("set @@tidb_pprof_sql_cpu = 0") tk.MustExec(`set @@block_encryption_mode = "aes-128-ecb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-128-ecb")) tk.MustExec(`set @@block_encryption_mode = "aes-192-ecb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-192-ecb")) tk.MustExec(`set @@block_encryption_mode = "aes-256-ecb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-256-ecb")) tk.MustExec(`set @@block_encryption_mode = "aes-128-cbc"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-128-cbc")) tk.MustExec(`set @@block_encryption_mode = "aes-192-cbc"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-192-cbc")) tk.MustExec(`set @@block_encryption_mode = "aes-256-cbc"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-256-cbc")) tk.MustExec(`set @@block_encryption_mode = "aes-128-ofb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-128-ofb")) tk.MustExec(`set @@block_encryption_mode = "aes-192-ofb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-192-ofb")) tk.MustExec(`set @@block_encryption_mode = "aes-256-ofb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-256-ofb")) tk.MustExec(`set @@block_encryption_mode = "aes-128-cfb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-128-cfb")) tk.MustExec(`set @@block_encryption_mode = "aes-192-cfb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-192-cfb")) tk.MustExec(`set @@block_encryption_mode = "aes-256-cfb"`) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-256-cfb")) require.Error(t, tk.ExecToErr("set @@block_encryption_mode = 'abc'")) tk.MustQuery(`select @@block_encryption_mode;`).Check(testkit.Rows("aes-256-cfb")) tk.MustExec(`set @@global.tidb_force_priority = "no_priority"`) tk.MustQuery(`select @@global.tidb_force_priority;`).Check(testkit.Rows("NO_PRIORITY")) tk.MustExec(`set @@global.tidb_force_priority = "low_priority"`) tk.MustQuery(`select @@global.tidb_force_priority;`).Check(testkit.Rows("LOW_PRIORITY")) tk.MustExec(`set @@global.tidb_force_priority = "high_priority"`) tk.MustQuery(`select @@global.tidb_force_priority;`).Check(testkit.Rows("HIGH_PRIORITY")) tk.MustExec(`set @@global.tidb_force_priority = "delayed"`) tk.MustQuery(`select @@global.tidb_force_priority;`).Check(testkit.Rows("DELAYED")) require.Error(t, tk.ExecToErr("set global tidb_force_priority = 'abc'")) tk.MustQuery(`select @@global.tidb_force_priority;`).Check(testkit.Rows("DELAYED")) tk.MustExec(`set @@session.tidb_ddl_reorg_priority = "priority_low"`) tk.MustQuery(`select @@session.tidb_ddl_reorg_priority;`).Check(testkit.Rows("PRIORITY_LOW")) tk.MustExec(`set @@session.tidb_ddl_reorg_priority = "priority_normal"`) tk.MustQuery(`select @@session.tidb_ddl_reorg_priority;`).Check(testkit.Rows("PRIORITY_NORMAL")) tk.MustExec(`set @@session.tidb_ddl_reorg_priority = "priority_high"`) tk.MustQuery(`select @@session.tidb_ddl_reorg_priority;`).Check(testkit.Rows("PRIORITY_HIGH")) require.Error(t, tk.ExecToErr("set session tidb_ddl_reorg_priority = 'abc'")) tk.MustQuery(`select @@session.tidb_ddl_reorg_priority;`).Check(testkit.Rows("PRIORITY_HIGH")) tk.MustExec("set tidb_opt_write_row_id = 1") tk.MustQuery(`select @@session.tidb_opt_write_row_id;`).Check(testkit.Rows("1")) tk.MustExec("set tidb_opt_write_row_id = 0") tk.MustQuery(`select @@session.tidb_opt_write_row_id;`).Check(testkit.Rows("0")) tk.MustExec("set tidb_opt_write_row_id = true") tk.MustQuery(`select @@session.tidb_opt_write_row_id;`).Check(testkit.Rows("1")) tk.MustExec("set tidb_opt_write_row_id = false") tk.MustQuery(`select @@session.tidb_opt_write_row_id;`).Check(testkit.Rows("0")) tk.MustExec("set tidb_opt_write_row_id = On") tk.MustQuery(`select @@session.tidb_opt_write_row_id;`).Check(testkit.Rows("1")) tk.MustExec("set tidb_opt_write_row_id = Off") tk.MustQuery(`select @@session.tidb_opt_write_row_id;`).Check(testkit.Rows("0")) require.Error(t, tk.ExecToErr("set tidb_opt_write_row_id = 'abc'")) tk.MustQuery(`select @@session.tidb_opt_write_row_id;`).Check(testkit.Rows("0")) tk.MustExec("set tidb_checksum_table_concurrency = 42") tk.MustQuery(`select @@tidb_checksum_table_concurrency;`).Check(testkit.Rows("42")) require.Error(t, tk.ExecToErr("set tidb_checksum_table_concurrency = 'abc'")) tk.MustQuery(`select @@tidb_checksum_table_concurrency;`).Check(testkit.Rows("42")) tk.MustExec("set tidb_checksum_table_concurrency = 257") tk.MustQuery(`select @@tidb_checksum_table_concurrency;`).Check(testkit.Rows(strconv.Itoa(variable.MaxConfigurableConcurrency))) tk.MustExec("set tidb_build_stats_concurrency = 42") tk.MustQuery(`select @@tidb_build_stats_concurrency;`).Check(testkit.Rows("42")) require.Error(t, tk.ExecToErr("set tidb_build_stats_concurrency = 'abc'")) tk.MustQuery(`select @@tidb_build_stats_concurrency;`).Check(testkit.Rows("42")) tk.MustExec("set tidb_build_stats_concurrency = 257") tk.MustQuery(`select @@tidb_build_stats_concurrency;`).Check(testkit.Rows(strconv.Itoa(variable.MaxConfigurableConcurrency))) tk.MustExec(`set tidb_partition_prune_mode = "static"`) tk.MustQuery(`select @@tidb_partition_prune_mode;`).Check(testkit.Rows("static")) tk.MustExec(`set tidb_partition_prune_mode = "dynamic"`) tk.MustQuery(`select @@tidb_partition_prune_mode;`).Check(testkit.Rows("dynamic")) tk.MustExec(`set tidb_partition_prune_mode = "static-only"`) tk.MustQuery(`select @@tidb_partition_prune_mode;`).Check(testkit.Rows("static")) tk.MustExec(`set tidb_partition_prune_mode = "dynamic-only"`) tk.MustQuery(`select @@tidb_partition_prune_mode;`).Check(testkit.Rows("dynamic")) require.Error(t, tk.ExecToErr("set tidb_partition_prune_mode = 'abc'")) tk.MustQuery(`select @@tidb_partition_prune_mode;`).Check(testkit.Rows("dynamic")) tk.MustExec("set tidb_constraint_check_in_place = 1") tk.MustQuery(`select @@session.tidb_constraint_check_in_place;`).Check(testkit.Rows("1")) tk.MustExec("set global tidb_constraint_check_in_place = 0") tk.MustQuery(`select @@global.tidb_constraint_check_in_place;`).Check(testkit.Rows("0")) tk.MustExec("set tidb_batch_commit = 0") tk.MustQuery("select @@session.tidb_batch_commit;").Check(testkit.Rows("0")) tk.MustExec("set tidb_batch_commit = 1") tk.MustQuery("select @@session.tidb_batch_commit;").Check(testkit.Rows("1")) require.Error(t, tk.ExecToErr("set global tidb_batch_commit = 0")) require.Error(t, tk.ExecToErr("set global tidb_batch_commit = 2")) // test skip isolation level check: init tk.MustExec("SET GLOBAL tidb_skip_isolation_level_check = 0") tk.MustExec("SET SESSION tidb_skip_isolation_level_check = 0") tk.MustExec("SET GLOBAL TRANSACTION ISOLATION LEVEL READ COMMITTED") tk.MustExec("SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED") tk.MustQuery("select @@global.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@global.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) // test skip isolation level check: error err = tk.ExecToErr("SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) err = tk.ExecToErr("SET GLOBAL TRANSACTION ISOLATION LEVEL SERIALIZABLE") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustQuery("select @@global.tx_isolation").Check(testkit.Rows("READ-COMMITTED")) tk.MustQuery("select @@global.transaction_isolation").Check(testkit.Rows("READ-COMMITTED")) // test skip isolation level check: success tk.MustExec("SET GLOBAL tidb_skip_isolation_level_check = 1") tk.MustExec("SET SESSION tidb_skip_isolation_level_check = 1") tk.MustExec("SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 8048 The isolation level 'SERIALIZABLE' is not supported. Set tidb_skip_isolation_level_check=1 to skip this error")) tk.MustQuery("select @@session.tx_isolation").Check(testkit.Rows("SERIALIZABLE")) tk.MustQuery("select @@session.transaction_isolation").Check(testkit.Rows("SERIALIZABLE")) // test skip isolation level check: success tk.MustExec("SET GLOBAL tidb_skip_isolation_level_check = 0") tk.MustExec("SET SESSION tidb_skip_isolation_level_check = 1") tk.MustExec("SET GLOBAL TRANSACTION ISOLATION LEVEL READ UNCOMMITTED") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 8048 The isolation level 'READ-UNCOMMITTED' is not supported. Set tidb_skip_isolation_level_check=1 to skip this error")) tk.MustQuery("select @@global.tx_isolation").Check(testkit.Rows("READ-UNCOMMITTED")) tk.MustQuery("select @@global.transaction_isolation").Check(testkit.Rows("READ-UNCOMMITTED")) // test skip isolation level check: reset tk.MustExec("SET GLOBAL transaction_isolation='REPEATABLE-READ'") // should reset tx_isolation back to rr before reset tidb_skip_isolation_level_check tk.MustExec("SET GLOBAL tidb_skip_isolation_level_check = 0") tk.MustExec("SET SESSION tidb_skip_isolation_level_check = 0") // test for tidb_wait_split_region_finish tk.MustQuery(`select @@session.tidb_wait_split_region_finish;`).Check(testkit.Rows("1")) tk.MustExec("set tidb_wait_split_region_finish = 1") tk.MustQuery(`select @@session.tidb_wait_split_region_finish;`).Check(testkit.Rows("1")) tk.MustExec("set tidb_wait_split_region_finish = 0") tk.MustQuery(`select @@session.tidb_wait_split_region_finish;`).Check(testkit.Rows("0")) // test for tidb_scatter_region tk.MustQuery(`select @@global.tidb_scatter_region;`).Check(testkit.Rows("0")) tk.MustExec("set global tidb_scatter_region = 1") tk.MustQuery(`select @@global.tidb_scatter_region;`).Check(testkit.Rows("1")) tk.MustExec("set global tidb_scatter_region = 0") tk.MustQuery(`select @@global.tidb_scatter_region;`).Check(testkit.Rows("0")) require.Error(t, tk.ExecToErr("set session tidb_scatter_region = 0")) require.Error(t, tk.ExecToErr(`select @@session.tidb_scatter_region;`)) // test for tidb_wait_split_region_timeout tk.MustQuery(`select @@session.tidb_wait_split_region_timeout;`).Check(testkit.Rows(strconv.Itoa(variable.DefWaitSplitRegionTimeout))) tk.MustExec("set tidb_wait_split_region_timeout = 1") tk.MustQuery(`select @@session.tidb_wait_split_region_timeout;`).Check(testkit.Rows("1")) tk.MustExec("set tidb_wait_split_region_timeout = 0") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_wait_split_region_timeout value: '0'")) tk.MustQuery(`select @@tidb_wait_split_region_timeout`).Check(testkit.Rows("1")) tk.MustQuery(`select @@session.tidb_wait_split_region_timeout;`).Check(testkit.Rows("1")) tk.MustExec("set session tidb_backoff_weight = 3") tk.MustQuery("select @@session.tidb_backoff_weight;").Check(testkit.Rows("3")) tk.MustExec("set session tidb_backoff_weight = 20") tk.MustQuery("select @@session.tidb_backoff_weight;").Check(testkit.Rows("20")) tk.MustExec("set session tidb_backoff_weight = -1") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_backoff_weight value: '-1'")) tk.MustExec("set global tidb_backoff_weight = 0") tk.MustQuery("select @@global.tidb_backoff_weight;").Check(testkit.Rows("0")) tk.MustExec("set global tidb_backoff_weight = 10") tk.MustQuery("select @@global.tidb_backoff_weight;").Check(testkit.Rows("10")) tk.MustExec("set @@tidb_expensive_query_time_threshold=70") tk.MustQuery("select @@tidb_expensive_query_time_threshold;").Check(testkit.Rows("70")) tk.MustQuery("select @@global.tidb_store_limit;").Check(testkit.Rows("0")) tk.MustExec("set @@global.tidb_store_limit = 100") tk.MustQuery("select @@global.tidb_store_limit;").Check(testkit.Rows("100")) tk.MustExec("set @@global.tidb_store_limit = 0") tk.MustExec("set global tidb_store_limit = 10000") tk.MustQuery("select @@global.tidb_store_limit;").Check(testkit.Rows("10000")) tk.MustQuery("select @@global.tidb_txn_commit_batch_size;").Check(testkit.Rows("16384")) tk.MustExec("set @@global.tidb_txn_commit_batch_size = 100") tk.MustQuery("select @@global.tidb_txn_commit_batch_size;").Check(testkit.Rows("100")) tk.MustExec("set @@global.tidb_txn_commit_batch_size = 0") tk.MustQuery("select @@global.tidb_txn_commit_batch_size;").Check(testkit.Rows("1")) tk.MustExec("set global tidb_txn_commit_batch_size = 100") tk.MustQuery("select @@global.tidb_txn_commit_batch_size;").Check(testkit.Rows("100")) tk.MustQuery("select @@session.tidb_metric_query_step;").Check(testkit.Rows("60")) tk.MustExec("set @@session.tidb_metric_query_step = 120") tk.MustExec("set @@session.tidb_metric_query_step = 9") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_metric_query_step value: '9'")) tk.MustQuery("select @@session.tidb_metric_query_step;").Check(testkit.Rows("10")) tk.MustQuery("select @@session.tidb_metric_query_range_duration;").Check(testkit.Rows("60")) tk.MustExec("set @@session.tidb_metric_query_range_duration = 120") tk.MustExec("set @@session.tidb_metric_query_range_duration = 9") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_metric_query_range_duration value: '9'")) tk.MustQuery("select @@session.tidb_metric_query_range_duration;").Check(testkit.Rows("10")) tk.MustExec("set @@cte_max_recursion_depth=100") tk.MustQuery("select @@cte_max_recursion_depth").Check(testkit.Rows("100")) tk.MustExec("set @@global.cte_max_recursion_depth=100") tk.MustQuery("select @@global.cte_max_recursion_depth").Check(testkit.Rows("100")) tk.MustExec("set @@cte_max_recursion_depth=-1") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect cte_max_recursion_depth value: '-1'")) tk.MustQuery("select @@cte_max_recursion_depth").Check(testkit.Rows("0")) // test for tidb_redact_log tk.MustQuery(`select @@global.tidb_redact_log;`).Check(testkit.Rows("0")) tk.MustExec("set global tidb_redact_log = 1") tk.MustQuery(`select @@global.tidb_redact_log;`).Check(testkit.Rows("1")) tk.MustExec("set global tidb_redact_log = 0") tk.MustQuery(`select @@global.tidb_redact_log;`).Check(testkit.Rows("0")) tk.MustExec("set session tidb_redact_log = 0") tk.MustQuery(`select @@session.tidb_redact_log;`).Check(testkit.Rows("0")) tk.MustExec("set session tidb_redact_log = 1") tk.MustQuery(`select @@session.tidb_redact_log;`).Check(testkit.Rows("1")) tk.MustQuery("select @@tidb_dml_batch_size;").Check(testkit.Rows("0")) tk.MustExec("set @@session.tidb_dml_batch_size = 120") tk.MustQuery("select @@tidb_dml_batch_size;").Check(testkit.Rows("120")) tk.MustExec("set @@session.tidb_dml_batch_size = -120") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_dml_batch_size value: '?'")) // redacted because of tidb_redact_log = 1 above tk.MustQuery("select @@session.tidb_dml_batch_size").Check(testkit.Rows("0")) tk.MustExec("set session tidb_redact_log = 0") tk.MustExec("set session tidb_dml_batch_size = -120") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_dml_batch_size value: '-120'")) // without redaction tk.MustExec("set @@session.tidb_dml_batch_size = 120") tk.MustExec("set @@global.tidb_dml_batch_size = 200") // now permitted due to TiDB #19809 tk.MustQuery("select @@tidb_dml_batch_size;").Check(testkit.Rows("120")) // global only applies to new sessions err = tk.ExecToErr("set tidb_enable_parallel_apply=-1") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar)) // test for tidb_mem_quota_apply_cache defVal := fmt.Sprintf("%v", variable.DefTiDBMemQuotaApplyCache) tk.MustQuery(`select @@tidb_mem_quota_apply_cache`).Check(testkit.Rows(defVal)) tk.MustExec(`set global tidb_mem_quota_apply_cache = 1`) tk.MustQuery(`select @@global.tidb_mem_quota_apply_cache`).Check(testkit.Rows("1")) tk.MustExec(`set global tidb_mem_quota_apply_cache = 0`) tk.MustQuery(`select @@global.tidb_mem_quota_apply_cache`).Check(testkit.Rows("0")) tk.MustExec(`set tidb_mem_quota_apply_cache = 123`) tk.MustQuery(`select @@global.tidb_mem_quota_apply_cache`).Check(testkit.Rows("0")) tk.MustQuery(`select @@tidb_mem_quota_apply_cache`).Check(testkit.Rows("123")) // test for tidb_mem_quota_bind_cache defVal = fmt.Sprintf("%v", variable.DefTiDBMemQuotaBindingCache) tk.MustQuery(`select @@tidb_mem_quota_binding_cache`).Check(testkit.Rows(defVal)) tk.MustExec(`set global tidb_mem_quota_binding_cache = 1`) tk.MustQuery(`select @@global.tidb_mem_quota_binding_cache`).Check(testkit.Rows("1")) tk.MustExec(`set global tidb_mem_quota_binding_cache = 0`) tk.MustQuery(`select @@global.tidb_mem_quota_binding_cache`).Check(testkit.Rows("0")) tk.MustExec(`set global tidb_mem_quota_binding_cache = 123`) tk.MustQuery(`select @@global.tidb_mem_quota_binding_cache`).Check(testkit.Rows("123")) tk.MustQuery(`select @@global.tidb_mem_quota_binding_cache`).Check(testkit.Rows("123")) // test for tidb_enable_parallel_apply tk.MustQuery(`select @@tidb_enable_parallel_apply`).Check(testkit.Rows("0")) tk.MustExec(`set global tidb_enable_parallel_apply = 1`) tk.MustQuery(`select @@global.tidb_enable_parallel_apply`).Check(testkit.Rows("1")) tk.MustExec(`set global tidb_enable_parallel_apply = 0`) tk.MustQuery(`select @@global.tidb_enable_parallel_apply`).Check(testkit.Rows("0")) tk.MustExec(`set tidb_enable_parallel_apply=1`) tk.MustQuery(`select @@global.tidb_enable_parallel_apply`).Check(testkit.Rows("0")) tk.MustQuery(`select @@tidb_enable_parallel_apply`).Check(testkit.Rows("1")) tk.MustQuery(`select @@global.tidb_general_log;`).Check(testkit.Rows("0")) tk.MustQuery(`show variables like 'tidb_general_log';`).Check(testkit.Rows("tidb_general_log OFF")) tk.MustExec("set tidb_general_log = 1") tk.MustQuery(`select @@global.tidb_general_log;`).Check(testkit.Rows("1")) tk.MustQuery(`show variables like 'tidb_general_log';`).Check(testkit.Rows("tidb_general_log ON")) tk.MustExec("set tidb_general_log = 0") tk.MustQuery(`select @@global.tidb_general_log;`).Check(testkit.Rows("0")) tk.MustQuery(`show variables like 'tidb_general_log';`).Check(testkit.Rows("tidb_general_log OFF")) tk.MustExec("set tidb_general_log = on") tk.MustQuery(`select @@global.tidb_general_log;`).Check(testkit.Rows("1")) tk.MustQuery(`show variables like 'tidb_general_log';`).Check(testkit.Rows("tidb_general_log ON")) tk.MustExec("set tidb_general_log = off") tk.MustQuery(`select @@global.tidb_general_log;`).Check(testkit.Rows("0")) tk.MustQuery(`show variables like 'tidb_general_log';`).Check(testkit.Rows("tidb_general_log OFF")) require.Error(t, tk.ExecToErr("set tidb_general_log = abc")) require.Error(t, tk.ExecToErr("set tidb_general_log = 123")) tk.MustExec(`SET @@character_set_results = NULL;`) tk.MustQuery(`select @@character_set_results;`).Check(testkit.Rows("")) varList := []string{"character_set_server", "character_set_client", "character_set_filesystem", "character_set_database"} for _, v := range varList { tk.MustGetErrCode(fmt.Sprintf("SET @@global.%s = @global_start_value;", v), mysql.ErrWrongValueForVar) tk.MustGetErrCode(fmt.Sprintf("SET @@%s = @global_start_value;", v), mysql.ErrWrongValueForVar) tk.MustGetErrCode(fmt.Sprintf("SET @@%s = NULL;", v), mysql.ErrWrongValueForVar) tk.MustGetErrCode(fmt.Sprintf("SET @@%s = \"\";", v), mysql.ErrWrongValueForVar) tk.MustGetErrMsg(fmt.Sprintf("SET @@%s = \"somecharset\";", v), "Unknown charset somecharset") // we do not support set character_set_xxx or collation_xxx to a collation id. tk.MustGetErrMsg(fmt.Sprintf("SET @@global.%s = 46;", v), "Unknown charset 46") tk.MustGetErrMsg(fmt.Sprintf("SET @@%s = 46;", v), "Unknown charset 46") } tk.MustExec("SET SESSION tidb_enable_extended_stats = on") tk.MustQuery("select @@session.tidb_enable_extended_stats").Check(testkit.Rows("1")) tk.MustExec("SET SESSION tidb_enable_extended_stats = off") tk.MustQuery("select @@session.tidb_enable_extended_stats").Check(testkit.Rows("0")) tk.MustExec("SET GLOBAL tidb_enable_extended_stats = on") tk.MustQuery("select @@global.tidb_enable_extended_stats").Check(testkit.Rows("1")) tk.MustExec("SET GLOBAL tidb_enable_extended_stats = off") tk.MustQuery("select @@global.tidb_enable_extended_stats").Check(testkit.Rows("0")) tk.MustExec("SET SESSION tidb_allow_fallback_to_tikv = 'tiflash'") tk.MustQuery("select @@session.tidb_allow_fallback_to_tikv").Check(testkit.Rows("tiflash")) tk.MustExec("SET SESSION tidb_allow_fallback_to_tikv = ''") tk.MustQuery("select @@session.tidb_allow_fallback_to_tikv").Check(testkit.Rows("")) tk.MustExec("SET GLOBAL tidb_allow_fallback_to_tikv = 'tiflash'") tk.MustQuery("select @@global.tidb_allow_fallback_to_tikv").Check(testkit.Rows("tiflash")) tk.MustExec("SET GLOBAL tidb_allow_fallback_to_tikv = ''") tk.MustQuery("select @@global.tidb_allow_fallback_to_tikv").Check(testkit.Rows("")) tk.MustExec("set @@tidb_allow_fallback_to_tikv = 'tiflash, tiflash, tiflash'") tk.MustQuery("select @@tidb_allow_fallback_to_tikv").Check(testkit.Rows("tiflash")) tk.MustGetErrMsg("SET SESSION tidb_allow_fallback_to_tikv = 'tikv,tiflash'", "[variable:1231]Variable 'tidb_allow_fallback_to_tikv' can't be set to the value of 'tikv,tiflash'") tk.MustGetErrMsg("SET GLOBAL tidb_allow_fallback_to_tikv = 'tikv,tiflash'", "[variable:1231]Variable 'tidb_allow_fallback_to_tikv' can't be set to the value of 'tikv,tiflash'") tk.MustGetErrMsg("set @@tidb_allow_fallback_to_tikv = 'tidb, tiflash, tiflash'", "[variable:1231]Variable 'tidb_allow_fallback_to_tikv' can't be set to the value of 'tidb, tiflash, tiflash'") tk.MustGetErrMsg("set @@tidb_allow_fallback_to_tikv = 'unknown, tiflash, tiflash'", "[variable:1231]Variable 'tidb_allow_fallback_to_tikv' can't be set to the value of 'unknown, tiflash, tiflash'") // Test issue #22145 tk.MustExec(`set global sync_relay_log = "'"`) tk.MustExec(`set @@global.tidb_enable_clustered_index = 'int_only'`) tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1287 'INT_ONLY' is deprecated and will be removed in a future release. Please use 'ON' or 'OFF' instead")) tk.MustExec(`set @@global.tidb_enable_clustered_index = 'off'`) tk.MustQuery(`show warnings`).Check(testkit.Rows()) tk.MustExec("set @@tidb_enable_clustered_index = 'off'") tk.MustQuery(`show warnings`).Check(testkit.Rows()) tk.MustExec("set @@tidb_enable_clustered_index = 'on'") tk.MustQuery(`show warnings`).Check(testkit.Rows()) tk.MustExec("set @@tidb_enable_clustered_index = 'int_only'") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1287 'INT_ONLY' is deprecated and will be removed in a future release. Please use 'ON' or 'OFF' instead")) // test for tidb_enable_ordered_result_mode tk.MustQuery(`select @@tidb_enable_ordered_result_mode`).Check(testkit.Rows("0")) tk.MustExec(`set global tidb_enable_ordered_result_mode = 1`) tk.MustQuery(`select @@global.tidb_enable_ordered_result_mode`).Check(testkit.Rows("1")) tk.MustExec(`set global tidb_enable_ordered_result_mode = 0`) tk.MustQuery(`select @@global.tidb_enable_ordered_result_mode`).Check(testkit.Rows("0")) tk.MustExec(`set tidb_enable_ordered_result_mode=1`) tk.MustQuery(`select @@global.tidb_enable_ordered_result_mode`).Check(testkit.Rows("0")) tk.MustQuery(`select @@tidb_enable_ordered_result_mode`).Check(testkit.Rows("1")) // test for tidb_opt_enable_correlation_adjustment tk.MustQuery(`select @@tidb_opt_enable_correlation_adjustment`).Check(testkit.Rows("1")) tk.MustExec(`set global tidb_opt_enable_correlation_adjustment = 0`) tk.MustQuery(`select @@global.tidb_opt_enable_correlation_adjustment`).Check(testkit.Rows("0")) tk.MustExec(`set global tidb_opt_enable_correlation_adjustment = 1`) tk.MustQuery(`select @@global.tidb_opt_enable_correlation_adjustment`).Check(testkit.Rows("1")) tk.MustExec(`set tidb_opt_enable_correlation_adjustment=0`) tk.MustQuery(`select @@global.tidb_opt_enable_correlation_adjustment`).Check(testkit.Rows("1")) tk.MustQuery(`select @@tidb_opt_enable_correlation_adjustment`).Check(testkit.Rows("0")) // test for tidb_opt_limit_push_down_threshold tk.MustQuery(`select @@tidb_opt_limit_push_down_threshold`).Check(testkit.Rows("100")) tk.MustExec(`set global tidb_opt_limit_push_down_threshold = 20`) tk.MustQuery(`select @@global.tidb_opt_limit_push_down_threshold`).Check(testkit.Rows("20")) tk.MustExec(`set global tidb_opt_limit_push_down_threshold = 100`) tk.MustQuery(`select @@global.tidb_opt_limit_push_down_threshold`).Check(testkit.Rows("100")) tk.MustExec(`set tidb_opt_limit_push_down_threshold = 20`) tk.MustQuery(`select @@global.tidb_opt_limit_push_down_threshold`).Check(testkit.Rows("100")) tk.MustQuery(`select @@tidb_opt_limit_push_down_threshold`).Check(testkit.Rows("20")) tk.MustQuery("select @@tidb_opt_prefer_range_scan").Check(testkit.Rows("0")) tk.MustExec("set global tidb_opt_prefer_range_scan = 1") tk.MustQuery("select @@global.tidb_opt_prefer_range_scan").Check(testkit.Rows("1")) tk.MustExec("set global tidb_opt_prefer_range_scan = 0") tk.MustQuery("select @@global.tidb_opt_prefer_range_scan").Check(testkit.Rows("0")) tk.MustExec("set session tidb_opt_prefer_range_scan = 1") tk.MustQuery("select @@session.tidb_opt_prefer_range_scan").Check(testkit.Rows("1")) tk.MustExec("set session tidb_opt_prefer_range_scan = 0") tk.MustQuery("select @@session.tidb_opt_prefer_range_scan").Check(testkit.Rows("0")) tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("0")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = 0.5") tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("0.5")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = 1") tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("1")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = 1.5") tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("1.5")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = 10") tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("10")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = -1") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_tso_client_batch_max_wait_time value: '-1'")) tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("0")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = -0.01") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_tso_client_batch_max_wait_time value: '-0.01'")) tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("0")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = 10.01") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_tso_client_batch_max_wait_time value: '10.01'")) tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("10")) tk.MustExec("set global tidb_tso_client_batch_max_wait_time = 10.1") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_tso_client_batch_max_wait_time value: '10.1'")) tk.MustQuery("select @@tidb_tso_client_batch_max_wait_time").Check(testkit.Rows("10")) require.Error(t, tk.ExecToErr("set tidb_tso_client_batch_max_wait_time = 1")) tk.MustQuery("select @@tidb_enable_tso_follower_proxy").Check(testkit.Rows("0")) tk.MustExec("set global tidb_enable_tso_follower_proxy = 1") tk.MustQuery("select @@tidb_enable_tso_follower_proxy").Check(testkit.Rows("1")) tk.MustExec("set global tidb_enable_tso_follower_proxy = 0") tk.MustQuery("select @@tidb_enable_tso_follower_proxy").Check(testkit.Rows("0")) require.Error(t, tk.ExecToErr("set tidb_enable_tso_follower_proxy = 1")) tk.MustQuery("select @@tidb_enable_historical_stats").Check(testkit.Rows("0")) tk.MustExec("set global tidb_enable_historical_stats = 1") tk.MustQuery("select @@tidb_enable_historical_stats").Check(testkit.Rows("1")) tk.MustExec("set global tidb_enable_historical_stats = 0") tk.MustQuery("select @@tidb_enable_historical_stats").Check(testkit.Rows("0")) // test for tidb_enable_column_tracking tk.MustQuery("select @@tidb_enable_column_tracking").Check(testkit.Rows("0")) tk.MustExec("set global tidb_enable_column_tracking = 1") tk.MustQuery("select @@tidb_enable_column_tracking").Check(testkit.Rows("1")) tk.MustExec("set global tidb_enable_column_tracking = 0") tk.MustQuery("select @@tidb_enable_column_tracking").Check(testkit.Rows("0")) // When set tidb_enable_column_tracking off, we record the time of the setting operation. tk.MustQuery("select count(1) from mysql.tidb where variable_name = 'tidb_disable_column_tracking_time' and variable_value is not null").Check(testkit.Rows("1")) tk.MustExec("set global tidb_enable_column_tracking = 1") tk.MustQuery("select @@tidb_enable_column_tracking").Check(testkit.Rows("1")) require.Error(t, tk.ExecToErr("select @@session.tidb_enable_column_tracking")) require.Error(t, tk.ExecToErr("set tidb_enable_column_tracking = 0")) require.Error(t, tk.ExecToErr("set global tidb_enable_column_tracking = -1")) // test for tidb_ignore_prepared_cache_close_stmt tk.MustQuery("select @@global.tidb_ignore_prepared_cache_close_stmt").Check(testkit.Rows("0")) // default value is 0 tk.MustExec("set global tidb_ignore_prepared_cache_close_stmt=1") tk.MustQuery("select @@global.tidb_ignore_prepared_cache_close_stmt").Check(testkit.Rows("1")) tk.MustQuery("show global variables like 'tidb_ignore_prepared_cache_close_stmt'").Check(testkit.Rows("tidb_ignore_prepared_cache_close_stmt ON")) tk.MustExec("set global tidb_ignore_prepared_cache_close_stmt=0") tk.MustQuery("select @@global.tidb_ignore_prepared_cache_close_stmt").Check(testkit.Rows("0")) tk.MustQuery("show global variables like 'tidb_ignore_prepared_cache_close_stmt'").Check(testkit.Rows("tidb_ignore_prepared_cache_close_stmt OFF")) // test for tidb_enable_new_cost_interface tk.MustQuery("select @@global.tidb_enable_new_cost_interface").Check(testkit.Rows("1")) // default value is 1 tk.MustExec("set global tidb_enable_new_cost_interface=0") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1287 'OFF' is deprecated and will be removed in a future release. Please use ON instead")) tk.MustQuery("select @@global.tidb_enable_new_cost_interface").Check(testkit.Rows("1")) tk.MustExec("set tidb_enable_new_cost_interface=0") tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1287 'OFF' is deprecated and will be removed in a future release. Please use ON instead")) tk.MustQuery("select @@session.tidb_enable_new_cost_interface").Check(testkit.Rows("1")) // test for tidb_remove_orderby_in_subquery tk.MustQuery("select @@session.tidb_remove_orderby_in_subquery").Check(testkit.Rows("0")) // default value is 0 tk.MustExec("set session tidb_remove_orderby_in_subquery=1") tk.MustQuery("select @@session.tidb_remove_orderby_in_subquery").Check(testkit.Rows("1")) tk.MustQuery("select @@global.tidb_remove_orderby_in_subquery").Check(testkit.Rows("0")) // default value is 0 tk.MustExec("set global tidb_remove_orderby_in_subquery=1") tk.MustQuery("select @@global.tidb_remove_orderby_in_subquery").Check(testkit.Rows("1")) // test for tidb_opt_skew_distinct_agg tk.MustQuery("select @@session.tidb_opt_skew_distinct_agg").Check(testkit.Rows("0")) // default value is 0 tk.MustExec("set session tidb_opt_skew_distinct_agg=1") tk.MustQuery("select @@session.tidb_opt_skew_distinct_agg").Check(testkit.Rows("1")) tk.MustQuery("select @@global.tidb_opt_skew_distinct_agg").Check(testkit.Rows("0")) // default value is 0 tk.MustExec("set global tidb_opt_skew_distinct_agg=1") tk.MustQuery("select @@global.tidb_opt_skew_distinct_agg").Check(testkit.Rows("1")) // test for tidb_opt_three_stage_distinct_agg tk.MustQuery("select @@session.tidb_opt_three_stage_distinct_agg").Check(testkit.Rows("1")) // default value is 1 tk.MustExec("set session tidb_opt_three_stage_distinct_agg=0") tk.MustQuery("select @@session.tidb_opt_three_stage_distinct_agg").Check(testkit.Rows("0")) tk.MustQuery("select @@global.tidb_opt_three_stage_distinct_agg").Check(testkit.Rows("1")) // default value is 1 tk.MustExec("set global tidb_opt_three_stage_distinct_agg=0") tk.MustQuery("select @@global.tidb_opt_three_stage_distinct_agg").Check(testkit.Rows("0")) // the value of max_allowed_packet should be a multiple of 1024 tk.MustExec("set @@global.max_allowed_packet=16385") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_allowed_packet value: '16385'")) result := tk.MustQuery("select @@global.max_allowed_packet;") result.Check(testkit.Rows("16384")) tk.MustExec("set @@global.max_allowed_packet=2047") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_allowed_packet value: '2047'")) result = tk.MustQuery("select @@global.max_allowed_packet;") result.Check(testkit.Rows("1024")) tk.MustExec("set @@global.max_allowed_packet=0") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_allowed_packet value: '0'")) result = tk.MustQuery("select @@global.max_allowed_packet;") result.Check(testkit.Rows("1024")) // test value of tidb_stats_cache_mem_quota tk.MustQuery("select @@global.tidb_stats_cache_mem_quota").Check(testkit.Rows("0")) tk.MustExec("set global tidb_stats_cache_mem_quota = 200") tk.MustQuery("select @@global.tidb_stats_cache_mem_quota").Check(testkit.Rows("200")) // assert quota must larger than -1 tk.MustExec("set global tidb_stats_cache_mem_quota = -1") tk.MustQuery("select @@global.tidb_stats_cache_mem_quota").Check(testkit.Rows("0")) // assert quota muster smaller than 1TB tk.MustExec("set global tidb_stats_cache_mem_quota = 1099511627777") tk.MustQuery("select @@global.tidb_stats_cache_mem_quota").Check(testkit.Rows("1099511627776")) // for read-only instance scoped system variables. tk.MustGetErrCode("set @@global.plugin_load = ''", errno.ErrIncorrectGlobalLocalVar) tk.MustGetErrCode("set @@global.plugin_dir = ''", errno.ErrIncorrectGlobalLocalVar) // test for tidb_max_auto_analyze_time tk.MustQuery("select @@tidb_max_auto_analyze_time").Check(testkit.Rows(strconv.Itoa(variable.DefTiDBMaxAutoAnalyzeTime))) tk.MustExec("set global tidb_max_auto_analyze_time = 60") tk.MustQuery("select @@tidb_max_auto_analyze_time").Check(testkit.Rows("60")) tk.MustExec("set global tidb_max_auto_analyze_time = -1") tk.MustQuery("select @@tidb_max_auto_analyze_time").Check(testkit.Rows("0")) // test variables for cost model ver2 tk.MustQuery("select @@tidb_cost_model_version").Check(testkit.Rows(fmt.Sprintf("%v", variable.DefTiDBCostModelVer))) tk.MustExec("set tidb_cost_model_version=3") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tidb_cost_model_version value: '3'")) tk.MustExec("set tidb_cost_model_version=0") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tidb_cost_model_version value: '0'")) tk.MustExec("set tidb_cost_model_version=2") tk.MustQuery("select @@tidb_cost_model_version").Check(testkit.Rows("2")) tk.MustQuery("select @@tidb_enable_analyze_snapshot").Check(testkit.Rows("0")) tk.MustExec("set global tidb_enable_analyze_snapshot = 1") tk.MustQuery("select @@global.tidb_enable_analyze_snapshot").Check(testkit.Rows("1")) tk.MustExec("set global tidb_enable_analyze_snapshot = 0") tk.MustQuery("select @@global.tidb_enable_analyze_snapshot").Check(testkit.Rows("0")) tk.MustExec("set session tidb_enable_analyze_snapshot = 1") tk.MustQuery("select @@session.tidb_enable_analyze_snapshot").Check(testkit.Rows("1")) tk.MustExec("set session tidb_enable_analyze_snapshot = 0") tk.MustQuery("select @@session.tidb_enable_analyze_snapshot").Check(testkit.Rows("0")) // test variables `init_connect' tk.MustGetErrCode("set global init_connect = '-1'", mysql.ErrWrongTypeForVar) tk.MustGetErrCode("set global init_connect = 'invalidstring'", mysql.ErrWrongTypeForVar) tk.MustExec("set global init_connect = 'select now(); select timestamp()'") // test variable 'tidb_enable_general_plan_cache' // global scope tk.MustQuery("select @@global.tidb_enable_general_plan_cache").Check(testkit.Rows("0")) // default value tk.MustExec("set global tidb_enable_general_plan_cache = 1") tk.MustQuery("select @@global.tidb_enable_general_plan_cache").Check(testkit.Rows("1")) tk.MustExec("set global tidb_enable_general_plan_cache = 0") tk.MustQuery("select @@global.tidb_enable_general_plan_cache").Check(testkit.Rows("0")) // session scope tk.MustQuery("select @@session.tidb_enable_general_plan_cache").Check(testkit.Rows("0")) // default value tk.MustExec("set session tidb_enable_general_plan_cache = 1") tk.MustQuery("select @@session.tidb_enable_general_plan_cache").Check(testkit.Rows("1")) tk.MustExec("set session tidb_enable_general_plan_cache = 0") tk.MustQuery("select @@session.tidb_enable_general_plan_cache").Check(testkit.Rows("0")) // test variable 'tidb_general_plan_cache-size' // global scope tk.MustQuery("select @@global.tidb_general_plan_cache_size").Check(testkit.Rows("100")) // default value tk.MustExec("set global tidb_general_plan_cache_size = 200") tk.MustQuery("select @@global.tidb_general_plan_cache_size").Check(testkit.Rows("200")) tk.MustExec("set global tidb_general_plan_cache_size = 200000000") // overflow tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_general_plan_cache_size value: '200000000'")) tk.MustQuery("select @@global.tidb_general_plan_cache_size").Check(testkit.Rows("100000")) // session scope tk.MustQuery("select @@session.tidb_general_plan_cache_size").Check(testkit.Rows("100")) // default value tk.MustExec("set session tidb_general_plan_cache_size = 300") tk.MustQuery("select @@session.tidb_general_plan_cache_size").Check(testkit.Rows("300")) tk.MustExec("set session tidb_general_plan_cache_size = -1") // underflow tk.MustQuery("show warnings").Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_general_plan_cache_size value: '-1'")) tk.MustQuery("select @@session.tidb_general_plan_cache_size").Check(testkit.Rows("1")) // test variable 'foreign_key_checks' // global scope tk.MustQuery("select @@global.foreign_key_checks").Check(testkit.Rows("0")) // default value tk.MustExec("set global foreign_key_checks = 1") tk.MustQuery("select @@global.foreign_key_checks").Check(testkit.Rows("1")) // session scope tk.MustQuery("select @@session.foreign_key_checks").Check(testkit.Rows("0")) // default value tk.MustExec("set session foreign_key_checks = 1") tk.MustQuery("select @@session.foreign_key_checks").Check(testkit.Rows("1")) // test variable 'foreign_key_checks' // global scope tk.MustQuery("select @@global.tidb_enable_foreign_key").Check(testkit.Rows("0")) // default value tk.MustExec("set global tidb_enable_foreign_key = 1") tk.MustQuery("select @@global.tidb_enable_foreign_key").Check(testkit.Rows("1")) // test variable 'tidb_opt_force_inline_cte' tk.MustQuery("select @@session.tidb_opt_force_inline_cte").Check(testkit.Rows("0")) // default value is 0 tk.MustExec("set session tidb_opt_force_inline_cte=1") tk.MustQuery("select @@session.tidb_opt_force_inline_cte").Check(testkit.Rows("1")) tk.MustQuery("select @@global.tidb_opt_force_inline_cte").Check(testkit.Rows("0")) // default value is 0 tk.MustExec("set global tidb_opt_force_inline_cte=1") tk.MustQuery("select @@global.tidb_opt_force_inline_cte").Check(testkit.Rows("1")) // test tidb_auto_analyze_partition_batch_size tk.MustQuery("select @@global.tidb_auto_analyze_partition_batch_size").Check(testkit.Rows("1")) // default value is 1 tk.MustExec("set global tidb_auto_analyze_partition_batch_size = 2") tk.MustQuery("select @@global.tidb_auto_analyze_partition_batch_size").Check(testkit.Rows("2")) tk.MustExec("set global tidb_auto_analyze_partition_batch_size = 0") tk.MustQuery("select @@global.tidb_auto_analyze_partition_batch_size").Check(testkit.Rows("1")) // min value is 1 tk.MustExec("set global tidb_auto_analyze_partition_batch_size = 9999") tk.MustQuery("select @@global.tidb_auto_analyze_partition_batch_size").Check(testkit.Rows("1024")) // max value is 1024 // test variable 'tidb_opt_prefix_index_single_scan' // global scope tk.MustQuery("select @@global.tidb_opt_prefix_index_single_scan").Check(testkit.Rows("1")) // default value tk.MustExec("set global tidb_opt_prefix_index_single_scan = 0") tk.MustQuery("select @@global.tidb_opt_prefix_index_single_scan").Check(testkit.Rows("0")) tk.MustExec("set global tidb_opt_prefix_index_single_scan = 1") tk.MustQuery("select @@global.tidb_opt_prefix_index_single_scan").Check(testkit.Rows("1")) // session scope tk.MustQuery("select @@session.tidb_opt_prefix_index_single_scan").Check(testkit.Rows("1")) // default value tk.MustExec("set session tidb_opt_prefix_index_single_scan = 0") tk.MustQuery("select @@session.tidb_opt_prefix_index_single_scan").Check(testkit.Rows("0")) tk.MustExec("set session tidb_opt_prefix_index_single_scan = 1") tk.MustQuery("select @@session.tidb_opt_prefix_index_single_scan").Check(testkit.Rows("1")) // test tidb_opt_range_max_size tk.MustQuery("select @@tidb_opt_range_max_size").Check(testkit.Rows("67108864")) tk.MustExec("set global tidb_opt_range_max_size = -1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tidb_opt_range_max_size value: '-1'")) tk.MustQuery("select @@global.tidb_opt_range_max_size").Check(testkit.Rows("0")) tk.MustExec("set global tidb_opt_range_max_size = 1048576") tk.MustQuery("select @@global.tidb_opt_range_max_size").Check(testkit.Rows("1048576")) tk.MustExec("set session tidb_opt_range_max_size = 2097152") tk.MustQuery("select @@session.tidb_opt_range_max_size").Check(testkit.Rows("2097152")) // test for password validation tk.MustQuery("SELECT @@GLOBAL.validate_password.enable").Check(testkit.Rows("0")) tk.MustQuery("SELECT @@GLOBAL.validate_password.length").Check(testkit.Rows("8")) tk.MustExec("SET GLOBAL validate_password.length = 3") tk.MustQuery("SELECT @@GLOBAL.validate_password.length").Check(testkit.Rows("4")) tk.MustExec("SET GLOBAL validate_password.mixed_case_count = 2") tk.MustQuery("SELECT @@GLOBAL.validate_password.length").Check(testkit.Rows("6")) // test tidb_cdc_write_source require.Equal(t, uint64(0), tk.Session().GetSessionVars().CDCWriteSource) tk.MustQuery("select @@tidb_cdc_write_source").Check(testkit.Rows("0")) tk.MustExec("set @@session.tidb_cdc_write_source = 2") tk.MustQuery("select @@tidb_cdc_write_source").Check(testkit.Rows("2")) require.Equal(t, uint64(2), tk.Session().GetSessionVars().CDCWriteSource) tk.MustExec("set @@session.tidb_cdc_write_source = 0") require.Equal(t, uint64(0), tk.Session().GetSessionVars().CDCWriteSource) } func TestGetSetNoopVars(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) // By default you can get/set noop sysvars without issue. tk.MustQuery("SELECT @@query_cache_type").Check(testkit.Rows("OFF")) tk.MustQuery("SHOW VARIABLES LIKE 'query_cache_type'").Check(testkit.Rows("query_cache_type OFF")) tk.MustExec("SET query_cache_type=2") tk.MustQuery("SELECT @@query_cache_type").Check(testkit.Rows("DEMAND")) // When tidb_enable_noop_variables is OFF, you can GET in @@ context // and always SET. But you can't see in SHOW VARIABLES. // Warnings are also returned. tk.MustExec("SET GLOBAL tidb_enable_noop_variables = OFF") defer tk.MustExec("SET GLOBAL tidb_enable_noop_variables = ON") tk.MustQuery("SELECT @@global.tidb_enable_noop_variables").Check(testkit.Rows("OFF")) tk.MustQuery("SELECT @@query_cache_type").Check(testkit.Rows("DEMAND")) tk.MustQuery("SHOW WARNINGS").Check(testkit.Rows("Warning 8145 variable query_cache_type has no effect in TiDB")) tk.MustQuery("SHOW VARIABLES LIKE 'query_cache_type'").Check(testkit.Rows()) tk.MustExec("SET query_cache_type = OFF") tk.MustQuery("SHOW WARNINGS").Check(testkit.Rows("Warning 8144 setting query_cache_type has no effect in TiDB")) // but the change is still effective. tk.MustQuery("SELECT @@query_cache_type").Check(testkit.Rows("OFF")) // Only ON and OFF supported err := tk.ExecToErr("SET GLOBAL tidb_enable_noop_variables = 2") require.Error(t, err) require.Equal(t, "[variable:1231]Variable 'tidb_enable_noop_variables' can't be set to the value of '2'", err.Error()) err = tk.ExecToErr("SET GLOBAL tidb_enable_noop_variables = 'warn'") require.Error(t, err) require.Equal(t, "[variable:1231]Variable 'tidb_enable_noop_variables' can't be set to the value of 'warn'", err.Error()) } func TestTruncateIncorrectIntSessionVar(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) testCases := []struct { sessionVarName string minValue int maxValue int }{ {"auto_increment_increment", 1, 65535}, {"auto_increment_offset", 1, 65535}, } for _, tc := range testCases { name := tc.sessionVarName selectSQL := fmt.Sprintf("select @@%s;", name) validValue := tc.minValue + (tc.maxValue-tc.minValue)/2 tk.MustExec(fmt.Sprintf("set @@%s = %d", name, validValue)) tk.MustQuery(selectSQL).Check(testkit.Rows(fmt.Sprintf("%d", validValue))) tk.MustExec(fmt.Sprintf("set @@%s = %d", name, tc.minValue-1)) warnMsg := fmt.Sprintf("Warning 1292 Truncated incorrect %s value: '%d'", name, tc.minValue-1) tk.MustQuery("show warnings").Check(testkit.Rows(warnMsg)) tk.MustQuery(selectSQL).Check(testkit.Rows(fmt.Sprintf("%d", tc.minValue))) tk.MustExec(fmt.Sprintf("set @@%s = %d", name, tc.maxValue+1)) warnMsg = fmt.Sprintf("Warning 1292 Truncated incorrect %s value: '%d'", name, tc.maxValue+1) tk.MustQuery("show warnings").Check(testkit.Rows(warnMsg)) tk.MustQuery(selectSQL).Check(testkit.Rows(fmt.Sprintf("%d", tc.maxValue))) } } func TestSetCharset(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) sessionVars := tk.Session().GetSessionVars() var characterSetVariables = []string{ "character_set_client", "character_set_connection", "character_set_results", "character_set_server", "character_set_database", "character_set_system", "character_set_filesystem", } check := func(args ...string) { for i, v := range characterSetVariables { sVar, err := sessionVars.GetSessionOrGlobalSystemVar(context.Background(), v) require.NoError(t, err) require.Equal(t, args[i], sVar, fmt.Sprintf("%d: %s", i, characterSetVariables[i])) } } check( "utf8mb4", "utf8mb4", "utf8mb4", "utf8mb4", "utf8mb4", "utf8", "binary", ) tk.MustExec(`SET NAMES latin1`) check( "latin1", "latin1", "latin1", "utf8mb4", "utf8mb4", "utf8", "binary", ) tk.MustExec(`SET NAMES default`) check( "utf8mb4", "utf8mb4", "utf8mb4", "utf8mb4", "utf8mb4", "utf8", "binary", ) // Issue #1523 tk.MustExec(`SET NAMES binary`) check( "binary", "binary", "binary", "utf8mb4", "utf8mb4", "utf8", "binary", ) tk.MustExec(`SET NAMES utf8`) check( "utf8", "utf8", "utf8", "utf8mb4", "utf8mb4", "utf8", "binary", ) tk.MustExec(`SET CHARACTER SET latin1`) check( "latin1", "utf8mb4", "latin1", "utf8mb4", "utf8mb4", "utf8", "binary", ) tk.MustExec(`SET CHARACTER SET default`) check( "utf8mb4", "utf8mb4", "utf8mb4", "utf8mb4", "utf8mb4", "utf8", "binary", ) } func TestSetCollationAndCharset(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("use test") ctx := tk.Session().(sessionctx.Context) sessionVars := ctx.GetSessionVars() cases := []struct { charset string collation string expectCharset string expectCollation string }{ {variable.CharacterSetConnection, variable.CollationConnection, "utf8", "utf8_bin"}, {variable.CharsetDatabase, variable.CollationDatabase, "utf8", "utf8_bin"}, {variable.CharacterSetServer, variable.CollationServer, "utf8", "utf8_bin"}, } for _, c := range cases { tk.MustExec(fmt.Sprintf("set %s = %s;", c.charset, c.expectCharset)) sVar, ok := sessionVars.GetSystemVar(c.charset) require.True(t, ok) require.Equal(t, c.expectCharset, sVar) sVar, ok = sessionVars.GetSystemVar(c.collation) require.True(t, ok) require.Equal(t, c.expectCollation, sVar) } tk = testkit.NewTestKit(t, store) tk.MustExec("use test") ctx = tk.Session().(sessionctx.Context) sessionVars = ctx.GetSessionVars() for _, c := range cases { tk.MustExec(fmt.Sprintf("set %s = %s;", c.collation, c.expectCollation)) sVar, ok := sessionVars.GetSystemVar(c.charset) require.True(t, ok) require.Equal(t, c.expectCharset, sVar) sVar, ok = sessionVars.GetSystemVar(c.collation) require.True(t, ok) require.Equal(t, c.expectCollation, sVar) } } func TestValidateSetVar(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) err := tk.ExecToErr("set global tidb_distsql_scan_concurrency='fff';") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set global tidb_distsql_scan_concurrency=-2;") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_distsql_scan_concurrency value: '-2'")) err = tk.ExecToErr("set @@tidb_distsql_scan_concurrency='fff';") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set @@tidb_distsql_scan_concurrency=-2;") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_distsql_scan_concurrency value: '-2'")) err = tk.ExecToErr("set @@tidb_batch_delete='ok';") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set @@tidb_batch_delete='On';") tk.MustQuery("select @@tidb_batch_delete;").Check(testkit.Rows("1")) tk.MustExec("set @@tidb_batch_delete='oFf';") tk.MustQuery("select @@tidb_batch_delete;").Check(testkit.Rows("0")) tk.MustExec("set @@tidb_batch_delete=1;") tk.MustQuery("select @@tidb_batch_delete;").Check(testkit.Rows("1")) tk.MustExec("set @@tidb_batch_delete=0;") tk.MustQuery("select @@tidb_batch_delete;").Check(testkit.Rows("0")) tk.MustExec("set @@tidb_opt_agg_push_down=off;") tk.MustQuery("select @@tidb_opt_agg_push_down;").Check(testkit.Rows("0")) tk.MustExec("set @@tidb_constraint_check_in_place=on;") tk.MustQuery("select @@tidb_constraint_check_in_place;").Check(testkit.Rows("1")) tk.MustExec("set @@tidb_general_log=0;") tk.MustQuery(`show warnings`).Check(testkit.Rows(fmt.Sprintf("Warning %d modifying tidb_general_log will require SET GLOBAL in a future version of TiDB", errno.ErrInstanceScope))) tk.MustQuery("select @@tidb_general_log;").Check(testkit.Rows("0")) tk.MustExec("set @@tidb_pprof_sql_cpu=1;") tk.MustQuery("select @@tidb_pprof_sql_cpu;").Check(testkit.Rows("1")) tk.MustExec("set @@tidb_pprof_sql_cpu=0;") tk.MustQuery("select @@tidb_pprof_sql_cpu;").Check(testkit.Rows("0")) err = tk.ExecToErr("set @@tidb_batch_delete=3;") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set @@group_concat_max_len=1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect group_concat_max_len value: '1'")) result := tk.MustQuery("select @@group_concat_max_len;") result.Check(testkit.Rows("4")) err = tk.ExecToErr("set @@group_concat_max_len = 18446744073709551616") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar), fmt.Sprintf("err %v", err)) // Test illegal type err = tk.ExecToErr("set @@group_concat_max_len='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set @@default_week_format=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect default_week_format value: '-1'")) result = tk.MustQuery("select @@default_week_format;") result.Check(testkit.Rows("0")) tk.MustExec("set @@default_week_format=9") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect default_week_format value: '9'")) result = tk.MustQuery("select @@default_week_format;") result.Check(testkit.Rows("7")) err = tk.ExecToErr("set @@error_count = 0") require.True(t, terror.ErrorEqual(err, variable.ErrIncorrectScope), fmt.Sprintf("err %v", err)) err = tk.ExecToErr("set @@warning_count = 0") require.True(t, terror.ErrorEqual(err, variable.ErrIncorrectScope), fmt.Sprintf("err %v", err)) tk.MustExec("set time_zone='SySTeM'") result = tk.MustQuery("select @@time_zone;") result.Check(testkit.Rows("SYSTEM")) // The following cases test value out of range and illegal type when setting system variables. // See https://dev.mysql.com/doc/refman/8.0/en/server-system-variables.html for more details. tk.MustExec("set @@global.max_connections=100001") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_connections value: '100001'")) result = tk.MustQuery("select @@global.max_connections;") result.Check(testkit.Rows("100000")) // "max_connections == 0" means there is no limitation on the number of connections. tk.MustExec("set @@global.max_connections=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_connections value: '-1'")) result = tk.MustQuery("select @@global.max_connections;") result.Check(testkit.Rows("0")) err = tk.ExecToErr("set @@global.max_connections='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@global.thread_pool_size=65") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect thread_pool_size value: '65'")) result = tk.MustQuery("select @@global.thread_pool_size;") result.Check(testkit.Rows("64")) tk.MustExec("set @@global.thread_pool_size=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect thread_pool_size value: '-1'")) result = tk.MustQuery("select @@global.thread_pool_size;") result.Check(testkit.Rows("1")) err = tk.ExecToErr("set @@global.thread_pool_size='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@global.max_allowed_packet=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_allowed_packet value: '-1'")) result = tk.MustQuery("select @@global.max_allowed_packet;") result.Check(testkit.Rows("1024")) err = tk.ExecToErr("set @@global.max_allowed_packet='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) err = tk.ExecToErr("set @@max_allowed_packet=default") require.True(t, terror.ErrorEqual(err, variable.ErrReadOnly)) tk.MustExec("set @@global.max_connect_errors=18446744073709551615") tk.MustExec("set @@global.max_connect_errors=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_connect_errors value: '-1'")) result = tk.MustQuery("select @@global.max_connect_errors;") result.Check(testkit.Rows("1")) err = tk.ExecToErr("set @@global.max_connect_errors=18446744073709551616") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@global.max_connections=100001") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_connections value: '100001'")) result = tk.MustQuery("select @@global.max_connections;") result.Check(testkit.Rows("100000")) tk.MustExec("set @@global.max_connections=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_connections value: '-1'")) result = tk.MustQuery("select @@global.max_connections;") result.Check(testkit.Rows("0")) err = tk.ExecToErr("set @@global.max_connections='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@max_sort_length=1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_sort_length value: '1'")) result = tk.MustQuery("select @@max_sort_length;") result.Check(testkit.Rows("4")) tk.MustExec("set @@max_sort_length=-100") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_sort_length value: '-100'")) result = tk.MustQuery("select @@max_sort_length;") result.Check(testkit.Rows("4")) tk.MustExec("set @@max_sort_length=8388609") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect max_sort_length value: '8388609'")) result = tk.MustQuery("select @@max_sort_length;") result.Check(testkit.Rows("8388608")) err = tk.ExecToErr("set @@max_sort_length='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@global.table_definition_cache=399") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect table_definition_cache value: '399'")) result = tk.MustQuery("select @@global.table_definition_cache;") result.Check(testkit.Rows("400")) tk.MustExec("set @@global.table_definition_cache=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect table_definition_cache value: '-1'")) result = tk.MustQuery("select @@global.table_definition_cache;") result.Check(testkit.Rows("400")) tk.MustExec("set @@global.table_definition_cache=524289") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect table_definition_cache value: '524289'")) result = tk.MustQuery("select @@global.table_definition_cache;") result.Check(testkit.Rows("524288")) err = tk.ExecToErr("set @@global.table_definition_cache='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@old_passwords=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect old_passwords value: '-1'")) result = tk.MustQuery("select @@old_passwords;") result.Check(testkit.Rows("0")) tk.MustExec("set @@old_passwords=3") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect old_passwords value: '3'")) result = tk.MustQuery("select @@old_passwords;") result.Check(testkit.Rows("2")) err = tk.ExecToErr("set @@old_passwords='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@tmp_table_size=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tmp_table_size value: '-1'")) result = tk.MustQuery("select @@tmp_table_size;") result.Check(testkit.Rows("1024")) tk.MustExec("set @@tmp_table_size=1020") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tmp_table_size value: '1020'")) result = tk.MustQuery("select @@tmp_table_size;") result.Check(testkit.Rows("1024")) tk.MustExec("set @@tmp_table_size=167772161") result = tk.MustQuery("select @@tmp_table_size;") result.Check(testkit.Rows("167772161")) tk.MustExec("set @@tmp_table_size=18446744073709551615") result = tk.MustQuery("select @@tmp_table_size;") result.Check(testkit.Rows("18446744073709551615")) err = tk.ExecToErr("set @@tmp_table_size=18446744073709551616") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) err = tk.ExecToErr("set @@tmp_table_size='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@tidb_tmp_table_max_size=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tidb_tmp_table_max_size value: '-1'")) result = tk.MustQuery("select @@tidb_tmp_table_max_size;") result.Check(testkit.Rows("1048576")) tk.MustExec("set @@tidb_tmp_table_max_size=1048575") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tidb_tmp_table_max_size value: '1048575'")) result = tk.MustQuery("select @@tidb_tmp_table_max_size;") result.Check(testkit.Rows("1048576")) tk.MustExec("set @@tidb_tmp_table_max_size=167772161") result = tk.MustQuery("select @@tidb_tmp_table_max_size;") result.Check(testkit.Rows("167772161")) tk.MustExec("set @@tidb_tmp_table_max_size=137438953472") result = tk.MustQuery("select @@tidb_tmp_table_max_size;") result.Check(testkit.Rows("137438953472")) tk.MustExec("set @@tidb_tmp_table_max_size=137438953473") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect tidb_tmp_table_max_size value: '137438953473'")) result = tk.MustQuery("select @@tidb_tmp_table_max_size;") result.Check(testkit.Rows("137438953472")) err = tk.ExecToErr("set @@tidb_tmp_table_max_size='hello'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongTypeForVar)) tk.MustExec("set @@global.connect_timeout=1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect connect_timeout value: '1'")) result = tk.MustQuery("select @@global.connect_timeout;") result.Check(testkit.Rows("2")) tk.MustExec("set @@global.connect_timeout=31536000") result = tk.MustQuery("select @@global.connect_timeout;") result.Check(testkit.Rows("31536000")) tk.MustExec("set @@global.connect_timeout=31536001") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect connect_timeout value: '31536001'")) result = tk.MustQuery("select @@global.connect_timeout;") result.Check(testkit.Rows("31536000")) result = tk.MustQuery("select @@sql_select_limit;") result.Check(testkit.Rows("18446744073709551615")) tk.MustExec("set @@sql_select_limit=default") result = tk.MustQuery("select @@sql_select_limit;") result.Check(testkit.Rows("18446744073709551615")) tk.MustExec("set @@sql_auto_is_null=00") result = tk.MustQuery("select @@sql_auto_is_null;") result.Check(testkit.Rows("0")) tk.MustExec("set @@sql_warnings=001") result = tk.MustQuery("select @@sql_warnings;") result.Check(testkit.Rows("1")) tk.MustExec("set @@sql_warnings=000") result = tk.MustQuery("select @@sql_warnings;") result.Check(testkit.Rows("0")) tk.MustExec("set @@global.super_read_only=-0") result = tk.MustQuery("select @@global.super_read_only;") result.Check(testkit.Rows("0")) err = tk.ExecToErr("set @@global.super_read_only=-1") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set @@global.innodb_status_output_locks=-1") result = tk.MustQuery("select @@global.innodb_status_output_locks;") result.Check(testkit.Rows("1")) tk.MustExec("set @@global.innodb_ft_enable_stopword=0000000") result = tk.MustQuery("select @@global.innodb_ft_enable_stopword;") result.Check(testkit.Rows("0")) tk.MustExec("set @@global.innodb_stats_on_metadata=1") result = tk.MustQuery("select @@global.innodb_stats_on_metadata;") result.Check(testkit.Rows("1")) tk.MustExec("set @@global.innodb_file_per_table=-50") result = tk.MustQuery("select @@global.innodb_file_per_table;") result.Check(testkit.Rows("1")) err = tk.ExecToErr("set @@global.innodb_ft_enable_stopword=2") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set @@query_cache_type=0") result = tk.MustQuery("select @@query_cache_type;") result.Check(testkit.Rows("OFF")) tk.MustExec("set @@query_cache_type=2") result = tk.MustQuery("select @@query_cache_type;") result.Check(testkit.Rows("DEMAND")) tk.MustExec("set @@global.sync_binlog=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect sync_binlog value: '-1'")) tk.MustExec("set @@global.sync_binlog=4294967299") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect sync_binlog value: '4294967299'")) tk.MustExec("set @@global.flush_time=31536001") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect flush_time value: '31536001'")) tk.MustExec("set @@global.interactive_timeout=31536001") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect interactive_timeout value: '31536001'")) tk.MustExec("set @@global.innodb_commit_concurrency = -1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_commit_concurrency value: '-1'")) tk.MustExec("set @@global.innodb_commit_concurrency = 1001") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_commit_concurrency value: '1001'")) tk.MustExec("set @@global.innodb_fast_shutdown = -1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_fast_shutdown value: '-1'")) tk.MustExec("set @@global.innodb_fast_shutdown = 3") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_fast_shutdown value: '3'")) tk.MustExec("set @@global.innodb_lock_wait_timeout = 0") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_lock_wait_timeout value: '0'")) tk.MustExec("set @@global.innodb_lock_wait_timeout = 1073741825") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_lock_wait_timeout value: '1073741825'")) tk.MustExec("set @@innodb_lock_wait_timeout = 0") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_lock_wait_timeout value: '0'")) tk.MustExec("set @@innodb_lock_wait_timeout = 1073741825") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect innodb_lock_wait_timeout value: '1073741825'")) tk.MustExec("set @@global.validate_password.number_count=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect validate_password.number_count value: '-1'")) tk.MustExec("set @@global.validate_password.length=-1") tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", "Warning|1292|Truncated incorrect validate_password.length value: '-1'")) err = tk.ExecToErr("set @@tx_isolation=''") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) err = tk.ExecToErr("set global tx_isolation=''") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) err = tk.ExecToErr("set @@transaction_isolation=''") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) err = tk.ExecToErr("set global transaction_isolation=''") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) err = tk.ExecToErr("set global tx_isolation='REPEATABLE-READ1'") require.True(t, terror.ErrorEqual(err, variable.ErrWrongValueForVar), fmt.Sprintf("err %v", err)) tk.MustExec("set @@tx_isolation='READ-COMMITTED'") result = tk.MustQuery("select @@tx_isolation;") result.Check(testkit.Rows("READ-COMMITTED")) tk.MustExec("set @@tx_isolation='read-COMMITTED'") result = tk.MustQuery("select @@tx_isolation;") result.Check(testkit.Rows("READ-COMMITTED")) tk.MustExec("set @@tx_isolation='REPEATABLE-READ'") result = tk.MustQuery("select @@tx_isolation;") result.Check(testkit.Rows("REPEATABLE-READ")) tk.MustExec("SET GLOBAL tidb_skip_isolation_level_check = 0") tk.MustExec("SET SESSION tidb_skip_isolation_level_check = 0") err = tk.ExecToErr("set @@tx_isolation='SERIALIZABLE'") require.True(t, terror.ErrorEqual(err, variable.ErrUnsupportedIsolationLevel), fmt.Sprintf("err %v", err)) tk.MustExec("set global allow_auto_random_explicit_insert=on;") tk.MustQuery("select @@global.allow_auto_random_explicit_insert;").Check(testkit.Rows("1")) } func TestSelectGlobalVar(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustQuery("select @@global.max_connections;").Check(testkit.Rows("0")) tk.MustQuery("select @@max_connections;").Check(testkit.Rows("0")) tk.MustExec("set @@global.max_connections=100;") tk.MustQuery("select @@global.max_connections;").Check(testkit.Rows("100")) tk.MustQuery("select @@max_connections;").Check(testkit.Rows("100")) tk.MustExec("set @@global.max_connections=0;") // test for unknown variable. err := tk.ExecToErr("select @@invalid") require.True(t, terror.ErrorEqual(err, variable.ErrUnknownSystemVar), fmt.Sprintf("err %v", err)) err = tk.ExecToErr("select @@global.invalid") require.True(t, terror.ErrorEqual(err, variable.ErrUnknownSystemVar), fmt.Sprintf("err %v", err)) } func TestSetConcurrency(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) // test default value tk.MustQuery("select @@tidb_executor_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.DefExecutorConcurrency))) tk.MustQuery("select @@tidb_index_lookup_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.ConcurrencyUnset))) tk.MustQuery("select @@tidb_index_lookup_join_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.ConcurrencyUnset))) tk.MustQuery("select @@tidb_hash_join_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.ConcurrencyUnset))) tk.MustQuery("select @@tidb_hashagg_partial_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.ConcurrencyUnset))) tk.MustQuery("select @@tidb_hashagg_final_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.ConcurrencyUnset))) tk.MustQuery("select @@tidb_window_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.ConcurrencyUnset))) tk.MustQuery("select @@tidb_streamagg_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.DefTiDBStreamAggConcurrency))) tk.MustQuery("select @@tidb_projection_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.ConcurrencyUnset))) tk.MustQuery("select @@tidb_distsql_scan_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.DefDistSQLScanConcurrency))) tk.MustQuery("select @@tidb_index_serial_scan_concurrency;").Check(testkit.Rows(strconv.Itoa(variable.DefIndexSerialScanConcurrency))) vars := tk.Session().GetSessionVars() require.Equal(t, variable.DefExecutorConcurrency, vars.ExecutorConcurrency) require.Equal(t, variable.DefExecutorConcurrency, vars.IndexLookupConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.IndexLookupJoinConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.HashJoinConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.HashAggPartialConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.HashAggFinalConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.WindowConcurrency()) require.Equal(t, variable.DefTiDBStreamAggConcurrency, vars.StreamAggConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.ProjectionConcurrency()) require.Equal(t, variable.DefDistSQLScanConcurrency, vars.DistSQLScanConcurrency()) require.Equal(t, variable.DefIndexSerialScanConcurrency, vars.IndexSerialScanConcurrency()) // test setting deprecated variables warnTpl := "Warning 1287 '%s' is deprecated and will be removed in a future release. Please use tidb_executor_concurrency instead" checkSet := func(v string) { tk.MustExec(fmt.Sprintf("set @@%s=1;", v)) tk.MustQuery("show warnings").Check(testkit.RowsWithSep("|", fmt.Sprintf(warnTpl, v))) tk.MustQuery(fmt.Sprintf("select @@%s;", v)).Check(testkit.Rows("1")) } checkSet(variable.TiDBIndexLookupConcurrency) require.Equal(t, 1, vars.IndexLookupConcurrency()) checkSet(variable.TiDBIndexLookupJoinConcurrency) require.Equal(t, 1, vars.IndexLookupJoinConcurrency()) checkSet(variable.TiDBHashJoinConcurrency) require.Equal(t, 1, vars.HashJoinConcurrency()) checkSet(variable.TiDBHashAggPartialConcurrency) require.Equal(t, 1, vars.HashAggPartialConcurrency()) checkSet(variable.TiDBHashAggFinalConcurrency) require.Equal(t, 1, vars.HashAggFinalConcurrency()) checkSet(variable.TiDBProjectionConcurrency) require.Equal(t, 1, vars.ProjectionConcurrency()) checkSet(variable.TiDBWindowConcurrency) require.Equal(t, 1, vars.WindowConcurrency()) checkSet(variable.TiDBStreamAggConcurrency) require.Equal(t, 1, vars.StreamAggConcurrency()) tk.MustExec(fmt.Sprintf("set @@%s=1;", variable.TiDBDistSQLScanConcurrency)) tk.MustQuery(fmt.Sprintf("select @@%s;", variable.TiDBDistSQLScanConcurrency)).Check(testkit.Rows("1")) require.Equal(t, 1, vars.DistSQLScanConcurrency()) tk.MustExec("set @@tidb_index_serial_scan_concurrency=4") tk.MustQuery("show warnings").Check(testkit.Rows()) tk.MustQuery("select @@tidb_index_serial_scan_concurrency;").Check(testkit.Rows("4")) require.Equal(t, 4, vars.IndexSerialScanConcurrency()) // test setting deprecated value unset tk.MustExec("set @@tidb_index_lookup_concurrency=-1;") tk.MustExec("set @@tidb_index_lookup_join_concurrency=-1;") tk.MustExec("set @@tidb_hash_join_concurrency=-1;") tk.MustExec("set @@tidb_hashagg_partial_concurrency=-1;") tk.MustExec("set @@tidb_hashagg_final_concurrency=-1;") tk.MustExec("set @@tidb_window_concurrency=-1;") tk.MustExec("set @@tidb_streamagg_concurrency=-1;") tk.MustExec("set @@tidb_projection_concurrency=-1;") require.Equal(t, variable.DefExecutorConcurrency, vars.IndexLookupConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.IndexLookupJoinConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.HashJoinConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.HashAggPartialConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.HashAggFinalConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.WindowConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.StreamAggConcurrency()) require.Equal(t, variable.DefExecutorConcurrency, vars.ProjectionConcurrency()) tk.MustExec("set @@tidb_executor_concurrency=-1;") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_executor_concurrency value: '-1'")) require.Equal(t, 1, vars.ExecutorConcurrency) } func TestEnableNoopFunctionsVar(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) defer func() { // Ensure global settings are reset. tk.MustExec("SET GLOBAL tx_read_only = 0") tk.MustExec("SET GLOBAL transaction_read_only = 0") tk.MustExec("SET GLOBAL read_only = 0") tk.MustExec("SET GLOBAL super_read_only = 0") tk.MustExec("SET GLOBAL offline_mode = 0") tk.MustExec("SET GLOBAL tidb_enable_noop_functions = 0") }() // test for tidb_enable_noop_functions tk.MustQuery(`select @@global.tidb_enable_noop_functions;`).Check(testkit.Rows("OFF")) tk.MustQuery(`select @@tidb_enable_noop_functions;`).Check(testkit.Rows("OFF")) // change session var to 1 tk.MustExec(`set tidb_enable_noop_functions=1;`) tk.MustQuery(`select @@tidb_enable_noop_functions;`).Check(testkit.Rows("ON")) tk.MustQuery(`select @@global.tidb_enable_noop_functions;`).Check(testkit.Rows("OFF")) // restore to 0 tk.MustExec(`set tidb_enable_noop_functions=0;`) tk.MustQuery(`select @@tidb_enable_noop_functions;`).Check(testkit.Rows("OFF")) tk.MustQuery(`select @@global.tidb_enable_noop_functions;`).Check(testkit.Rows("OFF")) // set test require.Error(t, tk.ExecToErr(`set tidb_enable_noop_functions='abc'`)) require.Error(t, tk.ExecToErr(`set tidb_enable_noop_functions=11`)) tk.MustExec(`set tidb_enable_noop_functions="off";`) tk.MustQuery(`select @@tidb_enable_noop_functions;`).Check(testkit.Rows("OFF")) tk.MustExec(`set tidb_enable_noop_functions="on";`) tk.MustQuery(`select @@tidb_enable_noop_functions;`).Check(testkit.Rows("ON")) tk.MustExec(`set tidb_enable_noop_functions=0;`) tk.MustQuery(`select @@tidb_enable_noop_functions;`).Check(testkit.Rows("OFF")) err := tk.ExecToErr("SET SESSION tx_read_only = 1") require.True(t, terror.ErrorEqual(err, variable.ErrFunctionsNoopImpl), fmt.Sprintf("err %v", err)) tk.MustExec("SET SESSION tx_read_only = 0") tk.MustQuery("select @@session.tx_read_only").Check(testkit.Rows("0")) tk.MustQuery("select @@session.transaction_read_only").Check(testkit.Rows("0")) err = tk.ExecToErr("SET GLOBAL tx_read_only = 1") // should fail. require.True(t, terror.ErrorEqual(err, variable.ErrFunctionsNoopImpl), fmt.Sprintf("err %v", err)) tk.MustExec("SET GLOBAL tx_read_only = 0") tk.MustQuery("select @@global.tx_read_only").Check(testkit.Rows("0")) tk.MustQuery("select @@global.transaction_read_only").Check(testkit.Rows("0")) err = tk.ExecToErr("SET SESSION transaction_read_only = 1") require.True(t, terror.ErrorEqual(err, variable.ErrFunctionsNoopImpl), fmt.Sprintf("err %v", err)) tk.MustExec("SET SESSION transaction_read_only = 0") tk.MustQuery("select @@session.tx_read_only").Check(testkit.Rows("0")) tk.MustQuery("select @@session.transaction_read_only").Check(testkit.Rows("0")) // works on SESSION because SESSION tidb_enable_noop_functions=1 tk.MustExec("SET tidb_enable_noop_functions = 1") tk.MustExec("SET SESSION transaction_read_only = 1") tk.MustQuery("select @@session.tx_read_only").Check(testkit.Rows("1")) tk.MustQuery("select @@session.transaction_read_only").Check(testkit.Rows("1")) // fails on GLOBAL because GLOBAL.tidb_enable_noop_functions still=0 err = tk.ExecToErr("SET GLOBAL transaction_read_only = 1") require.True(t, terror.ErrorEqual(err, variable.ErrFunctionsNoopImpl), fmt.Sprintf("err %v", err)) tk.MustExec("SET GLOBAL tidb_enable_noop_functions = 1") // now works tk.MustExec("SET GLOBAL transaction_read_only = 1") tk.MustQuery("select @@global.tx_read_only").Check(testkit.Rows("1")) tk.MustQuery("select @@global.transaction_read_only").Check(testkit.Rows("1")) tk.MustExec("SET GLOBAL transaction_read_only = 0") tk.MustQuery("select @@global.tx_read_only").Check(testkit.Rows("0")) tk.MustQuery("select @@global.transaction_read_only").Check(testkit.Rows("0")) require.Error(t, tk.ExecToErr("SET tidb_enable_noop_functions = 0")) // fails because transaction_read_only/tx_read_only = 1 tk.MustExec("SET transaction_read_only = 0") tk.MustExec("SET tidb_enable_noop_functions = 0") // now works. // setting session doesn't change global, which succeeds because global.transaction_read_only/tx_read_only = 0 tk.MustExec("SET GLOBAL tidb_enable_noop_functions = 0") // but if global.transaction_read_only=1, it would fail tk.MustExec("SET GLOBAL tidb_enable_noop_functions = 1") tk.MustExec("SET GLOBAL transaction_read_only = 1") // fails require.Error(t, tk.ExecToErr("SET GLOBAL tidb_enable_noop_functions = 0")) // reset for rest of tests. tk.MustExec("SET GLOBAL transaction_read_only = 0") tk.MustExec("SET GLOBAL tidb_enable_noop_functions = 0") tk.MustExec("set global read_only = 0") tk.MustQuery("select @@global.read_only;").Check(testkit.Rows("0")) tk.MustExec("set global read_only = off") tk.MustQuery("select @@global.read_only;").Check(testkit.Rows("0")) tk.MustExec("SET global tidb_enable_noop_functions = 1") tk.MustExec("set global read_only = 1") tk.MustQuery("select @@global.read_only;").Check(testkit.Rows("1")) tk.MustExec("set global read_only = on") tk.MustQuery("select @@global.read_only;").Check(testkit.Rows("1")) require.Error(t, tk.ExecToErr("set global read_only = abc")) } // https://github.com/pingcap/tidb/issues/29670 func TestDefaultBehavior(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustQuery("SELECT @@default_storage_engine").Check(testkit.Rows("InnoDB")) tk.MustExec("SET GLOBAL default_storage_engine = 'somethingweird'") tk.MustExec("SET default_storage_engine = 'MyISAM'") tk.MustQuery("SELECT @@default_storage_engine").Check(testkit.Rows("MyISAM")) tk.MustExec("SET default_storage_engine = DEFAULT") // reads from global value tk.MustQuery("SELECT @@default_storage_engine").Check(testkit.Rows("somethingweird")) tk.MustExec("SET @@SESSION.default_storage_engine = @@GLOBAL.default_storage_engine") // example from MySQL manual tk.MustQuery("SELECT @@default_storage_engine").Check(testkit.Rows("somethingweird")) tk.MustExec("SET GLOBAL default_storage_engine = 'somethingweird2'") tk.MustExec("SET default_storage_engine = @@GLOBAL.default_storage_engine") // variation of example tk.MustQuery("SELECT @@default_storage_engine").Check(testkit.Rows("somethingweird2")) tk.MustExec("SET default_storage_engine = DEFAULT") // restore default again for session global tk.MustExec("SET GLOBAL default_storage_engine = DEFAULT") // restore default for global tk.MustQuery("SELECT @@SESSION.default_storage_engine, @@GLOBAL.default_storage_engine").Check(testkit.Rows("somethingweird2 InnoDB")) // Try sql_mode option which has validation err := tk.ExecToErr("SET GLOBAL sql_mode = 'DEFAULT'") // illegal now require.EqualError(t, err, `ERROR 1231 (42000): Variable 'sql_mode' can't be set to the value of 'DEFAULT'`) tk.MustExec("SET GLOBAL sql_mode = DEFAULT") } func TestTiDBReadOnly(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) // turn on tidb_restricted_read_only should turn on tidb_super_read_only tk.MustExec("SET GLOBAL tidb_restricted_read_only = ON") tk.MustQuery("SELECT @@GLOBAL.tidb_super_read_only").Check(testkit.Rows("1")) // can't turn off tidb_super_read_only if tidb_restricted_read_only is on err := tk.ExecToErr("SET GLOBAL tidb_super_read_only = OFF") require.Error(t, err) require.Equal(t, "can't turn off tidb_super_read_only when tidb_restricted_read_only is on", err.Error()) // turn off tidb_restricted_read_only won't affect tidb_super_read_only tk.MustExec("SET GLOBAL tidb_restricted_read_only = OFF") tk.MustQuery("SELECT @@GLOBAL.tidb_restricted_read_only").Check(testkit.Rows("0")) tk.MustQuery("SELECT @@GLOBAL.tidb_super_read_only").Check(testkit.Rows("1")) // it is ok to turn off tidb_super_read_only now tk.MustExec("SET GLOBAL tidb_super_read_only = OFF") tk.MustQuery("SELECT @@GLOBAL.tidb_super_read_only").Check(testkit.Rows("0")) } func TestRemovedSysVars(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) // test for tidb_enable_noop_functions // In SET context, it just noops: tk.MustExec(`SET tidb_enable_global_temporary_table = 1`) tk.MustExec(`SET tidb_slow_log_masking = 1`) tk.MustExec(`SET GLOBAL tidb_enable_global_temporary_table = 1`) tk.MustExec(`SET GLOBAL tidb_slow_log_masking = 1`) // In SELECT context it returns a specifc error // (to avoid presenting dummy data) tk.MustGetErrCode("SELECT @@tidb_slow_log_masking", errno.ErrVariableNoLongerSupported) tk.MustGetErrCode("SELECT @@tidb_enable_global_temporary_table", errno.ErrVariableNoLongerSupported) } func TestSetClusterConfig(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("use test") serversInfo := []infoschema.ServerInfo{ {ServerType: "tidb", Address: "127.0.0.1:1111", StatusAddr: "127.0.0.1:1111"}, {ServerType: "tidb", Address: "127.0.0.1:2222", StatusAddr: "127.0.0.1:2222"}, {ServerType: "pd", Address: "127.0.0.1:3333", StatusAddr: "127.0.0.1:3333"}, {ServerType: "pd", Address: "127.0.0.1:4444", StatusAddr: "127.0.0.1:4444"}, {ServerType: "tikv", Address: "127.0.0.1:5555", StatusAddr: "127.0.0.1:5555"}, {ServerType: "tikv", Address: "127.0.0.1:6666", StatusAddr: "127.0.0.1:6666"}, {ServerType: "tiflash", Address: "127.0.0.1:3933", StatusAddr: "127.0.0.1:7777"}, } var serverInfoErr error serverInfoFunc := func(sessionctx.Context) ([]infoschema.ServerInfo, error) { return serversInfo, serverInfoErr } tk.Session().SetValue(executor.TestSetConfigServerInfoKey, serverInfoFunc) require.EqualError(t, tk.ExecToErr("set config xxx log.level='info'"), "unknown type xxx") require.EqualError(t, tk.ExecToErr("set config tidb log.level='info'"), "TiDB doesn't support to change configs online, please use SQL variables") require.EqualError(t, tk.ExecToErr("set config '127.0.0.1:1111' log.level='info'"), "TiDB doesn't support to change configs online, please use SQL variables") require.EqualError(t, tk.ExecToErr("set config '127.a.b.c:1234' log.level='info'"), "invalid instance 127.a.b.c:1234") // name doesn't resolve. require.EqualError(t, tk.ExecToErr("set config 'example.com:1111' log.level='info'"), "instance example.com:1111 is not found in this cluster") // name resolves. require.EqualError(t, tk.ExecToErr("set config tikv log.level=null"), "can't set config to null") require.EqualError(t, tk.ExecToErr("set config '1.1.1.1:1111' log.level='info'"), "instance 1.1.1.1:1111 is not found in this cluster") require.EqualError(t, tk.ExecToErr("set config tikv `raftstore.max-peer-down-duration`=DEFAULT"), "Unknown DEFAULT for SET CONFIG") require.ErrorContains(t, tk.ExecToErr("set config tiflash `server.snap-max-write-bytes-per-sec`='500MB'"), "This command can only change config items begin with 'raftstore-proxy'") httpCnt := 0 tk.Session().SetValue(executor.TestSetConfigHTTPHandlerKey, func(*http.Request) (*http.Response, error) { httpCnt++ return &http.Response{StatusCode: http.StatusOK, Body: io.NopCloser(nil)}, nil }) tk.MustExec("set config tikv log.level='info'") require.Equal(t, 2, httpCnt) httpCnt = 0 tk.MustExec("set config '127.0.0.1:5555' log.level='info'") require.Equal(t, 1, httpCnt) httpCnt = 0 tk.Session().SetValue(executor.TestSetConfigHTTPHandlerKey, func(req *http.Request) (*http.Response, error) { httpCnt++ body, err := ioutil.ReadAll(req.Body) require.NoError(t, err) // The `raftstore.` prefix is stripped. require.JSONEq(t, `{"server.snap-max-write-bytes-per-sec":"500MB"}`, string(body)) return &http.Response{StatusCode: http.StatusOK, Body: io.NopCloser(nil)}, nil }) tk.MustExec("set config tiflash `raftstore-proxy.server.snap-max-write-bytes-per-sec`='500MB'") require.Equal(t, 1, httpCnt) httpCnt = 0 tk.Session().SetValue(executor.TestSetConfigHTTPHandlerKey, func(*http.Request) (*http.Response, error) { return nil, errors.New("something wrong") }) tk.MustExec("set config tikv log.level='info'") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 1105 something wrong", "Warning 1105 something wrong")) tk.Session().SetValue(executor.TestSetConfigHTTPHandlerKey, func(*http.Request) (*http.Response, error) { return &http.Response{StatusCode: http.StatusBadRequest, Body: io.NopCloser(bytes.NewBufferString("WRONG"))}, nil }) tk.MustExec("set config tikv log.level='info'") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 1105 bad request to http://127.0.0.1:5555/config: WRONG", "Warning 1105 bad request to http://127.0.0.1:6666/config: WRONG")) } func TestSetClusterConfigJSONData(t *testing.T) { var d types.MyDecimal require.NoError(t, d.FromFloat64(123.456)) tyBool := types.NewFieldType(mysql.TypeTiny) tyBool.AddFlag(mysql.IsBooleanFlag) cases := []struct { val expression.Expression result string succ bool }{ {&expression.Constant{Value: types.NewIntDatum(1), RetType: tyBool}, `{"k":true}`, true}, {&expression.Constant{Value: types.NewIntDatum(0), RetType: tyBool}, `{"k":false}`, true}, {&expression.Constant{Value: types.NewIntDatum(2333), RetType: types.NewFieldType(mysql.TypeLong)}, `{"k":2333}`, true}, {&expression.Constant{Value: types.NewFloat64Datum(23.33), RetType: types.NewFieldType(mysql.TypeDouble)}, `{"k":23.33}`, true}, {&expression.Constant{Value: types.NewStringDatum("abcd"), RetType: types.NewFieldType(mysql.TypeString)}, `{"k":"abcd"}`, true}, {&expression.Constant{Value: types.NewDecimalDatum(&d), RetType: types.NewFieldType(mysql.TypeNewDecimal)}, `{"k":123.456}`, true}, {&expression.Constant{Value: types.NewDatum(nil), RetType: types.NewFieldType(mysql.TypeLonglong)}, "", false}, {&expression.Constant{RetType: types.NewFieldType(mysql.TypeJSON)}, "", false}, // unsupported type {nil, "", false}, {&expression.Constant{Value: types.NewDatum(`["no","no","lz4","lz4","lz4","zstd","zstd"]`), RetType: types.NewFieldType(mysql.TypeString)}, `{"k":"[\"no\",\"no\",\"lz4\",\"lz4\",\"lz4\",\"zstd\",\"zstd\"]"}`, true}, } ctx := mock.NewContext() for _, c := range cases { result, err := executor.ConvertConfigItem2JSON(ctx, "k", c.val) if c.succ { require.Equal(t, result, c.result) } else { require.Error(t, err) } } } func TestSetTopSQLVariables(t *testing.T) { require.NoError(t, failpoint.Enable("github.com/pingcap/tidb/domain/skipLoadSysVarCacheLoop", `return(true)`)) defer func() { require.NoError(t, failpoint.Disable("github.com/pingcap/tidb/domain/skipLoadSysVarCacheLoop")) }() store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("set @@global.tidb_enable_top_sql='On';") tk.MustQuery("select @@global.tidb_enable_top_sql;").Check(testkit.Rows("1")) tk.MustExec("set @@global.tidb_enable_top_sql='off';") tk.MustQuery("select @@global.tidb_enable_top_sql;").Check(testkit.Rows("0")) tk.MustExec("set @@global.tidb_top_sql_max_time_series_count=20;") tk.MustQuery("select @@global.tidb_top_sql_max_time_series_count;").Check(testkit.Rows("20")) require.Equal(t, int64(20), topsqlstate.GlobalState.MaxStatementCount.Load()) err := tk.ExecToErr("set @@global.tidb_top_sql_max_time_series_count='abc';") require.EqualError(t, err, "[variable:1232]Incorrect argument type to variable 'tidb_top_sql_max_time_series_count'") tk.MustExec("set @@global.tidb_top_sql_max_time_series_count='-1';") tk.MustQuery("select @@global.tidb_top_sql_max_time_series_count;").Check(testkit.Rows("1")) tk.MustExec("set @@global.tidb_top_sql_max_time_series_count='5001';") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_top_sql_max_time_series_count value: '5001'")) tk.MustQuery("select @@global.tidb_top_sql_max_time_series_count;").Check(testkit.Rows("5000")) tk.MustExec("set @@global.tidb_top_sql_max_time_series_count=20;") tk.MustQuery("select @@global.tidb_top_sql_max_time_series_count;").Check(testkit.Rows("20")) require.Equal(t, int64(20), topsqlstate.GlobalState.MaxStatementCount.Load()) tk.MustExec("set @@global.tidb_top_sql_max_meta_count=10000;") tk.MustQuery("select @@global.tidb_top_sql_max_meta_count;").Check(testkit.Rows("10000")) require.Equal(t, int64(10000), topsqlstate.GlobalState.MaxCollect.Load()) err = tk.ExecToErr("set @@global.tidb_top_sql_max_meta_count='abc';") require.EqualError(t, err, "[variable:1232]Incorrect argument type to variable 'tidb_top_sql_max_meta_count'") tk.MustExec("set @@global.tidb_top_sql_max_meta_count='-1';") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_top_sql_max_meta_count value: '-1'")) tk.MustQuery("select @@global.tidb_top_sql_max_meta_count;").Check(testkit.Rows("1")) tk.MustExec("set @@global.tidb_top_sql_max_meta_count='10001';") tk.MustQuery(`show warnings`).Check(testkit.Rows("Warning 1292 Truncated incorrect tidb_top_sql_max_meta_count value: '10001'")) tk.MustQuery("select @@global.tidb_top_sql_max_meta_count;").Check(testkit.Rows("10000")) tk.MustExec("set @@global.tidb_top_sql_max_meta_count=5000;") tk.MustQuery("select @@global.tidb_top_sql_max_meta_count;").Check(testkit.Rows("5000")) require.Equal(t, int64(5000), topsqlstate.GlobalState.MaxCollect.Load()) tk.MustQuery("show variables like '%top_sql%'").Check(testkit.Rows("tidb_enable_top_sql OFF", "tidb_top_sql_max_meta_count 5000", "tidb_top_sql_max_time_series_count 20")) tk.MustQuery("show global variables like '%top_sql%'").Check(testkit.Rows("tidb_enable_top_sql OFF", "tidb_top_sql_max_meta_count 5000", "tidb_top_sql_max_time_series_count 20")) } func TestPreparePlanCacheValid(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) // global scope tk.MustQuery("select @@global.tidb_prepared_plan_cache_size").Check(testkit.Rows("100")) // default value tk.MustExec("SET GLOBAL tidb_prepared_plan_cache_size = 0") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 1292 Truncated incorrect tidb_prepared_plan_cache_size value: '0'")) tk.MustQuery("select @@global.tidb_prepared_plan_cache_size").Check(testkit.Rows("1")) tk.MustExec("SET GLOBAL tidb_prepared_plan_cache_size = 2") tk.MustQuery("select @@global.tidb_prepared_plan_cache_size").Check(testkit.Rows("2")) // session scope tk.MustQuery("select @@session.tidb_prepared_plan_cache_size").Check(testkit.Rows("100")) // default value tk.MustExec("SET SESSION tidb_prepared_plan_cache_size = 0") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 1292 Truncated incorrect tidb_prepared_plan_cache_size value: '0'")) tk.MustQuery("select @@session.tidb_prepared_plan_cache_size").Check(testkit.Rows("1")) tk.MustExec("SET SESSION tidb_prepared_plan_cache_size = 2") tk.MustQuery("select @@session.tidb_prepared_plan_cache_size").Check(testkit.Rows("2")) tk.MustExec("SET GLOBAL tidb_prepared_plan_cache_memory_guard_ratio = -0.1") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 1292 Truncated incorrect tidb_prepared_plan_cache_memory_guard_ratio value: '-0.1'")) tk.MustQuery("select @@global.tidb_prepared_plan_cache_memory_guard_ratio").Check(testkit.Rows("0")) tk.MustExec("SET GLOBAL tidb_prepared_plan_cache_memory_guard_ratio = 2.2") tk.MustQuery("show warnings").Check(testkit.Rows( "Warning 1292 Truncated incorrect tidb_prepared_plan_cache_memory_guard_ratio value: '2.2'")) tk.MustQuery("select @@global.tidb_prepared_plan_cache_memory_guard_ratio").Check(testkit.Rows("1")) tk.MustExec("SET GLOBAL tidb_prepared_plan_cache_memory_guard_ratio = 0.5") tk.MustQuery("select @@global.tidb_prepared_plan_cache_memory_guard_ratio").Check(testkit.Rows("0.5")) tk.MustExec("SET GLOBAL tidb_enable_prepared_plan_cache = 0") tk.MustQuery("select @@global.tidb_enable_prepared_plan_cache").Check(testkit.Rows("0")) tk.MustExec("SET GLOBAL tidb_enable_prepared_plan_cache = 1") tk.MustQuery("select @@global.tidb_enable_prepared_plan_cache").Check(testkit.Rows("1")) tk.MustExec("SET GLOBAL tidb_enable_prepared_plan_cache = 0") tk.MustQuery("select @@global.tidb_enable_prepared_plan_cache").Check(testkit.Rows("0")) } func TestInstanceScopeSwitching(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("use test") // enable 'switching' to SESSION variables tk.MustExec("set tidb_enable_legacy_instance_scope = 1") tk.MustExec("set tidb_general_log = 1") tk.MustQuery(`show warnings`).Check(testkit.Rows(fmt.Sprintf("Warning %d modifying tidb_general_log will require SET GLOBAL in a future version of TiDB", errno.ErrInstanceScope))) // disable 'switching' to SESSION variables tk.MustExec("set tidb_enable_legacy_instance_scope = 0") tk.MustGetErrCode("set tidb_general_log = 1", errno.ErrGlobalVariable) } func TestGcMaxWaitTime(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("use test") tk.MustExec("set global tidb_gc_max_wait_time = 1000") tk.MustExec("set global tidb_gc_life_time = \"72h\"") tk.MustExec("set global tidb_gc_life_time = \"24h\"") tk.MustExec("set global tidb_gc_life_time = \"10m\"") tk.MustExec("set global tidb_gc_max_wait_time = 86400") tk.MustExec("set global tidb_gc_life_time = \"72h\"") tk.MustExec("set global tidb_gc_max_wait_time = 1000") } func TestTiFlashFineGrainedShuffle(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("use test") // Default is 0. tk.MustQuery("select @@tiflash_fine_grained_shuffle_stream_count;").Check(testkit.Rows("0")) tk.MustExec("set @@tiflash_fine_grained_shuffle_stream_count = 0") tk.MustQuery("select @@tiflash_fine_grained_shuffle_stream_count;").Check(testkit.Rows("0")) // Min val is -1. tk.MustExec("set @@tiflash_fine_grained_shuffle_stream_count = -2") tk.MustQuery("select @@tiflash_fine_grained_shuffle_stream_count;").Check(testkit.Rows("-1")) tk.MustExec("set @@tiflash_fine_grained_shuffle_stream_count = 0") tk.MustQuery("select @@tiflash_fine_grained_shuffle_stream_count;").Check(testkit.Rows("0")) tk.MustExec("set @@tiflash_fine_grained_shuffle_stream_count = 1024") tk.MustQuery("select @@tiflash_fine_grained_shuffle_stream_count;").Check(testkit.Rows("1024")) // Max val is 1024. tk.MustExec("set @@tiflash_fine_grained_shuffle_stream_count = 1025") tk.MustQuery("select @@tiflash_fine_grained_shuffle_stream_count;").Check(testkit.Rows("1024")) // Default is 8192. tk.MustQuery("select @@tiflash_fine_grained_shuffle_batch_size;").Check(testkit.Rows("8192")) // Min is 1. tk.MustExec("set @@tiflash_fine_grained_shuffle_batch_size = 0") tk.MustQuery("select @@tiflash_fine_grained_shuffle_batch_size;").Check(testkit.Rows("1")) tk.MustExec("set @@tiflash_fine_grained_shuffle_batch_size = -1") tk.MustQuery("select @@tiflash_fine_grained_shuffle_batch_size;").Check(testkit.Rows("1")) // Max is uint64_max. tk.MustExec("set @@tiflash_fine_grained_shuffle_batch_size = 18446744073709551615") tk.MustQuery("select @@tiflash_fine_grained_shuffle_batch_size;").Check(testkit.Rows("18446744073709551615")) // Test set global. tk.MustExec("set global tiflash_fine_grained_shuffle_stream_count = -1") tk.MustExec("set global tiflash_fine_grained_shuffle_batch_size = 8192") } func TestSetTiFlashFastScanVariable(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("use test") tk.MustExec("drop table if exists t") tk.MustExec("create table t(a int);") tk.MustExec("insert into t values(1);") // check the default tiflash read mode tk.MustQuery("select @@session.tiflash_fastscan").Check(testkit.Rows("0")) tk.MustQuery("select @@global.tiflash_fastscan").Check(testkit.Rows("0")) tk.MustExec("set @@tiflash_fastscan=ON;") tk.MustQuery("select @@session.tiflash_fastscan").Check(testkit.Rows("1")) tk.MustExec("set GLOBAL tiflash_fastscan=OFF;") tk.MustQuery("select @@global.tiflash_fastscan").Check(testkit.Rows("0")) } func TestSetPlanCacheMemoryMonitor(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("use test") tk.MustQuery("select @@session.tidb_enable_prepared_plan_cache_memory_monitor").Check(testkit.Rows("1")) tk.MustQuery("select @@global.tidb_enable_prepared_plan_cache_memory_monitor").Check(testkit.Rows("1")) tk.MustExec("set @@session.tidb_enable_prepared_plan_cache_memory_monitor=OFF;") tk.MustQuery("select @@session.tidb_enable_prepared_plan_cache_memory_monitor").Check(testkit.Rows("0")) tk.MustExec("set @@session.tidb_enable_prepared_plan_cache_memory_monitor=1;") tk.MustQuery("select @@session.tidb_enable_prepared_plan_cache_memory_monitor").Check(testkit.Rows("1")) tk.MustExec("set @@global.tidb_enable_prepared_plan_cache_memory_monitor=off;") tk.MustQuery("select @@global.tidb_enable_prepared_plan_cache_memory_monitor").Check(testkit.Rows("0")) } func TestSetChunkReuseVariable(t *testing.T) { store := testkit.CreateMockStore(t) tk := testkit.NewTestKit(t, store) tk.MustExec("set @@tidb_enable_reuse_chunk=ON;") tk.MustQuery("select @@session.tidb_enable_reuse_chunk").Check(testkit.Rows("1")) tk.MustExec("set GLOBAL tidb_enable_reuse_chunk=ON;") tk.MustQuery("select @@global.tidb_enable_reuse_chunk").Check(testkit.Rows("1")) tk.MustExec("set @@tidb_enable_reuse_chunk=OFF;") tk.MustQuery("select @@session.tidb_enable_reuse_chunk").Check(testkit.Rows("0")) tk.MustExec("set GLOBAL tidb_enable_reuse_chunk=OFF;") tk.MustQuery("select @@global.tidb_enable_reuse_chunk").Check(testkit.Rows("0")) // error value tk.MustGetErrCode("set @@tidb_enable_reuse_chunk=s;", errno.ErrWrongValueForVar) }