diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/AccreditServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/AccreditServiceImpl.java index ceb9695..205cdb6 100644 --- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/AccreditServiceImpl.java +++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/AccreditServiceImpl.java @@ -19,9 +19,9 @@ public class AccreditServiceImpl implements AccreditService{ @Override public Accredit findAccredit(Long tableId) { Accredit accredit = accreditMapper.findAccredit(tableId); - if(accredit==null){ - return accreditMapper.findAccreditBasic(tableId); - } +// if(accredit==null){ +// return accreditMapper.findAccreditBasic(tableId); +// } return accredit; } diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java index 85fdcaa..3865e69 100644 --- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java +++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java @@ -125,6 +125,7 @@ public class SourceServiceImpl extends ServiceImpl impleme Connection conn = null; try { conn = DriverManager.getConnection(url, user, password); + System.out.println("Connected to the MySQL server successfully."); TableInfo tableInfoInsert = TableInfo.builder()