Skip to content

Commit d1fbd57

Browse files
feat(auditplan): Create SQL management cost metric records only when the MySQL database type is used
1 parent c6eb84f commit d1fbd57

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

sqle/server/auditplan/task_wrap.go

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -309,10 +309,13 @@ func (at *TaskWrapper) pushSQLToManagerSQLQueue(sqlList []*model.SQLManageQueue,
309309
return err
310310
}
311311

312-
for _, sqlQueue := range SqlQueueList {
313-
err = createSqlManageCostMetricRecord(sqlQueue, ap.Instance)
314-
if err != nil {
315-
log.Logger().Errorf("createSqlManageCostMetricRecord: %v", err)
312+
// 目前只支持MySQL
313+
if ap.DBType == driverV2.DriverTypeMySQL {
314+
for _, sqlQueue := range SqlQueueList {
315+
err = createSqlManageCostMetricRecord(sqlQueue, ap.Instance)
316+
if err != nil {
317+
log.Logger().Errorf("createSqlManageCostMetricRecord: %v", err)
318+
}
316319
}
317320
}
318321
err = at.persist.PushSQLToManagerSQLQueue(SqlQueueList)
@@ -642,7 +645,7 @@ func createSqlManageCostMetricRecord(sqlManageQueue *model.SQLManageQueue, insta
642645
}
643646
cost, err := GetQueryCost(plugin, sqlManageQueue.SqlText)
644647
if err != nil {
645-
log.Logger().Errorf("createSqlManageCostMetricRecord: parse explain cost to float64 failed %v", err)
648+
log.Logger().Errorf("createSqlManageCostMetricRecord: failed %v", err)
646649
return err
647650
}
648651
storage := model.GetStorage()

0 commit comments

Comments
 (0)