Skip to content

Commit

Permalink
.
Browse files Browse the repository at this point in the history
Signed-off-by: ailinkid <[email protected]>
  • Loading branch information
AilinKid committed Mar 9, 2021
1 parent a15c38d commit 5020897
Showing 1 changed file with 2 additions and 13 deletions.
15 changes: 2 additions & 13 deletions ddl/util/util.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ const (
completeDeleteMultiRangesSQL = `DELETE FROM mysql.gc_delete_range WHERE job_id = %? AND element_id in (` // + idList + ")"
updateDeleteRangeSQL = `UPDATE mysql.gc_delete_range SET start_key = %? WHERE job_id = %? AND element_id = %? AND start_key = %?`
deleteDoneRecordSQL = `DELETE FROM mysql.gc_delete_range_done WHERE job_id = %? AND element_id = %?`
loadGlobalVars = `SELECT HIGH_PRIORITY variable_name, variable_value from mysql.global_variables where variable_name in (` // + nameList + ")"
loadGlobalVars = `SELECT HIGH_PRIORITY variable_name, variable_value from mysql.global_variables where variable_name in (%?)`
)

// DelRangeTask is for run delete-range command in gc_worker.
Expand Down Expand Up @@ -162,18 +162,7 @@ func LoadDDLVars(ctx sessionctx.Context) error {
// LoadGlobalVars loads global variable from mysql.global_variables.
func LoadGlobalVars(ctx sessionctx.Context, varNames []string) error {
if sctx, ok := ctx.(sqlexec.RestrictedSQLExecutor); ok {
var buf strings.Builder
buf.WriteString(loadGlobalVars)
paramNames := make([]interface{}, 0, len(varNames))
for i, name := range varNames {
if i > 0 {
buf.WriteString(", ")
}
buf.WriteString("%?")
paramNames = append(paramNames, name)
}
buf.WriteString(")")
stmt, err := sctx.ParseWithParams(context.Background(), buf.String(), paramNames...)
stmt, err := sctx.ParseWithParams(context.Background(), loadGlobalVars, varNames)
if err != nil {
return errors.Trace(err)
}
Expand Down

0 comments on commit 5020897

Please sign in to comment.