diff --git a/sqle/driver/mysql/rollback.go b/sqle/driver/mysql/rollback.go index 7e5647dbf7..9d4a7def67 100644 --- a/sqle/driver/mysql/rollback.go +++ b/sqle/driver/mysql/rollback.go @@ -647,7 +647,7 @@ func (i *MysqlDriverImpl) generateUpdateRollbackSql(stmt *ast.UpdateStmt) (strin } if isPk { if isPkChanged { - where = append(where, fmt.Sprintf("%s = '%s'", name, pkValue)) + where = append(where, fmt.Sprintf("%s = %s", name, pkValue)) } else { where = append(where, fmt.Sprintf("%s = %s", name, v))