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 {
