diff --git a/sqle/driver/mysql/rollback.go b/sqle/driver/mysql/rollback.go index 63a1b2b4b8..73bfe516f6 100644 --- a/sqle/driver/mysql/rollback.go +++ b/sqle/driver/mysql/rollback.go @@ -640,7 +640,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))