Squashed 'apollo-ios/' changes from 02abbfb28..f0c9d1282

f0c9d1282 Adding batching to sqlite selects (#725)
1aacca79c Update ROADMAP.md

git-subtree-dir: apollo-ios
git-subtree-split: f0c9d12820b460673a2ce8245963433b4086033b

Author: gh-action-runner

ROADMAP.md

@@ -1,6 +1,6 @@
 # 🔮 Apollo iOS Roadmap
 
-**Last updated: 2025-07-22**
+**Last updated: 2025-08-05**
 
 For up to date release notes, refer to the project's [Changelog](https://github.com/apollographql/apollo-ios/blob/main/CHANGELOG.md).
 
@@ -38,10 +38,16 @@ The `@defer` directive enables your queries to receive data for specific fields
 
 To support the breaking language changes in Swift 6, a major version 2.0 of Apollo iOS will be released. This version will include support for the new Swift Concurrency Model and improve upon networking and caching APIs.
 
-_Status: In design phase. Current RFC for design is available [here](https://github.com/apollographql/apollo-ios/issues/3411)._
+_Status: [Alpha release](https://github.com/apollographql/apollo-ios/releases)_
 
-- ✅ [`ExistentialAny` upcoming feature](https://github.com/apollographql/apollo-ios/issues/3205)
-- (in progress) [`Sendable` types and `async/await` APIs](https://github.com/apollographql/apollo-ios/issues/3291)
+Beta Release Milestones:
+
+* ✅ Apollo-iOS
+* ✅ ApolloCodegenLib
+* 🔲 ApolloWebSocket
+* 🔲 GraphQLQueryWatcher
+  
+Current RFC for design is available [here](https://github.com/apollographql/apollo-ios/issues/3411)._
 
 ### [Support codegen of operations without response models](https://github.com/apollographql/apollo-ios/issues/3165)
 

Sources/ApolloSQLite/ApolloSQLiteDatabase.swift

@@ -86,39 +86,49 @@ public final class ApolloSQLiteDatabase: SQLiteDatabase {
   }
 
   public func selectRawRows(forKeys keys: Set<CacheKey>) throws -> [DatabaseRow] {
-    guard !keys.isEmpty else { return [] }
-
-    return try performSync {
-      let placeholders = keys.map { _ in "?" }.joined(separator: ", ")
-      let sql = """
-      SELECT \(Self.keyColumnName), \(Self.recordColumName) FROM \(Self.tableName)
-      WHERE \(Self.keyColumnName) IN (\(placeholders))
-      """
-
-      let stmt = try prepareStatement(sql, errorMessage: "Failed to prepare select statement")
-      defer { sqlite3_finalize(stmt) }
-
-      for (index, key) in keys.enumerated() {
-        sqlite3_bind_text(stmt, Int32(index + 1), key, -1, SQLITE_TRANSIENT)
-      }
+      guard !keys.isEmpty else { return [] }
+
+      let batchSize = 500
+      var allRows = [DatabaseRow]()
+      let keyBatches = keys.chunked(into: batchSize)
+
+      for batch in keyBatches {
+        let rows = try performSync {
+          let placeholders = batch.map { _ in "?" }.joined(separator: ", ")
+          let sql = """
+          SELECT \(Self.keyColumnName), \(Self.recordColumName)
+          FROM \(Self.tableName)
+          WHERE \(Self.keyColumnName) IN (\(placeholders))
+          """
+
+          let stmt = try prepareStatement(sql, errorMessage: "Failed to prepare select statement")
+          defer { sqlite3_finalize(stmt) }
+
+          for (index, key) in batch.enumerated() {
+            sqlite3_bind_text(stmt, Int32(index + 1), key, -1, SQLITE_TRANSIENT)
+          }
 
-      var rows = [DatabaseRow]()
-      var result: Int32
-      repeat {
-          result = sqlite3_step(stmt)
-          if result == SQLITE_ROW {
+          var rows = [DatabaseRow]()
+          var result: Int32
+          repeat {
+            result = sqlite3_step(stmt)
+            if result == SQLITE_ROW {
               let key = String(cString: sqlite3_column_text(stmt, 0))
               let record = String(cString: sqlite3_column_text(stmt, 1))
               rows.append(DatabaseRow(cacheKey: key, storedInfo: record))
-          } else if result != SQLITE_DONE {
+            } else if result != SQLITE_DONE {
               let errorMsg = String(cString: sqlite3_errmsg(db))
               throw SQLiteError.step(message: "Failed to step raw row select: \(errorMsg)")
-          }
-      } while result != SQLITE_DONE
+            }
+          } while result != SQLITE_DONE
 
+          return rows
+        }
 
-      return rows
-    }
+        allRows.append(contentsOf: rows)
+      }
+
+      return allRows
   }
 
   public func addOrUpdate(records: [(cacheKey: CacheKey, recordString: String)]) throws {
@@ -202,3 +212,20 @@ public final class ApolloSQLiteDatabase: SQLiteDatabase {
     }
   }
 }
+
+// MARK: - Extensions
+
+extension Array {
+  func chunked(into size: Int) -> [[Element]] {
+    stride(from: 0, to: count, by: size).map {
+      Array(self[$0..<Swift.min($0 + size, count)])
+    }
+  }
+}
+
+extension Set {
+  func chunked(into size: Int) -> [[Element]] {
+    Array(self).chunked(into: size)
+  }
+}
+