提交修改

src/main/java/com/data/datarepo/services/DataMySQL2OracleService.java

@@ -2,6 +2,7 @@ package com.data.datarepo.services;
 
 import com.data.datarepo.domain.DataRepoTable;
 import com.data.datarepo.utils.DataSource;
+import com.data.datarepo.utils.DataSourceOra;
 import com.data.datarepo.utils.EquipmentNo;
 import com.data.datarepo.utils.SM4Utils;
 import com.mysql.cj.jdbc.MysqlDataSource;
@@ -13,13 +14,13 @@ import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
-public class DataMySQL2OracleService {
+public class DataMySQL2OracleService extends DataSourceOra {
     // 源数据库，目标数据库的连接配置
-    String mysql_jdbc_url = "jdbc:mysql://localhost/mz-cloud?user=root&password=password1&useUnicode=true&characterEncoding=gb2312";
-
-    String jdbc_url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
-    String jdbc_user = "DATAREP";
-    String jdbc_password = "sckjadmin";
+//    String mysql_jdbc_url = "jdbc:mysql://localhost/mz-cloud?user=root&password=password1&useUnicode=true&characterEncoding=gb2312";
+//
+//    String jdbc_url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
+//    String jdbc_user = "DATAREP";
+//    String jdbc_password = "sckjadmin";
     EquipmentNo equipmentNo =new EquipmentNo();
     DataCenterService dataCenterService=new DataCenterService();
     DataTypeService dataTypeService=new DataTypeService();
@@ -27,14 +28,13 @@ public class DataMySQL2OracleService {
 
     public DataRepoTable startProcess(String repo_name, String table_name, String up_num, String table_comment) throws Exception {
         // 创建到两个数据库的连接
-        Class.forName("com.mysql.cj.jdbc.Driver");
+//        Class.forName("com.mysql.cj.jdbc.Driver");
         MysqlDataSource basicDS = DataSource.getInstance().getMySqlDS();
         Connection connSource = basicDS.getConnection();
 //        Connection connSource = DriverManager.getConnection(mysql_jdbc_url);
 
-        Class.forName("oracle.jdbc.driver.OracleDriver");
-        Connection connDest = DriverManager.getConnection(jdbc_url, jdbc_user,
-                jdbc_password);
+//        Class.forName("oracle.jdbc.driver.OracleDriver");
+        Connection connDest = this.getConn();
 
         // 打开源数据库中相关表
         StringBuilder sb = new StringBuilder();