删除旧表

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/HanaOrderComponent.java

@@ -260,7 +260,7 @@ public class HanaOrderComponent {
 
     }
     /*批量插入*/
-    private void insertSalesOrderResult(ResultSet rs) throws Exception {
+  /*  private void insertSalesOrderResult(ResultSet rs) throws Exception {
         Connection conn = null;
         PreparedStatement pstm =null;
         PreparedStatement pstm1 =null;
@@ -277,7 +277,7 @@ public class HanaOrderComponent {
             if (rs.next()) {
                 long i=0;
                 ResultSetMetaData rsmd = rs.getMetaData();
-                /*循环遍历数据，创建执行批量插入的sql语句*/
+                *//*循环遍历数据，创建执行批量插入的sql语句*//*
                 do {
                     i++;
                     pstm.setString(1, rs.getString("VBELN"));
@@ -351,7 +351,7 @@ public class HanaOrderComponent {
                 }
             }
         }
-    }
+    }*/
 
     //C类
     private int  createTmabcTxt(ResultSet result) throws Exception {
@@ -1006,11 +1006,11 @@ public class HanaOrderComponent {
             Long endTime = System.currentTimeMillis();
             log.info("生成selfDeliverOrder-TXT用时：" + (endTime - startTime) + "毫秒");
 
-            conn = getMysqlConnection();
+         /*   conn = getMysqlConnection();
             //生产表
             String sql = "TRUNCATE TABLE meta_hana_self_deliver_order";
             pstm = conn.prepareStatement(sql);
-            pstm.execute();
+            pstm.execute();*/
         }catch (Exception e){
             e.printStackTrace();
         }finally {
@@ -1158,7 +1158,7 @@ public class HanaOrderComponent {
     }
 
     /*批量插入*/
-    private void insertDeliverOrderResult(ResultSet rs) throws Exception {
+    /*private void insertDeliverOrderResult(ResultSet rs) throws Exception {
         Connection conn = null;
         PreparedStatement pstm =null;
         PreparedStatement pstm1 =null;
@@ -1176,7 +1176,7 @@ public class HanaOrderComponent {
                 long i =0;
                 ResultSetMetaData rsmd = rs.getMetaData();
                 int colNum = rsmd.getColumnCount();
-                /*循环遍历数据，创建执行批量插入的sql语句*/
+                *//*循环遍历数据，创建执行批量插入的sql语句*//*
                 do {
                     pstm.setString(1, rs.getString("VBELN"));
                     pstm.setString(2, rs.getString("POSNR"));
@@ -1253,7 +1253,7 @@ public class HanaOrderComponent {
                 }
             }
         }
-    }
+    }*/
 
 
 
@@ -1409,7 +1409,7 @@ public class HanaOrderComponent {
                 conn.commit();
 
                 // 4. 异步删除旧表
-               /* CompletableFuture.runAsync(() -> {
+                CompletableFuture.runAsync(() -> {
                     try (Connection tempConn = getMysqlConnection();
                          Statement tempStmt = tempConn.createStatement()) {
                         tempStmt.execute("DROP TABLE IF EXISTS meta_hana_sales_order_old");
@@ -1420,7 +1420,7 @@ public class HanaOrderComponent {
                 }).exceptionally(ex -> {
                     log.error("异步删除旧表操作异常", ex);
                     return null;
-                });*/
+                });
 
                 // 清空缓存
                 String result = HttpUtils.sendGet(orderGetDataHook);
@@ -1542,7 +1542,7 @@ public class HanaOrderComponent {
                 conn.commit();
 
                 // 4. 异步删除旧表
-              /*  CompletableFuture.runAsync(() -> {
+                CompletableFuture.runAsync(() -> {
                     try (Connection tempConn = getMysqlConnection();
                          Statement tempStmt = tempConn.createStatement()) {
                         tempStmt.execute("DROP TABLE IF EXISTS meta_hana_self_deliver_order_old");
@@ -1553,7 +1553,7 @@ public class HanaOrderComponent {
                 }).exceptionally(ex -> {
                     log.error("异步删除旧表操作异常", ex);
                     return null;
-                });*/
+                });
 
 
             } catch (Exception e) {
@@ -1630,7 +1630,7 @@ public class HanaOrderComponent {
                 conn.commit();
 
                 // 4. 异步删除旧表
-               /* CompletableFuture.runAsync(() -> {
+                CompletableFuture.runAsync(() -> {
                     try (Connection tempConn = getMysqlConnection();
                          Statement tempStmt = tempConn.createStatement()) {
                         tempStmt.execute("DROP TABLE IF EXISTS meta_hana_deliver_order_old");
@@ -1641,7 +1641,7 @@ public class HanaOrderComponent {
                 }).exceptionally(ex -> {
                     log.error("异步删除旧表操作异常", ex);
                     return null;
-                });*/
+                });
 
                 // 清空缓存
                 String result = HttpUtils.sendGet(orderGetDataHook);