diff --git a/library/Director/Db.php b/library/Director/Db.php index 5905f8a0..120bbe78 100644 --- a/library/Director/Db.php +++ b/library/Director/Db.php @@ -55,6 +55,16 @@ class Db extends DbConnection return $this->db()->fetchOne($select); } + public function getImportrunRowsetChecksum($id) + { + $db = $this->db(); + $query = $db->select() + ->from('import_run', 'rowset_checksum') + ->where('id = ?', $id); + + return $db->fetchOne($query); + } + public function fetchLatestImportedRows($source, $columns = null) { $db = $this->db();