經過Core Data從數據庫中取出的對象,默認狀況下都是NSManagedObject對象.
NSManagedObject的工做模式有點相似於NSDictionary對象,經過鍵-值對來存取全部的實體屬性.
setValue:forkey:存儲屬性值(屬性名爲key);
valueForKey:獲取屬性值(屬性名爲key). 每一個NSManagedObject都知道本身屬於哪一個NSManagedObjectContextsql
負責數據和應用庫之間的交互(CRUD,即增刪改查、保存等接口都在這個對象中).
全部的NSManagedObject都存在於NSManagedObjectContext中,因此對象和context是相關聯的
每一個 context 和其餘 context 都是徹底獨立的
每一個NSManagedObjectContext都知道本身管理着哪些NSManagedObject數據庫
Core Data的模型文件bash
添加持久化存儲庫,CoreData的存儲類型(好比SQLite數據庫就是其中一種)
中間審查者,用來將對象圖管理部分和持久化部分捆綁在一塊兒,負責相互之間的交流(中介同樣)fetch
用來描述實體:至關於數據庫表中一組數據描述ui
@property (nonatomic) int16_t age;
@property (nonatomic) int64_t id;
@property (nullable, nonatomic, copy) NSString *name;
@property (nonatomic) BOOL sex;
複製代碼
#import <CoreData/CoreData.h>
複製代碼
// 建立數據庫
// 1. 實例化數據模型(將全部定義的模型都加載進來)
// merge——合併
self.managedObjectModel = [NSManagedObjectModel mergedModelFromBundles:nil];
// 2. 實例化持久化存儲調度,要創建起橋樑,須要模型
self.persistentStoreCoordinator = [[NSPersistentStoreCoordinator alloc] initWithManagedObjectModel:self.managedObjectModel];
// 3. 添加一個持久化的數據庫到存儲調度
// 3.1 創建數據庫保存在沙盒的URL
NSString *path = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES).lastObject;
NSString *filePath = [[path stringByAppendingString:@"/"] stringByAppendingString:@"wudan.sqlite"];
NSURL *pathUrl = [NSURL fileURLWithPath:filePath];
// 3.2 打開或者新建數據庫文件
// 若是文件不存在,則新建以後打開
// 否者直接打開數據庫
NSError *error;
@try {
[self.persistentStoreCoordinator addPersistentStoreWithType:NSSQLiteStoreType configuration:nil URL:pathUrl options:nil error:&error];
self.context = [[NSManagedObjectContext alloc] init];
self.context.persistentStoreCoordinator = self.persistentStoreCoordinator;
} @catch (NSException *exception) {
NSLog(@"Error:%@",error);
} @finally {
NSLog(@"打開數據庫");
}
複製代碼
- (void)queryAllResult:(void(^)(NSArray *dataArray))result {
NSMutableArray *array = [NSMutableArray array];
NSPredicate *predicate = [NSPredicate predicateWithFormat:@"id > 0"];
NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"User"];
request.predicate = predicate;
NSError *error;
NSArray *re = [self.context executeFetchRequest:request error:&error];
if (re.count != 0) {
for (User *user in re) {
[array addObject:user];
}
}
result(array);
}
複製代碼
- (void)queryUserInfoWithPageNo:(NSInteger)pageNo pageSize:(NSInteger)pageSize result:(void(^)(NSArray *dataArray))result {
NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"User"];
NSSortDescriptor *scoreSort = [NSSortDescriptor sortDescriptorWithKey:@"id" ascending:true];
request.sortDescriptors = @[scoreSort];
request.fetchOffset = (pageNo - 1) * pageSize;
request.fetchLimit = pageSize;
NSError *error = nil;
NSArray *re = [self.context executeFetchRequest:request error:&error];
NSMutableArray *array = [NSMutableArray array];
if (re.count != 0) {
for (User *user in re) {
[array addObject:user];
}
}
result(array);
}
複製代碼
- (void)queryUserInfoByObject:(id)object value:(id)value result:(void(^)(NSArray *dataArray))result {
NSMutableArray *array = [NSMutableArray array];
NSPredicate *predicate = [NSPredicate predicateWithFormat:[NSString stringWithFormat:@"%@ = '%@'", object, value]];
NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"User"];
request.predicate = predicate;
NSError *error;
NSArray *re = [self.context executeFetchRequest:request error:&error];
if (re.count != 0) {
for (User *user in re) {
[array addObject:user];
}
}
result(array);
}
複製代碼
- (void)addUserInfo:(NSInteger)userId name:(NSString *)name sex:(BOOL)sex age:(NSInteger)age success:(void(^)(void))success fail:(void(^)(void))fail {
__block NSArray *array;
[self queryUserInfoByObject:@"id" value:@(userId) result:^(NSArray * _Nonnull dataArray) {
array = dataArray;
}];
if (array.count == 0) {
User *user = [NSEntityDescription insertNewObjectForEntityForName:@"User" inManagedObjectContext:self.context];
user.name = name;
user.id = userId;
user.sex = sex;
user.age = age;
NSError *error;
@try {
[self.context save:&error];
success();
} @catch (NSException *exception) {
NSLog(@"%@", error);
fail();
} @finally {
NSLog(@"新增");
}
} else {
fail();
}
}
複製代碼
- (void)updateUserInfo:(NSInteger)userId infoDic:(NSDictionary *)dic success:(void(^)(void))success fail:(void(^)(void))fail {
NSPredicate *predicate = [NSPredicate predicateWithFormat:[NSString stringWithFormat:@"id = %ld", userId]];
NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"User"];
request.predicate = predicate;
NSError *error;
if (dic.count > 0) {
NSArray *re = [self.context executeFetchRequest:request error:&error];
if (re.count > 0) {
for (User *user in re) {
[dic enumerateKeysAndObjectsUsingBlock:^(id _Nonnull key, id _Nonnull obj, BOOL * _Nonnull stop) {
[user setValue:obj forKey:key];
}];
}
}
@try {
[self.context save:&error];
success();
} @catch (NSException *exception) {
NSLog(@"%@", error);
fail();
} @finally {
NSLog(@"更新");
}
}
}
複製代碼
- (void)deleteUserInfo:(NSInteger)userId success:(void(^)(void))success fail:(void(^)(void))fail {
NSPredicate *predicate = [NSPredicate predicateWithFormat:[NSString stringWithFormat:@"id = %ld", userId]];
NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"User"];
request.predicate = predicate;
NSError *error;
NSArray *re = [self.context executeFetchRequest:request error:&error];
if (re.count > 0) {
@try {
[self.context deleteObject:re.firstObject];
[self.context save:nil];
success();
} @catch (NSException *exception) {
NSLog(@"%@", error);
fail();
} @finally {
NSLog(@"刪除數據");
}
} else {
NSLog(@"數據庫中暫無該數據");
fail();
}
}
複製代碼