From 762abebf790f4255e790dca886baa3f8e047740c Mon Sep 17 00:00:00 2001 From: IrynaMatveieva Date: Thu, 1 May 2025 12:33:12 +0300 Subject: [PATCH] added query --- .../org/thingsboard/server/dao/sql/job/JobRepository.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/dao/src/main/java/org/thingsboard/server/dao/sql/job/JobRepository.java b/dao/src/main/java/org/thingsboard/server/dao/sql/job/JobRepository.java index a4d280aba4..0ecd517f51 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/sql/job/JobRepository.java +++ b/dao/src/main/java/org/thingsboard/server/dao/sql/job/JobRepository.java @@ -21,9 +21,11 @@ import org.springframework.data.domain.Page; import org.springframework.data.domain.Pageable; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.Lock; +import org.springframework.data.jpa.repository.Modifying; import org.springframework.data.jpa.repository.Query; import org.springframework.data.repository.query.Param; import org.springframework.stereotype.Repository; +import org.springframework.transaction.annotation.Transactional; import org.thingsboard.server.common.data.job.JobStatus; import org.thingsboard.server.common.data.job.JobType; import org.thingsboard.server.dao.model.sql.JobEntity; @@ -58,6 +60,9 @@ public interface JobRepository extends JpaRepository { "AND j.status = :status ORDER BY j.createdTime ASC, j.id ASC") JobEntity findOldestByTenantIdAndTypeAndStatusForUpdate(UUID tenantId, JobType type, JobStatus status, Limit limit); + @Transactional + @Modifying + @Query("DELETE FROM JobEntity j WHERE j.tenantId = :tenantId") void deleteByTenantId(UUID tenantId); }