CKQueryOperation首次返回nil cursor，records数组为空问题求助

我看了你的代码和问题描述，这种首次拉取cursor为nil但records为空、第二次才正常的情况，大概率是异步操作的时机问题加上代码里的几个小疏漏导致的，下面给你一步步排查和修复：

1. 核心问题：异步操作未等待就访问数据 #

你提到点击按钮后想立即展示结果，但CKQueryOperation是异步执行的——调用add(queryOperation)后，代码会继续往下走，而数据拉取和recordFetchedBlock的执行都是在后台队列完成的。如果你的UI逻辑是点击按钮后直接读取CloudKitDatabase.shared.records，这时候拉取操作还没完成，自然会看到空数组；而第二次点击时，第一次的异步拉取已经完成，records里才有数据。

修复方案：给fetchRecords添加一个完成回调，等所有数据拉取完毕（包括cursor分页的所有数据）再通知UI更新：

// 修改fetchRecords方法，添加完成回调
func fetchRecords(completion: @escaping ([CKRecord]?, Error?) -> Void) {
    // 每次拉取前清空旧数据，避免重复追加
    self.records.removeAll()
    
    let predicate = NSPredicate(value: true)
    let query = CKQuery(recordType: "OECD", predicate: predicate)
    let queryOperation = CKQueryOperation(query: query)
    
    queryOperation.recordFetchedBlock = { record in
        self.records.append(record)
    }
    
    queryOperation.queryCompletionBlock = { cursor, error in
        DispatchQueue.main.async {
            if let error = error {
                completion(nil, error)
                return
            }
            
            if let cursor = cursor {
                // 递归拉取下一页，完成后再回调
                self.queryServer(cursor, completion: completion)
            } else {
                // 所有数据拉取完成，返回结果
                completion(self.records, nil)
                print("所有数据拉取完成，共\(self.records.count)条")
            }
        }
    }
    
    // 设置操作优先级，确保用户触发的拉取优先执行
    queryOperation.qualityOfService = .userInitiated
    self.publicData.add(queryOperation)
}

// 同步修改queryServer方法，传递完成回调
func queryServer(_ cursor: CKQueryOperation.Cursor, completion: @escaping ([CKRecord]?, Error?) -> Void) {
    let queryOperation = CKQueryOperation(cursor: cursor)
    
    queryOperation.recordFetchedBlock = { record in
        self.records.append(record)
    }
    
    queryOperation.queryCompletionBlock = { cursor, error in
        DispatchQueue.main.async {
            if let error = error {
                completion(nil, error)
                return
            }
            
            if let cursor = cursor {
                self.queryServer(cursor, completion: completion)
            } else {
                completion(self.records, nil)
                print("分页数据拉取完成，共\(self.records.count)条")
            }
        }
    }
    
    queryOperation.qualityOfService = .userInitiated
    self.publicData.add(queryOperation)
}

然后在按钮点击事件里这样调用：

CloudKitDatabase.shared.fetchRecords { records, error in
    if let error = error {
        print("拉取失败：\(error.localizedDescription)")
        return
    }
    guard let records = records else { return }
    // 在这里更新UI，比如刷新tableView
    print("拉取到\(records.count)条数据")
    // self.tableView.reloadData()
}

2. 其他需要修复的细节 #

• 去掉单例初始化时的自动拉取：你的init()里调用了fetchRecords()，这会在单例第一次被访问时就自动发起查询，可能和你点击按钮的操作冲突，建议去掉这行代码，只在用户点击按钮时主动触发拉取。
• 解决线程安全问题：虽然recordFetchedBlock由CloudKit管理，但多个线程同时修改records数组可能存在竞态条件，可以给records加个串行队列保护：

private let recordsQueue = DispatchQueue(label: "com.yourApp.CloudKitRecordsQueue")
private var _records = [CKRecord]()
var records: [CKRecord] {
    get {
        return recordsQueue.sync { _records }
    }
    set {
        recordsQueue.sync { _records = newValue }
    }
}
// 然后在recordFetchedBlock里改成：
self.recordsQueue.sync {
    self._records.append(record)
}

• 防止重复拉取：如果用户快速多次点击按钮，会发起多个重复查询，建议加个isFetching标志位：

var isFetching = false

func fetchRecords(completion: @escaping ([CKRecord]?, Error?) -> Void) {
    guard !isFetching else { return }
    isFetching = true
    // ... 原有代码 ...
    // 在queryCompletionBlock的最后（无论成功失败）重置标志位
    queryOperation.queryCompletionBlock = { cursor, error in
        DispatchQueue.main.async {
            defer { self.isFetching = false }
            // ... 原有逻辑 ...
        }
    }
}

3. 额外排查建议 #

• 打开CloudKit Dashboard，确认OECD记录类型下确实有数据，并且公共数据库的读取权限设置正确（允许当前用户访问）。
• 在recordFetchedBlock里打印每条记录的ID，确认CloudKit确实返回了数据：

queryOperation.recordFetchedBlock = { record in
    print("获取到记录：\(record.recordID.recordName)")
    self.recordsQueue.sync {
        self._records.append(record)
    }
}

• 检查是否有iCloud权限未处理：如果用户拒绝了访问iCloud的权限，拉取会失败但错误信息可能不明显，建议添加权限申请逻辑。

内容的提问来源于stack exchange，提问作者Атанас Начков