FMDB常用API简述及多线程单例类封装

FMDB的简单使用

导入头文件 #import "FMDB.h"
全局的静态数据库对象
initialize
// 这个类在第一次使用时就被调用一次,后面就不会再调用;而且是先于实例化方法调用的.

static FMDatabase *_db;
+ (void)initialize {
 // NSLog(@"这个类在第一次使用时就被调用一次"); 
// 1.获取数据库路径
 NSString *SQLPath = [[NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) lastObject] stringByAppendingPathComponent:@"heros.db"];//heros是你的表名
 // 2.创建数据库和建表,只会执行一次 
_db = [FMDatabase databaseWithPath:SQLPath];
 // 3.打开数据库
 BOOL isOpen = [_db open]; 
if (isOpen) { 
  // 4.建表 
  BOOL isCreate = [_db executeUpdate:@"create table if not exists t_heros(id integer primary key,name text not null,age integer)"];
   if (isCreate) {
     NSLog(@"建表成功");
    } 
  } 
}

新增

[_db executeUpdateWithFormat:@"insert into t_heros(name,age) values('张三',18)"];

修改

[_db executeUpdateWithFormat:@"update t_heros set age = 19 where name = '张三'"];

删除

[_db executeUpdateWithFormat:@"delete from t_heros where name = '张三'"];

查询 -- 模糊查询

// 执行查询语句.获取到结果集
FMResultSet *resultSet = [_db executeQuery:@"select * from t_heros"];
// 遍历结果集,取数据
while ([resultSet next]) {
 // 取出来的数据 
NSString *name = [resultSet stringForColumn:@"name"];
 int age = [resultSet intForColumn:@"age"];
}

如果数据库里面的记录有很多条,那么就要像解析模型一样创建数据源去接收多条数据存到数据源

+ (NSArray *)selectHeros{  
  // 定义临时的模型数据  
  NSMutableArray *tmpM = [NSMutableArray array];  
  // 执行查询语句.获取到结果集  
  FMResultSet *resultSet = [_db executeQuery:@"select * from t_heros"];  
  // 遍历结果集,取数据  
  while ([resultSet next]) {       
 // 创建模型       
 Heros *hero = [[Heros alloc] init];     //自己的模型 
  // 取出来的数据    
    NSString *name = [resultSet stringForColumn:@"name"];     
   int age = [resultSet intForColumn:@"age"];  
      // 给模型赋值    ,name和age为模型里面的key,根据自己的实际情况更改
    hero.name = name;        
    hero.age = @(age);     
   // 将模型添加到模型数组      
  [tmpM addObject:hero];  
  }   
 return tmpM.copy;

到此简单的数据库增删改查都可以实现,那么问题来了

dispatch_async(dispatch_get_global_queue(0, 0), ^{
 [_db executeUpdateWithFormat:@"insert into t_heros(name,age) values('李四',19)"];
});
dispatch_async(dispatch_get_global_queue(0, 0), ^{ 
[_db executeUpdateWithFormat:@"insert into t_heros(name,age) values('周五',20)"];
});

项目中不可能只是单线程的情况,那么多线程情况下就有可能出现多条数据插入,只有一条数据成功的情况,因为FMDB默认不支持多线程去操作数据库,

分析FMDatabaseQueue
源码

- (void)inDatabase:(void (^)(FMDatabase *db))block { 
/* Get the currently executing queue (which should probably be nil, but in theory could be another DB queue * and then check it against self to make sure we're not about to deadlock. */ 
FMDatabaseQueue *currentSyncQueue = (__bridge id)dispatch_get_specific(kDispatchQueueSpecificKey); 
assert(currentSyncQueue != self && "inDatabase: was called reentrantly on the same queue, which would lead to a deadlock");
 FMDBRetain(self); 
// 串行队列+同步任务
 dispatch_sync(_queue, ^() {
 // 数据库实例
 FMDatabase *db = [self database];
 block(db); 
if ([db hasOpenResultSets]) {
 NSLog(@"Warning: there is at least one open result set around after performing [FMDatabaseQueue inDatabase:]");
#if defined(DEBUG) && DEBUG 
NSSet *openSetCopy = FMDBReturnAutoreleased(
[[db valueForKey:@"_openResultSets"] copy]);
 for (NSValue *rsInWrappedInATastyValueMeal in openSetCopy) {
 FMResultSet *rs = (FMResultSet *)[rsInWrappedInATastyValueMeal pointerValue]; 
NSLog(@"query: '%@'", [rs query]);
 }
#endif 
} 
});
 FMDBRelease(self);}

结论 :
FMDatabaseQueue管理着一个队里,这个队列是串行队列.
串行队列里面装的都是同步任务
同步任务里面就是操作数据库的代码
所以如果我们的 app 需要多线程操作数据库，那么就需要使用 FMDatabaseQueue 来保证线程安全了。切记不能在多个线程中共同一个 FMDatabase 对象并且在多个线程中同时使用，这个类本身不是线程安全的，这样使用会造成数据混乱等问题,我么需要实例化一个 FMDatabaseQueue区吃力多线程下的数据库操作

封装FMDatabaseQueue单例类
把FMDatabaseQueue定义成单例的目的是为了保证队列在内存中是唯一的一个,当有多个数据库操作任务时,都可以放在同一个队列中.

单例类继承自FMDatabaseQueue

#import "FMDB.h"
//继承FMDatabaseQueue
@interface FMDatabaseQueueManager : FMDatabaseQueue
+ (instancetype)sharedDatabaseQueue;
@end

FMDatabaseQueue
单例类实现

+ (instancetype)sharedDatabaseQueueManager{
 static FMDatabaseQueueManager *instance; 
static dispatch_once_t onceToken; dispatch_once(&onceToken, ^{
// 初始化队列的操作
 instance = [FMDatabaseQueueManager databaseQueueWithPath:@"/xxx/xxx/xxx/heros.db"];//数据库路径
 }); 
return instance;
 }

//实例化单利之后再进行数据库的操作

//创建数据库表

+ (void)initialize{
 // 创建和打开数据库
 [[FMDatabaseQueueManager sharedDatabaseQueue] inDatabase:^(FMDatabase *db) {
 // 建表
 BOOL isCreate = [db executeUpdate:@"create table if not exists t_heros(id integer primary key,name text not null,age integer)"];
 if (isCreate) { 
    NSLog(@"建表成功");
 }
 }];
}
//以新增为例
[[FMDatabaseQueueManager sharedDatabaseQueue] inDatabase:^(FMDatabase *db) { 
       [db executeUpdateWithFormat:@"insert into t_heros(name,age) values('张三',28)"];

FMDB常用API简述及多线程单例类封装

推荐阅读更多精彩内容