p_FMDB

作者: my__life | 来源:发表于2016-10-09 21:14 被阅读9次
    • 一.介绍:
      1.FMDB是什么?
      2.优点?
      3.核心类?
      4.根据路径打开数据库的三种情况?
      5.更新/查询操作?

    • 二.使用:1:初始化(路径、得到数据库、打开数据库(创表))、2:操作(executeUpdate(增删改)、executeQuery(查))。
      1.基本使用
      2.事务的使用 : (使用inTransaction>inDatabase(速度,省去新建事务时间))
      3.项目中的使用 :SQLiteManager类(NSObject) + SQLiteDAO层(数据层)
      (每条数据设置了对应的用户ID,每条数据也有自身id、把数据json体转为NSData存储)
      3.1 每条微博都有对应的唯一id,按大小来排列顺序;

      下拉刷新:去数据库中取>since_id(当前在tableView的模型数组statuesArr中最新微博的id(最大))---->没有的话------->网络请求(传入当前最大id,去获取比这个id大的微博数据。返回了不同的数据,这样新得到的微博数据不会与数据库中原有的数据重复---->存进数据库)

      上拉加载:去数据库去<max_id(当前在tableView的模型数组statuesArr中最后一条微博的id(最小))------>数据库中没有的话------->网络请求。

    关键:每条微博都有一个有大小顺序区分时间先后的独立 ID 。----不然很难做(为了服务器返回不同的数据,存进数据库的数据不重复,按先后加载限定数量的数据。)

    @implementation SQLiteManager
    
    +(SQLiteManager*)sharedInstance{
        
        static id instance;
        static dispatch_once_t onceToken;
        dispatch_once(&onceToken, ^{
            instance = [[self alloc]init];
        });
        return instance;
    }
    
    -(void)openDataBase:(NSString*)dbName{
        
        // 文件路径
        NSString *filePath = [dbName docDir];
        self.dbQueue = [FMDatabaseQueue databaseQueueWithPath:filePath];
        [self createTable];
    }
    
    //创建表:
    -(void)createTable{
    
        NSString *sql = @"CREATE TABLE IF NOT EXISTS 'T_Essence'('id' INTEGER PRIMARY KEY AUTOINCREMENT  NOT NULL ,'count' VARCHAR(255), 'page' VARCHAR(255), 'maxid' VARCHAR(255), 'maxtime' VARCHAR(255), 'list' TEXT)";
    
        [self.dbQueue inDatabase:^(FMDatabase *db) {
           
            [db executeUpdate:sql withArgumentsInArray:nil];
        }];
    }
    
    
    @implementation SQLiteDAO
    //返回什么? 在下一页的时候,传入maxid判断,从数据库中拿去。
    +(void)loadStatuses:(NSString*)sql andBlock:(void(^)(BSEssenceModel*))myBlock{
        
    //    NSString *sql = @"SELECT * FROM T_Essence";
        //执行sql语句:
        [[SQLiteManager sharedInstance].dbQueue inDatabase:^(FMDatabase *db) {
           
              FMResultSet *res = [db executeQuery:sql withArgumentsInArray:nil];
            
            if (res) {
                while ([res next]) {
                    BSEssenceModel *model = [[BSEssenceModel alloc]init];
                    model.count = [[res stringForColumn:@"count"]integerValue];
                    model.page = [[res stringForColumn:@"page"]integerValue];
                    model.maxid = [res stringForColumn:@"maxid"];
                    model.maxtime = [res stringForColumn:@"maxtime"];
                    NSString *listText = [res stringForColumn:@"list"];
                    NSData *data = [listText dataUsingEncoding:NSUTF8StringEncoding];
                    NSArray *arrList = [NSJSONSerialization JSONObjectWithData:data options:NSJSONReadingMutableContainers error:nil];
                    
                    NSMutableArray *arrData = [BSEssenceCellModel mj_objectArrayWithKeyValuesArray:arrList];
                    model.list = arrData;
                    myBlock(model);
                }
                
            }
        }];
    }
    
    //缓存数据:
    +(void)cacheStatuses:(NSDictionary*)response{
        
        NSDictionary *dict = response[@"info"];
        NSArray *arr = response[@"list"];
    
        NSString* count = dict[@"count"];
        NSString *page = dict[@"page"];
        NSString *maxid = dict[@"maxid"];
        NSString *maxtime = dict[@"maxtime"];
        
        
        [[SQLiteManager sharedInstance].dbQueue inTransaction:^(FMDatabase *db, BOOL *rollback) {
            
            NSString *sql = @"INSERT OR REPLACE INTO T_Essence (count,page,maxid,maxtime,list) VALUES (?,?,?,?,?)";
     
            NSData *data = [NSJSONSerialization dataWithJSONObject:arr options:NSJSONWritingPrettyPrinted error:nil];
            NSString *list = [[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding];
            
            if (![db executeUpdate:sql,count,page,maxid,maxtime,list]) {
                 *rollback = YES;
            }
        }];
    }
    
    
    • 三.FMDatabaseQueue的介绍与多线程问题
      3.1介绍: FMDatabaseQueue虽然看似一个队列,实际上它本身并不是,它通过内部创建一个Serial的dispatch_queue_t来处理通过inDatabase和inTransaction传入的Blocks,所以当我们在主线程(或者后台)调用inDatabase或者inTransactio时,代码实际上是同步的。
      FMDatabaseQueue这么设计的目的是让我们避免发生并发访问数据库的问题,因为对数据库的访问可能是随机的(在任何时候)、不同线程间(不同的网络回调等)的请求。内置一个Serial队列后,FMDatabaseQueue就变成线程安全了,所有的数据库访问都是同步执行,而且这比使用@synchronized或NSLock要高效得多。

    3.2 FMDatabaseQueue不是在次线程中操作、若要次线程操作在外面要包一层:

        });```
    
    -  问题:如果后台在执行大量的更新,而主线程也需要访问数据库,虽然要访问的数据量很少,但是在后台执行完之前,还是会阻塞主线程。
    -  参考答案:http://blog.csdn.net/zhangao0086/article/details/44223007

    相关文章

      网友评论

          本文标题:p_FMDB

          本文链接:https://www.haomeiwen.com/subject/nwlmyttx.html