summaryrefslogtreecommitdiff
path: root/it_dbi.class
diff options
context:
space:
mode:
Diffstat (limited to 'it_dbi.class')
-rw-r--r--it_dbi.class9
1 files changed, 7 insertions, 2 deletions
diff --git a/it_dbi.class b/it_dbi.class
index e371101..ce2e8c0 100644
--- a/it_dbi.class
+++ b/it_dbi.class
@@ -886,10 +886,15 @@ function delete($query = null)
/**
* Delete records matching query which were not touched since creation of this object or last call of this func
+ * @param $query Query for entries to be checked
+ * @param $p['mintouched'] Minimum records that have to be touched, error otherwise
+ * @param $p['it_error'] Parameters for too few records error message
*/
-function delete_untouched($query = null)
+function delete_untouched($query = null, $p = [])
{
- if ($this->select(['SELECT' => $this->escape_name($this->_p['keyfield'])] + (array)$query))
+ if (count((array)$this->_touchedids) < $p['mintouched'])
+ it::error((array)$p['it_error'] + ['title' => "skipping delete, only " . count((array)$this->_touchedids) . " records were touched"]);
+ else if ($this->select(['SELECT' => $this->escape_name($this->_p['keyfield'])] + (array)$query))
while ($this->iterate())
if (($id = $this->_key) && !$this->_touchedids[$id] && $this->delete())
$result[] = $id;