多上下文核心数据：合并到未保存的上下文
Multicontext Core Data: merging to unsaved context
我正在尝试实现这个核心数据栈：
PSC <--+-- MainMOC
|
+-- BackgroundPrivateMOC
有些事情我其实不明白。也许我们的 Persisten Store 中有一个对象，我们从主 MOC 中获取它以进行一些更改（用户手动更改它）。与此同时，我的 BG MOC 正在对同一个对象进行一些更改并将更改保存到 PS。保存完成后，我们必须将 BG MOC 合并到 MAIN MOC（这是一种常见做法）。合并后我期望的是 MAIN MOC 包含来自 BG MOC 的更改（因为这些更改比 MAIN 晚了一点）。但这实际上并没有发生。合并完成后我所拥有的只是我的 MAIN MOC 中的脏 refreshedObjects = 1，如果我通过 MAIN MOC 再次获取该对象，我看不到通过 BG MOC 进行的任何更改。
- 我应该如何正确地将 BG 更改传播到 MAIN MOC，同时
在更改 BG 之前未保存 MAIN MOC？
- 如何处理
合并完成后我的 MAIN MOC 非零
refreshedObjects 的情况，以及
如何将这些对象推送到 MAIN MOC 中以使其可供使用
获取并使用？
我相信我的示例代码可以帮助您更清楚地了解我的问题。您可以只下载我准备的项目 (https://www.dropbox.com/s/1qr50zto5j4hj40/ThreadedCoreData.zip?dl=0) 和 运行 XCTest。
这是失败的测试代码：
@implementation ThrdCoreData_Tests
- (void)setUp
{
[super setUp];
/**
OUR SIMPLE STACK:
PSC <--+-- MainMOC
|
+-- BackgroundPrivateMOC
*/
NSPersistentStoreCoordinator *coordinator = [self persistentStoreCoordinator];
// main context (Main queue)
_mainMOC = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSMainQueueConcurrencyType];
[_mainMOC setPersistentStoreCoordinator:coordinator];
[_mainMOC setMergePolicy:NSMergeByPropertyObjectTrumpMergePolicy];
// background context (Private Queue)
_bgMOC = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSPrivateQueueConcurrencyType];
_bgMOC.persistentStoreCoordinator = self.persistentStoreCoordinator;
[[NSNotificationCenter defaultCenter] addObserver:self
selector:@selector(mergeBGChangesToMain:)
name:NSManagedObjectContextDidSaveNotification
object:_bgMOC];
u_int32_t value = arc4random_uniform(3000000000); // simply generate new random values for the test
_mainMOCVlaue = [NSString stringWithFormat:@"%u" , value];
_expectedBGValue = [NSString stringWithFormat:@"%u" , value/2];
Earthquake * mainEq = [Earthquake MR_findFirstInContext:self.mainMOC];
if (!mainEq){ // At the very first time the test is running, create one single test oject.
Earthquake * mainEq = [Earthquake MR_createEntityInContext:self.mainMOC];
mainEq.location = nil; // initial value will be nil
[self.mainMOC MR_saveOnlySelfAndWait];
}
}
- (void)testThatBGMOCSuccessfullyMergesWithMain
{
_expectation = [self expectationWithDescription:@"test finished"];
// lets change our single object in main MOC. I expect that the value will be later overwritten by `_expectedBGValue`
Earthquake * mainEq = [Earthquake MR_findFirstInContext:self.mainMOC];
NSLog(@"\nCurrently stored value:\n%@\nNew main value:\n%@", mainEq.location, _mainMOCVlaue);
mainEq.location = _mainMOCVlaue; // the test will succeed if this line commented
// now change that object in BG MOC by setting `_expectedBGValue`
[_bgMOC performBlockAndWait:^{
Earthquake * bgEq = [Earthquake MR_findFirstInContext:_bgMOC];
bgEq.location = _expectedBGValue;
NSLog(@"\nNew expected value set:\n%@", _expectedBGValue);
[_bgMOC MR_saveToPersistentStoreAndWait]; // this will trigger the `mergeBGChangesToMain` method
}];
[self waitForExpectationsWithTimeout:3 handler:nil];
}
- (void)mergeBGChangesToMain:(NSNotification *)notification {
dispatch_async(dispatch_get_main_queue(), ^{
[self.mainMOC mergeChangesFromContextDidSaveNotification:notification];
// now after merge done, lets find our object with expected value `_expectedBGValue`:
Earthquake * expectedEQ = [Earthquake MR_findFirstByAttribute:@"location" withValue:_expectedBGValue inContext:self.mainMOC];
if (!expectedEQ){
Earthquake * eqFirst = [Earthquake MR_findFirstInContext:self.mainMOC];
NSLog(@"\nCurrent main MOC value is:\n%@\nexptected:\n%@", eqFirst.location, _expectedBGValue);
}
XCTAssert(expectedEQ != nil, @"Expected value not found");
[_expectation fulfill];
});
}
首先，在post编写核心数据代码时，建议大家不要post依赖第三方库的代码，除非第三方库与你的问题直接相关。我认为 MR 是神奇的记录，但我不使用它，它似乎只是把 post 的水搅浑了，因为谁知道它在做什么（或没有做什么）。
换句话说，尝试 trim 将示例减少到尽可能少的代码……不要更多……并且只在绝对必要时才包含第三方库。
其次，在为核心数据使用编写单元测试时，我建议使用内存堆栈。您总是从空开始，并且可以根据需要对其进行初始化。更容易用于测试。
就是说，您的问题是对 mergeChangesFromContextDidSaveNotification 做什么（和不做什么）的误解。
基本上，您在 Core Data 持久存储中有一个对象。您有两个不同的 MOC 通过同一个 PSC 附加到商店。
然后您的测试将对象加载到主 MOC 中，并在不保存到 PSC 的情况下更改值。然后第二个 MOC 加载同一个对象，并将其值更改为不同的值（即商店，两个 MOC 都对同一对象的特定属性具有不同的值）。
现在，当我们保存MOC时，如果有冲突，冲突会按照mergePolicy的指示处理。但是，合并策略不适用于 mergeChangesFromContextDidSaveNotification.
您可以将 mergeChangesFromContextDidSaveNotification 视为插入任何新对象、删除任何已删除的对象，以及 "refreshing" 任何更新的对象，同时保留任何本地更改。
在您的测试中，如果您添加另一个属性（例如，"title"）并更改 BG MOC 中的 "title" 和 "location"，但仅更改 "location"主 MOC，您会看到 "title" 按预期从 BG MOC 合并到主 MOC。
但是，正如您在问题中指出的那样，"location" 似乎没有合并。实际上，它确实被合并了，但是任何本地更改都会覆盖商店中的内容……这正是您想要发生的，因为用户可能进行了该更改，并且不希望它在背后被更改。
基本上，任何待处理的本地更改都将覆盖来自待合并 MOC 的更改。
如果你想要不同的东西，你必须在合并时实现那个行为，就像这样...
- (void)mergeBGChangesToMain:(NSNotification*)note {
NSMutableSet *updatedObjectIDs = [NSMutableSet set];
for (NSManagedObject *obj in [note.userInfo objectForKey:NSUpdatedObjectsKey]) {
[updatedObjectIDs addObject:[obj objectID]];
}
[_mainMOC performBlock:^{
for (NSManagedObject *obj in [_mainMOC updatedObjects]) {
if ([updatedObjectIDs containsObject:obj.objectID]) {
[_mainMOC refreshObject:obj mergeChanges:NO];
}
}
[_mainMOC mergeChangesFromContextDidSaveNotification:note];
}];
}
该代码首先收集从 MOC 合并中更新的每个对象的 ObjectIDs。
在进行合并之前，我们会查看合并到 MOC 中的每个更新对象。如果我们将一个对象合并到我们的 MOC 中，并且我们的 merge-to-MOC 也更改了该对象，那么我们希望允许 merged-from-MOC 中的值覆盖 merged-to-MOC 中的值。因此，我们从存储中刷新本地对象，基本上丢弃任何本地更改（有副作用，例如，导致对象成为错误，释放对任何关系的引用，并释放任何瞬态属性 - 参见 [=55 的文档=]:).
考虑以下类别，它解决了您的情况，以及使用 NSFetchedResultsController.
等观察者时的常见问题
@interface NSManagedObjectContext (WJHMerging)
- (void)mergeChangesIntoContext:(NSManagedObjectContext*)moc
withDidSaveNotification:(NSNotification*)notification
faultUpdatedObjects:(BOOL)faultUpdatedObjects
overrideLocalChanges:(BOOL)overrideLocalChanges
completion:(void(^)())completionBlock;
@end
@implementation NSManagedObjectContext (WJHMerging)
- (void)mergeChangesIntoContext:(NSManagedObjectContext *)moc
withDidSaveNotification:(NSNotification *)notification
faultUpdatedObjects:(BOOL)faultUpdatedObjects
overrideLocalChanges:(BOOL)overrideLocalChanges
completion:(void (^)())completionBlock {
NSAssert(self == notification.object, @"Not called with");
NSSet *updatedObjects = notification.userInfo[NSUpdatedObjectsKey];
NSMutableSet *updatedObjectIDs = nil;
if (overrideLocalChanges || faultUpdatedObjects) {
updatedObjectIDs = [NSMutableSet setWithCapacity:updatedObjects.count];
for (NSManagedObject *obj in updatedObjects) {
[updatedObjectIDs addObject:[obj objectID]];
}
}
[moc performBlock:^{
if (overrideLocalChanges) {
for (NSManagedObject *obj in [moc updatedObjects]) {
if ([updatedObjectIDs containsObject:obj.objectID]) {
[moc refreshObject:obj mergeChanges:NO];
}
}
}
if (faultUpdatedObjects) {
for (NSManagedObjectID *objectID in updatedObjectIDs) {
[[moc objectWithID:objectID] willAccessValueForKey:nil];
}
}
[moc mergeChangesFromContextDidSaveNotification:notification];
if (completionBlock) {
completionBlock();
}
}];
}
@end
我正在尝试实现这个核心数据栈：
PSC <--+-- MainMOC
|
+-- BackgroundPrivateMOC
有些事情我其实不明白。也许我们的 Persisten Store 中有一个对象，我们从主 MOC 中获取它以进行一些更改（用户手动更改它）。与此同时，我的 BG MOC 正在对同一个对象进行一些更改并将更改保存到 PS。保存完成后，我们必须将 BG MOC 合并到 MAIN MOC（这是一种常见做法）。合并后我期望的是 MAIN MOC 包含来自 BG MOC 的更改（因为这些更改比 MAIN 晚了一点）。但这实际上并没有发生。合并完成后我所拥有的只是我的 MAIN MOC 中的脏 refreshedObjects = 1，如果我通过 MAIN MOC 再次获取该对象，我看不到通过 BG MOC 进行的任何更改。
- 我应该如何正确地将 BG 更改传播到 MAIN MOC，同时 在更改 BG 之前未保存 MAIN MOC？
- 如何处理
合并完成后我的 MAIN MOC 非零
refreshedObjects的情况，以及 如何将这些对象推送到 MAIN MOC 中以使其可供使用 获取并使用？
我相信我的示例代码可以帮助您更清楚地了解我的问题。您可以只下载我准备的项目 (https://www.dropbox.com/s/1qr50zto5j4hj40/ThreadedCoreData.zip?dl=0) 和 运行 XCTest。
这是失败的测试代码：
@implementation ThrdCoreData_Tests
- (void)setUp
{
[super setUp];
/**
OUR SIMPLE STACK:
PSC <--+-- MainMOC
|
+-- BackgroundPrivateMOC
*/
NSPersistentStoreCoordinator *coordinator = [self persistentStoreCoordinator];
// main context (Main queue)
_mainMOC = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSMainQueueConcurrencyType];
[_mainMOC setPersistentStoreCoordinator:coordinator];
[_mainMOC setMergePolicy:NSMergeByPropertyObjectTrumpMergePolicy];
// background context (Private Queue)
_bgMOC = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSPrivateQueueConcurrencyType];
_bgMOC.persistentStoreCoordinator = self.persistentStoreCoordinator;
[[NSNotificationCenter defaultCenter] addObserver:self
selector:@selector(mergeBGChangesToMain:)
name:NSManagedObjectContextDidSaveNotification
object:_bgMOC];
u_int32_t value = arc4random_uniform(3000000000); // simply generate new random values for the test
_mainMOCVlaue = [NSString stringWithFormat:@"%u" , value];
_expectedBGValue = [NSString stringWithFormat:@"%u" , value/2];
Earthquake * mainEq = [Earthquake MR_findFirstInContext:self.mainMOC];
if (!mainEq){ // At the very first time the test is running, create one single test oject.
Earthquake * mainEq = [Earthquake MR_createEntityInContext:self.mainMOC];
mainEq.location = nil; // initial value will be nil
[self.mainMOC MR_saveOnlySelfAndWait];
}
}
- (void)testThatBGMOCSuccessfullyMergesWithMain
{
_expectation = [self expectationWithDescription:@"test finished"];
// lets change our single object in main MOC. I expect that the value will be later overwritten by `_expectedBGValue`
Earthquake * mainEq = [Earthquake MR_findFirstInContext:self.mainMOC];
NSLog(@"\nCurrently stored value:\n%@\nNew main value:\n%@", mainEq.location, _mainMOCVlaue);
mainEq.location = _mainMOCVlaue; // the test will succeed if this line commented
// now change that object in BG MOC by setting `_expectedBGValue`
[_bgMOC performBlockAndWait:^{
Earthquake * bgEq = [Earthquake MR_findFirstInContext:_bgMOC];
bgEq.location = _expectedBGValue;
NSLog(@"\nNew expected value set:\n%@", _expectedBGValue);
[_bgMOC MR_saveToPersistentStoreAndWait]; // this will trigger the `mergeBGChangesToMain` method
}];
[self waitForExpectationsWithTimeout:3 handler:nil];
}
- (void)mergeBGChangesToMain:(NSNotification *)notification {
dispatch_async(dispatch_get_main_queue(), ^{
[self.mainMOC mergeChangesFromContextDidSaveNotification:notification];
// now after merge done, lets find our object with expected value `_expectedBGValue`:
Earthquake * expectedEQ = [Earthquake MR_findFirstByAttribute:@"location" withValue:_expectedBGValue inContext:self.mainMOC];
if (!expectedEQ){
Earthquake * eqFirst = [Earthquake MR_findFirstInContext:self.mainMOC];
NSLog(@"\nCurrent main MOC value is:\n%@\nexptected:\n%@", eqFirst.location, _expectedBGValue);
}
XCTAssert(expectedEQ != nil, @"Expected value not found");
[_expectation fulfill];
});
}
首先，在post编写核心数据代码时，建议大家不要post依赖第三方库的代码，除非第三方库与你的问题直接相关。我认为 MR 是神奇的记录，但我不使用它，它似乎只是把 post 的水搅浑了，因为谁知道它在做什么（或没有做什么）。
换句话说，尝试 trim 将示例减少到尽可能少的代码……不要更多……并且只在绝对必要时才包含第三方库。
其次，在为核心数据使用编写单元测试时，我建议使用内存堆栈。您总是从空开始，并且可以根据需要对其进行初始化。更容易用于测试。
就是说，您的问题是对 mergeChangesFromContextDidSaveNotification 做什么（和不做什么）的误解。
基本上，您在 Core Data 持久存储中有一个对象。您有两个不同的 MOC 通过同一个 PSC 附加到商店。
然后您的测试将对象加载到主 MOC 中，并在不保存到 PSC 的情况下更改值。然后第二个 MOC 加载同一个对象，并将其值更改为不同的值（即商店，两个 MOC 都对同一对象的特定属性具有不同的值）。
现在，当我们保存MOC时，如果有冲突，冲突会按照mergePolicy的指示处理。但是，合并策略不适用于 mergeChangesFromContextDidSaveNotification.
您可以将 mergeChangesFromContextDidSaveNotification 视为插入任何新对象、删除任何已删除的对象，以及 "refreshing" 任何更新的对象，同时保留任何本地更改。
在您的测试中，如果您添加另一个属性（例如，"title"）并更改 BG MOC 中的 "title" 和 "location"，但仅更改 "location"主 MOC，您会看到 "title" 按预期从 BG MOC 合并到主 MOC。
但是，正如您在问题中指出的那样，"location" 似乎没有合并。实际上，它确实被合并了，但是任何本地更改都会覆盖商店中的内容……这正是您想要发生的，因为用户可能进行了该更改，并且不希望它在背后被更改。
基本上，任何待处理的本地更改都将覆盖来自待合并 MOC 的更改。
如果你想要不同的东西，你必须在合并时实现那个行为，就像这样...
- (void)mergeBGChangesToMain:(NSNotification*)note {
NSMutableSet *updatedObjectIDs = [NSMutableSet set];
for (NSManagedObject *obj in [note.userInfo objectForKey:NSUpdatedObjectsKey]) {
[updatedObjectIDs addObject:[obj objectID]];
}
[_mainMOC performBlock:^{
for (NSManagedObject *obj in [_mainMOC updatedObjects]) {
if ([updatedObjectIDs containsObject:obj.objectID]) {
[_mainMOC refreshObject:obj mergeChanges:NO];
}
}
[_mainMOC mergeChangesFromContextDidSaveNotification:note];
}];
}
该代码首先收集从 MOC 合并中更新的每个对象的 ObjectIDs。
在进行合并之前，我们会查看合并到 MOC 中的每个更新对象。如果我们将一个对象合并到我们的 MOC 中，并且我们的 merge-to-MOC 也更改了该对象，那么我们希望允许 merged-from-MOC 中的值覆盖 merged-to-MOC 中的值。因此，我们从存储中刷新本地对象，基本上丢弃任何本地更改（有副作用，例如，导致对象成为错误，释放对任何关系的引用，并释放任何瞬态属性 - 参见 [=55 的文档=]:).
考虑以下类别，它解决了您的情况，以及使用 NSFetchedResultsController.
@interface NSManagedObjectContext (WJHMerging)
- (void)mergeChangesIntoContext:(NSManagedObjectContext*)moc
withDidSaveNotification:(NSNotification*)notification
faultUpdatedObjects:(BOOL)faultUpdatedObjects
overrideLocalChanges:(BOOL)overrideLocalChanges
completion:(void(^)())completionBlock;
@end
@implementation NSManagedObjectContext (WJHMerging)
- (void)mergeChangesIntoContext:(NSManagedObjectContext *)moc
withDidSaveNotification:(NSNotification *)notification
faultUpdatedObjects:(BOOL)faultUpdatedObjects
overrideLocalChanges:(BOOL)overrideLocalChanges
completion:(void (^)())completionBlock {
NSAssert(self == notification.object, @"Not called with");
NSSet *updatedObjects = notification.userInfo[NSUpdatedObjectsKey];
NSMutableSet *updatedObjectIDs = nil;
if (overrideLocalChanges || faultUpdatedObjects) {
updatedObjectIDs = [NSMutableSet setWithCapacity:updatedObjects.count];
for (NSManagedObject *obj in updatedObjects) {
[updatedObjectIDs addObject:[obj objectID]];
}
}
[moc performBlock:^{
if (overrideLocalChanges) {
for (NSManagedObject *obj in [moc updatedObjects]) {
if ([updatedObjectIDs containsObject:obj.objectID]) {
[moc refreshObject:obj mergeChanges:NO];
}
}
}
if (faultUpdatedObjects) {
for (NSManagedObjectID *objectID in updatedObjectIDs) {
[[moc objectWithID:objectID] willAccessValueForKey:nil];
}
}
[moc mergeChangesFromContextDidSaveNotification:notification];
if (completionBlock) {
completionBlock();
}
}];
}
@end