From f86cc282a7acd1a66b6d4c66687140283c775cf7 Mon Sep 17 00:00:00 2001 From: ailanyin Date: Wed, 28 Jun 2023 22:09:02 +0800 Subject: [PATCH] first commit --- .../module/tenant/service/impl/SysTenantServiceImpl.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/qiaoba-modules/qiaoba-module-tenant/src/main/java/com/qiaoba/module/tenant/service/impl/SysTenantServiceImpl.java b/qiaoba-modules/qiaoba-module-tenant/src/main/java/com/qiaoba/module/tenant/service/impl/SysTenantServiceImpl.java index 5eef295..a353235 100644 --- a/qiaoba-modules/qiaoba-module-tenant/src/main/java/com/qiaoba/module/tenant/service/impl/SysTenantServiceImpl.java +++ b/qiaoba-modules/qiaoba-module-tenant/src/main/java/com/qiaoba/module/tenant/service/impl/SysTenantServiceImpl.java @@ -19,7 +19,6 @@ import com.qiaoba.common.redis.service.RedisService; import com.qiaoba.module.tenant.entity.SysTenant; import com.qiaoba.module.tenant.entity.SysTenantDatasource; import com.qiaoba.module.tenant.entity.param.SysTenantParam; -import com.qiaoba.module.tenant.handler.DataHandlerFactory; import com.qiaoba.module.tenant.mapper.SysTenantMapper; import com.qiaoba.module.tenant.service.SysTenantDatasourceService; import com.qiaoba.module.tenant.service.SysTenantService; @@ -112,12 +111,8 @@ public class SysTenantServiceImpl implements SysTenantService { if (Objects.isNull(sysTenant)) { throw new ServiceException("租户不存在"); } - // 初始化数据 + // 初始化数据 todo Connection connection = getConnection(sysTenant); - boolean result = DataHandlerFactory.getHandler(connection.getMetaData().getDatabaseProductName().trim()).handle(connection, tenantId, !SysTenant.COLUMN_MODE.equals(sysTenant.getMode())); - if (!result) { - throw new ServiceException("同步数据出错, 数据已回滚"); - } } @Override