panbaolin/SourceTermAnalysisSystem_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: panbaolin:9fa131fe9c06b3a7c9b46d014ccc064e8002c1d3
Branches Tags
panbaolin:master
panbaolin:main
...
compare: panbaolin:3dcf5db691649786da012431b0838edb22ee73b5
Branches Tags
panbaolin:master
panbaolin:main

2 Commits
9fa131fe9c ... 3dcf5db691

Author SHA1 Message Date
hekaiyu
3dcf5db691 Merge remote-tracking branch 'origin/master' 2025-10-23 10:20:41 +08:00
hekaiyu
e929c61f3b 保存表事务提交 2025-10-23 10:20:20 +08:00
3 changed files with 52 additions and 51 deletions
Show Stats Expand all files Collapse all files

10
jeecg-module-sync/src/main/java/org/jeecg/stasSyncStrategy/controller/StasSyncStrategyController.java
View File

@ -71,15 +71,7 @@ public class StasSyncStrategyController extends JeecgController<StasSyncStrategy
@Operation(summary="同步策略表-在目标库创建表结构")
@PostMapping(value = "/createTargetTables")
public Result<String> createTargetTables(@RequestBody List<StasSyncStrategy> stasSyncStrategys) {
if(null != stasSyncStrategys && stasSyncStrategys.size() > 0) {
String taskId = stasSyncStrategys.get(0).getTaskId();
stasSyncStrategyService.remove(new LambdaQueryWrapper<StasSyncStrategy>().eq(StasSyncStrategy::getTaskId, taskId));
for (StasSyncStrategy stasSyncStrategy : stasSyncStrategys) {
if(stasSyncStrategyService.validateTables(stasSyncStrategy)){
stasSyncStrategyService.createTargetTables(stasSyncStrategy);
}
}
}
stasSyncStrategyService.createTargetTables(stasSyncStrategys);
return Result.OK("添加成功！");
}

5
jeecg-module-sync/src/main/java/org/jeecg/stasSyncStrategy/service/IStasSyncStrategyService.java
View File

@ -4,6 +4,7 @@ import org.jeecg.modules.base.entity.StasSyncStrategy;
import com.baomidou.mybatisplus.extension.service.IService;
import java.sql.SQLException;
import java.util.List;
/**
* @Description: 同步策略表
@ -23,8 +24,8 @@ public interface IStasSyncStrategyService extends IService<StasSyncStrategy> {
/**
* 在目标库创建表结构
* @param stasSyncStrategy 同步策略信息
* @param stasSyncStrategys 同步策略信息
* @throws SQLException 数据库异常
*/
void createTargetTables(StasSyncStrategy stasSyncStrategy);
void createTargetTables(List<StasSyncStrategy> stasSyncStrategys);
}

12
jeecg-module-sync/src/main/java/org/jeecg/stasSyncStrategy/service/impl/StasSyncStrategyServiceImpl.java
View File

@ -1,5 +1,6 @@
package org.jeecg.stasSyncStrategy.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.RequiredArgsConstructor;
import org.jeecg.common.constant.enums.SourceDataTypeEnum;
import org.jeecg.common.exception.JeecgBootException;
@ -32,6 +33,7 @@ public class StasSyncStrategyServiceImpl extends ServiceImpl<StasSyncStrategyMap
private final StasTaskConfigMapper stasTaskConfigMapper;
private final StasDataSourceMapper stasDataSourceMapper;
private final StasSyncStrategyMapper stasSyncStrategyService;
/**
@ -67,12 +69,16 @@ public class StasSyncStrategyServiceImpl extends ServiceImpl<StasSyncStrategyMap
/**
* 在目标库创建表结构
* @param stasSyncStrategy 同步策略信息
* @param stasSyncStrategys 同步策略信息
* @throws SQLException 数据库异常
*/
@Transactional
@Override
public void createTargetTables(StasSyncStrategy stasSyncStrategy) {
public void createTargetTables(List<StasSyncStrategy> stasSyncStrategys) {
if(null != stasSyncStrategys && stasSyncStrategys.size() > 0) {
String taskId = stasSyncStrategys.get(0).getTaskId();
stasSyncStrategyService.delete(new LambdaQueryWrapper<StasSyncStrategy>().eq(StasSyncStrategy::getTaskId, taskId));
for (StasSyncStrategy stasSyncStrategy : stasSyncStrategys) {
StasTaskConfig stasTaskConfig = stasTaskConfigMapper.selectById(stasSyncStrategy.getTaskId());
StasDataSource sourceInfo = stasDataSourceMapper.selectById(stasTaskConfig.getSourceId());
StasDataSource targetInfo = stasDataSourceMapper.selectById(stasTaskConfig.getTargetId());
@ -116,6 +122,8 @@ public class StasSyncStrategyServiceImpl extends ServiceImpl<StasSyncStrategyMap
throw new JeecgBootException(e.getMessage());
}
}
}
}
/**
* 获取创建表的SQL语句