From 35776575a392ed5d7cc218c0314628e1c76fdc5f Mon Sep 17 00:00:00 2001 From: Thomas Gelf Date: Wed, 25 Nov 2015 21:01:11 +0100 Subject: [PATCH] Db::fetchLatestImportedRows: nested key support --- library/Director/Db.php | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/library/Director/Db.php b/library/Director/Db.php index 05aef3b8..f082eb69 100644 --- a/library/Director/Db.php +++ b/library/Director/Db.php @@ -178,9 +178,23 @@ class Db extends DbConnection return $objects; } - public function fetchLatestImportedRows($source, $columns = null) + public function fetchLatestImportedRows($source, $desiredColumns = null) { $db = $this->db(); + if ($desiredColumns === null) { + $columns = null; + } else { + $columns = array(); + foreach ($desiredColumns as $column) { + if (false === ($pos = strpos($column, '.'))) { + $columns[$column] = $column; + } else { + $column = substr($column, 0, $pos); + $columns[$column] = $column; + } + } + } + $lastRun = $db->select()->from('import_run', array('rowset_checksum')); if (is_int($source) || ctype_digit($source)) {