Db: optional filter for fetchImportedRowsetRows
This commit is contained in:
parent
77e0abe43f
commit
e4ed5eb04d
|
@ -418,7 +418,7 @@ class Db extends DbConnection
|
||||||
return $this->fetchImportedRowsetRows($checksum, $columns);
|
return $this->fetchImportedRowsetRows($checksum, $columns);
|
||||||
}
|
}
|
||||||
|
|
||||||
public function fetchImportedRowsetRows($checksum, $columns)
|
public function fetchImportedRowsetRows($checksum, $columns, $filter = null)
|
||||||
{
|
{
|
||||||
$db = $this->db();
|
$db = $this->db();
|
||||||
$binchecksum = Util::hex2binary($checksum);
|
$binchecksum = Util::hex2binary($checksum);
|
||||||
|
@ -469,6 +469,17 @@ class Db extends DbConnection
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if ($filter) {
|
||||||
|
$filtered = array();
|
||||||
|
foreach ($result as $key => $row) {
|
||||||
|
if ($filter->matches($row)) {
|
||||||
|
$filtered[$key] = $row;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return $filtered;
|
||||||
|
}
|
||||||
|
|
||||||
return $result;
|
return $result;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue