View Javadoc
   package com.bonevich.erj.db;
   
   import com.bonevich.erj.app.Application;
   import com.bonevich.util.Functor;
   import com.bonevich.util.JarFileClassLoader;
   
   import org.apache.commons.logging.Log;
   import org.apache.commons.logging.LogFactory;
   
  import java.sql.Connection;
  import java.sql.DriverManager;
  import java.util.*;
  
  import javax.sql.DataSource;
  
  public final class DatabaseLogin
  {
  	private static final Log _logger = LogFactory.getLog(DatabaseLogin.class);
  	
  	//////////////////////////////////////////////////////////
  	// Attributes
  	private SupportedDatabase _database;
  	private String _databaseName;
  	private String _driver;
  	private String _jdbcUrl;
  	private String _jarPath;
  	
  	private transient JarFileClassLoader _loader;
  	private transient Vector _driverNames;
  	
  	private Properties _loginProperties = new Properties();
  	private List       _loginFields = new ArrayList(10);
  
  	private Connection _connection;
  
  	//////////////////////////////////////////////////////////
  	// Constructors
  	DatabaseLogin(SupportedDatabase database)
  	{
  		_database = database;
  	}
  
  	public static DatabaseLogin getDefaultInstance()
  	{
  		return new DatabaseLogin(Application.getDefaultDatabase());
  	}
  	
  	//////////////////////////////////////////////////////////
  	// Operations
  	
  	/***
  	 * Returns the database.
  	 * @return SupportedDatabase
  	 */
  	public SupportedDatabase getSupportedDatabase()
  	{
  		return _database;
  	}
  
  	/***
  	 * Sets the database.
  	 * @param database The database to set
  	 */
  	public void setSupportedDatabase(SupportedDatabase database)
  	{
  		_database = database;
  	}
  
  	/***
  	 * Returns the display name of the targeted database (i.e. not the
  	 * vendor or RDMS name, but the name of the specific database instance).
  	 * @return String
  	 */
  	public String getDatabaseName()
  	{
  		return _databaseName;
  	}
  	public void setDatabaseName(String databaseName)
  	{
  		_databaseName = databaseName;
  	}
  
  	/***
  	 * Returns the driver.
  	 * @return String
  	 */
  	public String getDriver()
  	{
  		return _driver;
  	}
  
  	/***
  	 * Sets the driver.
  	 * @param driver The driver to set
  	 */
  	public void setDriver(String driver)
  	{
  		_driver = driver;
  	}
 
 	/***
 	 * Returns the jdbcUrl.
 	 * @return String
 	 */
 	public String getJdbcUrl()
 	{
 		return _jdbcUrl;
 	}
 
 	/***
 	 * Sets the jdbcUrl.
 	 * @param jdbcUrl The jdbcUrl to set
 	 */
 	public void setJdbcUrl(String jdbcUrl)
 	{
 		_jdbcUrl = jdbcUrl;
 	}
 
 	/***
 	 * Returns the jarPath.
 	 * @return String
 	 */
 	public String getJarPath()
 	{
 		return _jarPath;
 	}
 
 	/***
 	 * Sets the jdbcJarPath.
 	 * @param jarPath The jarPath to set
 	 */
 	public void setJarPath(String jarPath)
 	{
 		if (jarPath != null && !jarPath.equals(""))
 		{
 			_jarPath = jarPath;
 			try
 			{
 				_loader = new JarFileClassLoader(_jarPath, this);
 				_driverNames = _loader.loadClasses(
 					java.sql.Driver.class,
 					new Functor()
 					{
 						public Object function(Object arg)
 						{
 							Class clazz = (Class) arg;
 							return clazz.getName();
 						}
 					}
 				);
 			}
 			catch (Exception e)
 			{
 				_driverNames = new Vector();
 				_driverNames.add("[no drivers found]");
 			}
 		}
 		else
 		{
 			_jarPath = null;
 			_driverNames = new Vector();
 			_driverNames.add("[no drivers found]");
 		}
 	}
 
 	/***
 	 * Returns the loginProperties.
 	 * @return Properties
 	 */
 	public Properties getLoginProperties()
 	{
 		return _loginProperties;
 	}
 
 	/***
 	 * Sets the loginProperties.
 	 * @param loginProperties The loginProperties to set
 	 */
 	public void setLoginProperty(String key, String value)
 	{
 		if (_logger.isDebugEnabled())
 		{
 			_logger.debug("setting login prop: " + key + " = " + value);
 		}
 		if (key == null) return;
 		_loginProperties.setProperty(key, value);
 		_loginFields.add(new LoginFieldInfo(key, value));
 	}
 	
 	/***
 	 * Returns the loginFields.
 	 * @return List
 	 */
 	public List getLoginFields()
 	{
 		return _loginFields;
 	}
 
 	public static class LoginFieldInfo
 	{
 		public String _key, _value;
 		public LoginFieldInfo(String key, String value)
 		{
 			_key = key;
 			_value = value;
 		}
 		public String getKey() { return _key; }
 		public String getValue() { return _value; }
 	}
 
 	public Connection login() //throws LoginException
 	{
 		if (_connection == null)
 		{
 			synchronized(this)
 			{
 				if (_connection == null)
 				{
 					try
 					{
 						Class.forName(_driver);
 						_connection = DriverManager.getConnection(_jdbcUrl, _loginProperties);
 					}
 					catch (Exception e)
 					{
 						e.printStackTrace();
 					}
 				}
 			}
 		}
 		return _connection;
 	}
 
 	/***
 	 * Returns the driverNames.
 	 * @return Vector
 	 */
 	public Vector getDriverNames()
 	{
 		return _driverNames;
 	}
 
 	/***
 	 * Sets the driverNames.
 	 * @param driverNames The driverNames to set
 	 */
 	public void setDriverNames(Vector driverNames)
 	{
 		_driverNames = driverNames;
 	}
 	
 	/***
 	 * Method getDriverClass.
 	 * @return Class
 	 */
 	public Class getDriverClass()
 	{
 		try
 		{
 			return _loader.loadClass(_driver);
 		}
 		catch (Exception e)
 		{
 			return null;
 		}
 	}
 
 } /* end class DatabaseLogin */