diff --git a/src/com/platform/service/impl/OracleExtractServiceImpl.java b/src/com/platform/service/impl/OracleExtractServiceImpl.java index 7357c564..2449f6a1 100644 --- a/src/com/platform/service/impl/OracleExtractServiceImpl.java +++ b/src/com/platform/service/impl/OracleExtractServiceImpl.java @@ -106,10 +106,10 @@ public class OracleExtractServiceImpl implements IOracleExtractService { Connection conn = OracleConnector.ConnectionBuilder("jdbc:oracle:thin:@" + oracleModel.getIp() + ":" + oracleModel.getPort() + ":" + oracleModel.getDatabaseName(), oracleModel.getUser(), oracleModel.getPassword(), null); if (null == conn) { - new CustomException(Custom4exception.connect_Oracle_Except, null, oracleModel); + isConnect = false; + throw new CustomException(Custom4exception.connect_Oracle_Except, null, oracleModel); // FileOperateHelper.fileWrite(Configs.EXTRACT_LOG_LOCALTION // + dataInfolist.get(0).getName(), "创建oracle连接失败: [" + conn + "]\r\n"); - isConnect = false; }else { isConnect = oracleExtract.testConnect(conn); }