market sql script with resource path

Author: man-zhang

jdk_11_maven/em/embedded/rest/market/src/main/java/em/embedded/market/EmbeddedEvoMasterController.java

@@ -49,7 +49,6 @@ public static void main(String[] args) {
     private Connection sqlConnection;
     private List<DbSpecification> dbSpecification;
 
-
     private String INIT_DB_SCRIPT_PATH = "/data.sql";
 
     private String initSQLScript;
@@ -60,12 +59,6 @@ public EmbeddedEvoMasterController() {
 
     public EmbeddedEvoMasterController(int port) {
         setControllerPort(port);
-
-        try (InputStream in = getClass().getResourceAsStream(INIT_DB_SCRIPT_PATH)) {
-            initSQLScript = (new SqlScriptRunner()).readSQLCommandsAsString(new InputStreamReader(in));
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
     }
 
     @Override
@@ -93,7 +86,7 @@ public String startSut() {
         DbCleaner.clearDatabase_H2(sqlConnection);
 
         dbSpecification = Arrays.asList(new DbSpecification(DatabaseType.H2,sqlConnection)
-                .withInitSqlScript(initSQLScript));
+                .withInitSqlOnResourcePath(INIT_DB_SCRIPT_PATH));
 
         return "http://localhost:" + getSutPort();
     }

jdk_11_maven/em/external/rest/market/src/main/java/em/external/market/ExternalEvoMasterController.java

@@ -70,8 +70,6 @@ public static void main(String[] args) {
 
     private String INIT_DB_SCRIPT_PATH = "/data.sql";
 
-    private String initSQLScript;
-
     public ExternalEvoMasterController() {
         this(40100, "../core/target", 12345, 120, "java");
     }
@@ -88,12 +86,6 @@ public ExternalEvoMasterController(int controllerPort, String jarLocation, int s
         this.timeoutSeconds = timeoutSeconds;
         setControllerPort(controllerPort);
         setJavaCommand(command);
-
-        try (InputStream in = getClass().getResourceAsStream(INIT_DB_SCRIPT_PATH)) {
-            initSQLScript = (new SqlScriptRunner()).readSQLCommandsAsString(new InputStreamReader(in));
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
     }
 
     private String dbUrl( ) {
@@ -163,7 +155,7 @@ public void postStart() {
             DbCleaner.clearDatabase_H2(sqlConnection);
 
             dbSpecification = Arrays.asList(new DbSpecification(DatabaseType.H2,sqlConnection)
-                    .withInitSqlScript(initSQLScript));
+                    .withInitSqlOnResourcePath(INIT_DB_SCRIPT_PATH));
         } catch (Exception e) {
             throw new RuntimeException(e);
         }