上一篇文章我们学习了使用SQL函数进行SQL的增删改查，但是这些函数都是C语言的，用起来比较麻烦，为了解决这些问题就有了FMDB。

一. FMDB简介

1. 什么是FMDB

FMDB是iOS平台的SQLite数据库框架
FMDB以OC的方式封装了SQLite的C语言API

2. FMDB的优点

使用起来更加面向对象，省去了很多麻烦、冗余的C语言代码
对比苹果自带的Core Data框架，更加轻量级和灵活
提供了多线程安全的数据库操作方法，有效地防止数据混乱

3. FMDB核心类

FMDB有三个主要的类

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

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

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

二. FMDB的使用

1. FMDB常用方法

① 通过指定SQLite数据库文件路径来创建FMDatabase对象

FMDatabase *db = [FMDatabase databaseWithPath:path];
if (![db open]) {
    NSLog(@"数据库打开失败！");
}

文件路径有三种情况:
（1）具体文件路径
　　如果不存在会自动创建
（2）空字符串@""
　　会在临时目录创建一个空的数据库
　　当FMDatabase连接关闭时，数据库文件也被删除
（3）nil
　　会创建一个内存中临时数据库，当FMDatabase连接关闭时， 数据库会被销毁

② 使用executeUpdate:方法执行更新

在FMDB中，除查询以外的所有操作，都称为“更新”
create、drop、insert、update、delete等

- (BOOL)executeUpdate:(NSString*)sql, ...
- (BOOL)executeUpdateWithFormat:(NSString*)format, ...
- (BOOL)executeUpdate:(NSString*)sql withArgumentsInArray:(NSArray *)arguments

示例:

[db executeUpdate:@"UPDATE t_student SET age = ? WHERE name = ?;", @20, @"Jack"]

③ 使用executeQuery:方法执行查询

查询方法

- (FMResultSet *)executeQuery:(NSString*)sql, ...
- (FMResultSet *)executeQueryWithFormat:(NSString*)format, ...
- (FMResultSet *)executeQuery:(NSString *)sql withArgumentsInArray:(NSArray *)arguments

示例:

// 查询数据
FMResultSet *rs = [db executeQuery:@"SELECT * FROM t_student"];
 
//遍历结果集:
while ([rs next]) {
    NSString *name = [rs stringForColumn:@"name"];
    int age = [rs intForColumn:@"age"];
    double score = [rs doubleForColumn:@"score"];
}

2. FMDB简单使用

创建一个新项目，导入fmdb，在ViewController写如下代码：

#import "ViewController.h"
#import "FMDB.h"

@interface ViewController ()

@property(nonatomic,strong)FMDatabase *db;

@end

@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    
     //1.获得数据库文件的路径
     NSString *doc=[NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) lastObject];
     NSString *fileName=[doc stringByAppendingPathComponent:@"student.sqlite"];

    NSLog(@"%@",fileName);
     //2.获得数据库
     FMDatabase *db=[FMDatabase databaseWithPath:fileName];

     //3.打开数据库
     if ([db open]) {
         //4.创表
         BOOL result=[db executeUpdate:@"CREATE TABLE IF NOT EXISTS t_student (id integer PRIMARY KEY AUTOINCREMENT, name text NOT NULL, age integer NOT NULL);"];
         if (result) {
             NSLog(@"创表成功");
         }else {
             NSLog(@"创表失败");
         }
     }
     self.db=db;
}

-(void)touchesBegan:(NSSet *)touches withEvent:(UIEvent *)event {
    [self insert];
    //[self query];
    //[self delete];
}

//插入数据
-(void)insert {
    for (int i = 0; i<10; i++) {
        NSString *name = [NSString stringWithFormat:@"jack-%d", arc4random_uniform(100)];
        // executeUpdate : 不确定的参数用?来占位
        BOOL isSucess = [self.db executeUpdate:@"INSERT INTO t_student (name, age) VALUES (?, ?);", name, @(arc4random_uniform(40))];
        if (isSucess) {
            NSLog(@"插入成功");
        } else {
            NSLog(@"插入失败");
        }
        //[self.db executeUpdate:@"INSERT INTO t_student (name, age) VALUES (?, ?);" withArgumentsInArray:@[name, @(arc4random_uniform(40))]];

        //executeUpdateWithFormat : 不确定的参数用%@、%d等来占位
        //[self.db executeUpdateWithFormat:@"INSERT INTO t_student (name, age) VALUES (%@, %d);", name, arc4random_uniform(40)];
    }
}

//删除数据
-(void)delete {
    //[self.db executeUpdate:@"DELETE FROM t_student;"];
    [self.db executeUpdate:@"DROP TABLE IF EXISTS t_student;"];
    //[self.db executeUpdate:@"CREATE TABLE IF NOT EXISTS t_student (id integer PRIMARY KEY AUTOINCREMENT, name text NOT NULL, age integer NOT NULL);"];
}

//查询
- (void)query {
    // 1.执行查询语句
    FMResultSet *resultSet = [self.db executeQuery:@"SELECT * FROM t_student"];

    // 2.遍历结果
    while ([resultSet next]) {
        int ID = [resultSet intForColumn:@"id"];
        NSString *name = [resultSet stringForColumn:@"name"];
        int age = [resultSet intForColumn:@"age"];
        NSLog(@"%d %@ %d", ID, name, age);
    }
}
@end

执行插入操作，然后进入沙盒，使用Navicat打开student.sqlite文件，结果如下 插.png

执行查找操作，打印如下：

2019-11-06 17:07:43.172373+0800 FMDB的使用[98432:8262621] 创表成功
2019-11-06 17:07:45.684209+0800 FMDB的使用[98432:8262621] 1 jack-78 17
2019-11-06 17:07:45.684371+0800 FMDB的使用[98432:8262621] 2 jack-54 10
2019-11-06 17:07:45.684463+0800 FMDB的使用[98432:8262621] 3 jack-39 1
2019-11-06 17:07:45.684532+0800 FMDB的使用[98432:8262621] 4 jack-62 34
2019-11-06 17:07:45.684588+0800 FMDB的使用[98432:8262621] 5 jack-83 28
2019-11-06 17:07:45.684758+0800 FMDB的使用[98432:8262621] 6 jack-18 22
2019-11-06 17:07:45.685209+0800 FMDB的使用[98432:8262621] 7 jack-83 27

执行删除操作，在Navicat里重新关闭和打开数据库，发现t_student表已经被删除，如下： 删除.png

提示：如果ID设置为逐渐，且设置为自动增长的话，那么把表中的数据删除后，重新插入新的数据，ID的编号不是从0开始，而是接着之前的ID进行编号。

三. FMDatabaseQueue的使用

代码如下：

#import "FMDatabaseQueueController.h"
#import "FMDB.h"

@interface FMDatabaseQueueController ()

@property(nonatomic,strong)FMDatabaseQueue *queue;

@end

@implementation FMDatabaseQueueController

- (void)viewDidLoad {
    [super viewDidLoad];
    self.title = @"FMDB数据库队列";
    
    //1.获得数据库文件的路径
    NSString *doc=[NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES) lastObject];
    NSString *fileName=[doc stringByAppendingPathComponent:@"person.sqlite"];
    //2.获得数据库队列
    FMDatabaseQueue *queue=[FMDatabaseQueue databaseQueueWithPath:fileName];
//    FMDatabase *db=[FMDatabase databaseWithPath:fileName];

    //3.打开数据库
    [queue inDatabase:^(FMDatabase *db) {
         BOOL result=[db executeUpdate:@"CREATE TABLE IF NOT EXISTS t_person (id integer PRIMARY KEY AUTOINCREMENT, name text NOT NULL, age integer NOT NULL);"];
        if (result) {
            NSLog(@"创表成功");
        }else
        {
            NSLog(@"创表失败");
        }
    }];
    self.queue=queue;
}

-(void)touchesBegan:(NSSet *)touches withEvent:(UIEvent *)event
{
    //1. 插入数据
    //[self insertData];

    //2. 查询数据
    [self searchData];
}

- (void)insertData {
    [self.queue inDatabase:^(FMDatabase *db) {
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @22];
    }];
}

- (void)searchData {
    [self.queue inDatabase:^(FMDatabase *db) {
        // 1.执行查询语句
        FMResultSet *resultSet = [db executeQuery:@"SELECT * FROM t_person"];
        
        // 2.遍历结果
        while ([resultSet next]) {
            int ID = [resultSet intForColumn:@"id"];
            NSString *name = [resultSet stringForColumn:@"name"];
            int age = [resultSet intForColumn:@"age"];
            NSLog(@"%d %@ %d", ID, name, age);
        }
    }];
}
@end

先插入数据，之后查询结果，打印如下：

2019-11-07 09:09:44.397073+0800 FMDB的使用[99905:8369950] 创表成功
2019-11-07 09:09:46.897357+0800 FMDB的使用[99905:8369950] 1 wendingding 22

FMDatabaseQueue，它内部已经有一个数据库对象，且数据库的操作是线程安全的。

@interface FMDatabaseQueue () {
    dispatch_queue_t    _queue;
    FMDatabase          *_db;
}

补充：事务

没有事务的话会出现问题。

举例，转账的例子： 转账.png

update t_account set money = 500 where name = '张三';
update t_account set money = 1500 where name = '李四';

张三和李四账户都有1000块钱，如果张三要转账给李四500，需要执行上面两条SQL语句，考虑到安全性，要求这两条语句要么全部执行成功，要不全部执行失败。

事务：把多条语句放到同一个事务中，要么全部成功，要不全部失败（如果中途出现问题，那么会自动回滚），事务的执行具有原子性。

- (void)shiwu1 {
    //插入数据
     [self.queue inDatabase:^(FMDatabase *db) {
         [db beginTransaction];
         [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @22];
         [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @23];
         [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @24];
         [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @25];
         [db commit];
     }];
    //如果中途出现问题，那么会自动回滚，也可以选择手动回滚。
}

- (void)shiwu2 {
    //插入数据
     [self.queue inDatabase:^(FMDatabase *db) {
        [db beginTransaction];
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @22];
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @23];
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @24];
        [db rollback];
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @25];
        [db commit];
    }];
    //上面的代码。前三条插入语句是作废的
}

- (void)siwu3 {
[self.queue inTransaction:^(FMDatabase *db, BOOL *rollback) {
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @22];
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @23];
        [db executeUpdate:@"INSERT INTO t_person (name, age) VALUES (?, ?);",@"wendingding", @24];
    }];
    //说明：先开事务，再开始事务，之后执行block中的代码段，最后提交事务。
}

Demo地址：FMDB的使用