join force index

mrjgreen · Mar 31, 2015 · d9de7ef · d9de7ef
1 parent a05e5b3
commit d9de7ef
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/DbSync/Comparison/Hash.php b/src/DbSync/Comparison/Hash.php
@@ -171,7 +171,7 @@ private function compareLimit($offset, $blockSize)
     {
         return "SELECT " . $this->buildComparisonHash() . " FROM " .
                "(" .
-                    "SELECT $this->columns FROM %s FORCE INDEX (`PRIMARY`) WHERE 1 " .
+                    "SELECT $this->columns FROM %s FORCE INDEX (`PRIMARY`) %s WHERE 1 " .
                     $this->where . " ".
                     "ORDER BY $this->primaryKey " .
                     "LIMIT $offset, $blockSize" .
@@ -183,7 +183,7 @@ private function compareIndex($offset, $blockSize)
         $endOffset = $offset + $blockSize;
 
         return "SELECT " . $this->buildComparisonHash() . " FROM " .
-               " %s FORCE INDEX (`PRIMARY`) WHERE " .
+               " %s FORCE INDEX (`PRIMARY`) %s WHERE " .
                "$this->limitKey BETWEEN $offset AND $endOffset " .
                $this->where;
     }
@@ -204,9 +204,9 @@ public function compare($offset, $blockSize)
     {      
         $query = $this->limitKey ? $this->compareIndex($offset, $blockSize) : $this->compareLimit($offset, $blockSize);
 
-        $sourceHash = $this->source->fetchOne(sprintf($query,$this->sourcetable . ' ' . $this->joinSource));
+        $sourceHash = $this->source->fetchOne(sprintf($query,$this->sourcetable, $this->joinSource));
 
-        $destHash = $this->destination->fetchOne(sprintf($query,$this->desttable. ' ' . $this->joinDest));
+        $destHash = $this->destination->fetchOne(sprintf($query,$this->desttable, $this->joinDest));
 
         $this->lastComparisonEmpty = $sourceHash ? false : true;