ios - from - fetch core data swift 4

Swift Core Data Batch Updating creando registros duplicados en lugar de sobrescribir

Question

Parece que mi NSPredicate no está funcionando al actualizar los registros de Core Data . Al realizar una solicitud de recuperación, el mismo NSPredicate funciona sin problemas.

Cuando hago una Batch Update , simplemente crea nuevos registros duplicados en lugar de sobrescribir los existentes como se esperaba. ¿Porque Oh porque?

Aquí está mi código que hace la actualización:

let appDelegate = UIApplication.sharedApplication().delegate as AppDelegate

lazy var managedObjectContext : NSManagedObjectContext? = {
    if let managedObjectContext = self.appDelegate.managedObjectContext {
        return managedObjectContext
    }
    else {
        return nil
    }
    }()

func doesMessageExist(id: String) -> Bool {
    let fetchRequest = NSFetchRequest(entityName: "ChatMessage")
    let predicate = NSPredicate(format: "id == %@", id)
    fetchRequest.predicate = predicate
    fetchRequest.fetchLimit = 1

    let count = managedObjectContext!.countForFetchRequest(fetchRequest, error: nil)
    return (count > 0) ? true : false
}

func updateMessage(chatMessage: ChatMessage) {
    var batchRequest = NSBatchUpdateRequest(entityName: "ChatMessage")

    if doesMessageExist(chatMessage.id) {
        batchRequest.predicate = NSPredicate(format: "id == %@", chatMessage.id)
    }

    batchRequest.propertiesToUpdate = [
        "id" : chatMessage.id,
        "senderUserId" : chatMessage.senderUserId,
        "senderUsername" : chatMessage.senderUsername,
        "receiverUserId" : chatMessage.receiverUserId,
        "receiverUsername" : chatMessage.receiverUsername,
        "messageType" : chatMessage.messageType,
        "message" : chatMessage.message,
        "timestamp" : chatMessage.timestamp
    ]

    batchRequest.resultType = .UpdatedObjectsCountResultType
    var error : NSError?
    var results = self.managedObjectContext!.executeRequest(batchRequest, error: &error) as NSBatchUpdateResult
    if error == nil {
        println("Update Message: /(chatMessage.id) /(results.result)")
        appDelegate.saveContext()
    }
    else {
        println("Update Message Error: /(error?.localizedDescription)")
    }
}

Aquí está mi clase de ChatMessage :

class ChatMessage: NSManagedObject {

    @NSManaged var id: String
    @NSManaged var message: String
    @NSManaged var messageType: String
    @NSManaged var receiverUserId: String
    @NSManaged var receiverUsername: String
    @NSManaged var senderUserId: String
    @NSManaged var senderUsername: String
    @NSManaged var timestamp: NSDate

}

Aquí está la pila de datos básicos en mi AppDelegate:

lazy var applicationDocumentsDirectory: NSURL = {
    // The directory the application uses to store the Core Data store file. This code uses a directory named "com.walintukai.LFDate" in the application''s documents Application Support directory.
    let urls = NSFileManager.defaultManager().URLsForDirectory(.DocumentDirectory, inDomains: .UserDomainMask)
    return urls[urls.count-1] as NSURL
}()

lazy var managedObjectModel: NSManagedObjectModel = {
    // The managed object model for the application. This property is not optional. It is a fatal error for the application not to be able to find and load its model.
    let modelURL = NSBundle.mainBundle().URLForResource("LFDate", withExtension: "momd")!
    return NSManagedObjectModel(contentsOfURL: modelURL)!
}()

lazy var persistentStoreCoordinator: NSPersistentStoreCoordinator? = {
    // The persistent store coordinator for the application. This implementation creates and return a coordinator, having added the store for the application to it. This property is optional since there are legitimate error conditions that could cause the creation of the store to fail.
    // Create the coordinator and store
    var coordinator: NSPersistentStoreCoordinator? = NSPersistentStoreCoordinator(managedObjectModel: self.managedObjectModel)
    let url = self.applicationDocumentsDirectory.URLByAppendingPathComponent("LFDate.sqlite")
    var error: NSError? = nil
    var failureReason = "There was an error creating or loading the application''s saved data."
    if coordinator!.addPersistentStoreWithType(NSSQLiteStoreType, configuration: nil, URL: url, options: nil, error: &error) == nil {
        coordinator = nil
        // Report any error we got.
        let dict = NSMutableDictionary()
        dict[NSLocalizedDescriptionKey] = "Failed to initialize the application''s saved data"
        dict[NSLocalizedFailureReasonErrorKey] = failureReason
        dict[NSUnderlyingErrorKey] = error
        error = NSError(domain: "YOUR_ERROR_DOMAIN", code: 9999, userInfo: dict)
        // Replace this with code to handle the error appropriately.
        // abort() causes the application to generate a crash log and terminate. You should not use this function in a shipping application, although it may be useful during development.
        NSLog("Unresolved error /(error), /(error!.userInfo)")
        abort()
    }

    return coordinator
}()

lazy var managedObjectContext: NSManagedObjectContext? = {
    // Returns the managed object context for the application (which is already bound to the persistent store coordinator for the application.) This property is optional since there are legitimate error conditions that could cause the creation of the context to fail.
    let coordinator = self.persistentStoreCoordinator
    if coordinator == nil {
        return nil
    }
    var managedObjectContext = NSManagedObjectContext()
    managedObjectContext.persistentStoreCoordinator = coordinator
    managedObjectContext.mergePolicy = NSOverwriteMergePolicy
    return managedObjectContext
}()

// MARK: - Core Data Saving support

func saveContext () {
    dispatch_async(dispatch_get_main_queue(),{
        if let moc = self.managedObjectContext {
            var error: NSError? = nil
            if moc.hasChanges && !moc.save(&error) {
                // Replace this implementation with code to handle the error appropriately.
                // abort() causes the application to generate a crash log and terminate. You should not use this function in a shipping application, although it may be useful during development.
                NSLog("Database Save Error: /(error), /(error!.userInfo)")
                abort()
            }
        }
    });
}

Answer 1

Lamentablemente, no hay documentación para NSBatchUpdateRequest (¡ NSBatchUpdateRequest vergüenza, Apple!). Pero las solicitudes de actualización por lotes se cubrieron en WWDC 2014, sesión 225 (aquí está la transcripción de ASCII ).

En la sesión, se menciona que las actualizaciones por lotes omiten NSManagedObjectContext y realizan cambios directamente en el almacén persistente. Así que tienes que actualizar los objetos por ti mismo:

Entonces, si está interesado en actualizar su base de datos en masa, por ejemplo, establecer una marca en una columna en particular y luego reflejar esos cambios en la interfaz de usuario, necesitará recuperar los resultados o las ID de objetos gestionados, por lo que puede indicar el objeto, indicar al Contexto de objeto administrado que actualice los objetos con esos ID.

resultType especificar otro tipo de resultType para la solicitud por lotes:

batchRequest.resultType = .UpdatedObjectIDsResultType

Y luego, después de ejecutar la solicitud, debe actualizar los objetos utilizando la matriz devuelta de NSManagedObjectID (ejemplo de código de Big Nerd Ranch , reescrito en Swift):

for objectsID in objectsIDs {
    var error : NSError? = nil
    if let object = context.existingObjectWithID(objectsID as NSManagedObjectID, error: &error) {
        context.refreshObject(object, mergeChanges: true)
    }
}

Answer 2

Pruebe este código para NSBatchUpdateRequest sin duplicar los registros en swift3

func batchUpdate{ 
        let appDelegate = UIApplication.shared.delegate as! AppDelegate
        let managedContext = appDelegate.managedObjectContext
        let batchRequest = NSBatchUpdateRequest(entityName: "ENTITY_NAME")
        batchRequest.propertiesToUpdate = [ "PROPERTY_NAME" : "CHANGE_VALUE`enter code here`"]
        batchRequest.resultType = .updatedObjectIDsResultType

        do{
           let objectIDs = try managedContext.execute(batchRequest) as! NSBatchUpdateResult
           let objects = objectIDs.result as! [NSManagedObjectID]

            objects.forEach({ objID in
                let managedObject = managedContext.object(with: objID)
                managedContext.refresh(managedObject, mergeChanges: false)
            })
        } catch {
        }
}

Answer 3

Su función doesMessageExist es incorrecta.

Verifica el recuento para que la solicitud de recuperación no sea igual a NSNotFound , lo que solo se hará en caso de error. Si no se puede encontrar el mensaje, devolverá cero, si se puede encontrar, devolverá uno (o más, si tiene varios objetos con la misma ID).

En el momento en que su código diga que el mensaje siempre existe.

Por cierto, ninguno de los códigos en esta pregunta está creando nuevos objetos, y executeRequest no es un método en NSManagedObjectContext, por lo que probablemente debería incluir su implementación en la pregunta.