增加测试判断(刘大为需求)

src/main/java/com/example/bigsql/service/CreateDatabasesByV3File.java

@@ -199,6 +199,7 @@ public class CreateDatabasesByV3File {
 
     }
 
+
     /**
      * 读取文件 并创建数据库和表
      */
@@ -222,6 +223,7 @@ public class CreateDatabasesByV3File {
                 log.info("开始解析sql文件,文件名：" + f.getName());
                 //场站编号
                 String name = f.getName().substring(0, 6);
+                boolean isTest = f.getName().startsWith("测试", f.getName().length() - 6);
                 String csvFilePath = "/home/bigsql/csvdir/" + name + File.separator;
                 //String csvFilePath = "/Users/xiaowang/个人/csvdir/" + name + File.separator;
                 //判断csvFilePath这个目录是否存在 如果不存在则创建目录
@@ -265,7 +267,11 @@ public class CreateDatabasesByV3File {
                                 }
                             }
                             sqlStatements = sqlStatements.stream().filter(s -> s.startsWith("CREATE") || s.startsWith("DROP")).collect(Collectors.toList());
-                            databasesName = "ipfcst_" + name + "_" + DateUtil.format(new Date(), DatePattern.PURE_DATETIME_FORMAT);
+                            if (isTest) {
+                                databasesName = "ipfcst_" + name + "_test_" + DateUtil.format(new Date(), DatePattern.PURE_DATE_FORMAT);
+                            } else {
+                                databasesName = "ipfcst_" + name + "_" + DateUtil.format(new Date(), DatePattern.PURE_DATETIME_FORMAT);
+                            }
                             Connection conn = JyDbUtil.conn;
 
                             int num = 0;