organization创建完成

src/main/resources/application.yml

@@ -53,7 +53,7 @@ spring:
     ds3:
       ## Hikari连接池的设置 Hikari 时间单位都是毫秒
       type: com.zaxxer.hikari.HikariDataSource
-      jdbc-url: jdbc:oracle:thin:@11.71.15.26:1521:oracycn
+      jdbc-url: jdbc:oracle:thin:@11.71.15.26:1521/oracycn
       username: Zy_autodata0
       password: "#XJYTzygsauto2019"
       driver-class-name: oracle.jdbc.OracleDriver

src/test/java/com/gct/tools/etlcamelhuge/EtlCamelHugeApplicationTests.java

@@ -19,7 +19,7 @@ import java.time.format.DateTimeFormatter;
 import java.util.*;
 
 @RunWith(SpringRunner.class)
-@SpringBootTest
+@SpringBootTest(classes = EtlCamelHugeApplication.class)
 class EtlCamelHugeApplicationTests {
 
     @Resource(name = "oracle")
@@ -57,21 +57,23 @@ class EtlCamelHugeApplicationTests {
 
         results.forEach(rowMap->{
             Stack<String> orgPreStack = new Stack<>();
-            Map<String,Object> parentObj = null;
-            while((parentObj=parentObjMap.get(rowMap.get("PARENT_ID").toString()))!=null){
+            Map<String,Object> parentObj = rowMap;
+
+            while((parentObj=parentObjMap.get(parentObj .get("ORG_ID").toString()))!=null){
                 orgPreStack.push(parentObj.get("ORG_NAME").toString());
             }
             StringBuilder orgIdPre = new StringBuilder();
             while (!orgPreStack.isEmpty()){
-                orgIdPre.append("@").append(orgPreStack.pop());
+                orgIdPre.append(orgPreStack.pop()).append("@");
             }
-            String orgIdPreStr = orgIdPre.delete(0, 1).toString();
+            orgIdPre.append(rowMap.get("ORG_NAME"));
+            String orgIdPreStr = orgIdPre.toString();
             String sqlInsertOrg = String.format("insert into centralbase.cb_pc_organization(" +
                     "org_id,org_name,org_code,org_level,parent_id,org_id_pre) " +
-                    "values(%s,%s,%s,%s,%s,%s)",rowMap.get("ORG_ID"),rowMap.get("ORG_NAME"),rowMap.get("ORG_CODE"),rowMap.get("ORG_LEVEL")
+                    "values('%s','%s','%s','%s','%s','%s')",rowMap.get("ORG_ID"),rowMap.get("ORG_NAME"),rowMap.get("ORG_CODE"),rowMap.get("ORG_LEVEL")
                     ,rowMap.get("PARENT_ID"),orgIdPreStr);
-            System.out.println(sqlInsertOrg);
-//            centralbaseTemplate.execute(sqlInsertOrg);
+//            System.out.println(sqlInsertOrg);
+            centralbaseTemplate.execute(sqlInsertOrg);
 
         });
     }