关闭connection连接，去掉多余的一行sql = br.readLine();

src/com/platform/service/thread/ThreadExtractStandardSqlServer.java

@@ -93,15 +93,16 @@ public class ThreadExtractStandardSqlServer extends Thread{
 					// TODO Auto-generated catch block
 					e.printStackTrace();
 				}
+				 Connection payConn = null;
 				try {
 					File paySql = new File(payFilePath);
 					//获取连接
-					Connection conn = OracleConnector.connectionBuilder("jdbc:oracle:thin:@" + oracleConnect.getIp() + ":" + oracleConnect.getPort() + ":"
+					payConn = OracleConnector.connectionBuilder("jdbc:oracle:thin:@" + oracleConnect.getIp() + ":" + oracleConnect.getPort() + ":"
 							+ oracleConnect.getDatabaseName(), oracleConnect.getUser(), oracleConnect.getPassword(), null);
 					// 创建表空间    创建  抽取标准表的 用户并授权
-					oracleExtract.createTableSpace(conn, collectOracle , oracleConnect); //
-					oracleExtract.createOnlyUser(conn, collectOracle, oracleConnect);//
-					createPay(conn, collectOracle);
+					oracleExtract.createTableSpace(payConn, collectOracle , oracleConnect); //
+					oracleExtract.createOnlyUser(payConn, collectOracle, oracleConnect);//
+					createPay(payConn, collectOracle);
 				
 					//读取文件流
 					FileInputStream fis = new FileInputStream(paySql);
@@ -109,9 +110,8 @@ public class ThreadExtractStandardSqlServer extends Thread{
 					String sql = br.readLine();
 					while (sql != null) {
 						//TODO 执行sql
-						sql = br.readLine();
 						String resultSql = sql.replace(";", "");
-						OracleConnector.execOracleSQL(conn, resultSql, FileOperateHelper.addLastSeparator(Configs.EXTRACT_STANDARD_LOG_LOCALTION)
+						OracleConnector.execOracleSQL(payConn, resultSql, FileOperateHelper.addLastSeparator(Configs.EXTRACT_STANDARD_LOG_LOCALTION)
 								+ "CQ"+element.getAreaCode()+"_"+element.getSysCode()+"_"+element.getDataVersion()+".log");
 						sql = br.readLine();
 					}
@@ -139,6 +139,14 @@ public class ThreadExtractStandardSqlServer extends Thread{
 					// TODO Auto-generated catch block
 					e.printStackTrace();
 				} 
+				finally{
+					try {
+						payConn.close();
+					} catch (SQLException e) {
+						// TODO Auto-generated catch block
+						e.printStackTrace();
+					}
+				}
 			}
 			 // 查询最新的 数据记录
 			 this.getDataByCk(element);
@@ -171,7 +179,6 @@ public class ThreadExtractStandardSqlServer extends Thread{
 					while (sql != null) {
 						//TODO 执行sql
 						//TODO 执行sql
-						sql = br.readLine();
 						String resultSql = sql.replace(";", "");
 						OracleConnector.execOracleSQL(conn, resultSql, FileOperateHelper.addLastSeparator(Configs.EXTRACT_STANDARD_LOG_LOCALTION)
 								+ "CQ"+element.getAreaCode()+"_"+element.getSysCode()+"_"+element.getDataVersion()+".log");