add cache invalidation

max-hoffman · max-hoffman · commit fb510d95a742 · 2024-12-19T09:36:14.000-08:00
diff --git a/sql/base_session.go b/sql/base_session.go
@@ -178,6 +178,9 @@ func (s *BaseSession) setSessVar(ctx *Context, sysVar SystemVariable, value inte
 	}
 	sysVarName := strings.ToLower(sysVar.GetName())
 	s.systemVars[sysVarName] = svv
+	if sysVarName == characterSetResultsSysVarName {
+		s.charset = CharacterSet_Unspecified
+	}
 	return nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -178,6 +178,9 @@ func (s BaseSession) setSessVar(ctx Context, sysVar SystemVariable, value inte`
`178`	`178`	`}`
`179`	`179`	`sysVarName := strings.ToLower(sysVar.GetName())`
`180`	`180`	`s.systemVars[sysVarName] = svv`
	`181`	`+ if sysVarName == characterSetResultsSysVarName {`
	`182`	`+ s.charset = CharacterSet_Unspecified`
	`183`	`+ }`
`181`	`184`	`return nil`
`182`	`185`	`}`
`183`	`186`