我有一个 AbstractConnection 类，它处理使用从外部 API 检索到的数据更新我的数据库模型。然后我有一个从 AbstractConnection 继承的类，它处理我正在使用的 API 的所有细节（因为将来会有其他人）并返回数组/哈希中的属性。
一个操作涉及加载 10,000 多条记录，API 限制每个请求的数量或记录，并提供一个偏移查询的“下一个”URL，以便您可以加载一系列请求中的所有记录。我不希望在我的 API 特定方法中将大量不可知的记录加载到内存中，因此我希望能够在获得每批记录后立即更新它们。但是，我担心将太多特定于 API 的实现暴露给 AbstractConnection。
以前有人处理过这样的事情吗？谢谢！