new package: ohdm2geoserverrendering

- added OHDM2Geoserverrendering class

Author: teceP

src/ohdm2geoserverrendering/OHDM2Geoserverrendering.java

@@ -0,0 +1,326 @@
+package ohdm2geoserverrendering;
+
+import util.DB;
+import util.Parameter;
+import util.SQLStatementQueue;
+
+import java.io.*;
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.jar.JarEntry;
+import java.util.jar.JarFile;
+
+public class OHDM2Geoserverrendering {
+
+    public List<String> defaultSQLStatementList = new ArrayList<>();
+    public List<String> actualSQLStatementList = new ArrayList<>();
+
+    String admin_labels_sql = "";
+    String amenities_sql = "";
+    String boundaries_sql = "";
+    String buildings_sql = "";
+    String housenumbers_sql = "";
+    String landusages_sql = "";
+    String places_sql = "";
+    String roads_sql = "";
+    String transport_areas_sql = "";
+    String transport_points_sql = "";
+    String waterarea_sql = "";
+    String waterways_sql = "";
+
+    public static void main(String[] args) throws SQLException, IOException {
+        String sourceParameterFileName = "db_ohdm.txt";
+        String targetParameterFileName = "db_rendering.txt";
+        
+
+        if(args.length > 0) {
+            sourceParameterFileName = args[0];
+        }
+
+        if(args.length > 1) {
+            targetParameterFileName = args[1];
+        }
+            
+//            Connection sourceConnection = Importer.createLocalTestSourceConnection();
+//            Connection targetConnection = Importer.createLocalTestTargetConnection();
+
+        Parameter sourceParameter = new Parameter(sourceParameterFileName);
+        Parameter targetParameter = new Parameter(targetParameterFileName);
+
+        Connection connection = DB.createConnection(targetParameter);
+
+        String targetSchema = targetParameter.getSchema();
+            
+        String sourceSchema = sourceParameter.getSchema();
+        
+        SQLStatementQueue sql = new SQLStatementQueue(connection);
+        OHDM2Geoserverrendering renderer = new OHDM2Geoserverrendering();
+
+        renderer.loadSQLFiles();
+        renderer.changeDefaultParametersToActual(targetSchema, sourceSchema);
+
+
+        renderer.executeSQLStatements(sql);
+        
+        System.out.println("Render tables creation for Geoserver finished");
+
+        System.out.println("Start copying symbols into user-dir..");
+        renderer.loadSymbolsFromResources();
+        System.out.println("Start copying css-files into user-dir..");
+        renderer.loadCssFromResourecs();
+
+        if(!renderer.checkFiles()){
+            System.out.println("CSS and/or symbolfiles couldnt be created successfully.\n" +
+                    "Please download these files manually from: https://github.com/teceP/OSMImportUpdateGeoserverResources");
+        }else{
+            System.out.println("CSS and symbolfiles has been created successfully.");
+        }
+
+    }
+
+    void loadSQLFiles(){
+            System.out.println("Load SQL-Files...");
+
+            admin_labels_sql = loadSqlFromResources("resources/sqls/admin_labels.sql");
+            amenities_sql = loadSqlFromResources("resources/sqls/amenities.sql");
+            boundaries_sql = loadSqlFromResources("resources/sqls/boundaries.sql");
+            buildings_sql = loadSqlFromResources("resources/sqls/buildings.sql");
+            housenumbers_sql = loadSqlFromResources("resources/sqls/housenumbers.sql");
+            landusages_sql = loadSqlFromResources("resources/sqls/landusages.sql");
+            places_sql = loadSqlFromResources("resources/sqls/places.sql");
+            roads_sql  = loadSqlFromResources("resources/sqls/roads.sql");
+            transport_areas_sql = loadSqlFromResources("resources/sqls/transport_areas.sql");
+            transport_points_sql = loadSqlFromResources("resources/sqls/transport_points.sql");
+            waterarea_sql = loadSqlFromResources("resources/sqls/waterarea.sql");
+            waterways_sql = loadSqlFromResources("resources/sqls/waterways.sql");
+
+        defaultSQLStatementList.add(admin_labels_sql);
+        defaultSQLStatementList.add(amenities_sql);
+        defaultSQLStatementList.add(boundaries_sql);
+        defaultSQLStatementList.add(buildings_sql);
+        defaultSQLStatementList.add(housenumbers_sql);
+        defaultSQLStatementList.add(landusages_sql);
+        defaultSQLStatementList.add(places_sql);
+        defaultSQLStatementList.add(roads_sql);
+        defaultSQLStatementList.add(transport_areas_sql);
+        defaultSQLStatementList.add(transport_points_sql);
+        defaultSQLStatementList.add(waterarea_sql);
+        defaultSQLStatementList.add(waterways_sql);
+    }
+
+    void changeDefaultParametersToActual(String targetSchema, String sourceSchema){
+        for (String statement : defaultSQLStatementList) {
+
+            String actualStatement = statement.replaceAll("my_test_schema", targetSchema);
+            actualStatement = actualStatement.replaceAll("ohdm", sourceSchema);
+
+            actualSQLStatementList.add(actualStatement);
+        }
+    }
+
+    void executeSQLStatements(SQLStatementQueue sql){
+
+        System.out.println(actualSQLStatementList.size() + " statements in queue. Start execute SQL files... ");
+
+        float eachPercentage = 100/actualSQLStatementList.size();
+        float currentPercentage = 0;
+
+            for(String statement: actualSQLStatementList){
+                sql.append(statement);
+                try {
+                    sql.forceExecute();
+                } catch (SQLException e) {
+                    e.printStackTrace();
+                }
+                sql.resetStatement();
+                currentPercentage = currentPercentage + eachPercentage;
+                System.out.println(currentPercentage + " % finished.");
+            }
+
+
+        System.out.println("100 % finished.");
+
+    }
+
+    public void deleteOldDatas(File dir){
+
+        if(dir.exists()){
+            //clean up
+            if(dir.isDirectory()){
+                String[] files = dir.list();
+                for(String file : files){
+                    File currentFile = new File(file);
+                    currentFile.delete();
+                }
+            }
+        }
+
+    }
+
+    public String loadSqlFromResources(String path){
+        InputStream in = getClass().getResourceAsStream(path);
+        BufferedReader reader = new BufferedReader(new InputStreamReader(in));
+        String content = "";
+        try {
+            content = readFile(reader);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+
+        System.out.println("File loaded from: " + path);
+        return content;
+    }
+
+
+    public String readFile(BufferedReader reader) throws IOException {
+        String content = "";
+        String line = reader.readLine();
+
+        while(line != null){
+            content = content + " " + line + System.lineSeparator();
+            line = reader.readLine();
+        }
+
+        return content;
+    }
+
+    /**
+     * CSS
+     */
+
+    void loadCssFromResourecs(){
+        File targetdir = new File("css");
+
+        this.deleteOldDatas(targetdir);
+
+        targetdir.mkdir();
+
+        JarFile jar = null;
+        String path = "resources/css/";
+        try {
+            jar = new JarFile("OSMImportUpdate.jar");
+            Enumeration<JarEntry> entries = jar.entries();
+            while (entries.hasMoreElements()) {
+                JarEntry entry = entries.nextElement();
+
+                if (entry.getName().contains(path) && !entry.isDirectory()) {
+                    System.out.println("Load symbol: " + entry.getName());
+                    createCssFromResources("/" + entry.getName());
+                }
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    void createCssFromResources(String filename){
+
+        try {
+            InputStream in = getClass().getResourceAsStream(filename);
+            BufferedReader reader = new BufferedReader(new InputStreamReader(in));
+
+            String content = readFile(reader);
+
+            int pos = filename.length()-1;
+
+            while(filename.charAt(pos) != '/'){
+                pos--;
+            }
+
+            filename = filename.substring(pos);
+
+            File file = new File("css" + filename);
+            file.createNewFile();
+
+            BufferedWriter writer = new BufferedWriter(new FileWriter(file)); //write file (content)
+            writer.write(content);
+            writer.close();
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * Symbols
+     */
+
+    public void loadSymbolsFromResources(){
+
+        System.out.println("Symbol files will be copied to working dir..(" + System.getProperty("user.dir") + "/symbols/ )");
+
+        File targetdir = new File("symbols");
+
+        this.deleteOldDatas(targetdir);
+
+        targetdir.mkdir();
+
+        JarFile jar = null;
+        String path = "resources/symbols/";
+        try {
+            jar = new JarFile("OSMImportUpdate.jar");
+            Enumeration<JarEntry> entries = jar.entries();
+            while (entries.hasMoreElements()) {
+                JarEntry entry = entries.nextElement();
+
+                if (entry.getName().contains(path) && !entry.isDirectory()) {
+                    System.out.println("Load symbol: " + entry.getName());
+                    createSymbolsFromResources("/" + entry.getName());
+                }
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public void createSymbolsFromResources(String filename){
+
+        //There are some problems with writing and reading the SVG files..
+        //Methode shouldnt be used till its working.. Download symbols from git repo (link in main-method)
+
+       /* try {
+            BufferedImage bimage = ImageIO.read(getClass().getResource(filename));
+
+            int pos = filename.length()-1;
+
+            while(filename.charAt(pos) != '/'){
+                pos--;
+            }
+
+            filename = filename.substring(pos);
+
+            File file = new File("symbols" + filename);
+            file.createNewFile();
+            ImageIO.write(bimage, "png", file);
+
+        } catch (IOException e) {
+           // e.printStackTrace();
+        }*/
+    }
+
+    public boolean checkFiles(){
+        File symbols = new File("symbols");
+        boolean symbolFiles = false;
+
+        if(symbols.isDirectory()){
+            if(symbols.listFiles().length > 0){
+                symbolFiles = true;
+            }
+        }
+
+        File css = new File("css");
+        boolean cssFiles = false;
+
+        if(css.isDirectory()){
+            if(css.listFiles().length > 0){
+                cssFiles = true;
+            }
+        }
+
+        return symbolFiles && cssFiles;
+    }
+
+}