diff --git a/src/com/platform/service/impl/OracleExtractServiceImpl.java b/src/com/platform/service/impl/OracleExtractServiceImpl.java index a53bef9b..7357c564 100644 --- a/src/com/platform/service/impl/OracleExtractServiceImpl.java +++ b/src/com/platform/service/impl/OracleExtractServiceImpl.java @@ -100,6 +100,22 @@ public class OracleExtractServiceImpl implements IOracleExtractService { return isSuccess; } + @Override + public boolean isConnectTotalOracle(GatherOracleInfo oracleModel) throws Exception { + boolean isConnect = false; + 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); +// FileOperateHelper.fileWrite(Configs.EXTRACT_LOG_LOCALTION +// + dataInfolist.get(0).getName(), "创建oracle连接失败: [" + conn + "]\r\n"); + isConnect = false; + }else { + isConnect = oracleExtract.testConnect(conn); + } + return isConnect; + } + // @Override // public boolean extractOracle(String name, List dataInfos, GatherOracleInfo oracleConnect) throws Exception { // boolean isSuccess = false;