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

説明を見る。

package org.objectweb.cjdbc.controller.connection;

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

import org.objectweb.cjdbc.common.exceptions.UnreachableBackendException;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;

public class SimpleConnectionManager extends AbstractConnectionManager
    implements
      Serializable
{
  private int nbOfConnections = 0;

  public SimpleConnectionManager(String backendUrl, String backendName,
      String login, String password, String driverPath, String driverClassName)
  {
    super(backendUrl, backendName, login, password, driverPath, driverClassName);
  }

  protected Object clone() throws CloneNotSupportedException
  {
    return new SimpleConnectionManager(backendUrl, backendName, rLogin,
        rPassword, driverPath, driverClassName);
  }

  public void initializeConnections() throws SQLException
  {
    initialized = true;
  }

  public void finalizeConnections() throws SQLException
  {
    initialized = false;
  }

  public Connection getConnection() throws UnreachableBackendException
  {
    if (!initialized)
    {
      logger
          .error("Requesting a connection from a non-initialized connection manager");
      return null;
    }

    addConnection();
    Connection c = getConnectionFromDriver();
    if (c == null)
    {
      removeConnection();
      logger.error("Unable to get connection from " + backendUrl);
      if (nbOfConnections == 0)
      {
        logger.error("Backend '" + backendUrl + "' is considered unreachable. "
            + "(No active connection and none can be opened)");
        throw new UnreachableBackendException();
      }
    }
    return c;
  }

  public void releaseConnection(Connection connection)
  {
    removeConnection();
    try
    {
      connection.close();
    }
    catch (SQLException e)
    {
      logger.error("Failed to close connection for '" + backendUrl + "'", e);
    }
  }

  public void deleteConnection(Connection c)
  {
  }

  public int getCurrentNumberOfConnections()
  {
    return nbOfConnections;
  }

  private synchronized void addConnection()
  {
    nbOfConnections++;
  }

  private synchronized void removeConnection()
  {
    nbOfConnections--;
  }

  public String getXmlImpl()
  {
    return "<" + DatabasesXmlTags.ELT_SimpleConnectionManager + "/>";
  }

}

---