svn commit: r721031 - /ode/branches/APACHE_ODE_1.X/scheduler-simple/src/main/java/org/apache/ode/scheduler/simple/JdbcDelegate.java

[mriou]

Author: mriou
Date: Wed Nov 26 15:19:45 2008
New Revision: 721031

URL: http://svn.apache.org/viewvc?rev=721031&view=rev
Log:
Forgot the queries, there are days like these...

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=721031&r1=721030&r2=721031&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:19:45 2008
@@ -54,8 +54,11 @@
     private static final String UPGRADE_JOB_DEFAULT = "update ODE_JOB set 
nodeid = ? where nodeid is null "
             + "and mod(ts,?) = ? and ts < ?";
 
+    private static final String UPGRADE_JOB_DB2 = "update ODE_JOB set nodeid = 
? where nodeid is null "
+            + "and mod(ts,CAST(? AS BIGINT)) = ? and ts < ?";
+    
     private static final String UPGRADE_JOB_SQLSERVER = "update ODE_JOB set 
nodeid = ? where nodeid is null "
-        + "and (ts % ?) = ? and ts < ?";
+            + "and (ts % ?) = ? and ts < ?";
 
     private static final String SAVE_JOB = "insert into ODE_JOB "
             + " (jobid, nodeid, ts, scheduled, transacted, details) values(?, 
?, ?, ?, ?, ?)";