From 536d81c915d794cc55b0d7a228be663c20fbd998 Mon Sep 17 00:00:00 2001
From: chenlw <874313221@qq.com>
Date: Tue, 13 Dec 2016 09:56:52 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=BD=E5=8F=96=E6=A0=87=E5=87=86=E8=A1=A8?=
=?UTF-8?q?=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../ThreadExtractStandardSqlServer.java | 31 +++++++++++++++----
1 file changed, 25 insertions(+), 6 deletions(-)
diff --git a/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java b/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java
index aaf628e6..db043e90 100644
--- a/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java
+++ b/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java
@@ -8,6 +8,7 @@ import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.sql.Connection;
+import java.util.Date;
import java.util.List;
import com.base.CustomException;
@@ -20,6 +21,7 @@ import com.platform.oracle.OracleConnector;
import com.platform.service.OracleExtractHelper;
import com.platform.utils.Configs;
import com.platform.utils.Constant;
+import com.platform.utils.DateForm;
import com.platform.utils.FileOperateHelper;
/** sqlServer 抽取 标准表 线程
@@ -53,7 +55,20 @@ public class ThreadExtractStandardSqlServer extends Thread{
public void run() {
for (CheckoutEntity element : Extractlist) {
//校验结果：成功或失 0：未校验，1：不需校验，2：正在校验，3：校验成功，4：校验失败，5：待抽取，6：正在抽取，7：抽取完成
+ //设置 日志 的 文件名
+ OracleConnectorParams collectOracle = new OracleConnectorParams();
+ collectOracle.setName("CQ"+ element.getAreaCode().toLowerCase()+"_"+element.getSysCode()+"_"+element.getDataVersion());
//TODO 开始抽取
+ // sql日志记录时间：
+ FileOperateHelper
+ .fileWrite(
+ Configs.EXTRACT_STANDARD_LOG_LOCALTION
+ + collectOracle.getName()
+ + ".log",
+ "\r\n 开始抽取标准表 \r\n"
+ + DateForm
+ .date2StringBysecond(new Date())
+ + "\r\n");
//如果校验成功的 才 进行 抽取----支付标准表
if (Constant.CHECKOUT_STATUS_FIVE.equals(element.getPayResultLast())
|| Constant.CHECKOUT_STATUS_SIX.equals(element.getPayResultLast())) {
@@ -73,9 +88,6 @@ public class ThreadExtractStandardSqlServer extends Thread{
//获取连接
Connection conn = OracleConnector.connectionBuilder("jdbc:oracle:thin:@" + oracleConnect.getIp() + ":" + oracleConnect.getPort() + ":"
+ oracleConnect.getDatabaseName(), oracleConnect.getUser(), oracleConnect.getPassword(), null);
- //设置 日志 的 文件名
- OracleConnectorParams collectOracle = new OracleConnectorParams();
- collectOracle.setName("CQ"+ element.getAreaCode().toLowerCase()+"_"+element.getSysCode()+"_"+element.getDataVersion());
// 创建表空间 创建 抽取标准表的 用户并授权
oracleExtract.createTableSpace(conn, collectOracle , oracleConnect); //
oracleExtract.createOnlyUser(conn, collectOracle, oracleConnect);//
@@ -136,9 +148,6 @@ public class ThreadExtractStandardSqlServer extends Thread{
File execSql = new File(execFilePath);
Connection conn = OracleConnector.connectionBuilder("jdbc:oracle:thin:@" + oracleConnect.getIp() + ":" + oracleConnect.getPort() + ":"
+ oracleConnect.getDatabaseName(), oracleConnect.getUser(), oracleConnect.getPassword(), null);
- //设置 日志 的 文件名
- OracleConnectorParams collectOracle = new OracleConnectorParams();
- collectOracle.setName("CQ"+ element.getAreaCode().toLowerCase()+"_"+element.getSysCode()+"_"+element.getDataVersion());
// 创建表空间 创建 抽取标准表的 用户并授权
oracleExtract.createTableSpace(conn, collectOracle , oracleConnect); //
oracleExtract.createOnlyUser(conn, collectOracle, oracleConnect);//
@@ -182,6 +191,16 @@ public class ThreadExtractStandardSqlServer extends Thread{
}
}
+ // sql日志记录时间：
+ FileOperateHelper
+ .fileWrite(
+ Configs.EXTRACT_STANDARD_LOG_LOCALTION
+ + collectOracle.getName()
+ + ".log",
+ "\r\n 抽取标准表结束 >>>>>>>>>> "
+ + DateForm
+ .date2StringBysecond(new Date())
+ + "\r\n\r\n\n");
}
}