This is an automated email from the ASF dual-hosted git repository.
hefengen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new 281a1a317b [type:fix] fix(admin): Ensure data consistency by adding
@Transactional (#5992)
281a1a317b is described below
commit 281a1a317bc4fb713269c467d8d95eb0ce6f15c7
Author: yqw570994511 <[email protected]>
AuthorDate: Mon Apr 7 14:17:04 2025 +0800
[type:fix] fix(admin): Ensure data consistency by adding @Transactional
(#5992)
Co-authored-by: yuqianwei <qq120405>
Co-authored-by: aias00 <[email protected]>
---
.../java/org/apache/shenyu/admin/service/impl/AppAuthServiceImpl.java | 2 ++
.../java/org/apache/shenyu/admin/service/impl/DiscoveryServiceImpl.java | 1 +
.../java/org/apache/shenyu/admin/service/impl/MetaDataServiceImpl.java | 1 +
3 files changed, 4 insertions(+)
diff --git
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/AppAuthServiceImpl.java
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/AppAuthServiceImpl.java
index 39f13ee5cd..73be2cb91e 100644
---
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/AppAuthServiceImpl.java
+++
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/AppAuthServiceImpl.java
@@ -140,6 +140,7 @@ public class AppAuthServiceImpl implements AppAuthService {
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public ShenyuAdminResult applyUpdate(final AuthApplyDTO authApplyDTO) {
if (StringUtils.isAnyBlank(authApplyDTO.getAppKey(),
authApplyDTO.getAppName())
|| authApplyDTO.getOpen() &&
CollectionUtils.isEmpty(authApplyDTO.getPathList())) {
@@ -212,6 +213,7 @@ public class AppAuthServiceImpl implements AppAuthService {
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public ShenyuAdminResult updateDetailPath(final AuthPathWarpDTO
authPathWarpDTO) {
AppAuthDO appAuthDO =
appAuthMapper.selectById(authPathWarpDTO.getId());
if (Objects.isNull(appAuthDO)) {
diff --git
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/DiscoveryServiceImpl.java
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/DiscoveryServiceImpl.java
index 9765c9577b..99bc75d6da 100644
---
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/DiscoveryServiceImpl.java
+++
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/DiscoveryServiceImpl.java
@@ -452,6 +452,7 @@ public class DiscoveryServiceImpl implements
DiscoveryService {
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public ConfigImportResult importData(final String namespace, final
List<DiscoveryDTO> discoveryList, final ConfigsImportContext context) {
if (CollectionUtils.isEmpty(discoveryList)) {
return ConfigImportResult.success();
diff --git
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/MetaDataServiceImpl.java
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/MetaDataServiceImpl.java
index 75f20af13b..ae52536cb1 100644
---
a/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/MetaDataServiceImpl.java
+++
b/shenyu-admin/src/main/java/org/apache/shenyu/admin/service/impl/MetaDataServiceImpl.java
@@ -102,6 +102,7 @@ public class MetaDataServiceImpl implements MetaDataService
{
}
@Override
+ @Transactional(rollbackFor = Exception.class)
public String createOrUpdate(final MetaDataDTO metaDataDTO) {
return StringUtils.isBlank(metaDataDTO.getId()) ?
this.create(metaDataDTO) : this.update(metaDataDTO);
}