數據庫讀取操做通常都是多線程訪問的。在對數據進行讀取時,咱們要保證其當前狀態不能被修改,即讀取時加鎖,不然就會出現數據錯誤混亂。
IOS中經常使用的兩種數據持久化存儲方式:CoreData和SQLite,二者都須要設置線程安全,在這裏以FMDB來解釋對SQLite的線程安全訪問。sql
1.沒有線程安全的執行方式:數據庫
//************** 數據庫保存圖片 ******************// FMDatabase *database = [FMDatabase databaseWithPath:[self getDatabasePath]]; //打開數據庫 [database open]; NSString *sql = @"create table if not exists Test (id integer primary key autoincrement,name text,image blob);"; //建立表 [database executeUpdate:sql]; //把UIImage對象轉化爲NSData NSData *data = UIImagePNGRepresentation([UIImage imageNamed:@"user_browse"]); //寫入數據 sql = @"insert into Test (name,image) values (?,?)"; [database executeUpdate:sql,@"張三",data]; //讀取顯示 sql = @"select * from Test;"; FMResultSet *resultSet = [database executeQuery:sql]; while (resultSet.next) { //[resultSet dataForColumn:@"image"]; NSData *imageData = [resultSet dataForColumnIndex:2]; UIImageView *imageView = [[UIImageView alloc] initWithFrame:CGRectMake(0, 0, 300, 300)]; imageView.image = [UIImage imageWithData:imageData]; [self.view addSubview:imageView]; }
2,使用線程隊列安全
//************** 數據庫線程安全 ***********// FMDatabaseQueue *queue = [[FMDatabaseQueue alloc] initWithPath:[self getDatabasePath]]; [queue inDatabase:^(FMDatabase *db) { //線程安全的 __block NSString *sql = @"create table if not exists Test (id integer primary key autoincrement,name text,image blob);"; //建立表 [database executeUpdate:sql]; }]; //插入數據 [queue inDatabase:^(FMDatabase *db) { //寫入數據 sql = @"insert into Test (name,image) values (?,?)"; [database executeUpdate:sql,@"張三",data]; }]; //讀取 [queue inDatabase:^(FMDatabase *db) { //讀取顯示 sql = @"select * from Test;"; FMResultSet *resultSet = [database executeQuery:sql]; while (resultSet.next) { //[resultSet dataForColumn:@"image"]; NSData *imageData = [resultSet dataForColumnIndex:2]; UIImageView *imageView = [[UIImageView alloc] initWithFrame:CGRectMake(0, 0, 300, 300)]; imageView.image = [UIImage imageWithData:imageData]; [self.view addSubview:imageView]; } }];
分析一下線程安全下的FMDB的實現:
在當使用FMDBDatabaseQueue建立數據庫時,會使用GCD建立一個線程隊列:多線程
。。。 _queue = dispatch_queue_create([[NSString stringWithFormat:@"fmdb.%@", self] UTF8String], NULL); dispatch_queue_set_specific(_queue, kDispatchQueueSpecificKey, (__bridge void *)self, NULL); _openFlags = openFlags; 。。。
而後在讀取時調用[queue inDatabase:^(FMDatabase *db)
方法,在block中會鎖定當前數據庫app
dispatch_sync(_queue, ^() { FMDatabase *db = [self database]; block(db); …… }
咱們能夠看到實際上這裏是對整個數據庫進行加鎖,以此來保證線程安全的。spa
1.沒有線程安全的coredata數據讀取:線程
NSManagedObjectContext對象的建立:_managedObjectContext = [[NSManagedObjectContext alloc] init];
code
插入數據操做:(AppDetailModal爲數據模型)orm
context 爲返回的 _managedObjectContext對象
AppDetailModal *newapp = [NSEntityDescription insertNewObjectForEntityForName:TableName inManagedObjectContext:context];
其餘查詢、更新、刪除操做
//獲取Entity
NSEntityDescription *entity = [NSEntityDescription entityForName:TableName inManagedObjectContext:context];
2.線程安全的coreData操做:
首先建立並行的NSManagedObjectContext對象
NSManagedObjectContext* context=[[NSManagedObjectContext alloc] initWithConcurrencyType:NSPrivateQueueConcurrencyType];
而後在執行讀取操做時使用一下兩個方法: -(void)performBlock:(void (^)(void))block -(void)performBlockAndWait:(void (^)(void))block
[context performBlock:^{ //要執行的讀取操做 }];