diff --git a/modules/aggregator.module b/modules/aggregator.module index 9fcba5afd38..31f73c77d6d 100644 --- a/modules/aggregator.module +++ b/modules/aggregator.module @@ -218,7 +218,7 @@ function import_refresh($feed) { $items[] = "iid = '$item->iid'"; } - if ($items) { + if (sizeof($items) > 50) { db_query("DELETE FROM item WHERE ". implode(" OR ", array_slice($items, 0, - 50))); } diff --git a/modules/aggregator/aggregator.module b/modules/aggregator/aggregator.module index 9fcba5afd38..31f73c77d6d 100644 --- a/modules/aggregator/aggregator.module +++ b/modules/aggregator/aggregator.module @@ -218,7 +218,7 @@ function import_refresh($feed) { $items[] = "iid = '$item->iid'"; } - if ($items) { + if (sizeof($items) > 50) { db_query("DELETE FROM item WHERE ". implode(" OR ", array_slice($items, 0, - 50))); } diff --git a/modules/import.module b/modules/import.module index 9fcba5afd38..31f73c77d6d 100644 --- a/modules/import.module +++ b/modules/import.module @@ -218,7 +218,7 @@ function import_refresh($feed) { $items[] = "iid = '$item->iid'"; } - if ($items) { + if (sizeof($items) > 50) { db_query("DELETE FROM item WHERE ". implode(" OR ", array_slice($items, 0, - 50))); }