You are viewing a plain text version of this content. The canonical link for it is here.
Posted to wsrp4j-dev@portals.apache.org by dl...@apache.org on 2006/12/25 18:05:59 UTC
svn commit: r490154 -
/portals/wsrp4j/trunk/persistence-db/src/java/org/apache/wsrp4j/persistence/db/driver/PersistentHandlerImpl.java
Author: dlouzan
Date: Mon Dec 25 09:05:59 2006
New Revision: 490154
URL: http://svn.apache.org/viewvc?view=rev&rev=490154
Log:
Externalized transaction demarcation.
Modified:
portals/wsrp4j/trunk/persistence-db/src/java/org/apache/wsrp4j/persistence/db/driver/PersistentHandlerImpl.java
Modified: portals/wsrp4j/trunk/persistence-db/src/java/org/apache/wsrp4j/persistence/db/driver/PersistentHandlerImpl.java
URL: http://svn.apache.org/viewvc/portals/wsrp4j/trunk/persistence-db/src/java/org/apache/wsrp4j/persistence/db/driver/PersistentHandlerImpl.java?view=diff&rev=490154&r1=490153&r2=490154
==============================================================================
--- portals/wsrp4j/trunk/persistence-db/src/java/org/apache/wsrp4j/persistence/db/driver/PersistentHandlerImpl.java (original)
+++ portals/wsrp4j/trunk/persistence-db/src/java/org/apache/wsrp4j/persistence/db/driver/PersistentHandlerImpl.java Mon Dec 25 09:05:59 2006
@@ -87,20 +87,12 @@
try {
- /* Start the transaction */
- session.beginTransaction();
-
/* Load object from the DB */
PersistentDataObjectDB pdoDB =
(PersistentDataObjectDB) persistentDataObject;
pdoDB.load(pdoDB, session);
- /* Commit the transaction */
- session.getTransaction().commit();
-
} catch (Exception e) {
- /* Rollback the operation */
- session.getTransaction().rollback();
/* Throw the exception */
WSRPXHelper.throwX(log, ErrorCodes.RESTORE_OBJECT_ERROR, e);
}
@@ -136,20 +128,12 @@
try {
- /* Start the transaction */
- session.beginTransaction();
-
/* Load all objects from the DB */
PersistentDataObjectDB pdoDB =
(PersistentDataObjectDB) persistentDataObject;
pdoDB.loadAll(pdoDB, session);
- /* Commit the transaction */
- session.getTransaction().commit();
-
} catch (Exception e) {
- /* Rollback the operation */
- session.getTransaction().rollback();
/* Throw the exception */
WSRPXHelper.throwX(log, ErrorCodes.RESTORE_OBJECT_ERROR, e);
}
@@ -184,21 +168,12 @@
try {
- /* Start the transaction */
- session = HibernateUtil.getSessionFactory().getCurrentSession();
- session.beginTransaction();
-
/* Store object to the DB */
PersistentDataObjectDB pdoDB =
(PersistentDataObjectDB) persistentDataObject;
pdoDB.save(pdoDB, session);
- /* Commit the transaction */
- session.getTransaction().commit();
-
} catch (Exception e) {
- /* Rollback the operation */
- session.getTransaction().rollback();
/* Throw the exception */
WSRPXHelper.throwX(log, ErrorCodes.RESTORE_OBJECT_ERROR, e);
}
@@ -231,21 +206,12 @@
try {
- /* Start the transaction */
- session = HibernateUtil.getSessionFactory().getCurrentSession();
- session.beginTransaction();
-
/* Delete object from the DB */
PersistentDataObjectDB pdoDB =
(PersistentDataObjectDB) persistentDataObject;
pdoDB.delete(pdoDB, session);
- /* Commit the transaction */
- session.getTransaction().commit();
-
} catch (Exception e) {
- /* Rollback the operation */
- session.getTransaction().rollback();
/* Throw the exception */
WSRPXHelper.throwX(log, ErrorCodes.RESTORE_OBJECT_ERROR, e);
}