fix: correct SQL argument handling in Get method of MySQLReplicateSto…

…re (#177)
zilliztech · Feb 19, 2025 · e1f76f9 · e1f76f9
1 parent cb90bff
commit e1f76f9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/store/mysql_replicate_store.go b/server/store/mysql_replicate_store.go
@@ -82,8 +82,8 @@ func (s *MySQLReplicateStore) Get(ctx context.Context, key string, withPrefix bo
 		sqlStr = fmt.Sprintf("SELECT task_msg_value FROM task_msg WHERE task_msg_key LIKE '%s%%'", taskMsgKey)
 	} else {
 		sqlStr = "SELECT task_msg_value FROM task_msg WHERE task_msg_key = ?"
+		sqlArgs = append(sqlArgs, taskMsgKey)
 	}
-	sqlArgs = append(sqlArgs, taskMsgKey)
 
 	rows, err := s.db.QueryContext(ctx, sqlStr, sqlArgs...)
 	if err != nil {