svn commit: r1601436 - /manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java

[kwright]

Author: kwright
Date: Mon Jun  9 16:37:14 2014
New Revision: 1601436

URL: http://svn.apache.org/r1601436
Log:
Fix query repeat issue, for real this time

Modified:
    
manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java

Modified: 
manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
URL: 
http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java?rev=1601436&r1=1601435&r2=1601436&view=diff
==============================================================================
--- 
manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
 (original)
+++ 
manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
 Mon Jun  9 16:37:14 2014
@@ -2940,7 +2940,7 @@ public class JobManager implements IJobM
 
           // Now we can tack the limit onto the query.  Before this point, 
remainingDocuments would be crap
           int limitValue = vList.getRemainingDocuments();
-          query += database.constructOffsetLimitClause(0,limitValue,true);
+          String finalQuery = query + 
database.constructOffsetLimitClause(0,limitValue,true);
 
           if (Logging.perf.isDebugEnabled())
           {
@@ -2951,7 +2951,7 @@ public class JobManager implements IJobM
           database.beginTransaction();
           try
           {
-            IResultSet set = 
database.performQuery(query,list,null,null,-1,vList);
+            IResultSet set = 
database.performQuery(finalQuery,list,null,null,-1,vList);
 
             if (Logging.perf.isDebugEnabled())
               Logging.perf.debug(" Queuing 
"+Integer.toString(set.getRowCount())+" documents");