Skip to content

Commit d569e98

Browse files
committed
fix(server): delete scheduler-xxx while deleting a project
1 parent 0bc3c9b commit d569e98

3 files changed

Lines changed: 18 additions & 0 deletions

File tree

server/infra/dao/src/main/java/com/antgroup/openspg/server/infra/dao/mapper/ProjectDOMapper.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,12 @@ public interface ProjectDOMapper {
4242

4343
void deleteFromKgBuilderJob(Long id);
4444

45+
void deleteFromKgSchedulerInstance(Long id);
46+
47+
void deleteFromKgSchedulerJob(Long id);
48+
49+
void deleteFromKgSchedulerTask(Long id);
50+
4551
void deleteFromKgResourcePermission(Long projectId);
4652

4753
int insert(ProjectDO record);

server/infra/dao/src/main/java/com/antgroup/openspg/server/infra/dao/repository/common/ProjectRepositoryImpl.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,9 @@ public Integer deleteById(Long projectId) {
8585
projectDOMapper.deleteFromKgReasonTask(projectId);
8686
projectDOMapper.deleteFromKgReasonTutorial(projectId);
8787
projectDOMapper.deleteFromKgBuilderJob(projectId);
88+
projectDOMapper.deleteFromKgSchedulerInstance(projectId);
89+
projectDOMapper.deleteFromKgSchedulerJob(projectId);
90+
projectDOMapper.deleteFromKgSchedulerTask(projectId);
8891
projectDOMapper.deleteFromKgResourcePermission(projectId);
8992
return projectDOMapper.deleteByPrimaryKey(projectId);
9093
}

server/infra/dao/src/main/resources/mapper/ProjectDOMapper.xml

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -138,6 +138,15 @@
138138
<delete id="deleteFromKgBuilderJob" parameterType="java.lang.Long">
139139
DELETE FROM kg_builder_job WHERE project_id = #{id,jdbcType=BIGINT};
140140
</delete>
141+
<delete id="deleteFromKgSchedulerInstance" parameterType="java.lang.Long">
142+
DELETE FROM kg_scheduler_instance WHERE project_id = #{id,jdbcType=BIGINT};
143+
</delete>
144+
<delete id="deleteFromKgSchedulerJob" parameterType="java.lang.Long">
145+
DELETE FROM kg_scheduler_job WHERE project_id = #{id,jdbcType=BIGINT};
146+
</delete>
147+
<delete id="deleteFromKgSchedulerTask" parameterType="java.lang.Long">
148+
DELETE FROM kg_scheduler_task WHERE project_id = #{id,jdbcType=BIGINT};
149+
</delete>
141150
<delete id="deleteFromKgResourcePermission" parameterType="java.lang.Long">
142151
DELETE FROM kg_resource_permission WHERE resource_id = #{id,jdbcType=BIGINT} and resource_tag = 'KNOWLEDGE_BASE';
143152
</delete>

0 commit comments

Comments
 (0)