Skip to content

Commit

Permalink
ce modify: cancel EstimateSQLAffectRows
Browse files Browse the repository at this point in the history
  • Loading branch information
winfredLIN committed Nov 21, 2024
1 parent bd428ef commit 5b8c591
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions sqle/server/sqled.go
Original file line number Diff line number Diff line change
Expand Up @@ -302,10 +302,6 @@ func (a *action) audit() (err error) {
if a.task.EnableBackup {
backupTasks := make([]*model.BackupTask, 0, len(a.task.ExecuteSQLs))
for _, sql := range a.task.ExecuteSQLs {
affectedRows, err := a.plugin.EstimateSQLAffectRows(context.TODO(), sql.Content)
if err == nil {
sql.RowAffects = affectedRows.Count
}
backupTasks = append(backupTasks, initModelBackupTask(a.task, sql))
}
err = st.BatchCreateBackupTasks(backupTasks)
Expand Down

0 comments on commit 5b8c591

Please sign in to comment.