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 2008/11/27 00:16:09 UTC
svn commit: r721028 -
/ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java
Author: mriou
Date: Wed Nov 26 15:16:08 2008
New Revision: 721028
URL: http://svn.apache.org/viewvc?rev=721028&view=rev
Log:
ODE-441 simpleScheduler SQLException in JdbcDelegate.updateAssignToNode
Modified:
ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java
Modified: ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java?rev=721028&r1=721027&r2=721028&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java (original)
+++ ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java Wed Nov 26 15:16:08 2008
@@ -214,10 +214,12 @@
PreparedStatement ps = null;
try {
con = getConnection();
- if (_dialect == Dialect.SQLSERVER) {
- ps = con.prepareStatement(UPGRADE_JOB_SQLSERVER);
+ if (_dialect == Dialect.SQLSERVER || _dialect == Dialect.SYBASE) {
+ ps = con.prepareStatement(UPGRADE_JOB_SQLSERVER);
+ } else if (_dialect == Dialect.DB2) {
+ ps = con.prepareStatement(UPGRADE_JOB_DB2);
} else {
- ps = con.prepareStatement(UPGRADE_JOB_DEFAULT);
+ ps = con.prepareStatement(UPGRADE_JOB_DEFAULT);
}
ps.setString(1, node);
ps.setInt(2, numNodes);