a_bazu
/
cloud-property
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix:() 优化任务调动方法

master
Yueng 2024-09-10 19:54:40 +08:00
parent 798568fa9f
commit 70b0f5f0d9
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cloud-property-server/src/main/java/com/muyu/server/controller/DataLinkController.java
View File

@ -44,12 +44,12 @@ public class DataLinkController {
* @return 反护试图
*/
@PostMapping("/addProduct")
public Result addProduct(@RequestParam("targetDatabase") String basicDataName,
public Result addProduct(@RequestParam("targetDatabase") String targetDatabase,
@RequestParam("targetTableName") String targetTableName,
@RequestBody DataValue[][] listList){
long begin = System.currentTimeMillis();
int i = dataLinkService.addProduct(basicDataName,targetTableName,listList);
int i = dataLinkService.addProduct(targetDatabase,targetTableName,listList);
long end = System.currentTimeMillis();

2
cloud-property-server/src/main/java/com/muyu/server/service/DataLinkService.java
View File

@ -66,5 +66,5 @@ public interface DataLinkService {
* @param listList sql语句
* @return 反护试图
*/
int addProduct(String basicDataName, String targetTableName, DataValue[]... listList);
int addProduct(String targetDatabase, String targetTableName, DataValue[]... listList);
}

4
cloud-property-server/src/main/java/com/muyu/server/service/impl/DataLinkServiceImpl.java
View File

@ -140,9 +140,9 @@ public class DataLinkServiceImpl implements DataLinkService {
*/
@Override
@Log(title = "添加产品数据库", businessType = BusinessType.INSERT)
public int addProduct(String databaseName, String targetTableName, DataValue[]... listList) {
public int addProduct(String targetDatabase, String targetTableName, DataValue[]... listList) {
Connect connect = connectService.selectData(databaseName);
Connect connect = connectService.selectData(targetDatabase);
ConnectReq connectReq = new ConnectReq();
HikariConfig hikariConfig = new HikariConfig();