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.commons.lang.StringUtils;

import org.apache.log4j.Logger;

import org.hibernate.cache.internal.NoCachingRegionFactory;

import org.hibernate.cache.spi.RegionFactory;

import org.hibernate.cfg.Environment;

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.model.name.NomenclaturalCode;

/**

 * @author a.mueller

 *

 */

public class CdmDataSource extends CdmDataSourceBase {

	@SuppressWarnings("unused")

	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 NomenclaturalCode nomenclaturalCode;

	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 boolean registerSearchListener = false;

	private Class<? extends RegionFactory> cacheProviderClass = NoCachingRegionFactory.class;

	public static CdmDataSource NewInstance(DatabaseTypeEnum dbType, String server, String database, String username, String password){

		return new CdmDataSource(dbType, server, database, -1, username, password, null, null, null);

	}

	public static CdmDataSource NewInstance(DatabaseTypeEnum dbType, String server, String database, int port, String username, String password){

		return new CdmDataSource(dbType, server, database, port, username, password, null, null, null);

	}

	public static CdmDataSource NewInstance(DatabaseTypeEnum dbType, String server, String database, String username, String password , NomenclaturalCode code){

		return new CdmDataSource(dbType, server, database, -1, username, password, null, null, code);

	}

	public static CdmDataSource NewInstance(DatabaseTypeEnum dbType, String server, String database, int port, String username, String password , NomenclaturalCode code){

		return new CdmDataSource(dbType, server, database, port, username, password, null, null, code);

	}

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

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

	}

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

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

	}

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

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

	}

	static public CdmDataSource  NewPostgreSQLInstance(String server, String database, int port, String username, String password, NomenclaturalCode code){

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

	}

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

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

	}

	static public CdmDataSource  NewSqlServer2005Instance(String server, String database, int port, String username, String password /*, NomenclaturalCode code*/){

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

	}

	/** in work

	 * @param code TODO*/

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

		return NewH2EmbeddedInstance(database, username, password, null,  null);

	}

	/** in work

	 * @param code TODO*/

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

		return NewH2EmbeddedInstance(database, username, password, null, code);

	}

	/** in work

	 * @param code TODO*/

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

		//FIXME in work

		int port = -1;

		H2Mode mode = H2Mode.EMBEDDED;

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

		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, null);

		return dataSource;

	}

	public static CdmDataSource NewInstance(ICdmDataSource dataSource) {

		return new CdmDataSource(dataSource.getDatabaseType(),

				dataSource.getServer(),

				dataSource.getDatabase(),

				dataSource.getPort(),

				dataSource.getUsername(),

				dataSource.getPassword(),

				dataSource.getFilePath(),

				dataSource.getMode(),

				dataSource.getNomenclaturalCode());

	}

	/**

	 * @param server

	 * @param database

	 * @param port

	 */

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

		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;

		this.nomenclaturalCode = code;

	}

	/* (non-Javadoc)

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

	 * A CdmDataSource does not have a name representation therefore the database name is returned

	 */

	@Override

	public String getName() {

		return database;

	}

	@Override

	public String getServer() {

		return server;

	}

	@Override

	public int getPort() {

		return port;

	}

	@Override

	public NomenclaturalCode getNomenclaturalCode() {

		return nomenclaturalCode;

	}

	@Override

	public BeanDefinition getDatasourceBean(){

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

		//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<Object> keys = (Enumeration<Object>)persistentProperties.keys();

		while (keys.hasMoreElements()){

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

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

			Properties a = Environment.getProperties();

		}

		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;

	}

	@Override

	public BeanDefinition getHibernatePropertiesBean(DbSchemaValidation hbm2dll){

		boolean showSql = false;

		boolean formatSql = false;

		boolean registerSearchListener = false;

		Class<? extends RegionFactory> cacheProviderClass = NoCachingRegionFactory.class;

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

	}

	@Override

	public BeanDefinition getHibernatePropertiesBean(DbSchemaValidation hbm2dll, Boolean showSql, Boolean formatSql, Boolean registerSearchListener, Class<? extends RegionFactory> 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;

		}

		if(registerSearchListener == null){

			registerSearchListener = this.registerSearchListener;

		}

		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.getHibernateDialectCanonicalName());

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

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

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

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

		props.setProperty("hibernate.search.autoregister_listeners", String.valueOf(registerSearchListener));

		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;

	}

	@Override

	public String getDatabase() {

		return database;

	}

	@Override

	public void setDatabase(String database) {

		this.database = database;		

	}

	@Override

	public DatabaseTypeEnum getDatabaseType() {

		return dbType;

	}

	@Override

	public String getFilePath() {

		return filePath;

	}

	@Override

	public H2Mode getMode() {

		return mode;

	}

	@Override

	public void setMode(H2Mode h2Mode) {

		this.mode = h2Mode;

	}

	@Override

	public String getPassword() {

		return password;

	}

	@Override

	public void setPassword(String password) {

		this.password = password;

	}

	@Override

	public String getUsername() {

		return username;

	}

	@Override

	public void setUsername(String username) {

		this.username = username;

	}

	@Override

	public String toString() {

		if (StringUtils.isBlank(this.database)){

			return super.toString();

		}else{

			String result = "DataSource<" + dbType.getConnectionString(this).replace(CdmUtils.Nz(password), "") + ">";

			return result;

		}

	}

}