src/org/objectweb/cjdbc/controller/connection/DriverManager.java

説明を見る。

package org.objectweb.cjdbc.controller.connection;

import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;

import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.common.log.Trace;
import org.objectweb.cjdbc.controller.core.Controller;
import org.objectweb.cjdbc.controller.core.ControllerConstants;

public class DriverManager
{

  static Trace       logger         = Trace
                                        .getLogger("org.objectweb.cjdbc.controller.connection.DriverManager");

  private static Set defaultDrivers = new HashSet();

  private static Map namedDrivers   = new HashMap();

  public static Connection getConnection(String url, String user,
      String password, String driverPathName, String driverClassName)
      throws SQLException
  {
    Driver driver = null;
    boolean isDefaultPath = false;

    if (driverPathName == null)
    {
      // no path specified
      // have we already loaded this driver
      driver = (Driver) namedDrivers.get(driverClassName);
      if (driver == null)
      {
        // the driver has not yet been loaded
        // first we try to load class from classpath
        try
        {
          if (driverClassName != null)
          {
            loadDriverClass(driverClassName);
          }
          return java.sql.DriverManager.getConnection(url, user, password);
        }
        catch (ClassNotFoundException e)
        {
          if (driverClassName == null)
          {
            throw new SQLException(
                "could not load driver as no class name is specified ");
          }
          try
          {
            driverPathName = getDriversDir().getAbsolutePath();
            isDefaultPath = true;
          }
          catch (IOException ioExc)
          {
            throw new SQLException("could not find default drivers directory");
          }
        }
      }
    }

    if (driver == null)
    {
      // have we already loaded this named driver ?
      driver = (Driver) namedDrivers.get(driverPathName);
    }

    if (driver == null)
    {
      // no driver with this name has been loaded so far
      try
      {
        File path = convertToAbsolutePath(driverPathName);
        // we load the driver now
        if (logger.isDebugEnabled())
        {
          logger.debug("loading driver with name " + driverPathName
              + " for class " + driverClassName);
        }
        driver = loadDriver(path, driverClassName);
      }
      catch (Exception e)
      {
        if (logger.isDebugEnabled())
        {
          logger.debug("could not load driver for class " + driverClassName, e);
        }
        throw new SQLException("could not load driver for class name "
            + driverClassName + " and driverPath " + driverPathName);
      }

      // driver has been loaded successfully, we cache it for
      // further use
      if (isDefaultPath)
      {// we cache it with the class name
        namedDrivers.put(driverClassName, driver);
      }
      else
      {
        // we cache it with the pathName
        namedDrivers.put(driverPathName, driver);
      }
    }

    return getConnectionForDriver(url, user, password, driver);
  }

  public static void loadDriverClass(String driverClassName)
      throws ClassNotFoundException
  {
    if (!defaultDrivers.contains(driverClassName))
    {
      if (logger.isDebugEnabled())
      {
        logger.debug("we are using default classloader and driverClassName ="
            + driverClassName);
      }
      Class.forName(driverClassName);
      if (logger.isDebugEnabled())
        logger.debug(Translate.get("backend.driver.loaded", driverClassName));
      // the driver was successfully loaded
      defaultDrivers.add(driverClassName);
    }
  }

  public static File convertToAbsolutePath(String pathName) throws IOException
  {
    File dir = null;

    if (pathName != null)
    {
      File path = new File(pathName);
      if (path.canRead())
        return path;
      else
        throw new IOException("Invalid path name " + pathName);
    }
    else
    {
      dir = getDriversDir();
    }

    if (!dir.canRead())
    {
      String msg = Translate.get("controller.driver.dir.not.found");
      logger.error(msg);
      throw new IOException(msg);
    }

    return dir;
  }

  private static File getDriversDir() throws IOException
  {
    URL url = Controller.class
        .getResource(ControllerConstants.C_JDBC_DRIVER_JAR_FILE);
    File driversDir = new File(url.getFile()).getParentFile();

    if (!driversDir.exists())
    {
      String msg = Translate.get("controller.driver.dir.not.found");
      logger.error(msg);
      throw new IOException(msg);
    }
    return driversDir;
  }

  private static Connection getConnectionForDriver(String url, String user,
      String password, Driver driver) throws SQLException
  {
    java.util.Properties info = new java.util.Properties();
    if (user != null)
    {
      info.put("user", user);
    }
    if (password != null)
    {
      info.put("password", password);
    }

    return driver.connect(url, info);
  }

  private static Driver loadDriver(File path, String driverClassName)
      throws ClassNotFoundException, InstantiationException,
      IllegalAccessException
  {
    ClassLoader loader = new DriverClassLoader(null, path);

    // load java.sql.DriverManager with the new classloader
    // Driver instances register with the DriverManager and we want the new
    // Driver to register with its own DriverManager
    // Otherwise the new Driver would register with the default DriverManager
    // and possibly overwrite an other driver with the same name
    Class.forName(java.sql.DriverManager.class.getName(), true, loader);

    // load class
    Class driverClass = Class.forName(driverClassName, true, loader);

    if (logger.isDebugEnabled())
      logger.debug(Translate.get("backend.driver.loaded", driverClassName));

    // get an instance of the class and return it
    return (Driver) driverClass.newInstance();

  }

}

---