diff --git a/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java b/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java index adc89e8..9e6bf5a 100644 --- a/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java +++ b/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java @@ -412,6 +412,7 @@ public class MySqlDataSource extends BaseDataAbsSource { .type(map.get(i).getType()) .build(); dataValues[c][i-1]=build; + } } log.info("askldkjjjsk查询完毕啊{}",c); diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/AccreditController.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/AccreditController.java index abb0b94..d236709 100644 --- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/AccreditController.java +++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/AccreditController.java @@ -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; + }