Index: trunk/ippToPsps/perl/ippToPsps/IppToPspsDb.pm
===================================================================
--- trunk/ippToPsps/perl/ippToPsps/IppToPspsDb.pm	(revision 29185)
+++ trunk/ippToPsps/perl/ippToPsps/IppToPspsDb.pm	(revision 29186)
@@ -9,5 +9,4 @@
 our @ISA = qw(ippToPsps::MySQLDb);    # inherits from MySQLDb
 
-
 ###########################################################################
 #
@@ -19,8 +18,8 @@
 
     my $query = $self->{_db}->prepare(<<SQL);
-    SELECT created, exp_id, batch_id, survey_id, deleted, dvo_db, processed, on_datastore, loaded_to_ODM, merge_worthy, merged 
+    SELECT created, batch_type, exp_id, batch_id, survey_id, deleted, dvo_db, processed, on_datastore, loaded_to_ODM, merge_worthy, merged 
         FROM batches 
         WHERE created >= '$fromTime'
-        AND created <= '$toTime';
+        AND created <= '$toTime'
 SQL
 
@@ -30,5 +29,4 @@
     my $count = scalar @{${$batches}};
 
-   printf( "* Found %d batch%s\n", $count, ($count==1) ? "" : "es");
    return $count;
 }
@@ -43,5 +41,5 @@
 
     my $query = $self->{_db}->prepare(<<SQL);
-    SELECT created, exp_id, batch_id, survey_id, deleted, dvo_db, processed, on_datastore, loaded_to_ODM, merge_worthy, merged
+    SELECT created, batch_type, exp_id, batch_id, survey_id, deleted, dvo_db, processed, on_datastore, loaded_to_ODM, merge_worthy, merged
         FROM batches 
         WHERE batch_id = $batch_id 
@@ -52,5 +50,4 @@
     my $count = scalar @{${$batches}};
 
-   printf( "* Found %d batch%s\n", $count, ($count==1) ? "" : "es");
    return $count;
 }
@@ -103,6 +100,6 @@
 #
 ########################################################################################
-sub updateBatch {
-    my ($self, $batchId, $expId, $processed, $published, $totalDetections, $minObjId, $maxObjId) = @_;
+sub setAsProcessed {
+    my ($self, $batchId, $expId, $totalDetections, $minObjId, $maxObjId) = @_;
 
     if (!$minObjId) {$minObjId = -1;}
@@ -114,6 +111,5 @@
     UPDATE batches 
         SET 
-          processed = $processed, 
-          on_datastore = $published, 
+          processed = 1, 
           total_detections = $totalDetections,
           min_obj_id = $minObjId,
@@ -128,4 +124,22 @@
 #######################################################################################
 #
+# Sets published state of a batch 
+#
+########################################################################################
+sub setPublished {
+    my ($self, $batchId, $expId, $published) = @_;
+
+    my $query = $self->{_db}->prepare(<<SQL);
+    UPDATE batches 
+        SET on_datastore = $published 
+        WHERE batch_id = $batchId 
+        AND exp_id = $expId;
+SQL
+
+    $query->execute; # TODO check response of this
+}
+
+#######################################################################################
+#
 # Checks whether we have successfully processed this exposure 
 #
@@ -138,5 +152,4 @@
         FROM batches 
         WHERE exp_id = $expId
-        AND created > '2010-08-12'
         AND processed = 1;
 SQL
@@ -179,5 +192,5 @@
     $query->execute;
 
-    print "* New batch '$batchId' for exposure ID = $expId and survey = '$surveyType'\n";
+    print "* New batch '$batchId' for exposure ID = '$expId' and survey = '$surveyType'\n";
 
     return $batchId;