Skip to content

Commit b501d29

Browse files
authored
Merge pull request #3031 from actiontech/fix_instance_audit_plan_sql
fix(model): 修复 SQL 审计计划关联查询
2 parents c1b9226 + e746628 commit b501d29

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sqle/model/instance_audit_plan.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -792,7 +792,7 @@ TODO 优先级:低 目的: 优化该方法的SQL性能
792792
func (s *Storage) GetSQLsToAuditFromManage() ([]*SQLManageRecord, error) {
793793
manageRecords := []*SQLManageRecord{}
794794
err := s.db.Limit(1000).Model(SQLManageRecord{}).
795-
Joins("JOIN audit_plans_v2 apv ON sql_manage_records.source_id = apv.instance_audit_plan_id AND sql_manage_records.source = apv.type AND apv.deleted_at IS NULL").
795+
Joins("JOIN audit_plans_v2 apv ON sql_manage_records.source_id = CONCAT(apv.instance_audit_plan_id, '') AND sql_manage_records.source = apv.type AND apv.deleted_at IS NULL").
796796
Joins("JOIN sql_manage_record_processes smrp ON sql_manage_records.id =smrp.sql_manage_record_id").
797797
Where("sql_manage_records.updated_at > smrp.last_audit_time OR smrp.last_audit_time IS NULL").
798798
Find(&manageRecords).Error

0 commit comments

Comments
 (0)