Transaction problem Jboss + hibernate

[marek]

Hi,

we started to use Jboss 3.2.6 with hibernate 2.1.7c. Everything is working fine except that no data are persistened into database upon commint neither when shutting down jboss. Here is the code snippet using ThreadLocal object to hold sessions and transactions:

private static ThreadLocal threadSession = new ThreadLocal();

private static ThreadLocal threadTransaction = new ThreadLocal();

private static SessionFactory sessionFactory;

static {
 try {
 sessionFactory = new Configuration().configure().buildSessionFactory();
 } catch (Throwable e) {
 e.printStackTrace();
 throw new ExceptionInInitializerError(e);
 }
 }

public Object initSession() throws Exception {
 Session session = (Session) threadSession.get();
 try {
 if (session == null) {
 session = sessionFactory.openSession();
 threadSession.set(session);
 System.out.println("Session # " + session.toString() + " opened");
 }
 if (!session.isConnected()) {
 session.reconnect();
 System.out.println("Session # " + session.toString() + " reconnectd");
 }
 } catch (HibernateException e) {
 e.printStackTrace();
 throw e;
 }
 return session;
 }

protected Session getSession() throws Exception {
 Session session = (Session) threadSession.get();
 try {
 if (session == null){
 session = sessionFactory.openSession();
 threadSession.set(session);
 } else if (session != null && !session.isOpen()){
 session = sessionFactory.openSession();
 threadSession.set(session);
 Transaction tx = (Transaction)threadTransaction.get();
 if (tx != null){
 commitTransaction();
 }
 }
 } catch (HibernateException ex) {
 throw new Exception(ex);
 }
 return session;
 }

public void closeSession() throws Exception {
 Session session = (Session) threadSession.get();
 try {
 threadSession.set(null);
 if (session != null && session.isOpen()) {
 session.flush();
 System.out.println("Closing session # " + session.toString());
 session.close();
 }
 } catch (HibernateException e) {
 e.printStackTrace();
 throw e;
 }
 }

public void beginTransaction() throws Exception {
 Transaction trans = (Transaction) threadTransaction.get();
 try {
 if (trans == null) {
 trans = ((Session) getSession()).beginTransaction();
 threadTransaction.set(trans);
 }
 } catch (HibernateException e) {
 e.printStackTrace();
 throw e;
 }
 }

public void commitTransaction() throws Exception {
 Transaction trans = (Transaction) threadTransaction.get();
 try {
 if (trans != null && !trans.wasCommitted() && !trans.wasRolledBack()) {
// getSession().flush();
// Connection commit works but we could not use it in transaction environment
// getSession().connection().commit();
 trans.commit();
 getSession().close();
 threadTransaction.set(null);
 threadSession.set(null);
 }
 } catch (HibernateException e) {
 rollbackTransaction();
 getSession().flush();
 getSession().close();
 threadSession.set(null);
 e.printStackTrace();
 throw e;
 }
 }

 public void rollbackTransaction() throws Exception {
 Transaction trans = (Transaction) threadTransaction.get();
 try {
 threadTransaction.set(null);
 if (trans != null && !trans.wasCommitted() && !trans.wasRolledBack()) {
 trans.rollback();
 }
 } catch (HibernateException e) {
 e.printStackTrace();
 throw e;
 } finally {
 closeSession();
 }
 }

 public Object saveObject(Object object) throws Exception {
// getSession().saveOrUpdate(object);
 getSession().save(object);
 return object;
 }



 public Object updateObject(Object object) throws Exception {
//## return saveObject(object);
 getSession().saveOrUpdate(object);
 return null;
 }


 public void deleteObject(Object obj) throws Exception {
 Session ses = getSession();
 ses.delete(obj);
 }

 public Collection findObjects(String query) throws Exception {
 return getSession().find(query);
 }

 public Collection findObject(String query, Object obj, Object type) throws Exception {
 Type htype = (Type) type;
 return getSession().find(query, obj, htype);
 }

 public Collection findObjects(String query, Object[] objs, Object[] types) throws Exception {
 Type[] htypes = (Type[]) types;
 return getSession().find(query, objs, htypes);
 }

 public Collection findObjects(String query, Map parameters) throws Exception {
 Query q = getSession().createQuery(query);

 Iterator iter = parameters.keySet().iterator();
 while(iter.hasNext()) {
 String key = (String) iter.next();
 q.setParameter(key, parameters.get(key));
 }

 return q.list();
 }

 public Object findById(Class cl, long id) {
 Object obj = null;

 try {
 Long newId = new Long(id);
 obj = getSession().get(cl, newId);
 } catch (Exception e) {
 e.printStackTrace();
 }
 return obj;
 }

 public Collection findAllObjects(Class voClass) throws Exception {
 Collection result = null;
 Session ses = getSession();
 if (ses.isOpen()) {
 System.out.println("Session is open");
 } else {
 System.out.println("Session is closed");
 }
 result = ses.find("from " + voClass.getName());
 closeSession();
 return result;
 }

hibernate.cfg.xml

<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE hibernate-configuration
 PUBLIC "-//Hibernate/Hibernate Configuration DTD//EN"
 "http://hibernate.sourceforge.net/hibernate-configuration-2.0.dtd">

<hibernate-configuration>
 <!--session-factory name="java:comp/env/jndi/HibernateSessionFactory"-->
 <session-factory>
 <!-- local connection properties -->
 <property name="hibernate.connection.url">jdbc:postgresql://localhost/test</property>
 <property name="hibernate.connection.driver_class">org.postgresql.Driver</property>
 <property name="hibernate.connection.username">test</property>
 <property name="hibernate.connection.password">test</property>

 <!-- transaction configuration -->
 <property name="hibernate.transaction.factory_class">net.sf.hibernate.transaction.JTATransactionFactory</property>
 <property name="hibernate.transaction.manager_lookup_class">net.sf.hibernate.transaction.JBossTransactionManagerLookup</property>

 <!-- DB pooling configuration -->
 <property name="hibernate.c3p0.minPoolSize">5</property>
 <property name="hibernate.c3p0.maxPoolSize">20</property>
 <property name="hibernate.c3p0.timeout">1800</property>
 <property name="hibernate.c3p0.max_statement">50</property>

 <!-- dialect for PostgreSQL -->
 <property name="dialect">net.sf.hibernate.dialect.PostgreSQLDialect</property>
 <property name="hibernate.show_sql">true</property>

<!-- <property name="hibernate.use_outer_join">true</property> -->

<mapping resource="/blabla/UMUser.xml" />

 </session-factory>
</hibernate-configuration>

we are using stateless session beans this way:

public long createUser(UserDTO dto) {
 long result = OPERATION_ERROR;

 try {
 UserManagementDAO dao = new UserManagementDAO();

 dao.initSession();
 dao.beginTransaction();

 // find user by login (unique name)
 UMUser user = (UMUser)dao.findUserByLogin(dto.getLogin());
 if (user != null) {
 // error when login allready exists is database
 log.error("[createUser]: login already exists");
 return result;
 }

 // create user value object from user dto
 user = new UMUser();
 user.setLogin(dto.getLogin());
 user.setPassword(dto.getPassword());
 user.setUserName(dto.getUserName());

 // save user into database
 user = (UMUser) dao.saveObject(user);

 dao.commitTransaction();
 dao.closeSession();

 // return userId
 result = user.getId();

 } catch (Exception e) {
 log.error("[createUser]: ", e);
 }
 return result;
 }

the data and changes are shown in presentation layer but never persisted into db. I'm almost mad about this spending last whole week to browsing newsgroups and forums searching for solution. Would be there any kindly help?