From a4434ecddc587d483f6d04a85ca9de82d4969fb9 Mon Sep 17 00:00:00 2001
From: chenlw <874313221@qq.com>
Date: Sat, 8 Oct 2016 17:06:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E9=93=BE=E6=8E=A5=E6=B1=87?=
 =?UTF-8?q?=E6=80=BB=E6=95=B0=E6=8D=AE=E5=BA=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/OracleExtractServiceImpl.java   | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

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<OracleConnectorParams> dataInfos, GatherOracleInfo oracleConnect) throws Exception {
 //		boolean isSuccess = false;