TreeData
/
cloud-etl-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改方法

master
lwj 2024-09-10 16:38:06 +08:00
parent 12fc454041
commit cb6ff86f50
2 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java
View File

@ -412,6 +412,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
.type(map.get(i).getType())
.build();
dataValues[c][i-1]=build;
}
}
log.info("askldkjjjsk查询完毕啊{}",c);

21
cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/AccreditController.java
View File

@ -7,6 +7,8 @@ import com.muyu.domain.Accredit;
import com.muyu.domain.rep.AccreditDeptRep;
import com.muyu.domain.rep.AccreditUserRep;
import com.muyu.domain.req.AccreditReq;
import com.muyu.mysql.MySqlDataSource;
import com.muyu.mysql.MySqlQuery;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@ -21,8 +23,8 @@ public class AccreditController {
private AccreditService accreditService;
@Autowired
private TableInfoService tableInfoService;
// @Autowired
// private MySqlDataSource mySqlDataSource;
@Autowired
private MySqlDataSource mySqlDataSource;
//根据表Id查询数据库名称接入名称和表名称
@GetMapping("/findAccredit")
@ -63,13 +65,14 @@ public class AccreditController {
return i>0?Result.success(i):Result.error();
}
// @PostMapping("texttt")
// public Result remove(@RequestBody MySqlQuery query) {
// mySqlDataSource.setQuery(query);
// System.out.println("amnmnmnmnmnmmnnm");
// mySqlDataSource.getRows();
// return null;
// }
@PostMapping("texttt")
public Result remove(@RequestBody MySqlQuery query) {
mySqlDataSource.setQuery(query);
System.out.println("amnmnmnmnmnmmnnm");
mySqlDataSource.getRows();
return null;
}