diff --git a/library/Director/Objects/ImportRun.php b/library/Director/Objects/ImportRun.php index 3994997f..f339c2c5 100644 --- a/library/Director/Objects/ImportRun.php +++ b/library/Director/Objects/ImportRun.php @@ -57,7 +57,7 @@ class ImportRun extends DbObject return $db->fetchCol($query); } - public function fetchRows($columns, $filter = null) + public function fetchRows($columns, $filter = null, $keys = null) { $db = $this->getDb(); $binchecksum = $this->rowset_checksum; @@ -96,6 +96,10 @@ class ImportRun extends DbObject $empty->$k = null; } + if ($keys !== null) { + $query->where('r.object_name IN (?)', $keys); + } + foreach ($db->fetchAll($query) as $row) { if (! array_key_exists($row->object_name, $result)) { $result[$row->object_name] = clone($empty);