最近看了FCModel和FMDB的源碼,覺得FCModel確實不錯,但網(wǎng)上資源不多,因此寫下這篇文章,來介紹一下FCModel及自己的理解。
一. FMDB
FMDB是對Sqlite的OC的封裝,封裝了Sqlite的繁瑣的C語言代碼,對外提供一些簡單的接口,用于操作數(shù)據(jù)庫。FMDB的使用參考唐巧老師的博客,寫的很詳細 在iOS開發(fā)中使用FMDB
二. FCModel
- FCModel在FMDB的基礎(chǔ)上,封裝了FMDB提供的功能,加入了對象數(shù)據(jù)模型。它的readme這樣介紹的:FCModel是一個操作SQL易取可選擇的核心數(shù)據(jù)模型,CoreData的替代性選擇。適用于那些喜歡Core Data的便利性,但又想要對實現(xiàn)、性能、數(shù)據(jù)庫模式、查詢、索引、遷移以及使用原始SQL查詢等擁有更多掌控的開發(fā)者。
它是這樣做的,比如查詢操作,調(diào)用FMDB的查詢接口之后,利用運行時的class_getProperty方法和KVC機制構(gòu)造對象,返回給外部OC對象,而不是FMDB直接返回的數(shù)據(jù)。 - CoreData也是支持對象的存儲的,能夠存儲OC對象并且從數(shù)據(jù)庫中獲取OC對象,它的底層數(shù)據(jù)庫用的是Sqlite。但是CoreData非線程安全,多線程協(xié)作很麻煩。FCModel會有內(nèi)存級的緩存,可以保證多個頁面引用的其實是同一個model,保證數(shù)據(jù)的一致性。FCModel是用信號量機制來控制線程的同步的。
- 下面分析FCModel的源碼:
1)FCModel文件夾下包括FCModel、FCModelCacheObject、FCModelDatabaseQueue三個類的.h .m文件。FCModel繼承NSObject,在FMDB的基礎(chǔ)上,能夠更加方便的在數(shù)據(jù)庫中操作自己的對象。
2)FCModel類的主要屬性及核心方法作用解釋如下圖:

+ (NSArray *)allLoadedInstances;
當(dāng)你使用它的時候,如果其他線程加載了一個新的對象,這個array則已經(jīng)過期了。這個數(shù)組中的東西都是被加載的對象,但是不能保證包括了所有的對象,如果你在不同的線程中使用SELECTs。
+ (void)inDatabaseSync:(void (^)(FMDatabase *db))block;
你可以在相同的數(shù)據(jù)庫對象上隨意使用自己的查詢操作,他們都會在FCModel的私有數(shù)據(jù)庫操作隊列中同步執(zhí)行。
+ (void)dataWasUpdatedExternally;數(shù)據(jù)被外部更新
如果在實例外部的任何FCModel表執(zhí)行INSERT/UPDATE/DELETE,則這個方法會被調(diào)用
創(chuàng)建、插入、更新、刪除操作。使用信號量機制,控制多線程同步。
static dispatch_once_t token;
dispatch_once(&token, ^{
g_instancesReadLock = dispatch_semaphore_create(1);
g_instances = [NSMutableDictionary dictionary];
});
此處的dispatch_semaphore是GCD用來同步的一種方式,與它相關(guān)的共有三個函數(shù),分別是
dispatch_semaphore_create,
dispatch_semaphore_signal,
dispatch_semaphore_wait。
- dispatch_semaphore_t dispatch_semaphore_create(long value);傳入的參數(shù)為long,輸出一個dispatch_semaphore_t類型且值為value的信號量。信號量機制控制線程同步,與OS里面的信號量機制相同
- long dispatch_semaphore_signal(dispatch_semaphore_t dsema)這個函數(shù)會使傳入的信號量dsema的值加1;
dispatch_semaphore_signal的返回值為long類型,當(dāng)返回值為0時表示當(dāng)前并沒有線程等待其處理的信號量,其處理的信號量的值加1即可。當(dāng)返回值不為0時,表示其當(dāng)前有(一個或多個)線程等待其處理的信號量,并且該函數(shù)喚醒了一個等待的線程(當(dāng)線程有優(yōu)先級時,喚醒優(yōu)先級最高的線程;否則隨機喚醒)。dispatch_semaphore_wait的返回值也為long型。當(dāng)其返回0時表示在timeout之前,該函數(shù)所處的線程被成功喚醒。當(dāng)其返回不為0時,表示timeout發(fā)生。 - long dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout);這個函數(shù)會使傳入的信號量dsema的值減1;
這個函數(shù)的作用是這樣的,如果dsema信號量的值大于0,該函數(shù)所處線程就繼續(xù)執(zhí)行下面的語句,并且將信號量的值減1;如果desema的值為0,那么這個函數(shù)就阻塞當(dāng)前線程等待timeout(注意timeout的類型為dispatch_time_t,不能直接傳入整型或float型數(shù)),如果等待的期間desema的值被dispatch_semaphore_signal函數(shù)加1了,且該函數(shù)(即dispatch_semaphore_wait)所處線程獲得了信號量,那么就繼續(xù)向下執(zhí)行并將信號量減1。如果等待期間沒有獲取到信號量或者信號量的值一直為0,那么等到timeout時,其所處線程自動執(zhí)行其后語句。
在FCModel中,其中一個線程加載所有實例的時候,創(chuàng)建一個信號量鎖g_instancesReadLock,執(zhí)行wait操作,信號量減一,
NSMapTable *classCache = g_instances[self];
NSArray *instances = classCache ? [classCache.objectEnumerator.allObjects copy] : [NSArray array];執(zhí)行signal操作,信號量加1.
創(chuàng)建鎖的邏輯,放在dispatch_once{}中,只會執(zhí)行一次。
查看緩存中是否有該實例,執(zhí)行wait操作,信號量減一。查看該對象是否在緩存中,是否在DB中,查詢結(jié)束后執(zhí)行Signal操作,信號量加一。如果某個線程在執(zhí)行查詢緩存操作,另一個線程想要執(zhí)行查詢或創(chuàng)建操作,都需要等待,當(dāng)信號量為0時,再對它執(zhí)行wait操作,會進入阻塞狀態(tài),等待信號量的釋放。
注冊新的實例及移除實例,都使用信號量控制同步。
三. FCModel的使用
官網(wǎng)上有使用介紹FCModel
要自己創(chuàng)建一個Model類,一定要繼承FCModel,在自己定義的Model類中加入創(chuàng)建數(shù)據(jù)庫及創(chuàng)建表的邏輯,然后使用FCModel中的數(shù)據(jù)庫方法即可方便的完成數(shù)據(jù)庫表的增刪改查。
下面舉個列子,使用FMDB存取數(shù)據(jù)和使用FCModel存取數(shù)據(jù),通過對比,就可以發(fā)現(xiàn)FCModel的便捷之處。
獲取數(shù)據(jù)庫中的用戶表信息,從數(shù)據(jù)庫中查詢之后,需要用dictionary存儲起來,再用dictionary去構(gòu)造user實體。那如果還有其他的很多表對應(yīng)的實體,比如:部門、user的聯(lián)系人等等,獲取每一個表的信息時都要像下面這段代碼這樣做,用dictionary存儲數(shù)據(jù)庫返回的結(jié)果,再用dictionary數(shù)據(jù)構(gòu)造對應(yīng)的實體。同理,數(shù)據(jù)庫存儲的時候也是這樣,先將實體轉(zhuǎn)成dictionary,再一一存儲。這樣是不是很麻煩?太多繁瑣的重復(fù)邏輯的代碼。使用FCModel的話,就是在將Dictionary生成實體的時候,使用運行時,生成對象,這樣所有的實體都可以用這一個接口來完成dictionary轉(zhuǎn)實體,是不是減少了很多代碼?所以,對于有ORM需求的項目,使用FCModel比使用FMDB要好很多。
- (void)getAllUsers:(Complection )completion
{
[_dataBaseQueue inDatabase:^(FMDatabase *db) {
if ([_database tableExists:usersTableName])
{
NSMutableArray* array = [[NSMutableArray alloc] init];
NSString* sqlString = [NSString stringWithFormat:@"SELECT * FROM %@ ", usersTableName];
FMResultSet* result = [_database executeQuery:sqlString];
UserEntity* user = nil;
while ([result next])
{
user = [self userFromResult:result];
[array addObject:user];
}
}
}];
}
- (UserEntity*)userFromResult:(FMResultSet*)resultSet
{
NSMutableDictionary *dic = [NSMutableDictionary new];
[dic safeSetObject:[resultSet stringForColumn:@"name"] forKey:@"name"];
[dic safeSetObject:[resultSet stringForColumn:@"id"] forKey:@"userId"];
[dic safeSetObject:[NSNumber numberWithInt:[resultSet intForColumn:@"Sex"]] forKey:@"sex"];
[dic safeSetObject:[resultSet stringForColumn:@"telphone"] forKey:@"telphone"];
[dic safeSetObject:[resultSet stringForColumn:@"email"] forKey:@"email"];
UserEntity* user = [UserEntity dicToUserEntity:dic];
return user;
}