SwiftData：如何在SwiftUI外部监听数据库变化？

你可以通过两种核心方案实现非SwiftUI环境下对Trip数组变化的监听，覆盖新增、删除、排序变更等场景：

方法一：监听ModelContext的变更通知 #

SwiftData的ModelContext底层基于Core Data，可通过监听NSManagedObjectContext.didSaveNotification捕获数据变更，每次上下文保存后重新查询更新数据集。

示例代码 #

import SwiftData
import Combine

class TripManager {
    private let container: ModelContainer
    private let context: ModelContext
    private var cancellables = Set<AnyCancellable>()
    var trips: [Trip] = []
    
    init() {
        // 实际项目中需替换为错误处理，避免try!
        self.container = try! ModelContainer(for: Trip.self)
        self.context = ModelContext(container)
        // 初始加载数据
        loadTrips()
        // 注册上下文保存通知监听
        NotificationCenter.default.publisher(for: NSManagedObjectContext.didSaveNotification, object: context)
            .sink { [weak self] _ in
                self?.loadTrips()
            }
            .store(in: &cancellables)
    }
    
    private func loadTrips() {
        let fetchDescriptor = FetchDescriptor<Trip>()
        do {
            self.trips = try context.fetch(fetchDescriptor)
            // 此处可添加自定义回调，通知外部数据已更新
            print("数据集更新：共\(trips.count)条Trip")
        } catch {
            print("查询Trip失败：\(error)")
        }
    }
    
    // 示例：新增Trip
    func addTrip(name: String) {
        let trip = Trip(name: name)
        context.insert(trip)
        try? context.save()
    }
    
    // 示例：删除Trip
    func deleteTrip(_ trip: Trip) {
        context.delete(trip)
        try? context.save()
    }
}

精细化控制（可选） #

如果不想每次保存都重新查询，可在通知回调中检查是否是Trip实体的变更：

.sink { [weak self] notification in
    guard let self = self else { return }
    let userInfo = notification.userInfo ?? [:]
    let inserted = userInfo[NSInsertedObjectsKey] as? Set<NSManagedObject> ?? []
    let updated = userInfo[NSUpdatedObjectsKey] as? Set<NSManagedObject> ?? []
    let deleted = userInfo[NSDeletedObjectsKey] as? Set<NSManagedObject> ?? []
    
    // 仅当Trip实体有变更时更新数据集
    let hasTripChanges = inserted.contains { $0 is Trip } ||
                         updated.contains { $0 is Trip } ||
                         deleted.contains { $0 is Trip }
    
    if hasTripChanges {
        self.loadTrips()
    }
}

方法二：结合Observation框架实现可观察数据集 #

如果需要让trips数组本身成为可观察对象，让外部代码能订阅其变化，可使用Swift的Observation框架：

示例代码 #

import SwiftData
import Combine
import Observation

@Observable
class TripManager {
    var trips: [Trip] = []
    private let container: ModelContainer
    private let context: ModelContext
    private var cancellables = Set<AnyCancellable>()
    
    init() {
        self.container = try! ModelContainer(for: Trip.self)
        self.context = ModelContext(container)
        loadTrips()
        setupNotificationListener()
    }
    
    private func setupNotificationListener() {
        NotificationCenter.default.publisher(for: NSManagedObjectContext.didSaveNotification, object: context)
            .sink { [weak self] notification in
                guard let self = self else { return }
                let userInfo = notification.userInfo ?? [:]
                let affectedObjects = (userInfo[NSInsertedObjectsKey] as? Set<NSManagedObject> ?? [])
                    .union(userInfo[NSUpdatedObjectsKey] as? Set<NSManagedObject> ?? [])
                    .union(userInfo[NSDeletedObjectsKey] as? Set<NSManagedObject> ?? [])
                
                if !affectedObjects.filter({ $0 is Trip }).isEmpty {
                    self.loadTrips()
                }
            }
            .store(in: &cancellables)
    }
    
    private func loadTrips() {
        let fetchDescriptor = FetchDescriptor<Trip>()
        do {
            self.trips = try context.fetch(fetchDescriptor)
        } catch {
            print("查询失败：\(error)")
        }
    }
    
    // 数据操作方法...
}

外部订阅示例 #

let manager = TripManager()
// 订阅trips数组的变化
withObservationTracking {
    print("当前Trip数量：\(manager.trips.count)")
} onChange: {
    print("Trip数组已变更：当前数量\(manager.trips.count)")
}

注意事项 #

• 确保监听的是目标ModelContext实例，避免跨上下文的变更遗漏。
• 如果在后台线程操作数据，更新数据集或通知外部时需切换到主线程。
• 示例中使用try!仅为简化代码，实际项目必须处理ModelContainer初始化的错误。

内容的提问来源于stack exchange，提问作者SwiftedMind