调整存储过程

src/main/java/com/data/datarepo/controller/DataController.java

@@ -113,28 +113,13 @@ public class DataController {
     }
 
     @RequestMapping("/repoBJ")
-    public String datarepoBJ(String[] repo_name, HttpServletRequest request, HttpServletResponse response) throws SQLException {
-        DataRepoTable dataRepoTable = new DataRepoTable();
-        List<DataRepoTable> tableList = new ArrayList<DataRepoTable>();
-        if (repo_name != null) {
-            for (int i = 0; i < repo_name.length; i++) {
-                String[] value1 = new String[repo_name.length];
-                String[] value2 = new String[repo_name.length];
-                String[] value3 = new String[repo_name.length];
-                String[] value4 = new String[repo_name.length];
-                String temp = repo_name[i];
-                String[] itempsplit = temp.split("-");
-                value1[i] = itempsplit[0];
-                value2[i] = itempsplit[1];
-                value3[i] = itempsplit[2];
-                value4[i] = itempsplit[3];
-                dataRepoTable = dataService.testSelectBJ(value1[i], value2[i], value3[i], value4[i]);
-                tableList.add(dataRepoTable);
-                System.out.println("表：" + value1[i] + "加载完成:100%");
-            }
-        }
-        request.setAttribute("DataRepoTableList", tableList);
-        return "dataList";
+    public String datarepoBJ(String[] repo_name) throws SQLException {
+        String[] value2 = new String[repo_name.length];
+        String temp = repo_name[0];
+        String[] itempsplit = temp.split("-");
+        value2[0] = itempsplit[1];
+        dataService.testSelectBJ(value2[0]);
+        return "redirect:/data/list";
     }
 
 }

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

@@ -10,20 +10,15 @@ import java.sql.PreparedStatement;
 import java.sql.SQLException;
 
 public class DataLoadService extends DataSourceOra{
-    public void testLoad(String repo_name,String up_num) throws SQLException {
+    public void testLoad(String up_num) throws SQLException {
         Connection conn=null;
         CallableStatement cstmt=null;
         try{
             conn=this.getConn();
-            String oldName=repo_name+"_OLD";
-            String seSql="select * from "+oldName+" where up_num='"+up_num+"'";
-//            System.out.println(seSql);
-            cstmt=conn.prepareCall("{ call DATAREP.largedata_insert(?,?)}");
-            cstmt.setString(1,repo_name);
-            cstmt.setString(2,seSql);
-//            cstmt.setString(3,up_num);
+            cstmt=conn.prepareCall("{ call DATAREP.largedata_insert(?)}");
+            cstmt.setString(1,up_num);
             cstmt.execute();
-            System.out.println("表："+repo_name+"执行成功！");
+            System.out.println("执行成功！");
         }
         catch(Exception e)
         {

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

@@ -187,6 +187,7 @@ public class DataMySQL2OracleService extends DataSourceOra {
             dataRepoTable.setTable_name(table_name);
             dataRepoTable.setRepo_name(repo_name);
             dataRepoTable.setUp_num(up_num);
+            dataCenterService.insertUpnum(dataRepoTable);
         } catch (Exception e) {
             connDest.rollback();
             e.printStackTrace();
@@ -243,11 +244,7 @@ public class DataMySQL2OracleService extends DataSourceOra {
             if (connDest != null) {
                 connDest.close();
             }
-
-
         }
-
-
         return dataRepoTable;
     }
 

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

@@ -171,16 +171,8 @@ public class DataService {
     }
 
 
-    public DataRepoTable testSelectBJ(String repo_name, String up_num, String table_name, String table_comment) throws SQLException {
-        DataRepoTable dataRepoTable = new DataRepoTable();
-        dataRepoTable.setRepo_name(repo_name);
-        dataRepoTable.setUp_num(up_num);
-        dataRepoTable.setTable_name(table_name);
-        dataRepoTable.setTable_comment(table_comment);
-        dataDeleteService.DataDelete(repo_name);
-        dataLoadService.testLoad(repo_name, up_num);
-        dataCenterService.insertUpnum(dataRepoTable);
-        return dataRepoTable;
+    public void testSelectBJ(String up_num) throws SQLException {
+        dataLoadService.testLoad(up_num);
     }
 
     public DataRepoTable testSelectResult(String repo_name, String up_num, String table_name, String table_comment) throws SQLException {