Open Source Repository

Home /hibernate/hibernate-3.2.4.ga | Repository Home


org/hibernate/connection/DatasourceConnectionProvider.java
//$Id: DatasourceConnectionProvider.java 10075 2006-07-01 12:50:34Z epbernard $
package org.hibernate.connection;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

import javax.sql.DataSource;

import org.hibernate.HibernateException;
import org.hibernate.cfg.Environment;
import org.hibernate.util.NamingHelper;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 * A connection provider that uses a <tt>DataSource</tt> registered with JNDI.
 * Hibernate will use this <tt>ConnectionProvider</tt> by default if the
 * property <tt>hibernate.connection.datasource</tt> is set.
 @see ConnectionProvider
 @author Gavin King
 */
public class DatasourceConnectionProvider implements ConnectionProvider {
  private DataSource ds;
  private String user;
  private String pass;

  private static final Log log = LogFactory.getLog(DatasourceConnectionProvider.class);

  public DataSource getDataSource() {
    return ds;
  }

  public void setDataSource(DataSource ds) {
    this.ds = ds;
  }

  public void configure(Properties propsthrows HibernateException {

    String jndiName = props.getProperty(Environment.DATASOURCE);
    if (jndiName==null) {
      String msg = "datasource JNDI name was not specified by property " + Environment.DATASOURCE;
      log.fatal(msg);
      throw new HibernateException(msg);
    }

    user = props.getProperty(Environment.USER);
    pass = props.getProperty(Environment.PASS);

    try {
      ds = (DataSourceNamingHelper.getInitialContext(props).lookup(jndiName);
    }
    catch (Exception e) {
      log.fatal"Could not find datasource: " + jndiName, e );
      throw new HibernateException"Could not find datasource", e );
    }
    if (ds==null) {
      throw new HibernateException"Could not find datasource: " + jndiName );
    }
    log.info"Using datasource: " + jndiName );
  }

  public Connection getConnection() throws SQLException {
    if (user != null || pass != null) {
      return ds.getConnection(user, pass);
    }
    else {
      return ds.getConnection();
    }
  }

  public void closeConnection(Connection connthrows SQLException {
    conn.close();
  }

  public void close() {}

  /**
   @see ConnectionProvider#supportsAggressiveRelease()
   */
  public boolean supportsAggressiveRelease() {
    return true;
  }

}