12.第三方源码-FMDB

1、简述：

  • FMDB是iOS平台的SQLite数据库框架，是对libsqlite3框架的封装

  • FMDB以OC的方式封装了SQLite的C语言API

2、FMDB的优点：

  • 使用起来更加面向对象，省去了很多麻烦、冗余的C语言代码

  • 对比苹果自带的Core Data框架，更加轻量级和灵活

  • 提供了多线程安全的数据库操作方法，有效地防止数据混乱

3、FMDB的github地址 传送门

4、FMDB的三个核心类

FMDatabase —— 一个FMDatabase对象就代表一个单独的SQLite数据库 用来执行SQL语句

FMResultSet —— 使用FMDatabase执行查询后的结果集

FMDatabaseQueue —— 用于在多线程中执行多个查询或更新，它是线程安全的

1.什么是FMDB

iOS中使用C语言函数对原生SQLite数据库进行增删改查操作，复杂麻烦，于是，就出现了一系列将SQLite API封装的库，如FMDB
FMDB是针对libsqlite3框架进行封装的三方，它以OC的方式封装了SQLite的C语言的API，使用步骤与SQLite相似
FMDB的优点是：
(1) 使用时面向对象，避免了复杂的C语言代码
(2) 对比苹果自带的Core Data框架，更加轻量级和灵活
(3) 提供多线程安全处理数据库操作方法，保证多线程安全跟数据准确性
FMDB缺点：
(1) 因为是OC语言开发，只能在iOS平台上使用，所以实现跨平台操作时存在限制性
FMDB 在Git上的下载链接地址：https://github.com/ccgus/fmdb
2.主要类型
FMDatabase：一个FMDatabase对象代表一个单独的SQLite数据库，通过SQLite语句执行数据库的增删改查操作
FMResultSet：使用FMDatabase对象查询数据库后的结果集
FMDatabaseQueue：用于多线程操作数据库，它保证线程安全
3.FMDB使用方式
(1) GItHub中下载FMDB，将文件导入工程中
(2) 导入libsqlite3.0框架，导入头文件FMDatabase.h
(3) 创建数据库路径，创建数据库，操作前开启数据库，构建操作SQLite语句，数据库执行增删改查操作，操作完关闭数据库
4.FMDB基本使用示例：🌰
(0) 创建Person类

@interface PersonVO : NSObject
@property (nonatomic, assign) int ID;
@property (nonatomic, copy) NSString *name;
@property (nonatomic, copy) NSString *phone;
@property (nonatomic, assign) int score;

@end

(1) 使用FMDBbase类创建数据库

//1.创建database路径
    NSString *docuPath = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES)[0];
    NSString *dbPath = [docuPath stringByAppendingPathComponent:@"test.db"];
    NSLog(@"!!!dbPath = %@",dbPath);
     //2.创建对应路径下数据库
    db = [FMDatabase databaseWithPath:dbPath];
    //3.在数据库中进行增删改查操作时，需要判断数据库是否open，如果open失败，可能是权限或者资源不足，数据库操作完成通常使用close关闭数据库
    [db open];
    if (![db open]) {
        NSLog(@"db open fail");
        return;
    }
    //4.数据库中创建表（可创建多张）
    NSString *sql = @"create table if not exists t_student ('ID' INTEGER PRIMARY KEY AUTOINCREMENT,'name' TEXT NOT NULL, 'phone' TEXT NOT NULL,'score' INTEGER NOT NULL)";
    //5.执行更新操作 此处database直接操作，不考虑多线程问题，多线程问题，用FMDatabaseQueue 每次数据库操作之后都会返回bool数值，YES，表示success，NO，表示fail,可以通过 @see lastError @see lastErrorCode @see lastErrorMessage
    BOOL result = [db executeUpdate:sql];
    if (result) {
        NSLog(@"create table success");

    }
    [db close];

(2) 插入命令sql语句

/**
 增删改查中 除了查询（executeQuery），其余操作都用（executeUpdate）
 //1.sql语句中跟columnname 绑定的value 用 ？表示，不加‘’，可选参数是对象类型如：NSString，不是基本数据结构类型如：int，方法自动匹配对象类型
 - (BOOL)executeUpdate:(NSString*)sql, ...;
 //2.sql语句中跟columnname 绑定的value 用%@／%d表示，不加‘’
 - (BOOL)executeUpdateWithFormat:(NSString *)format, ... NS_FORMAT_FUNCTION(1,2);
 //3.sql语句中跟columnname 绑定的value 用 ？表示的地方依次用 (NSArray *)arguments 对应的数据替代
 - (BOOL)executeUpdate:(NSString*)sql withArgumentsInArray:(NSArray *)arguments;
 //4.同3 ，区别在于多一个error指针，记录更新失败
 - (BOOL)executeUpdate:(NSString*)sql values:(NSArray * _Nullable)values error:(NSError * _Nullable __autoreleasing *)error;
 //5.同3，区别在于用 ？ 表示的地方依次用(NSDictionary *)arguments中对应的数据替代
 - (BOOL)executeUpdate:(NSString*)sql withParameterDictionary:(NSDictionary *)arguments;
 - (BOOL)executeUpdate:(NSString*)sql withVAList: (va_list)args;
 */
//0.直接sql语句
//    BOOL result = [db executeUpdate:@"insert into 't_student' (ID,name,phone,score) values(110,'x1','11',83)"];
    //1.
//    BOOL result = [db executeUpdate:@"insert into 't_student'(ID,name,phone,score) values(?,?,?,?)",@111,@"x2",@"12",@23];
    //2.
//    BOOL result = [db executeUpdateWithFormat:@"insert into 't_student' (ID,name,phone,score) values(%d,%@,%@,%d)",112,@"x3",@"13",43];
    //3.
BOOL result = [db executeUpdate:@"insert into 't_student'(ID,name,phone,score) values(?,?,?,?)" withArgumentsInArray:@[@113,@"x3",@"13",@53]];
    if (result) {
        NSLog(@"insert into 't_studet' success");
        [self showAlertWithTitle:@"insert  success" message:nil person:nil];
    } else {
        [self showAlertWithTitle:[db lastError].description message:nil person:nil];
    }
    [db close];

(3) 删除命令sql语句

[db open];
    ///0.直接sql语句
//    BOOL result = [db executeUpdate:@"delete from 't_student' where ID = 110"];
    //1.
//    BOOL result = [db executeUpdate:@"delete from 't_student' where ID = ?",@(111)];
    //2.
//    BOOL result = [db executeUpdateWithFormat:@"delete from 't_student' where ID = %d",112];
    //3.
      BOOL result = [db executeUpdate:@"delete from 't_student' where ID = ?" withArgumentsInArray:@[@113]];
    if (result) {
        NSLog(@"delete from 't_student' success");
        [self showAlertWithTitle:@"delete  success" message:nil person:nil];
    } else {
        [self showAlertWithTitle:[db lastError].description message:nil person:nil];
    }
    [db close];

(4) 更新命令sql语句

[db open];
    //0.直接sql语句
//    BOOL result = [db executeUpdate:@"update 't_student' set ID = 110 where name = 'x1'"];
    //1.
//    BOOL result = [db executeUpdate:@"update 't_student' set ID = ? where name = ?",@111,@"x2" ];
    //2.
//    BOOL result = [db executeUpdateWithFormat:@"update 't_student' set ID = %d where name = %@",113,@"x3" ];
    //3.
    BOOL result = [db executeUpdate:@"update 't_student' set ID = ? where name = ?" withArgumentsInArray:@[@113,@"x3"]];
    if (result) {
        NSLog(@"update 't_student' success");
        [self showAlertWithTitle:@"update  success" message:nil person:nil];
    } else {
        [self showAlertWithTitle:[db lastError].description message:nil person:nil];
    }
    [db close];

(5) 查询命令sql语句

/**
FMResultSet根据column name获取对应数据的方法
intForColumn：
longForColumn：
longLongIntForColumn：
boolForColumn：
doubleForColumn：
stringForColumn：
dataForColumn：
dataNoCopyForColumn：
UTF8StringForColumnIndex：
objectForColumn：
*/
[db open];
    //0.直接sql语句
//    FMResultSet *result = [db executeQuery:@"select * from 't_student' where ID = 110"];
    //1.
//    FMResultSet *result = [db executeQuery:@"select *from 't_student' where ID = ?",@111];
    //2.
//    FMResultSet *result = [db executeQueryWithFormat:@"select * from 't_student' where ID = %d",112];
    //3.
    FMResultSet *result = [db executeQuery:@"select * from 't_student' where ID = ?" withArgumentsInArray:@[@113]];
    //4
//    FMResultSet *result = [db executeQuery:@"select * from 't_sutdent' where ID = ?" withParameterDictionary:@{@"ID":@114}];
    NSMutableArray *arr = [NSMutableArray array];
    while ([result next]) {
        PersonVO *person = [PersonVO new];
        person.ID = [result intForColumn:@"ID"];
        person.name = [result stringForColumn:@"name"];
        person.phone = [result stringForColumn:@"phone"];
        person.score = [result intForColumn:@"score"];
        [arr addObject:person];
        NSLog(@"从数据库查询到的人员 %@",person.name);
        [self showAlertWithTitle:@"query  success" message:nil person:person];

    }

5.FMDB的事务
(1) 事务定义：
事务(Transaction)是并发操作的基本单位，是指单个逻辑工作单位执行的一系列操作序列，这些操作要不都成功，要不就不成功，事务是数据库维护数据一致性的单位，在每个事务结束时，都能保证数据一致性与准确性，通常事务跟程序是两个不同的概念，一个程序中包含多个事务，事务主要解决并发条件下操作数据库，保证数据
(2) 事务特征：
原子性（Atomic）：事务中包含的一系列操作被看作一个逻辑单元，这个逻辑单元要不全部成功，要不全部失败
一致性（Consistency）：事务中包含的一系列操作，只有合法的数据被写入数据库，一些列操作失败之后，事务会滚到最初创建事务的状态
隔离性（Isolation）：对数据进行修改的多个事务之间是隔离的，每个事务是独立的，不应该以任何方式来影响其他事务
持久性（Durability）事务完成之后，事务处理的结果必须得到固化，它对于系统的影响是永久的，该修改即使出现系统固执也将一直保留，真实的修改了数据库
(3) 事务语句：

/**
 transaction:事务 开启一个事务执行多个任务，效率高
 1.fmdb 封装transaction 方法，操作简单
 - (BOOL)beginTransaction;
 - (BOOL)beginDeferredTransaction;
 - (BOOL)beginImmediateTransaction;
 - (BOOL)beginExclusiveTransaction;
 - (BOOL)commit;
 - (BOOL)rollback;
 等等
 */

开启事务 ：beginTransaction
回滚事务：rollback
提交事务：commit
(4) 事务代码
用事务处理一系列数据库操作，省时效率高

- (void)handleTransaction:(UIButton *)sender {
    NSString *documentPath = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES)[0];
    NSString *dbPath = [documentPath stringByAppendingPathComponent:@"test1.db"];
    FMDatabase *db = [[FMDatabase alloc]initWithPath:dbPath];
    [db open];
    if (![db isOpen]) {
        return;
    }
    BOOL result = [db executeUpdate:@"create table if not exists text1 (name text,age,integer,ID integer)"];
    if (result) {
        NSLog(@"create table success");
    }
    //1.开启事务
    [db beginTransaction];
    NSDate *begin = [NSDate date];
    BOOL rollBack = NO;
    @try {
       //2.在事务中执行任务
        for (int i = 0; i< 500; i++) {
            NSString *name = [NSString stringWithFormat:@"text_%d",i];
            NSInteger age = i;
            NSInteger ID = i *1000;

            BOOL result = [db executeUpdate:@"insert into text1(name,age,ID) values(:name,:age,:ID)" withParameterDictionary:@{@"name":name,@"age":[NSNumber numberWithInteger:age],@"ID":@(ID)}];
            if (result) {
                NSLog(@"在事务中insert success");
            }
        }
    }
    @catch(NSException *exception) {
        //3.在事务中执行任务失败，退回开启事务之前的状态
        rollBack = YES;
        [db rollback];
    }
    @finally {
        //4\. 在事务中执行任务成功之后
        rollBack = NO;
        [db commit];
    }
    NSDate *end = [NSDate date];
    NSTimeInterval time = [end timeIntervalSinceDate:begin];
    NSLog(@"在事务中执行插入任务 所需要的时间 = %f",time);

}

未使用事务执行一系列操作

-(void)handleNotransaction:(UIButton *)sender {
    NSString *documentPath = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES)[0];
    NSString *dbPath = [documentPath stringByAppendingPathComponent:@"test1.db"];
    FMDatabase *db = [FMDatabase databaseWithPath:dbPath];
    [db open];
    if (![db isOpen]) {
        return;
    }
    BOOL result = [db executeUpdate:@"create table if not exists text2('ID' INTEGER PRIMARY KEY AUTOINCREMENT,name TEXT,age INTRGER)"];
    if (!result) {
        [db close];
    }
    NSDate *begin = [NSDate date];
    for (int i = 0; i< 500; i++) {
        NSString *name = [NSString stringWithFormat:@"text_%d",i];
        NSInteger age = i;
        NSInteger ID = i *1000;

        BOOL result = [db executeUpdate:@"insert into text2(name,age,ID) values(:name,:age,:ID)" withParameterDictionary:@{@"name":name,@"age":[NSNumber numberWithInteger:age],@"ID":@(ID)}];
        if (result) {
            NSLog(@"不在事务中insert success");
        }
    }
    NSDate *end = [NSDate date];
    NSTimeInterval time = [end timeIntervalSinceDate:begin];
    NSLog(@"不在事务中执行插入任务 所需要的时间 = %f",time);
}

比较结果如下：
在事务中执行插入任务 所需要的时间 = 0.426221
不在事务中执行插入任务 所需要的时间 = 0.790417

  1. 附练习demo：https://github.com/sisios/fmdb_demo 
#import "QXMSqliteManager.h"

@implementation QXMSqliteManager

+ (instancetype)shareManager
{
    static QXMSqliteManager *_instance;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        _instance = [[QXMSqliteManager alloc] init];
    });
    return _instance;
}

FMDatabase *_db;
- (void)save:(id)object sqlPathDocuments:(NSString *)sqlPathDocuments tableName:(NSString *)tableName mainKey:(NSString *)key pageNum:(NSInteger)pageNum clearTable:(BOOL)clear
{
    NSString *sqlPath = [[NSString stringWithFormat:@"%@.sqlite",sqlPathDocuments] appendDocumentDir];
    _db = [FMDatabase databaseWithPath:sqlPath];
    [_db open];

    if ([_db open]) {
        NSString *KEY1 = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS %@  (%@ INTEGER NOT NULL,data BLOB NOT NULL,PRIMARY KEY (%@));", tableName, key,key];
        BOOL res = [_db executeUpdate:KEY1];
        //        BOOL res = [_db executeUpdate:@"CREATE TABLE IF NOT EXISTS t_status  (id INTEGER PRIMARY KEY AUTOINCREMENT, pageNum integer PRIMARY KEY AUTOINCREMENT,data BLOB NOT NULL);"];
        if(res){
            CKLog(@"创表执行成功");
        }else{
            CKLog(@"创表执行失败");
        }
    }else{
        return;
    }
    
    if (clear) {
        BOOL dele1 = [_db executeUpdate:[NSString stringWithFormat:@"DELETE FROM %@", tableName]];
        if(dele1){
            CKLog(@"清表成功");
        }else{
            CKLog(@"清表失败");
        }
    }
    
    if ([NSJSONSerialization isValidJSONObject:object]) {
        // 2.转换为二进制
        NSData *data = [NSJSONSerialization
                        dataWithJSONObject:object options:NSJSONWritingPrettyPrinted error:NULL];
        // 注意: 在FMDB中可以想字符串拼接一样, 利用?作为占位符. 以后在后面拼接需要的数据
        NSString *updateStr = [NSString stringWithFormat:@"insert into %@ ( data ) values (?);", tableName];
        BOOL res2 = [_db executeUpdate:updateStr, data];
        
        if(res2){
            CKLog(@"添加数据成功");
        }else{
            CKLog(@"添加数据失败");
        }
        
    } else {
        CKLog(@"转换失败");
    }
    [_db close];
}

- (id)readFMDBSqlPathDocuments:(NSString *)sqlPathDocuments tableName:(NSString *)tableName key:(NSString *)key pageNum:(int )pageNum
{
    NSString *sqlPath = [[NSString stringWithFormat:@"%@.sqlite",sqlPathDocuments] appendDocumentDir];
    _db = [FMDatabase databaseWithPath:sqlPath];
    id object;
    [_db open];
    if ([_db open]) {
        //     1.从数据库中查询数据
        FMResultSet *set = nil;
        NSString *str1 = [NSString stringWithFormat:@"SELECT * FROM %@ WHERE %@ = %d;", tableName,key,pageNum];
        set =[_db executeQuery:str1];
        //        set =[_db executeQuery:@"SELECT sum FROM t_status;"];
        while ([set next]) {
            // 1.取出存储的二进制数据
            NSData *data = [set dataForColumn:@"data"];
            // 2.将二进制转换为字典
            object = [NSJSONSerialization JSONObjectWithData:data options:NSJSONReadingMutableContainers error:NULL];
            // 3.利用框架将字典转换为模型
            //            CKLog(@"===11==%@===",object);
            return object;
        }
        
    }
    [_db close];
    return object;
}

用法

#pragma mark - 数据库缓存======================
static NSString *const QXMsqlDBName                                 = @"QXM";//数据库名称
static NSString *const QXMstartInfoMainKey                          = @"pageNum";//主键
static NSString *const QXMStartInfoTbleName_OptionalUnlogin         = @"QXMStartInfoTbleName_OptionalUnlogin";//自选未登录缓存数组表名称

#pragma mark - 缓存保存未登录资产-FMDB数据库
+ (void)saveFMDBUnloginOptionalData:(id)responseObject data:(NSDictionary*)data{
    [[QXMSqliteManager shareManager] save:responseObject sqlPathDocuments:QXMsqlDBName tableName:QXMStartInfoTbleName_OptionalUnlogin mainKey:QXMstartInfoMainKey pageNum:1 clearTable:YES];
}
#pragma mark - 读取存未登录资产-FMDB数据库
+ (NSArray *)readFMDBUnloginOptionalData:(id)responseObject data:(NSDictionary*)data{
    return [[QXMSqliteManager shareManager] readFMDBSqlPathDocuments:QXMsqlDBName tableName:QXMStartInfoTbleName_OptionalUnlogin key:QXMstartInfoMainKey pageNum:1];
}

https://www.jianshu.com/p/8b469f9c9ad3
https://www.jianshu.com/p/7ac1c6eb63ed

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 202,009评论 5赞 474
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 84,808评论 2赞 378
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 148,891评论 0赞 335
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,283评论 1赞 272
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,285评论 5赞 363
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,409评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,809评论 3赞 393
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,487评论 0赞 256
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,680评论 1赞 295
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,499评论 2赞 318
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,548评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,268评论 4赞 318
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,815评论 3赞 304
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,872评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,102评论 1赞 258
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,683评论 2赞 348
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,253评论 2赞 341