You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2007/02/14 01:18:11 UTC
svn commit: r507326 -
/incubator/ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionFactoryImpl.java
Author: mriou
Date: Tue Feb 13 16:18:10 2007
New Revision: 507326
URL: http://svn.apache.org/viewvc?view=rev&rev=507326
Log:
Giving the ability to override Hibernate isolation level.
Modified:
incubator/ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionFactoryImpl.java
Modified: incubator/ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionFactoryImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionFactoryImpl.java?view=diff&rev=507326&r1=507325&r2=507326
==============================================================================
--- incubator/ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionFactoryImpl.java (original)
+++ incubator/ode/trunk/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionFactoryImpl.java Tue Feb 13 16:18:10 2007
@@ -18,14 +18,6 @@
*/
package org.apache.ode.daohib.bpel;
-import java.sql.Connection;
-import java.sql.DatabaseMetaData;
-import java.util.HashMap;
-import java.util.Properties;
-
-import javax.sql.DataSource;
-import javax.transaction.TransactionManager;
-
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.ode.bpel.dao.BpelDAOConnection;
@@ -38,6 +30,13 @@
import org.hibernate.dialect.Dialect;
import org.hibernate.dialect.DialectFactory;
+import javax.sql.DataSource;
+import javax.transaction.TransactionManager;
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.util.HashMap;
+import java.util.Properties;
+
/**
* Hibernate-based {@link org.apache.ode.bpel.dao.BpelDAOConnectionFactory}
* implementation.
@@ -111,6 +110,12 @@
__log.error(errmsg);
}
}
+
+ // Isolation levels override
+ if (System.getProperty("ode.connection.isolation") != null) {
+ String level = System.getProperty("ode.connection.isolation", "2");
+ properties.put(Environment.ISOLATION, level);
+ }
SessionManager sm = new SessionManager(properties, _ds, _tm);
_sessionManager = sm;