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

説明を見る。

package org.objectweb.cjdbc.controller.connection;

import java.io.Serializable;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Hashtable;

import org.objectweb.cjdbc.common.exceptions.UnreachableBackendException;
import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.common.log.Trace;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;
import org.objectweb.cjdbc.common.xml.XmlComponent;

public abstract class AbstractConnectionManager
    implements
      Serializable,
      XmlComponent,
      Cloneable
{
  /*
   * How the code is organized ? 1. Member variables 2. Connection handling 3.
   * Getter/Setter (possibly in alphabetical order)
   */

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

  protected String            backendUrl;

  protected String            backendName;

  protected String            rLogin;

  protected String            rPassword;

  protected String            driverClassName;

  protected String            driverPath;

  protected boolean           initialized;

  private transient Hashtable connectionForTransaction;

  private String              vLogin;

  /*
   * Constructor(s)
   */

  public AbstractConnectionManager(String backendUrl, String backendName,
      String rLogin, String rPassword, String driverPath, String driverClassName)
  {
    if (backendUrl == null)
      throw new IllegalArgumentException(
          "Illegal null database backend URL in AbstractConnectionManager constructor");

    if (backendName == null)
      throw new IllegalArgumentException(
          "Illegal null database backend name in AbstractConnectionManager constructor");

    if (rLogin == null)
      throw new IllegalArgumentException(
          "Illegal null database backend login in AbstractConnectionManager constructor");

    if (rPassword == null)
      throw new IllegalArgumentException(
          "Illegal null database backend password in AbstractConnectionManager constructor");

    if (driverPath != null)
    {
      if (driverClassName == null)
      {
        throw new IllegalArgumentException(
            "Illegal null database backend driverClassName in AbstractConnectionManager constructor");
      }
    }
    this.backendUrl = backendUrl;
    this.backendName = backendName;
    this.rLogin = rLogin;
    this.rPassword = rPassword;
    this.driverPath = driverPath;
    this.driverClassName = driverClassName;
    connectionForTransaction = new Hashtable();

  }

  public AbstractConnectionManager copy(String url, String name)
      throws Exception
  {
    AbstractConnectionManager connectionManager = (AbstractConnectionManager) this
        .clone();
    connectionManager.backendName = name;
    connectionManager.backendUrl = url;
    return connectionManager;
  }

  /*
   * Connection handling
   */

  public abstract void initializeConnections() throws SQLException;

  public abstract void finalizeConnections() throws SQLException;

  public Connection getConnectionFromDriver()

  {
    try
    {
      return DriverManager.getConnection(backendUrl, rLogin, rPassword,
          driverPath, driverClassName);
    }
    catch (SQLException ignore)
    {
      if (logger.isDebugEnabled())
      {
        logger.debug("failed to get connection for driver ", ignore);
      }
      return null;
    }
  }

  public abstract Connection getConnection() throws UnreachableBackendException;

  public Connection getConnection(long transactionId)
      throws UnreachableBackendException
  {
    Connection c = getConnection();
    if (c != null)
      connectionForTransaction.put(new Long(transactionId), c);
    return c;
  }

  public Connection retrieveConnection(long transactionId)
  {
    Long id = new Long(transactionId);
    return (Connection) connectionForTransaction.get(id);
  }

  public abstract void releaseConnection(Connection connection);

  public void releaseConnection(long transactionId)
  {
    Connection c = (Connection) connectionForTransaction.remove(new Long(
        transactionId));

    if (c == null)
      logger.error(Translate.get("connection.transaction.unknown",
          transactionId));
    else
      releaseConnection(c);
  }

  public abstract void deleteConnection(Connection connection);

  public void deleteConnection(long transactionId)
  {
    Connection c = (Connection) connectionForTransaction.remove(new Long(
        transactionId));

    if (c == null)
      logger.error(Translate.get("connection.transaction.unknown",
          transactionId));
    else
      deleteConnection(c);
  }

  public boolean isInitialized()
  {
    return initialized;
  }

  /*
   * Getter/setter methods
   */

  public String getLogin()
  {
    return rLogin;
  }

  public void setLogin(String rLogin)
  {
    this.rLogin = rLogin;
  }

  public String getPassword()
  {
    return rPassword;
  }

  public void setPassword(String rPassword)
  {
    this.rPassword = rPassword;
  }

  /*
   * Debug/monitoring information
   */

  public abstract String getXmlImpl();

  public String getXml()
  {
    StringBuffer info = new StringBuffer();
    info.append("<" + DatabasesXmlTags.ELT_ConnectionManager + " "
        + DatabasesXmlTags.ATT_vLogin + "=\"" + vLogin + "\"  " + ""
        + DatabasesXmlTags.ATT_rLogin + "=\"" + rLogin + "\"  " + ""
        + DatabasesXmlTags.ATT_rPassword + "=\"" + rPassword + "\"  " + ">");
    info.append(this.getXmlImpl());
    info.append("</" + DatabasesXmlTags.ELT_ConnectionManager + ">");
    return info.toString();
  }

  protected void finalize() throws Throwable
  {
    if (isInitialized())
      finalizeConnections();
    super.finalize();
  }

  public String getVLogin()
  {
    return vLogin;
  }

  public void setVLogin(String login)
  {
    vLogin = login;
  }

  public abstract int getCurrentNumberOfConnections();

  public String getDriverClassName()
  {
    return driverClassName;
  }

  public void setDriverClassName(String driverClassName)
  {
    this.driverClassName = driverClassName;
  }

  public String getDriverPath()
  {
    return driverPath;
  }

  public void setDriverPath(String driverPath)
  {
    this.driverPath = driverPath;
  }

  protected abstract Object clone() throws CloneNotSupportedException;
}

---