merge of localization branch into HEAD. mh and zap
[mir.git] / source / mir / misc / MirConfig.java
index 2aa322c..a3e9199 100755 (executable)
@@ -1,20 +1,20 @@
-/*
- * put your module comment here
- */
-
-
 package  mir.misc;
 
-import  javax.servlet.http.*;
 import  java.net.*;
 import  java.io.*;
 import  java.util.*;
 import  java.lang.*;
-import  com.javaexchange.dbConnectionBroker.*;
+
+import  javax.servlet.ServletContext;
+import  javax.servlet.http.*;
+
+import  mir.storage.StorageObjectException;
+import  mir.storage.DatabaseAdaptor;
+import com.codestudio.util.*;
 
 /**
  * Title:        Mir
- * Description:  Class that allows access to all Mir 
+ * Description:  Class that allows access to all Mir
  *               config values
  * Copyright:    Copyright (c) 2001
  * Company:      Indymedia
@@ -25,109 +25,159 @@ import  com.javaexchange.dbConnectionBroker.*;
 
 /**
  * This class is a layer above the Configuration
- * It manages access to config variables that are 
+ * It manages access to config variables that are
  * both generated on the fly and found in the config file.
  */
 
 public class MirConfig extends Configuration {
-  private static HashMap configHash = new HashMap();
-  private static HashMap brokerHash = new HashMap();
 
+  private static HashMap configHash = null;
+  private static HashMap brokerHash = new HashMap();
   private static int      instances=0;
 
   /**
    * Initializes Configuration hash that contains all values.
-   * loads the config.properties file and any other values
-   * @param Uri, the root Uri of the install
-   * @param Home, The absolute path if the install root.
-   * @param Name, The name of the servlet (usually "Mir")
+   * loads the properties-file and any other values
+   * @param uri, the root Uri of the install
+   * @param home, The absolute path if the install root.
+   * @param name, The name of the servlet (usually "Mir")
    * @param confName, the name of the config file to load.
    */
-  public static void initConfig(String Home, String Uri, String Name, String confName) {
+  public static synchronized void initConfig(ServletContext ctx, String uri,
+                                            String name, String confName) {
     initConfResource(confName);
+    configHash = new HashMap();
 
-    configHash.put("Home", Home);
-    configHash.put("RootUri", Uri);
-    configHash.put("ServletName", Name);
-   
-    Enumeration ResKeys = getResourceKeys();
-    while(ResKeys.hasMoreElements()) {
-      String keyNm = (String)ResKeys.nextElement();
+    configHash.put("Home", ctx.getRealPath("/"));
+    configHash.put("ServletContext", ctx);
+    configHash.put("RootUri", uri);
+
+    Enumeration resKeys = getResourceKeys();
+    while(resKeys.hasMoreElements()) {
+      String keyNm = (String)resKeys.nextElement();
       configHash.put(keyNm, getProperty(keyNm));
     }
   }
-
   /**
    * Returns the property asked for by pulling it out a HashMap
    * @param a String containing the property name (key)
    * @return a String containing the prop. value
    */
-  public static String getProp(String PropName) {
-    return (String)configHash.get(PropName);
+  public static void setServletName(String servletName) {
+    configHash.put("ServletName",servletName);
   }
 
-  public static void addBroker(String driver, String URL){
+  /**
+   * Returns the property asked for by pulling it out a HashMap
+   * @param a String containing the property name (key)
+   * @return a String containing the prop. value
+   */
+  public static String getProp(String propName) {
+    String result = (String)configHash.get(propName);
 
-    System.err.println("--trying to add broker");
-    String username,passwd,min,max,log,reset;
+    if (result==null)
+      throw new ConfigException("config property '"+propName+"' not available!");
 
-    if(!brokerHash.containsKey("Pool.broker")){
-      username=getProp("Database.Username");
-      passwd=getProp("Database.Password");
-      min=getProp("Database.poolMin");
-      max=getProp("Database.poolMax");
-      log=getProp("Home") + configHash.get("Database.PoolLog");
-      reset=getProp("Database.poolResetTime");
 
-      try{
-        System.err.println("-- making Broker for -"
-                            +driver+" - " +URL
-                            + " log " + log + " user "
-                            + username + " pass: " + passwd);
-
-        DbConnectionBroker br = new DbConnectionBroker(driver,URL,username,passwd,(new Integer(min)).intValue(),
-                                                      (new Integer(max)).intValue(),log,(new Float(reset)).floatValue());
-        if (br!=null){
-          instances++;
-          brokerHash.put("Pool.broker",br);
-        } else {
-            throw new Exception();
-        }
-      } catch(Exception e){
-        System.err.println("Der ConnectionBroker konnte nicht initializiert werden"+ e.toString());e.printStackTrace();
-      }
-    } // end if
+
+    return result;
   }
 
   /**
-   * Liefert DBConnectionBroker einer Configuration zurueck
-   * @param confFilename
-   * @return DBConnectionBroker
+   * Returns the property asked for by pulling it out a HashMap and
+   * appending it to configproperty "Home"
+   * @param a String containing the property name (key)
+   * @return a String containing the prop.value
    */
-  public static DbConnectionBroker getBroker() {
-    DbConnectionBroker broker=null;
-    broker=(DbConnectionBroker)brokerHash.get("Pool.broker");
-    if (broker==null) {
-      System.err.println("Konnte kein ConnectionPoolBroker initialisiert werden");
-    }
-    return broker;
+  public static String getPropWithHome(String propName) {
+    return getProp("Home") + getProp(propName);
   }
 
   /**
-   * Liefert Anzahl der Instantiierten DBConnectionBroker zurueck
-   * @return
+   * Returns the property asked for iin raw Object form by
+   * pulling it out a HashMap
+   * @param a String containing the property name (key)
+   * @return an Object containing the prop.value
    */
-  public static int getBrokerInstances() {
-    return instances;
+  public static Object getPropAsObject(String propName) {
+    return configHash.get(propName);
   }
 
-  public static DbConnectionBroker getBrokerInfo(){
-    return (DbConnectionBroker)brokerHash.get("Pool.broker");
+  public static void initDbPool () throws StorageObjectException {
+    if (configHash == null) {
+        throw new StorageObjectException("MirConfig -- Trying initialize "+
+                                        "DB pool when system not yet "+
+                                        "configured");
+    }
+    String dbUser=getProp("Database.Username");
+    String dbPassword=getProp("Database.Password");
+    String dbHost=getProp("Database.Host");
+    String dbAdapName=getProp("Database.Adaptor");
+    DatabaseAdaptor adaptor;
+    try {
+      adaptor = (DatabaseAdaptor)Class.forName(dbAdapName).newInstance();
+    } catch (Exception e) {
+      throw new StorageObjectException("Could not load DB adapator: "+
+                                        e.toString());
+    }
+    String dbDriver=adaptor.getDriver();
+    String dbUrl=adaptor.getURL(dbUser,dbPassword, dbHost);
+    System.out.println("adding Broker with: " +dbDriver+":"+dbUrl );
+    addBroker( dbDriver, dbUrl);
+  }
+
+  public static void addBroker(String driver, String URL)
+    throws StorageObjectException {
+
+    if (configHash == null) {
+        throw new StorageObjectException("MirConfig -- Trying initialize "+
+                                        "DB pool when system not yet "+
+                                        "configured");
+    }
+    String username,passwd,min,max,log,reset,dbname,dblogfile;
+
+    if(!brokerHash.containsKey("Pool.broker")){
+      username=getProp("Database.Username");
+      passwd=getProp("Database.Password");
+      min=getProp("Database.poolMin");
+      max=getProp("Database.poolMax");
+      dbname=getProp("Database.Name");
+      log=getProp("Home")+ configHash.get("Database.PoolLog");
+      reset=getProp("Database.poolResetTime");
+      dblogfile=getPropWithHome("Database.Logfile");
+
+      System.err.println("-- making Broker for -"
+                          +driver+" - " +URL
+                          + " log " + log + " user "
+                          + username + " pass: " + passwd);
+
+      JDBCPoolMetaData meta = new JDBCPoolMetaData();
+      meta.setDbname(dbname);
+      meta.setDriver(driver);
+      meta.setURL(URL);
+      meta.setUserName(username);
+      meta.setPassword(passwd);
+      meta.setJNDIName("mir");
+      meta.setMaximumSize(Integer.parseInt(max));
+      meta.setMinimumSize(Integer.parseInt(min));
+      meta.setPoolPreparedStatements(false);
+      meta.setCacheEnabled(false);
+      meta.setCacheSize(15);
+      meta.setDebugging(false);
+      meta.setLogFile(dblogfile+".pool");
+
+      JDBCPool pool = SQLManager.getInstance().createPool(meta);
+
+      if (pool!=null){
+        instances++;
+        brokerHash.put("Pool.broker",pool);
+      }
+
+    } // end if
   }
 
   /**
-   * Finalize Methode
+   * Finalize method
    */
   public void finalize(){
     instances --;
@@ -136,5 +186,4 @@ public class MirConfig extends Configuration {
     } catch (Throwable t) {}
   }
 
-
 }