|
|
|
|
@ -1,5 +1,7 @@
|
|
|
|
|
package com.platform.service;
|
|
|
|
|
|
|
|
|
|
import io.fabric8.kubernetes.api.model.Config;
|
|
|
|
|
|
|
|
|
|
import java.sql.Connection;
|
|
|
|
|
import java.sql.ResultSet;
|
|
|
|
|
import java.sql.SQLException;
|
|
|
|
|
@ -142,6 +144,60 @@ public class OracleExtractHelper {
|
|
|
|
|
// FileOperateHelper
|
|
|
|
|
// .fileWrite(
|
|
|
|
|
// Configs.EXTRACT_LOG_LOCALTION + oc.getName(),
|
|
|
|
|
// grantSql+"\r\n");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 创建用户并授权
|
|
|
|
|
*
|
|
|
|
|
* @param conn 汇总库连接
|
|
|
|
|
* @param oc 汇总库信息
|
|
|
|
|
*/
|
|
|
|
|
public void createOnlyUser(Connection conn, OracleConnectorParams oc, GatherOracleInfo totalOracle) {
|
|
|
|
|
String strTUser = Configs.GATHER_STANDARD_USER_NAME;
|
|
|
|
|
|
|
|
|
|
String sql = "Create user " + strTUser + " default tablespace "
|
|
|
|
|
+ totalOracle.getTableName() + " identified by "
|
|
|
|
|
+ Configs.GATHER_TABLE_PASSWORD;
|
|
|
|
|
String grantSql = "grant connect, resource, dba to " + strTUser;
|
|
|
|
|
|
|
|
|
|
OracleConnector.execOracleSQL(conn, sql, Configs.EXTRACT_STANDARD_LOG_LOCALTION + oc.getName());
|
|
|
|
|
// FileOperateHelper
|
|
|
|
|
// .fileWrite(
|
|
|
|
|
// Configs.EXTRACT_LOG_LOCALTION + oc.getName(),
|
|
|
|
|
// sql+"\r\n");
|
|
|
|
|
|
|
|
|
|
OracleConnector.execOracleSQL(conn, grantSql, Configs.EXTRACT_STANDARD_LOG_LOCALTION + oc.getName());
|
|
|
|
|
// FileOperateHelper
|
|
|
|
|
// .fileWrite(
|
|
|
|
|
// Configs.EXTRACT_LOG_LOCALTION + oc.getName(),
|
|
|
|
|
// grantSql+"\r\n");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 创建用户并授权
|
|
|
|
|
*
|
|
|
|
|
* @param conn 汇总库连接
|
|
|
|
|
* @param oc 汇总库信息
|
|
|
|
|
*/
|
|
|
|
|
public void createTable(Connection conn, OracleConnectorParams oc, GatherOracleInfo totalOracle) {
|
|
|
|
|
String strTUser = oc.getName() + totalOracle.getSuffix();
|
|
|
|
|
|
|
|
|
|
String sql = "Create table " + strTUser + " default tablespace "
|
|
|
|
|
+ totalOracle.getTableName() + " identified by "
|
|
|
|
|
+ Configs.GATHER_TABLE_PASSWORD;
|
|
|
|
|
String grantSql = "grant connect, resource, dba to " + strTUser;
|
|
|
|
|
|
|
|
|
|
OracleConnector.execOracleSQL(conn, sql, Configs.EXTRACT_LOG_LOCALTION + oc.getName());
|
|
|
|
|
// FileOperateHelper
|
|
|
|
|
// .fileWrite(
|
|
|
|
|
// Configs.EXTRACT_LOG_LOCALTION + oc.getName(),
|
|
|
|
|
// sql+"\r\n");
|
|
|
|
|
|
|
|
|
|
OracleConnector.execOracleSQL(conn, grantSql, Configs.EXTRACT_LOG_LOCALTION + oc.getName());
|
|
|
|
|
// FileOperateHelper
|
|
|
|
|
// .fileWrite(
|
|
|
|
|
// Configs.EXTRACT_LOG_LOCALTION + oc.getName(),
|
|
|
|
|
// grantSql+"\r\n");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -201,4 +257,60 @@ public class OracleExtractHelper {
|
|
|
|
|
}
|
|
|
|
|
return flag;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 执行抽取操作--支付表
|
|
|
|
|
*
|
|
|
|
|
* @param conn 汇总库连接
|
|
|
|
|
* @param oc 采集库
|
|
|
|
|
*/
|
|
|
|
|
public void extractStandardPayTable(Connection conn, OracleConnectorParams oc, GatherOracleInfo totalOracle) {
|
|
|
|
|
String strTUser = Configs.GATHER_STANDARD_USER_NAME;
|
|
|
|
|
createPay(conn, oc);
|
|
|
|
|
String sql = "insert into " + strTUser + "." + Configs.GATHER_STANDARD_PAY_TABLE_NAME + "select * from "
|
|
|
|
|
+ strTUser + "." + Configs.GATHER_STANDARD_PAY_TABLE_NAME +"'@LINKTO"
|
|
|
|
|
+ oc.getName();
|
|
|
|
|
String resultSql = sql.replace(";", "");
|
|
|
|
|
OracleConnector.execUpdateOracleSQL(conn, resultSql, Configs.EXTRACT_STANDARD_LOG_LOCALTION + oc.getName());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/** 执行抽取操作--执行表
|
|
|
|
|
* @param conn
|
|
|
|
|
* @param collectOracle
|
|
|
|
|
* @param oracleModel
|
|
|
|
|
*/
|
|
|
|
|
public void extractStandardExecTable(Connection conn,
|
|
|
|
|
OracleConnectorParams collectOracle, GatherOracleInfo oracleModel) {
|
|
|
|
|
createExec(conn, collectOracle);
|
|
|
|
|
String strTUser = Configs.GATHER_STANDARD_USER_NAME;
|
|
|
|
|
|
|
|
|
|
String sql = "insert into " + strTUser + "." + Configs.GATHER_STANDARD_EXEC_TABLE_NAME + "select * from "
|
|
|
|
|
+ strTUser + "." + Configs.GATHER_STANDARD_EXEC_TABLE_NAME +"'@LINKTO"
|
|
|
|
|
+ collectOracle.getName();
|
|
|
|
|
String resultSql = sql.replace(";", "");
|
|
|
|
|
OracleConnector.execUpdateOracleSQL(conn, resultSql, Configs.EXTRACT_STANDARD_LOG_LOCALTION + collectOracle.getName());
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void createPay(Connection conn, OracleConnectorParams oc) {
|
|
|
|
|
String payCmd = "CREATE TABLE u_bzbjy.zfxxb(XZQHDM Varchar(255),XZQHMC Varchar(255),PZBH Varchar(255),LYZBKZH Varchar(255),"
|
|
|
|
|
+ "ZFDATE Varchar(255),YSDWCODE Varchar(255),YSDWNAME Varchar(255),YWGKCS Varchar(255),XMCODE Varchar(255),XMNAME Varchar(255),"
|
|
|
|
|
+"XMLBCODE Varchar(255),XMLBNAME Varchar(255),ZB_NO Varchar(255),GNFLCODE Varchar(255),GNFLNAME Varchar(255),JJFLCODE Varchar(255),"
|
|
|
|
|
+"JJFLNAME Varchar(255),ZJXZCODE Varchar(255),ZJXZNAME Varchar(255),JSBFFSNAME Varchar(255),SKR Varchar(255),SKRYH Varchar(255),"
|
|
|
|
|
+ "SKRZHZH Varchar(255),FKZHCODE Varchar(255),FKZHNAME Varchar(255),FKYHCODE Varchar(255),FKYHNAME Varchar(255),QSZHCODE Varchar(255),"
|
|
|
|
|
+ "QSZHNAME Varchar(255),QSYHCODE Varchar(255),QSYHNAME Varchar(255),JE Numeric(18,2), SFTK Varchar(255),NIAN Varchar(255),ZY Varchar(255))";
|
|
|
|
|
|
|
|
|
|
OracleConnector.execOracleSQL(conn, payCmd, Configs.EXTRACT_STANDARD_LOG_LOCALTION + oc.getName());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void createExec(Connection conn, OracleConnectorParams oc) {
|
|
|
|
|
String execCmd = "CREATE TABLE u_bzbjy.kzxzb(XZQHDM Varchar(255),XZQHMC Varchar(255),YSND Varchar(255),ZBCODE Varchar(255),ZB_ID Varchar(255),ZB_NO Varchar(255),"
|
|
|
|
|
+ "ZBDJLXCODE Varchar(255),ZBDJLXNAME Varchar(255),ZBLXNAME Varchar(255),DOCNO Varchar(255),ZBSM Varchar(255),ZBFWDATE Varchar(255),ZBYSLXCODE Varchar(255),"
|
|
|
|
|
+ "ZBYSLXNAME Varchar(255),ZBYSLYNAME Varchar(255),YSDWCODE Varchar(255),YSDWNAME Varchar(255),GNFLCODE Varchar(255),GNFLNAME Varchar(255),JJFLCODE Varchar(255),"
|
|
|
|
|
+ "JJFLNAME Varchar(255),ZBGLCSNAME Varchar(255),SZGLCODE Varchar(255),SZGLNAME Varchar(255),XMCODE Varchar(255),XMNAME Varchar(255),GZBZ Varchar(255),"
|
|
|
|
|
+ "JJBZ Varchar(255),CGBZ Varchar(255),ZFFSCODE Varchar(255),ZFFSNAME Varchar(255),JZZFBZ Varchar(255),ZBJE Numeric(18,2),ZBTJJE Numeric(18,2),ZBDJJE Numeric(18,2),"
|
|
|
|
|
+ "ZBKYJE Numeric(18,2),ZYZFBZ Varchar(255),BZ Varchar(255))";
|
|
|
|
|
|
|
|
|
|
OracleConnector.execOracleSQL(conn, execCmd, Configs.EXTRACT_STANDARD_LOG_LOCALTION + oc.getName());
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
