EDIT

/**

* Copyright (C) 2007 EDIT

* European Distributed Institute of Taxonomy 

* http://www.e-taxonomy.eu

* 

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

package eu.etaxonomy.cdm.database;

import java.util.Enumeration;

import java.util.Properties;

import org.apache.log4j.Logger;

import org.hibernate.cache.CacheProvider;

import org.hibernate.cache.NoCacheProvider;

import org.springframework.beans.MutablePropertyValues;

import org.springframework.beans.factory.config.BeanDefinition;

import org.springframework.beans.factory.config.PropertiesFactoryBean;

import org.springframework.beans.factory.support.AbstractBeanDefinition;

import org.springframework.beans.factory.support.RootBeanDefinition;

import eu.etaxonomy.cdm.common.CdmUtils;

import eu.etaxonomy.cdm.database.DatabaseTypeEnum;

import eu.etaxonomy.cdm.database.DbSchemaValidation;

/**

 * @author a.mueller

 *

 */

public class CdmDataSource implements ICdmDataSource {

	private static final Logger logger = Logger.getLogger(CdmDataSource.class);

	private DatabaseTypeEnum dbType;

	private String server;

	private String database; 

	private int port = -1;

	private String username;

	private String password;

	private String filePath;

	private H2Mode mode;

	private boolean isLazy = true;

	private String initMethodName = null;

	private String destroyMethodName = null;

	private DbSchemaValidation hbm2dll = DbSchemaValidation.VALIDATE;

	private boolean showSql = false;

	private boolean formatSql = false;

	private Class<? extends CacheProvider> cacheProviderClass = NoCacheProvider.class;;

	static public CdmDataSource  NewMySqlInstance(String server, String database, String username, String password){

		return new CdmDataSource(DatabaseTypeEnum.MySQL, server, database, -1, username, password, null, null);

	}

	static public CdmDataSource  NewMySqlInstance(String server, String database, int port, String username, String password){

		return new CdmDataSource(DatabaseTypeEnum.MySQL, server, database, port, username, password, null, null);

	}

	static public CdmDataSource  NewSqlServer2005Instance(String server, String database, String username, String password){

		return new CdmDataSource(DatabaseTypeEnum.SqlServer2005, server, database, -1, username, password, null, null);

	}

	static public CdmDataSource  NewSqlServer2005Instance(String server, String database, int port, String username, String password){

		return new CdmDataSource(DatabaseTypeEnum.SqlServer2005, server, database, port, username, password, null, null);

	}

	/** in work */

	static public CdmDataSource  NewH2EmbeddedInstance(String database, String username, String password){

		//FIXME in work

		int port = -1;

		H2Mode mode = H2Mode.EMBEDDED;

		CdmDataSource dataSource = new CdmDataSource(DatabaseTypeEnum.H2, null, database, port, username, password, null, mode);

		return dataSource;

	}

	/** in work */

	static public CdmDataSource  NewH2InMemoryInstance(){

		//FIXME in work

		int port = -1;

		H2Mode mode = H2Mode.IN_MEMORY;

		String username = "sa";

		String password = "";

		CdmDataSource dataSource = new CdmDataSource(DatabaseTypeEnum.H2, null, null, port, username, password, null, mode);

		return dataSource;

	}

	/**

	 * @param server

	 * @param database

	 * @param port

	 */

	protected CdmDataSource(DatabaseTypeEnum dbType, String server, String database, int port, String username, String password, String filePath, H2Mode mode) {

		super();

		this.dbType = dbType;

		this.server = server;

		this.database = database;

		this.port = port;

		this.username = username;

		this.password = password;

		this.initMethodName = dbType.getInitMethod();

		this.destroyMethodName = dbType.getDestroyMethod();

		this.filePath = filePath;

		this.mode = mode;

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.cdm.database.ICdmDataSource#getName()

	 */

	public String getName() {

		return database;

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.cdm.api.application.ICdmDataSource#getDatasourceBean()

	 */

	public BeanDefinition getDatasourceBean(){

		AbstractBeanDefinition bd = new RootBeanDefinition(dbType.getDriverManagerDataSourceClass());

		//attributes

		bd.setLazyInit(isLazy);

		if (! CdmUtils.Nz(initMethodName).trim().equals("") ){

			bd.setInitMethodName(initMethodName);

		}

		if (! CdmUtils.Nz(destroyMethodName).trim().equals("") ){

			bd.setInitMethodName(destroyMethodName);

		}

		//properties

		MutablePropertyValues props = new MutablePropertyValues();

		Properties persistentProperties = getDatasourceProperties();

		Enumeration<String> keys = (Enumeration)persistentProperties.keys(); 

		while (keys.hasMoreElements()){

			String key = (String)keys.nextElement();

			props.addPropertyValue(key, persistentProperties.getProperty(key));

		}

		bd.setPropertyValues(props);

		return bd;

	}

	/**

	 * Returns the list of properties that are defined in the datasource    

	 * @return 

	 */

	private Properties getDatasourceProperties(){

		Properties result = new Properties();

		result.put("driverClassName", dbType.getDriverClassName());

		String connectionString = dbType.getConnectionString(this);

		result.put("url", connectionString);

		result.put("username", username);

		result.put("password", password);

		return result;

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.cdm.api.application.ICdmDataSource#getHibernatePropertiesBean(eu.etaxonomy.cdm.database.CdmPersistentDataSource.HBM2DDL)

	 */

	public BeanDefinition getHibernatePropertiesBean(DbSchemaValidation hbm2dll){

		boolean showSql = false;

		boolean formatSql = false;

		Class<? extends CacheProvider> cacheProviderClass = NoCacheProvider.class;

		return getHibernatePropertiesBean(hbm2dll, showSql, formatSql, cacheProviderClass);

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.cdm.api.application.ICdmDataSource#getHibernatePropertiesBean(eu.etaxonomy.cdm.database.CdmPersistentDataSource.HBM2DDL, java.lang.Boolean, java.lang.Boolean, java.lang.Class)

	 */

	public BeanDefinition getHibernatePropertiesBean(DbSchemaValidation hbm2dll, Boolean showSql, Boolean formatSql, Class<? extends CacheProvider> cacheProviderClass){

		//Hibernate default values

		if (hbm2dll == null){

			hbm2dll = this.hbm2dll;

		}

		if (showSql == null){

			showSql = this.showSql;

		}

		if (formatSql == null){

			formatSql = this.formatSql;

		}

		if (cacheProviderClass == null){

			cacheProviderClass = this.cacheProviderClass;

		}

		DatabaseTypeEnum dbtype = dbType;

		AbstractBeanDefinition bd = new RootBeanDefinition(PropertiesFactoryBean.class);

		MutablePropertyValues hibernateProps = new MutablePropertyValues();

		Properties props = new Properties();

		props.setProperty("hibernate.hbm2ddl.auto", hbm2dll.toString());

		props.setProperty("hibernate.dialect", dbtype.getHibernateDialect());

		props.setProperty("hibernate.cache.provider_class", cacheProviderClass.getName());

		props.setProperty("hibernate.show_sql", String.valueOf(showSql));

		props.setProperty("hibernate.format_sql", String.valueOf(formatSql));

		hibernateProps.addPropertyValue("properties",props);

		bd.setPropertyValues(hibernateProps);

		return bd;

	}

	public String getInitMethodName() {

		return initMethodName;

	}

	public void setInitMethodName(String initMethodName) {

		this.initMethodName = initMethodName;

	}

	public String getDestroyMethodName() {

		return destroyMethodName;

	}

	public void setDestroyMethodName(String destroyMethodName) {

		this.destroyMethodName = destroyMethodName;

	}

	public String getDatabase() {

		return database;

	}

	public DatabaseTypeEnum getDatabaseType() {

		return dbType;

	}

	public String getFilePath() {

		return filePath;

	}

	public int getPort() {

		return port;

	}

	public String getServer() {

		return server;

	}

	public H2Mode getMode() {

		return mode;

	}	

}