add mintouched argument to delete_untouched to prevent deletes on importer problems

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;