sascha@4067: package de.intevation.aft;
sascha@4067: 
sascha@4072: import java.io.File;
sascha@4072: 
sascha@4073: import java.sql.SQLException;
sascha@4073: 
sascha@4072: import org.w3c.dom.Document;
sascha@4072: 
sascha@4072: import de.intevation.utils.XML;
sascha@4072: 
sascha@4072: import de.intevation.db.ConnectionBuilder;
sascha@4075: import de.intevation.db.ConnectedStatements;
sascha@4072: 
sascha@4067: public class Sync
sascha@4067: {
sascha@4072:     public static final String FLYS = "flys";
sascha@4072:     public static final String AFT  = "aft";
sascha@4072: 
sascha@4072:     public static final String CONFIG_FILE =
sascha@4072:         System.getProperty("config.file", "config.xml");
sascha@4072: 
sascha@4067:     public static void main(String [] args) {
sascha@4072: 
sascha@4072:         File configFile = new File(CONFIG_FILE);
sascha@4072: 
sascha@4072:         if (!configFile.isFile() || !configFile.canRead()) {
sascha@4072:             System.err.println("cannot read config file");
sascha@4072:             System.exit(1);
sascha@4072:         }
sascha@4072: 
sascha@4072:         Document config = XML.parseDocument(configFile, Boolean.FALSE);
sascha@4072: 
sascha@4072:         if (config == null) {
sascha@4072:             System.err.println("cannot load config");
sascha@4072:             System.exit(1);
sascha@4072:         }
sascha@4072: 
sascha@4073:         ConnectionBuilder aftConnectionBuilder =
sascha@4073:             new ConnectionBuilder(AFT, config);
sascha@4073: 
sascha@4072:         ConnectionBuilder flysConnectionBuilder =
sascha@4072:             new ConnectionBuilder(FLYS, config);
sascha@4072: 
sascha@4075:         ConnectedStatements aftStatements  = null;
sascha@4075:         ConnectedStatements flysStatements = null;
sascha@4073:         try {
sascha@4075:             aftStatements  = aftConnectionBuilder.getConnectedStatements();
sascha@4075:             flysStatements = flysConnectionBuilder.getConnectedStatements();
sascha@4075:             Rivers rivers = new Rivers();
sascha@4075:             rivers.sync(aftStatements, flysStatements);
sascha@4073:         }
sascha@4073:         catch (SQLException sqle) {
sascha@4075:             sqle.printStackTrace();
sascha@4073:             System.err.println("syncing failed: " + sqle.getMessage());
sascha@4073:         }
sascha@4073:         finally {
sascha@4075:             if (aftStatements != null) {
sascha@4075:                 aftStatements.close();
sascha@4075:             }
sascha@4075:             if (flysStatements != null) {
sascha@4075:                 flysStatements.close();
sascha@4075:             }
sascha@4073:         }
sascha@4067:     }
sascha@4067: }
sascha@4067: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :