Browse Source

可以通过接口生成表空间并划分表分区

zoro 1 year ago
parent
commit
f6e57483c0

+ 32 - 33
src/main/java/com/example/sqlrun/service/impl/SpaceAndPartitionServiceImpl.java

@@ -69,7 +69,7 @@ public class SpaceAndPartitionServiceImpl implements SpaceAndPartitionService {
             statement.clearBatch();
         }
         Date lastDate = (Date) tableSpaces.get(tableSpaces.size() - 1).get(SpaceEnum.DATE.getName());
-        rule.setLastAddTablespaceTime(DateUtils.monthAddNum(lastDate,1));
+        rule.setLastAddTablespaceTime(DateUtils.monthAddNum(lastDate, 1));
         rule.setLastAddPartitionTime(DateUtils.dayAddNum(DateUtils.monthAddNum(lastDate, 1), -1));
         ruleService.updateById(rule);
     }
@@ -84,38 +84,37 @@ public class SpaceAndPartitionServiceImpl implements SpaceAndPartitionService {
 
     @Override
     public String createTableSpace(Map<String, String> paramBody) {
-//    try {
-//      String tableSpaceNamePrefix = paramBody.get("tableSpaceName");
-//      String tableSpaceFileNamePrefix = paramBody.get("tableSpaceFileName");
-//      String tableSpacePath = paramBody.get("tableSpacePath");
-//      Integer initSize = Integer.valueOf(paramBody.get("initSize"));
-//      Integer nextSize = Integer.valueOf(paramBody.get("nextSize"));
-//      Integer maxSize = Integer.valueOf(paramBody.get("maxSize"));
-//      String startDate = paramBody.get("startDate");
-//      Integer wanted = Integer.valueOf(paramBody.get("wanted"));
-//      List<Map> maps =
-//          MakeTableSpace.makeTableSpaceSql(
-//              tableSpaceNamePrefix,
-//              tableSpaceFileNamePrefix,
-//              tableSpacePath,
-//              initSize,
-//              nextSize,
-//              maxSize,
-//              startDate,
-//              wanted);
-//      for (Map map : maps) {
-//        statement.execute(map.get(SpaceEnum.TABLESPACE_SQL.getName()).toString());
-//      }
-//      Map map = maps.get(maps.size() - 1);
-//      return "最后一个表空间时间"
-//          + map.get(SpaceEnum.DATE.getName())
-//          + "\n"
-//          + "最后一个表空间名称"
-//          + map.get(SpaceEnum.TABLESPACENAME.getName());
-//    } catch (Exception e) {
-//      return "error" + e.getMessage();
-//    }
-        return null;
+        try {
+            String tableSpaceNamePrefix = paramBody.get("tableSpaceName");
+            String tableSpaceFileNamePrefix = paramBody.get("tableSpaceFileName");
+            String tableSpacePath = paramBody.get("tableSpacePath");
+            Integer initSize = Integer.valueOf(paramBody.get("initSize"));
+            Integer nextSize = Integer.valueOf(paramBody.get("nextSize"));
+            Integer maxSize = Integer.valueOf(paramBody.get("maxSize"));
+            Date startDate = DateUtils.stringToDate(paramBody.get("startDate"), "yyyy-MM-dd");
+            Integer wanted = Integer.valueOf(paramBody.get("wanted"));
+            List<Map> maps =
+                    MakeTableSpace.makeTableSpaceSql(
+                            tableSpaceNamePrefix,
+                            tableSpaceFileNamePrefix,
+                            tableSpacePath,
+                            initSize,
+                            nextSize,
+                            maxSize,
+                            startDate,
+                            wanted);
+            for (Map map : maps) {
+                statement.execute(map.get(SpaceEnum.TABLESPACE_SQL.getName()).toString());
+            }
+            Map map = maps.get(maps.size() - 1);
+            return "最后一个表空间时间"
+                    + map.get(SpaceEnum.DATE.getName())
+                    + "\n"
+                    + "最后一个表空间名称"
+                    + map.get(SpaceEnum.TABLESPACENAME.getName());
+        } catch (Exception e) {
+            return "error" + e.getMessage();
+        }
     }
 
     @Override