diff --git a/normalized-cache-sqlite-incubating/src/commonMain/kotlin/com/apollographql/cache/normalized/sql/SqlNormalizedCache.kt b/normalized-cache-sqlite-incubating/src/commonMain/kotlin/com/apollographql/cache/normalized/sql/SqlNormalizedCache.kt index e9ae2a70..8ad54c21 100644 --- a/normalized-cache-sqlite-incubating/src/commonMain/kotlin/com/apollographql/cache/normalized/sql/SqlNormalizedCache.kt +++ b/normalized-cache-sqlite-incubating/src/commonMain/kotlin/com/apollographql/cache/normalized/sql/SqlNormalizedCache.kt @@ -137,8 +137,10 @@ class SqlNormalizedCache internal constructor( } else { emptySet() } - recordDatabase.delete(keys + referencedKeys) - return recordDatabase.changes().toInt() + return (keys + referencedKeys).chunked(999).sumOf { chunkedKeys -> + recordDatabase.delete(chunkedKeys) + recordDatabase.changes().toInt() + } } /**