diff --git a/br/pkg/lightning/backend/kv/session.go b/br/pkg/lightning/backend/kv/session.go
index 54a761e3d1470..1cc261b677fe4 100644
--- a/br/pkg/lightning/backend/kv/session.go
+++ b/br/pkg/lightning/backend/kv/session.go
@@ -253,8 +253,11 @@ func NewSession(options *SessionOptions, logger log.Logger) sessionctx.Context {
 }
 
 func newSession(options *SessionOptions, logger log.Logger) *session {
+	s := &session{
+		values: make(map[fmt.Stringer]interface{}, 1),
+	}
 	sqlMode := options.SQLMode
-	vars := variable.NewSessionVars()
+	vars := variable.NewSessionVars(s)
 	vars.SkipUTF8Check = true
 	vars.StmtCtx.InInsertStmt = true
 	vars.StmtCtx.BatchCheck = true
@@ -289,10 +292,7 @@ func newSession(options *SessionOptions, logger log.Logger) *session {
 			log.ShortError(err))
 	}
 	vars.TxnCtx = nil
-	s := &session{
-		vars:   vars,
-		values: make(map[fmt.Stringer]interface{}, 1),
-	}
+	s.vars = vars
 	s.txn.kvPairs = &KvPairs{}
 
 	return s
diff --git a/distsql/distsql_test.go b/distsql/distsql_test.go
index 50e21f6b66702..52aa62ba112fa 100644
--- a/distsql/distsql_test.go
+++ b/distsql/distsql_test.go
@@ -321,7 +321,7 @@ func createSelectNormalByBenchmarkTest(batch, totalRows int, ctx sessionctx.Cont
 		SetDAGRequest(&tipb.DAGRequest{}).
 		SetDesc(false).
 		SetKeepOrder(false).
-		SetFromSessionVars(variable.NewSessionVars()).
+		SetFromSessionVars(variable.NewSessionVars(nil)).
 		SetMemTracker(memory.NewTracker(-1, -1)).
 		Build()
 
@@ -390,7 +390,7 @@ func createSelectNormal(t *testing.T, batch, totalRows int, planIDs []int, sctx
 		SetDAGRequest(&tipb.DAGRequest{}).
 		SetDesc(false).
 		SetKeepOrder(false).
-		SetFromSessionVars(variable.NewSessionVars()).
+		SetFromSessionVars(variable.NewSessionVars(nil)).
 		SetMemTracker(memory.NewTracker(-1, -1)).
 		Build()
 	require.NoError(t, err)
diff --git a/distsql/request_builder_test.go b/distsql/request_builder_test.go
index 53ea7ff4a3c56..0a11b9e04512c 100644
--- a/distsql/request_builder_test.go
+++ b/distsql/request_builder_test.go
@@ -235,7 +235,7 @@ func TestRequestBuilder1(t *testing.T) {
 		SetDAGRequest(&tipb.DAGRequest{}).
 		SetDesc(false).
 		SetKeepOrder(false).
-		SetFromSessionVars(variable.NewSessionVars()).
+		SetFromSessionVars(variable.NewSessionVars(nil)).
 		Build()
 	require.NoError(t, err)
 	expect := &kv.Request{
@@ -318,7 +318,7 @@ func TestRequestBuilder2(t *testing.T) {
 		SetDAGRequest(&tipb.DAGRequest{}).
 		SetDesc(false).
 		SetKeepOrder(false).
-		SetFromSessionVars(variable.NewSessionVars()).
+		SetFromSessionVars(variable.NewSessionVars(nil)).
 		Build()
 	require.NoError(t, err)
 	expect := &kv.Request{
@@ -371,7 +371,7 @@ func TestRequestBuilder3(t *testing.T) {
 		SetDAGRequest(&tipb.DAGRequest{}).
 		SetDesc(false).
 		SetKeepOrder(false).
-		SetFromSessionVars(variable.NewSessionVars()).
+		SetFromSessionVars(variable.NewSessionVars(nil)).
 		Build()
 	require.NoError(t, err)
 	expect := &kv.Request{
@@ -436,7 +436,7 @@ func TestRequestBuilder4(t *testing.T) {
 		SetDAGRequest(&tipb.DAGRequest{}).
 		SetDesc(false).
 		SetKeepOrder(false).
-		SetFromSessionVars(variable.NewSessionVars()).
+		SetFromSessionVars(variable.NewSessionVars(nil)).
 		Build()
 	require.NoError(t, err)
 	expect := &kv.Request{
@@ -543,7 +543,7 @@ func TestRequestBuilder7(t *testing.T) {
 		// copy iterator variable into a new variable, see issue #27779
 		replicaRead := replicaRead
 		t.Run(replicaRead.src, func(t *testing.T) {
-			vars := variable.NewSessionVars()
+			vars := variable.NewSessionVars(nil)
 			vars.SetReplicaRead(replicaRead.replicaReadType)
 
 			concurrency := 10
@@ -573,7 +573,7 @@ func TestRequestBuilder7(t *testing.T) {
 }
 
 func TestRequestBuilder8(t *testing.T) {
-	sv := variable.NewSessionVars()
+	sv := variable.NewSessionVars(nil)
 	actual, err := (&RequestBuilder{}).
 		SetFromSessionVars(sv).
 		Build()
@@ -640,7 +640,7 @@ func TestIndexRangesToKVRangesWithFbs(t *testing.T) {
 }
 
 func TestScanLimitConcurrency(t *testing.T) {
-	vars := variable.NewSessionVars()
+	vars := variable.NewSessionVars(nil)
 	for _, tt := range []struct {
 		tp          tipb.ExecType
 		limit       uint64
diff --git a/executor/executor_pkg_test.go b/executor/executor_pkg_test.go
index 3944948fbcfc8..6e8f2ba1e2921 100644
--- a/executor/executor_pkg_test.go
+++ b/executor/executor_pkg_test.go
@@ -258,7 +258,7 @@ func getGrowing(m aggPartialResultMapper) bool {
 }
 
 func TestFilterTemporaryTableKeys(t *testing.T) {
-	vars := variable.NewSessionVars()
+	vars := variable.NewSessionVars(nil)
 	const tableID int64 = 3
 	vars.TxnCtx = &variable.TransactionContext{
 		TxnCtxNoNeedToRestore: variable.TxnCtxNoNeedToRestore{
diff --git a/session/bootstrap_test.go b/session/bootstrap_test.go
index 6c3b459d8ee72..68ce4e8d3ac44 100644
--- a/session/bootstrap_test.go
+++ b/session/bootstrap_test.go
@@ -141,7 +141,7 @@ func TestBootstrapWithError(t *testing.T) {
 	{
 		se := &session{
 			store:       store,
-			sessionVars: variable.NewSessionVars(),
+			sessionVars: variable.NewSessionVars(nil),
 		}
 		se.functionUsageMu.builtinFunctionUsage = make(telemetry.BuiltinFunctionsUsage)
 		se.txn.init()
diff --git a/session/schema_amender_test.go b/session/schema_amender_test.go
index d2d746a8887b2..e82faba8e6e56 100644
--- a/session/schema_amender_test.go
+++ b/session/schema_amender_test.go
@@ -255,7 +255,7 @@ func TestAmendCollectAndGenMutations(t *testing.T) {
 	defer func() { require.NoError(t, store.Close()) }()
 	se := &session{
 		store:       store,
-		sessionVars: variable.NewSessionVars(),
+		sessionVars: variable.NewSessionVars(nil),
 	}
 	se.mu.values = make(map[fmt.Stringer]interface{})
 	domain.BindDomain(se, domain.NewMockDomain())
diff --git a/session/session.go b/session/session.go
index 3ee97f078f5b6..e40b82cf07052 100644
--- a/session/session.go
+++ b/session/session.go
@@ -2902,13 +2902,14 @@ func createSessionWithOpt(store kv.Storage, opt *Opt) (*session, error) {
 	}
 	s := &session{
 		store:                 store,
-		sessionVars:           variable.NewSessionVars(),
 		ddlOwnerManager:       dom.DDL().OwnerManager(),
 		client:                store.GetClient(),
 		mppClient:             store.GetMPPClient(),
 		stmtStats:             stmtstats.CreateStatementStats(),
 		sessionStatesHandlers: make(map[sessionstates.SessionStateType]sessionctx.SessionStatesHandler),
 	}
+	s.sessionVars = variable.NewSessionVars(s)
+
 	s.functionUsageMu.builtinFunctionUsage = make(telemetry.BuiltinFunctionsUsage)
 	if opt != nil && opt.PreparedPlanCache != nil {
 		s.preparedPlanCache = opt.PreparedPlanCache
@@ -2936,7 +2937,7 @@ func createSessionWithOpt(store kv.Storage, opt *Opt) (*session, error) {
 func CreateSessionWithDomain(store kv.Storage, dom *domain.Domain) (*session, error) {
 	s := &session{
 		store:                 store,
-		sessionVars:           variable.NewSessionVars(),
+		sessionVars:           variable.NewSessionVars(nil),
 		client:                store.GetClient(),
 		mppClient:             store.GetMPPClient(),
 		stmtStats:             stmtstats.CreateStatementStats(),
diff --git a/sessionctx/variable/mock_globalaccessor.go b/sessionctx/variable/mock_globalaccessor.go
index 969892dc6f736..c4bb86748e9fd 100644
--- a/sessionctx/variable/mock_globalaccessor.go
+++ b/sessionctx/variable/mock_globalaccessor.go
@@ -43,7 +43,7 @@ func NewMockGlobalAccessor4Tests() *MockGlobalAccessor {
 	// mock.SessionVars = vars
 	// vars.GlobalVarsAccessor = mock
 
-	tmp.SessionVars = NewSessionVars()
+	tmp.SessionVars = NewSessionVars(nil)
 
 	// Set all sysvars to the default value
 	for k, sv := range GetSysVars() {
diff --git a/sessionctx/variable/mock_globalaccessor_test.go b/sessionctx/variable/mock_globalaccessor_test.go
index f3a2051d38802..57ed4931a342d 100644
--- a/sessionctx/variable/mock_globalaccessor_test.go
+++ b/sessionctx/variable/mock_globalaccessor_test.go
@@ -23,7 +23,7 @@ import (
 
 func TestMockAPI(t *testing.T) {
 	defer view.Stop()
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	mock := NewMockGlobalAccessor4Tests()
 	mock.SessionVars = vars
 	vars.GlobalVarsAccessor = mock
diff --git a/sessionctx/variable/session.go b/sessionctx/variable/session.go
index db3606baf60b3..c4dc136ea3dec 100644
--- a/sessionctx/variable/session.go
+++ b/sessionctx/variable/session.go
@@ -598,6 +598,11 @@ func (s *SessionVars) GetUserVarType(name string) (*types.FieldType, bool) {
 	return ft, ok
 }
 
+// HookContext contains the necessary variables for executing set/get hook
+type HookContext interface {
+	GetStore() kv.Storage
+}
+
 // SessionVars is to handle user-defined or global variables in the current session.
 type SessionVars struct {
 	Concurrency
@@ -1288,6 +1293,8 @@ type SessionVars struct {
 
 	// LastPlanReplayerToken indicates the last plan replayer token
 	LastPlanReplayerToken string
+
+	HookContext
 }
 
 // GetPreparedStmtByName returns the prepared statement specified by stmtName.
@@ -1478,7 +1485,7 @@ func (connInfo *ConnectionInfo) IsSecureTransport() bool {
 }
 
 // NewSessionVars creates a session vars object.
-func NewSessionVars() *SessionVars {
+func NewSessionVars(hctx HookContext) *SessionVars {
 	vars := &SessionVars{
 		userVars: struct {
 			lock   sync.RWMutex
@@ -1580,6 +1587,7 @@ func NewSessionVars() *SessionVars {
 		TiFlashFastScan:               DefTiFlashFastScan,
 		EnableTiFlashReadForWriteStmt: DefTiDBEnableTiFlashReadForWriteStmt,
 		ForeignKeyChecks:              DefTiDBForeignKeyChecks,
+		HookContext:                   hctx,
 	}
 	vars.KVVars = tikvstore.NewVariables(&vars.Killed)
 	vars.Concurrency = Concurrency{
diff --git a/sessionctx/variable/session_test.go b/sessionctx/variable/session_test.go
index 6dc6812f85a03..91f1394499c97 100644
--- a/sessionctx/variable/session_test.go
+++ b/sessionctx/variable/session_test.go
@@ -26,6 +26,7 @@ import (
 	plannercore "github.com/pingcap/tidb/planner/core"
 	"github.com/pingcap/tidb/sessionctx/stmtctx"
 	"github.com/pingcap/tidb/sessionctx/variable"
+	"github.com/pingcap/tidb/testkit"
 	"github.com/pingcap/tidb/util/execdetails"
 	"github.com/pingcap/tidb/util/mock"
 	"github.com/stretchr/testify/require"
@@ -33,7 +34,7 @@ import (
 )
 
 func TestSetSystemVariable(t *testing.T) {
-	v := variable.NewSessionVars()
+	v := variable.NewSessionVars(nil)
 	v.GlobalVarsAccessor = variable.NewMockGlobalAccessor4Tests()
 	v.TimeZone = time.UTC
 	mtx := new(sync.Mutex)
@@ -291,7 +292,7 @@ func TestIsolationRead(t *testing.T) {
 	config.UpdateGlobal(func(conf *config.Config) {
 		conf.IsolationRead.Engines = []string{"tiflash", "tidb"}
 	})
-	sessVars := variable.NewSessionVars()
+	sessVars := variable.NewSessionVars(nil)
 	_, ok := sessVars.IsolationReadEngines[kv.TiDB]
 	require.True(t, ok)
 	_, ok = sessVars.IsolationReadEngines[kv.TiKV]
@@ -393,7 +394,7 @@ func TestTransactionContextSavepoint(t *testing.T) {
 }
 
 func TestGeneralPlanCacheStmt(t *testing.T) {
-	sessVars := variable.NewSessionVars()
+	sessVars := variable.NewSessionVars(nil)
 	sessVars.GeneralPlanCacheSize = 100
 	sql1 := "select * from t where a>?"
 	sql2 := "select * from t where a<?"
@@ -408,3 +409,16 @@ func TestGeneralPlanCacheStmt(t *testing.T) {
 	require.NotNil(t, sessVars.GetGeneralPlanCacheStmt(sql1))
 	require.NotNil(t, sessVars.GetGeneralPlanCacheStmt(sql2))
 }
+
+func TestHookContext(t *testing.T) {
+	store := testkit.CreateMockStore(t)
+	ctx := mock.NewContext()
+	ctx.Store = store
+	sv := variable.SysVar{Scope: variable.ScopeGlobal | variable.ScopeSession, Name: "testhooksysvar", Value: variable.On, Type: variable.TypeBool, SetSession: func(s *variable.SessionVars, val string) error {
+		require.Equal(t, s.GetStore(), store)
+		return nil
+	}}
+	variable.RegisterSysVar(&sv)
+
+	ctx.GetSessionVars().SetSystemVar("testhooksysvar", "test")
+}
diff --git a/sessionctx/variable/sysvar_test.go b/sessionctx/variable/sysvar_test.go
index a3aadde315370..de70fe600be78 100644
--- a/sessionctx/variable/sysvar_test.go
+++ b/sessionctx/variable/sysvar_test.go
@@ -30,7 +30,7 @@ import (
 
 func TestSQLSelectLimit(t *testing.T) {
 	sv := GetSysVar(SQLSelectLimit)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := sv.Validate(vars, "-10", ScopeSession)
 	require.NoError(t, err) // it has autoconvert out of range.
 	require.Equal(t, "0", val)
@@ -45,7 +45,7 @@ func TestSQLSelectLimit(t *testing.T) {
 
 func TestSQLModeVar(t *testing.T) {
 	sv := GetSysVar(SQLModeVar)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := sv.Validate(vars, "strict_trans_tabLES  ", ScopeSession)
 	require.NoError(t, err)
 	require.Equal(t, "STRICT_TRANS_TABLES", val)
@@ -78,7 +78,7 @@ func TestSQLModeVar(t *testing.T) {
 
 func TestMaxExecutionTime(t *testing.T) {
 	sv := GetSysVar(MaxExecutionTime)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	val, err := sv.Validate(vars, "-10", ScopeSession)
 	require.NoError(t, err) // it has autoconvert out of range.
@@ -94,7 +94,7 @@ func TestMaxExecutionTime(t *testing.T) {
 
 func TestCollationServer(t *testing.T) {
 	sv := GetSysVar(CollationServer)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	val, err := sv.Validate(vars, "LATIN1_bin", ScopeSession)
 	require.NoError(t, err)
@@ -112,7 +112,7 @@ func TestCollationServer(t *testing.T) {
 
 func TestTimeZone(t *testing.T) {
 	sv := GetSysVar(TimeZone)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	// TiDB uses the Golang TZ library, so TZs are case-sensitive.
 	// Unfortunately this is not strictly MySQL compatible. i.e.
@@ -144,7 +144,7 @@ func TestTimeZone(t *testing.T) {
 
 func TestTxnIsolation(t *testing.T) {
 	sv := GetSysVar(TxnIsolation)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sv.Validate(vars, "on", ScopeSession)
 	require.Equal(t, "[variable:1231]Variable 'tx_isolation' can't be set to the value of 'on'", err.Error())
@@ -172,7 +172,7 @@ func TestTxnIsolation(t *testing.T) {
 	require.Equal(t, "SERIALIZABLE", val)
 
 	// Init TiDBSkipIsolationLevelCheck like what loadCommonGlobalVariables does
-	vars = NewSessionVars()
+	vars = NewSessionVars(nil)
 	require.NoError(t, vars.SetSystemVarWithRelaxedValidation(TiDBSkipIsolationLevelCheck, "1"))
 	val, err = sv.Validate(vars, "Serializable", ScopeSession)
 	require.NoError(t, err)
@@ -181,7 +181,7 @@ func TestTxnIsolation(t *testing.T) {
 
 func TestTiDBMultiStatementMode(t *testing.T) {
 	sv := GetSysVar(TiDBMultiStatementMode)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	val, err := sv.Validate(vars, "on", ScopeSession)
 	require.NoError(t, err)
@@ -203,7 +203,7 @@ func TestTiDBMultiStatementMode(t *testing.T) {
 }
 
 func TestReadOnlyNoop(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	mock := NewMockGlobalAccessor4Tests()
 	mock.SessionVars = vars
 	vars.GlobalVarsAccessor = mock
@@ -254,7 +254,7 @@ func TestSkipInit(t *testing.T) {
 }
 
 func TestSessionGetterFuncs(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := vars.GetSessionOrGlobalSystemVar(TiDBCurrentTS)
 	require.NoError(t, err)
 	require.Equal(t, fmt.Sprintf("%d", vars.TxnCtx.StartTS), val)
@@ -283,7 +283,7 @@ func TestSessionGetterFuncs(t *testing.T) {
 }
 
 func TestInstanceScopedVars(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := vars.GetSessionOrGlobalSystemVar(TiDBGeneralLog)
 	require.NoError(t, err)
 	require.Equal(t, BoolToOnOff(ProcessGeneralLog.Load()), val)
@@ -358,7 +358,7 @@ func TestInstanceScopedVars(t *testing.T) {
 
 func TestSecureAuth(t *testing.T) {
 	sv := GetSysVar(SecureAuth)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	_, err := sv.Validate(vars, "OFF", ScopeGlobal)
 	require.Equal(t, "[variable:1231]Variable 'secure_auth' can't be set to the value of 'OFF'", err.Error())
 	val, err := sv.Validate(vars, "ON", ScopeGlobal)
@@ -368,7 +368,7 @@ func TestSecureAuth(t *testing.T) {
 
 func TestTiDBReplicaRead(t *testing.T) {
 	sv := GetSysVar(TiDBReplicaRead)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := sv.Validate(vars, "follower", ScopeGlobal)
 	require.Equal(t, val, "follower")
 	require.NoError(t, err)
@@ -376,7 +376,7 @@ func TestTiDBReplicaRead(t *testing.T) {
 
 func TestSQLAutoIsNull(t *testing.T) {
 	svSQL, svNoop := GetSysVar(SQLAutoIsNull), GetSysVar(TiDBEnableNoopFuncs)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 	_, err := svSQL.Validate(vars, "ON", ScopeSession)
 	require.True(t, terror.ErrorEqual(err, ErrFunctionsNoopImpl))
@@ -401,7 +401,7 @@ func TestSQLAutoIsNull(t *testing.T) {
 }
 
 func TestLastInsertID(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := vars.GetSessionOrGlobalSystemVar(LastInsertID)
 	require.NoError(t, err)
 	require.Equal(t, val, "0")
@@ -413,7 +413,7 @@ func TestLastInsertID(t *testing.T) {
 }
 
 func TestTimestamp(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := vars.GetSessionOrGlobalSystemVar(Timestamp)
 	require.NoError(t, err)
 	require.NotEqual(t, "", val)
@@ -449,7 +449,7 @@ func TestTimestamp(t *testing.T) {
 }
 
 func TestIdentity(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := vars.GetSessionOrGlobalSystemVar(Identity)
 	require.NoError(t, err)
 	require.Equal(t, val, "0")
@@ -462,7 +462,7 @@ func TestIdentity(t *testing.T) {
 
 func TestLcTimeNamesReadOnly(t *testing.T) {
 	sv := GetSysVar("lc_time_names")
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 	_, err := sv.Validate(vars, "newvalue", ScopeGlobal)
 	require.Error(t, err)
@@ -470,7 +470,7 @@ func TestLcTimeNamesReadOnly(t *testing.T) {
 
 func TestLcMessagesReadOnly(t *testing.T) {
 	sv := GetSysVar("lc_messages")
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 	_, err := sv.Validate(vars, "newvalue", ScopeGlobal)
 	require.Error(t, err)
@@ -478,7 +478,7 @@ func TestLcMessagesReadOnly(t *testing.T) {
 
 func TestDDLWorkers(t *testing.T) {
 	svWorkerCount, svBatchSize := GetSysVar(TiDBDDLReorgWorkerCount), GetSysVar(TiDBDDLReorgBatchSize)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 
 	val, err := svWorkerCount.Validate(vars, "-100", ScopeGlobal)
@@ -503,7 +503,7 @@ func TestDDLWorkers(t *testing.T) {
 }
 
 func TestDefaultCharsetAndCollation(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := vars.GetSessionOrGlobalSystemVar(CharacterSetConnection)
 	require.NoError(t, err)
 	require.Equal(t, val, mysql.DefaultCharset)
@@ -513,7 +513,7 @@ func TestDefaultCharsetAndCollation(t *testing.T) {
 }
 
 func TestIndexMergeSwitcher(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 	val, err := vars.GetSessionOrGlobalSystemVar(TiDBEnableIndexMerge)
 	require.NoError(t, err)
@@ -523,7 +523,7 @@ func TestIndexMergeSwitcher(t *testing.T) {
 
 func TestNetBufferLength(t *testing.T) {
 	netBufferLength := GetSysVar(NetBufferLength)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 
 	val, err := netBufferLength.Validate(vars, "1", ScopeGlobal)
@@ -539,7 +539,7 @@ func TestNetBufferLength(t *testing.T) {
 
 func TestTiDBBatchPendingTiFlashCount(t *testing.T) {
 	sv := GetSysVar(TiDBBatchPendingTiFlashCount)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := sv.Validate(vars, "-10", ScopeSession)
 	require.NoError(t, err) // it has autoconvert out of range.
 	require.Equal(t, "0", val)
@@ -555,7 +555,7 @@ func TestTiDBBatchPendingTiFlashCount(t *testing.T) {
 
 func TestTiDBMemQuotaQuery(t *testing.T) {
 	sv := GetSysVar(TiDBMemQuotaQuery)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	for _, scope := range []ScopeFlag{ScopeGlobal, ScopeSession} {
 		newVal := 32 * 1024 * 1024
@@ -575,7 +575,7 @@ func TestTiDBMemQuotaQuery(t *testing.T) {
 
 func TestTiDBQueryLogMaxLen(t *testing.T) {
 	sv := GetSysVar(TiDBQueryLogMaxLen)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	newVal := 32 * 1024 * 1024
 	val, err := sv.Validate(vars, fmt.Sprintf("%d", newVal), ScopeGlobal)
@@ -601,7 +601,7 @@ func TestTiDBQueryLogMaxLen(t *testing.T) {
 
 func TestTiDBCommitterConcurrency(t *testing.T) {
 	sv := GetSysVar(TiDBCommitterConcurrency)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	newVal := 1024
 	val, err := sv.Validate(vars, fmt.Sprintf("%d", newVal), ScopeGlobal)
@@ -627,7 +627,7 @@ func TestTiDBCommitterConcurrency(t *testing.T) {
 
 func TestTiDBDDLFlashbackConcurrency(t *testing.T) {
 	sv := GetSysVar(TiDBDDLFlashbackConcurrency)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	newVal := 128
 	val, err := sv.Validate(vars, fmt.Sprintf("%d", newVal), ScopeGlobal)
@@ -652,7 +652,7 @@ func TestTiDBDDLFlashbackConcurrency(t *testing.T) {
 }
 
 func TestDefaultMemoryDebugModeValue(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val, err := vars.GetSessionOrGlobalSystemVar(TiDBMemoryDebugModeMinHeapInUse)
 	require.NoError(t, err)
 	require.Equal(t, val, "0")
@@ -662,7 +662,7 @@ func TestDefaultMemoryDebugModeValue(t *testing.T) {
 }
 
 func TestDefaultPartitionPruneMode(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	mock := NewMockGlobalAccessor4Tests()
 	mock.SessionVars = vars
 	vars.GlobalVarsAccessor = mock
@@ -673,7 +673,7 @@ func TestDefaultPartitionPruneMode(t *testing.T) {
 }
 
 func TestSetTIDBFastDDL(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	mock := NewMockGlobalAccessor4Tests()
 	mock.SessionVars = vars
 	vars.GlobalVarsAccessor = mock
@@ -698,7 +698,7 @@ func TestSetTIDBFastDDL(t *testing.T) {
 }
 
 func TestSetTIDBDiskQuota(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	mock := NewMockGlobalAccessor4Tests()
 	mock.SessionVars = vars
 	vars.GlobalVarsAccessor = mock
@@ -749,7 +749,7 @@ func TestSetTIDBDiskQuota(t *testing.T) {
 }
 
 func TestTiDBServerMemoryLimit(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	mock := NewMockGlobalAccessor4Tests()
 	mock.SessionVars = vars
 	vars.GlobalVarsAccessor = mock
diff --git a/sessionctx/variable/variable_test.go b/sessionctx/variable/variable_test.go
index ebf89f39b0a6c..57052a37f6b58 100644
--- a/sessionctx/variable/variable_test.go
+++ b/sessionctx/variable/variable_test.go
@@ -90,7 +90,7 @@ func TestRegistrationOfNewSysVar(t *testing.T) {
 	sysVar := GetSysVar("mynewsysvar")
 	require.NotNil(t, sysVar)
 
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	// It is a boolean, try to set it to a bogus value
 	_, err := sysVar.Validate(vars, "ABCD", ScopeSession)
@@ -114,7 +114,7 @@ func TestRegistrationOfNewSysVar(t *testing.T) {
 
 func TestIntValidation(t *testing.T) {
 	sv := SysVar{Scope: ScopeGlobal | ScopeSession, Name: "mynewsysvar", Value: "123", Type: TypeInt, MinValue: 10, MaxValue: 300, AllowAutoValue: true}
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sv.Validate(vars, "oN", ScopeSession)
 	require.Equal(t, "[variable:1232]Incorrect argument type to variable 'mynewsysvar'", err.Error())
@@ -139,7 +139,7 @@ func TestIntValidation(t *testing.T) {
 
 func TestUintValidation(t *testing.T) {
 	sv := SysVar{Scope: ScopeGlobal | ScopeSession, Name: "mynewsysvar", Value: "123", Type: TypeUnsigned, MinValue: 10, MaxValue: 300, AllowAutoValue: true}
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sv.Validate(vars, "oN", ScopeSession)
 	require.Equal(t, "[variable:1232]Incorrect argument type to variable 'mynewsysvar'", err.Error())
@@ -174,7 +174,7 @@ func TestUintValidation(t *testing.T) {
 
 func TestEnumValidation(t *testing.T) {
 	sv := SysVar{Scope: ScopeGlobal | ScopeSession, Name: "mynewsysvar", Value: On, Type: TypeEnum, PossibleValues: []string{"OFF", "ON", "AUTO"}}
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sv.Validate(vars, "randomstring", ScopeSession)
 	require.Equal(t, "[variable:1231]Variable 'mynewsysvar' can't be set to the value of 'randomstring'", err.Error())
@@ -199,7 +199,7 @@ func TestEnumValidation(t *testing.T) {
 
 func TestDurationValidation(t *testing.T) {
 	sv := SysVar{Scope: ScopeGlobal | ScopeSession, Name: "mynewsysvar", Value: "10m0s", Type: TypeDuration, MinValue: int64(time.Second), MaxValue: uint64(time.Hour)}
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sv.Validate(vars, "1hr", ScopeSession)
 	require.Equal(t, "[variable:1232]Incorrect argument type to variable 'mynewsysvar'", err.Error())
@@ -215,7 +215,7 @@ func TestDurationValidation(t *testing.T) {
 
 func TestFloatValidation(t *testing.T) {
 	sv := SysVar{Scope: ScopeGlobal | ScopeSession, Name: "mynewsysvar", Value: "10m0s", Type: TypeFloat, MinValue: 2, MaxValue: 7}
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sv.Validate(vars, "stringval", ScopeSession)
 	require.Equal(t, "[variable:1232]Incorrect argument type to variable 'mynewsysvar'", err.Error())
@@ -234,7 +234,7 @@ func TestFloatValidation(t *testing.T) {
 
 func TestBoolValidation(t *testing.T) {
 	sv := SysVar{Scope: ScopeGlobal | ScopeSession, Name: "mynewsysvar", Value: Off, Type: TypeBool}
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sv.Validate(vars, "0.000", ScopeSession)
 	require.Equal(t, "[variable:1231]Variable 'mynewsysvar' can't be set to the value of '0.000'", err.Error())
@@ -311,7 +311,7 @@ func TestSynonyms(t *testing.T) {
 	sysVar := GetSysVar(TxnIsolation)
 	require.NotNil(t, sysVar)
 
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	// It does not permit SERIALIZABLE by default.
 	_, err := sysVar.Validate(vars, "SERIALIZABLE", ScopeSession)
@@ -342,7 +342,7 @@ func TestDeprecation(t *testing.T) {
 	sysVar := GetSysVar(TiDBIndexLookupConcurrency)
 	require.NotNil(t, sysVar)
 
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	_, err := sysVar.Validate(vars, "123", ScopeSession)
 	require.NoError(t, err)
@@ -411,7 +411,7 @@ func TestIsNoop(t *testing.T) {
 // the default itself must validate without error provided the scope and read-only is correct.
 // The default values should also be normalized for consistency.
 func TestDefaultValuesAreSettable(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 	for _, sv := range GetSysVars() {
 		if sv.HasSessionScope() && !sv.ReadOnly {
@@ -517,7 +517,7 @@ func TestSkipInitIsUsed(t *testing.T) {
 
 func TestValidateWithRelaxedValidation(t *testing.T) {
 	sv := GetSysVar(SecureAuth)
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	val := sv.ValidateWithRelaxedValidation(vars, "1", ScopeGlobal)
 	require.Equal(t, "ON", val)
 }
@@ -574,7 +574,7 @@ func TestInstanceScope(t *testing.T) {
 	sysVar := GetSysVar("newinstancesysvar")
 	require.NotNil(t, sysVar)
 
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	// It is a boolean, try to set it to a bogus value
 	_, err := sysVar.Validate(vars, "ABCD", ScopeInstance)
diff --git a/sessionctx/variable/varsutil_test.go b/sessionctx/variable/varsutil_test.go
index 3833956a51fbf..68e55bc33aea8 100644
--- a/sessionctx/variable/varsutil_test.go
+++ b/sessionctx/variable/varsutil_test.go
@@ -49,7 +49,7 @@ func TestTiDBOptOn(t *testing.T) {
 }
 
 func TestNewSessionVars(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 
 	require.Equal(t, DefIndexJoinBatchSize, vars.IndexJoinBatchSize)
 	require.Equal(t, DefIndexLookupSize, vars.IndexLookupSize)
@@ -103,7 +103,7 @@ func assertFieldsGreaterThanZero(t *testing.T, val reflect.Value) {
 }
 
 func TestVarsutil(t *testing.T) {
-	v := NewSessionVars()
+	v := NewSessionVars(nil)
 	v.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 
 	err := v.SetSystemVar("autocommit", "1")
@@ -457,7 +457,7 @@ func TestVarsutil(t *testing.T) {
 }
 
 func TestValidate(t *testing.T) {
-	v := NewSessionVars()
+	v := NewSessionVars(nil)
 	v.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 	v.TimeZone = time.UTC
 
@@ -586,7 +586,7 @@ func TestValidate(t *testing.T) {
 }
 
 func TestValidateStmtSummary(t *testing.T) {
-	v := NewSessionVars()
+	v := NewSessionVars(nil)
 	v.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 	v.TimeZone = time.UTC
 
@@ -628,7 +628,7 @@ func TestValidateStmtSummary(t *testing.T) {
 }
 
 func TestConcurrencyVariables(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	vars.GlobalVarsAccessor = NewMockGlobalAccessor4Tests()
 
 	wdConcurrency := 2
@@ -685,7 +685,7 @@ func TestHelperFuncs(t *testing.T) {
 }
 
 func TestStmtVars(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	err := vars.SetStmtVar("bogussysvar", "1")
 	require.Equal(t, "[variable:1193]Unknown system variable 'bogussysvar'", err.Error())
 	err = vars.SetStmtVar(MaxExecutionTime, "ACDC")
@@ -695,7 +695,7 @@ func TestStmtVars(t *testing.T) {
 }
 
 func TestSessionStatesSystemVar(t *testing.T) {
-	vars := NewSessionVars()
+	vars := NewSessionVars(nil)
 	err := vars.SetSystemVar("autocommit", "1")
 	require.NoError(t, err)
 	val, keep, err := vars.GetSessionStatesSystemVar("autocommit")
diff --git a/table/tables/mutation_checker_test.go b/table/tables/mutation_checker_test.go
index 4a2bfd0508949..658905fcf14e4 100644
--- a/table/tables/mutation_checker_test.go
+++ b/table/tables/mutation_checker_test.go
@@ -87,7 +87,7 @@ func TestCompareIndexData(t *testing.T) {
 }
 
 func TestCheckRowInsertionConsistency(t *testing.T) {
-	sessVars := variable.NewSessionVars()
+	sessVars := variable.NewSessionVars(nil)
 	rd := rowcodec.Encoder{Enable: true}
 
 	// mocked data
@@ -230,7 +230,7 @@ func TestCheckIndexKeysAndCheckHandleConsistency(t *testing.T) {
 			{ID: 2, Offset: 1, FieldType: *types.NewFieldType(mysql.TypeDatetime)},
 		},
 	}
-	sessVars := variable.NewSessionVars()
+	sessVars := variable.NewSessionVars(nil)
 	rd := rowcodec.Encoder{Enable: true}
 
 	now := types.CurrentTime(mysql.TypeDatetime)
diff --git a/util/mock/context.go b/util/mock/context.go
index b97398bc506e2..fd4c4d8bef376 100644
--- a/util/mock/context.go
+++ b/util/mock/context.go
@@ -439,11 +439,11 @@ func (*Context) Close() {}
 func NewContext() *Context {
 	ctx, cancel := context.WithCancel(context.Background())
 	sctx := &Context{
-		values:      make(map[fmt.Stringer]interface{}),
-		sessionVars: variable.NewSessionVars(),
-		ctx:         ctx,
-		cancel:      cancel,
+		values: make(map[fmt.Stringer]interface{}),
+		ctx:    ctx,
+		cancel: cancel,
 	}
+	sctx.sessionVars = variable.NewSessionVars(sctx)
 	sctx.sessionVars.InitChunkSize = 2
 	sctx.sessionVars.MaxChunkSize = 32
 	sctx.sessionVars.StmtCtx.TimeZone = time.UTC