HibernateConnection.java

package bonpay.partner.database.connector;
import java.sql.Connection;
import java.util.Properties;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.AnnotationConfiguration;

/** êëàññ, êîòîðûé ñîçäàåò Hibernate.Session íà îñíîâàíèè Connection */
public class HibernateConnection {
	private SessionFactory sessionFactory=null;
	private IConnector connectorFactory; 
	
	/** ñîçäàòü íà áàçå Connection Hibernate íàäñòðîéêó 
	 * @param connectorFactory - êîííåêòîð, êîòîðûé ìîæåò ãåíåðèðîâàòü Connection ê áàçå äàííûõ
	 * @param hibernateDialect - "org.hibernate.dialect.FirebirdDialect"
	 * ( example for HSQLDB - org.hsqldb.jdbcDriver)
	 * @throws âûáðàñûâàåò èñêëþ÷åíèå â ñëó÷àå, êîãäà íå óäàëîñü ñîçäàòü Hibernate 
	 * */
	public HibernateConnection(IConnector connectorFactory, String hibernateDialect,Class<?> ... classes) throws Exception{
		this.connectorFactory=connectorFactory;
		sessionFactory=getAnnotationConfiguration(hibernateDialect,classes).buildSessionFactory();		
	}

	
	private AnnotationConfiguration getAnnotationConfiguration(String hibernateDialect,Class<?> ... classes){
		AnnotationConfiguration aconf = new AnnotationConfiguration();
		Properties properties=new Properties();
		properties.put("hibernate.dialect", hibernateDialect);
		properties.put("hibernate.connection.driver_class", "org.firebirdsql.jdbc.FBDriver");
		//properties.put("hibernate.connection.url", "jdbc:hsqldb:mem:baseball");
		//properties.put("hibernate.connection.username", "sa");
		//properties.put("hibernate.connection.password", "");
		properties.put("hibernate.connection.pool_size", "10");
		properties.put("hibernate.connection.autocommit", "false");
		//properties.put("hibernate.cache.provider_class", "org.hibernate.cache.HashtableCacheProvider");
		//properties.put("hibernate.hbm2ddl.auto", "create-drop");
		//properties.put("hibernate.show_sql", "true");

		//properties.put("hibernate.connection.datasource", "java:comp/env/jdbc/test");
		//hibernate.connection.datasource  	 datasource JNDI name
		//hibernate.jndi.url 	URL of the JNDI provider (optional)
		//hibernate.jndi.class 	class of the JNDI InitialContextFactory (optional) 
		
		//properties.put("hibernate.c3p0.min_size","5");
		//properties.put("hibernate.c3p0.max_size","20");
		//properties.put("hibernate.c3p0.timeout","1800");
		//properties.put("hibernate.c3p0.max_statements","50");
		
		aconf.setProperties(properties);
		for(int counter=0;counter<classes.length;counter++){
			aconf.addAnnotatedClass(classes[counter]);
		}
		return aconf;
	}
	/** get Hibernate Session */
	public Session openSession(Connection connection){
		try{
			return sessionFactory.openSession(connection);
		}catch(Exception ex){
			System.err.println("HibernateConnection GetConnection Exception: "+ex.getMessage());
			return null;
		}
	}
	
	/** get Hibernate Session */
/*	public Session openSession(Connection connection){
		try{
			return sessionFactory.openSession(this.connection);
		}catch(Exception ex){
			System.err.println("openSession Exception: "+ex.getMessage());
			return null;
		}
	}
*/	
	/** get Connection */
	public Connection getConnection(){
		Connection connection=this.connectorFactory.getConnection();
		try{
			connection.setAutoCommit(false);
		}catch(Exception ex){};
		return connection;
	}
	
	/** çàêðûòü âñå ñîåäèíåíèÿ ñ áàçîé äàííûõ */
	public void close(){
		System.out.println("close");
		this.sessionFactory.close();
		this.connectorFactory.closeAllConnection();
	}
	
	public void finalize(){
		this.close();
	}
}