You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by ka...@apache.org on 2008/12/05 21:04:39 UTC
svn commit: r723840 -
/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/extvar/jdbc/JdbcExternalVariableModule.java
Author: karthick
Date: Fri Dec 5 12:04:39 2008
New Revision: 723840
URL: http://svn.apache.org/viewvc?rev=723840&view=rev
Log:
Allow rollback of external variable configuration
Modified:
ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/extvar/jdbc/JdbcExternalVariableModule.java
Modified: ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/extvar/jdbc/JdbcExternalVariableModule.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/extvar/jdbc/JdbcExternalVariableModule.java?rev=723840&r1=723839&r2=723840&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/extvar/jdbc/JdbcExternalVariableModule.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/extvar/jdbc/JdbcExternalVariableModule.java Fri Dec 5 12:04:39 2008
@@ -109,10 +109,12 @@
DatabaseMetaData metaData;
try {
conn = ds.getConnection();
+ conn.setAutoCommit(false);
metaData = conn.getMetaData();
} catch (Exception ex) {
throw new ExternalVariableModuleException("Unable to open database connection for external variable " + evarId, ex);
}
+
try {
DbExternalVariable dbev = new DbExternalVariable(evarId, ds);
@@ -211,7 +213,13 @@
throw new ExternalVariableModuleException("External variable " + evarId + " did not have any <column> elements!");
_vars.put(evarId, dbev);
+
+ conn.commit();
} catch (SQLException se) {
+ try {
+ conn.rollback();
+ } catch (SQLException e) {
+ }
throw new ExternalVariableModuleException("SQL Error", se);
} finally {
try {