CoreData 的使用以及 CoreData 中的多线程问题

CoreData的使用

1.coreData简介

      coreData是苹果对sqlite的封装,不用操作sqlite语句,他提供了对象关系映射功能,能将oc对象转化成数据,保存在sqlite中,也能将保存的数据还原成oc对象;

      coredata有两种队列:私有队列,主队列

       coreData中的主要包括这几个部分:管理对象上下文,数据持久化协调器,模型文件(包含实体,实体对应的是实体类),

2.coreData的使用

//    1.创建模型文件 ［相当于一个数据库里的所有表］

//    2.添加实体(可以添加多个实体) ,添加相应实体的属性［添加一个实体相当于数据库中添加了一张表］

• Undefined: 默认值，参与编译会报错

• Integer 16: 整数，表示范围 -32768 ~ 32767

• Integer 32: 整数，表示范围 -2147483648 ~ 2147483647

• Integer 64: 整数，表示范围 –9223372036854775808 ~ 9223372036854775807

• Float: 小数，通过MAXFLOAT宏定义来看，最大值用科学计数法表示是 0x1.fffffep+127f

• Double: 小数，小数位比Float更精确，表示范围更大

• String: 字符串，用NSString表示

• Boolean: 布尔值，用NSNumber表示

• Date: 时间，用NSDate表示

• Binary Data: 二进制，用NSData表示

• Transformable: OC对象，用id表示。可以在创建托管对象类文件后，手动改为对应的OC类名。使用的前提是，这个OC对象必须遵守并实现NSCoding协议

  
  

//    3.创建对应的实体类() [相当于管理对象模型，有一个实体就创建一个实体类，就相当于一个实体模型]

那么对于CoreData, 我们不用直接接触sql语句, 这种表间的联合查询我们应该怎么办呢?

CoreData 的联合查询.

1.我们创建一个部门的示例, 请注意 Employee 的 Releationships 部分.

这里, 实际上Department做为Employee的外键, 在Employee中有一个字段为depart. 如此设置之后,这两张表已经完成前面我们描述的表间关联, 不用出现join关键字, 我们已经将两张表牢牢的绑在一起了.

//    4.生成管理对象上下文 并关联模型文件生成数据库

    /*

     * 关联的时候，如果本地没有数据库文件，Ｃoreadata自己会创建

     */

    // 创建上下文

    NSManagedObjectContext *context = [[NSManagedObjectContext alloc] init];

    // model模型文件

  // NSManagedObjectModel *model =[NSManagedObjectModel mergedModelFromBundles:nil];//使用这个方法，如果 bundles为nil会把bundles里面的所有模型文件的表放在一个数据库中

  //使用下面这个方法,是把一个模型文件对应一个数据库

    NSURL *companyURL = [[NSBundle mainBundle]URLForResource:modelName  withExtension:@"momd"];

    NSManagedObjectModel *model = [[NSManagedObjectModel alloc]initWithContentsOfURL:companyURL];

  

    // 持久化存储调度器（通过她把模型链接到本地数据库）

    // 持久化，把数据保存到一个文件，而不是内存

    NSPersistentStoreCoordinator *store = [[NSPersistentStoreCoordinator alloc] initWithManagedObjectModel:model];

    

    // 告诉Coredata数据库的名字和路径

    NSString *doc = [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) lastObject];

    

    NSString *sqlitePath = [doc stringByAppendingPathComponent:@"company.sqlite"];

    NSLog(@"%@",sqlitePath);

／／添加持久化存储（也就时设置存储类型和存储路径）

    [store addPersistentStoreWithType:NSSQLiteStoreType configuration:nil URL:[NSURLfileURLWithPath:sqlitePath] options:nil error:nil];

    //设置上下文的持久化调度器

    context.persistentStoreCoordinator = store;

    _context = context;

}

==========

//使用这个方法是把不同的模型文件的表放到不同的数据库中

-(NSManagedObjectContext *)setupContextWithModelName:(NSString*)modelName{

    

    //    1.创建模型文件［相当于一个数据库里的表］

    //    2.添加实体［一张表］

    //    3.创建实体类 [相当模型]

    //    4.生成上下文关联模型文件生成数据库

    /*

     * 关联的时候，如果本地没有数据库文件，Ｃoreadata自己会创建

     */

    

    // 上下文

    NSManagedObjectContext *context = [[NSManagedObjectContext alloc]init];

    

    // 上下文关连数据库

    

    // model模型文件

    NSURL *companyURL = [[NSBundlemainBundle]URLForResource:modelNamewithExtension:@"momd"];

    NSManagedObjectModel *model = [[NSManagedObjectModelalloc]initWithContentsOfURL:companyURL];

    

    // 持久化存储调度器

    // 持久化，把数据保存到一个文件，而不是内存

    NSPersistentStoreCoordinator *store = [[NSPersistentStoreCoordinatoralloc]initWithManagedObjectModel:model];

    

    // 告诉Coredata数据库的名字和路径

    NSString *doc = [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory,NSUserDomainMask,YES)lastObject];

    

    NSString *sqliteName = [NSStringstringWithFormat:@"%@.sqlite",modelName];

    NSString *sqlitePath = [doc stringByAppendingPathComponent:sqliteName];

    NSLog(@"%@",sqlitePath);

    [store addPersistentStoreWithType:NSSQLiteStoreType configuration:nil URL:[NSURLfileURLWithPath:sqlitePath] options:nil error:nil];

    

    context.persistentStoreCoordinator = store;

    

    return context;

}

==========

// 数据库的操作 CURD Create Update  Read Delete

#pragma mark -----增

    // 通过模型文件中的实体创建一个员工对象

    //Employee *emp = [[Employee alloc] init];

    Employee *emp = [NSEntityDescription insertNewObjectForEntityForName:@"Employee"inManagedObjectContext:_context];

    emp.name = @"wangwu";

    emp.height = @1.80;

    emp.birthday = [NSDate date];

    

    // 直接保存数据库

    NSError *error = nil;

    [_context save:&error];

    

    if (error) {

        NSLog(@"%@",error);

    }

#pragma mark ----查

   

    // 1.FectchRequest 创建抓取请求对象

    NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"Employee"];

    

    // 2.设置过滤条件

    // 查找zhangsan

    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name = %@",

                        @"zhangsan"];

    request.predicate = pre;

    

    // 3.设置排序

    // 身高的升序排序

    NSSortDescriptor *heigtSort = [NSSortDescriptor sortDescriptorWithKey:@"height"ascending:NO];

    request.sortDescriptors = @[heigtSort];

    

    

    // 4.执行请求

    NSError *error = nil;

    

    NSArray *emps = [_context executeFetchRequest:request error:&error];

    if (error) {

        NSLog(@"error");

    }

    

    //NSLog(@"%@",emps);

    //遍历员工

    for (Employee *emp in emps) {

        NSLog(@"名字 %@ 身高 %@ 生日 %@",emp.name,emp.height,emp.birthday);

    }

    

#pragma mark -----改

    // 1.查找到zhangsan

    // 1.1FectchRequest 抓取请求对象

    NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"Employee"];

    

    // 1.2设置过滤条件

    // 查找zhangsan

    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name = %@",

                        @"zhangsan"];

    request.predicate = pre;

    

    // 1.3执行请求

    NSArray *emps = [_context executeFetchRequest:request error:nil];

    

    

    // 2.更新身高

    for (Employee *e in emps) {

        e.height = @2.0;

    }

    

    // 3.保存

    [_context save:nil];

#pragma mark ------删

    

    // 1.查找lisi

    // 1.1FectchRequest 抓取请求对象

    NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"Employee"];

    

    // 1.2设置过滤条件

    // 查找zhangsan

    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name = %@",

                        @"lisi"];

    request.predicate = pre;

    

    // 1.3执行请求

    NSArray *emps = [_context executeFetchRequest:request error:nil];

    

    // 2.删除

    for (Employee *e in emps) {

        [_context deleteObject:e];

    }

    

    // 3.保存

    [_context save:nil];

====================================

模糊查询:

// 1.FectchRequest 抓取请求对象

    NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"Employee"];

  //设置身高的升序排序

    NSSortDescriptor *heigtSort = [NSSortDescriptor sortDescriptorWithKey:@"height"ascending:NO];

    request.sortDescriptors = @[heigtSort];

    

    // 模糊查询

    // 名字以"wang"开头

//    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name BEGINSWITH %@",@"wangwu1"];

//    request.predicate = pre;

    

    // 名字以"1"结尾

//    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name ENDSWITH %@",@"1"];

//    request.predicate = pre;

    

    // 名字包含"wu1"

//    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name CONTAINS %@",@"wu1"];

//    request.predicate = pre;

    

    // like

    //以wangwu1*结尾

    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name like %@",@"*wu12"];

    //以wangwu1开头

    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name like %@",@"wu12*"];

     //匹配正则表达式

    NSPredicate *pre = [NSPredicate predicateWithFormat:@"name like %@",@"正则表达是语句"];

    request.predicate = pre;

    // 4.执行请求

    NSError *error = nil;

    

    NSArray *emps = [_context executeFetchRequest:request error:&error];

    

====================================

分页查询

// 1.FectchRequest 抓取请求对象

    NSFetchRequest *request = [NSFetchRequest fetchRequestWithEntityName:@"Employee"];

// 设置身高的升序排序

    NSSortDescriptor *heigtSort = [NSSortDescriptorsortDescriptorWithKey:@"height"ascending:NO];

    request.sortDescriptors = @[heigtSort];

    

    // 总有共有15数据

    // 每次获取6条数据

    // 第一页 0,6

    // 第二页 6,6

    // 第三页 12,6 3条数据

    // 分页查询 limit 0,5

    

    // 分页的起始索引

    request.fetchOffset = 12;

    

    // 分页的条数

    request.fetchLimit = 6;

    

    // 4.执行请求

    NSError *error = nil;

    

    NSArray *emps = [_context executeFetchRequest:requesterror:&error];//执行查询

++++++++++++++++++++++++++++

直接创建查询结果控制器查询

//懒加载

-(NSFetchedResultsController *)fetchController

{

    if (_fetchController ==nil) {

        //查询请求

        NSFetchRequest *fetchrequest = [[NSFetchRequestalloc]init];

        

        //1.获取实体描述

        fetchrequest.entity = [NSEntityDescriptionentityForName:@"XMPPUserCoreDataStorageObject"inManagedObjectContext:[XMPPRosterCoreDataStoragesharedInstance].mainThreadManagedObjectContext];

        ／／获取实体描述

<code class="hljs vhdl has-numbering" style="display: block; padding: 0px; background-color: transparent; color: inherit; box-sizing: border-box; font-family: 'Source Code Pro', monospace;font-size:undefined; white-space: pre; border-top-left-radius: 0px; border-top-right-radius: 0px; border-bottom-right-radius: 0px; border-bottom-left-radius: 0px; word-wrap: normal; background-position: initial initial; background-repeat: initial initial;"> NSEntityDescription *<span class="hljs-keyword" style="color: rgb(0, 0, 136); box-sizing: border-box;">entity</span> = [NSEntityDescription entityForName:TableName inManagedObjectContext:<span class="hljs-keyword" style="color: rgb(0, 0, 136); box-sizing: border-box;">context</span>];</code><ul class="pre-numbering" style="box-sizing: border-box; position: absolute; width: 50px; background-color: rgb(238, 238, 238); top: 0px; left: 0px; margin: 0px; padding: 6px 0px 40px; border-right-width: 1px; border-right-style: solid; border-right-color: rgb(221, 221, 221); list-style: none; text-align: right;"></ul>

        //2.谓词

        NSPredicate *pre = [NSPredicatepredicateWithFormat:@"subscription = %@",@"both"];

        [fetchrequest setPredicate:pre];

        

        //3.排序

        NSSortDescriptor *sort = [NSSortDescriptorsortDescriptorWithKey:@"jidStr"ascending:YES];

        fetchrequest.sortDescriptors = @[sort];

        

        

        //创建对象查询控制器对象

        _fetchController = [[NSFetchedResultsControlleralloc]initWithFetchRequest:fetchrequestmanagedObjectContext:[XMPPRosterCoreDataStoragesharedInstance].mainThreadManagedObjectContextsectionNameKeyPath:nilcacheName:@"contacts"];

        

        //代理

        _fetchController.delegate =self;

        

    }

    return_fetchController;

}

-(NSArray *)contactEntity

{

    if (_contactEntity ==nil) {

        _contactEntity = [NSArrayarray];

    }

    return_contactEntity;

}

- (void)viewDidLoad {

    [superviewDidLoad];

    

    

 // 查询数据

   [self.fetchControllerperformFetch:nil];//执行查询获取请求

    self.contactEntity = self.fetchController.fetchedObjects;

}

//查询控制器请求代理方法

-(void)controllerDidChangeContent:(NSFetchedResultsController*)controller

{

    //重新获取数据

    self.contactEntity =self.fetchController.fetchedObjects;

    

    //刷新

    [self.tableViewreloadData];

}

＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋＋

===================

//对数组的排序

    NSSortDescriptor *heigtSort = [NSSortDescriptorsortDescriptorWithKey:@"height"ascending:NO];

//    NSArray *resultArr=[arr sortedArrayUsingDescriptor:@[height]];

==============================================

CoreData中的多线程问题

1.一种比较好的iOS模式就是使用一个NSPersistentStoreCoordinator，以及两个独立的Contexts,一个context负责主线程与UI协作，一个context在后台负责耗时的处理,用Notifications的方式通知主线程的NSManagedObjectContext进行mergeChangesFromContextDidSaveNotification操作
2.后台线程做读写更新，而主线程只读
3.CoreData中的NSManagedObjectContext在多线程中不安全,如果想要多线程访问CoreData的话，最好的方法是一个线程一个NSManagedObjectContext,每个NSManagedObjectContext对象实例都可以使用同一个NSPersistentStoreCoordinator实例，这个实例可以很安全的顺序访_问永久存储，这是因为NSManagedObjectContext会在便用NSPersistentStoreCoordinator前上锁。ios5.0为NSManagedObjectContext提供了initWithConcurrentcyType方法，其中的一个NSPrivateQueueConcurrencyType，会自动的创建一个新线程来存放NSManagedObjectContext而且它还会自动创建NSPersistentStoreCoordinator,

通常主线程context使用NSMainQueueConcurrencyType,其他线程childContext使用NSPrivateQueueConcurrencyType. child和parent的特点是要用Block进行操作,performBlock,或者performBlockAndWait，保证线程安全。这两个函数的区别是performBlock不会阻塞运行的线程，相当于异步操作，performBlockAndWait会阻塞运行线程，相当于同步操作。