闲了好久，不知道写点什么，把最近使用FMDB的过程写一下吧！

1. 建立DBManager

建立单例来管理数据库的创建，开启，及增删改查操作。

2. 初始化DataBase，table

使用类属性创建DataBase及DbQueue

@property (nonatomic, class, readonly) FMDatabase *sharedDataBase;
@property (nonatomic, class, readonly) FMDatabaseQueue *dbQueue;

实现方法

+ (FMDatabase *)sharedDataBase {
    static FMDatabase *accountDB = nil;
    @synchronized (self) {
        if (accountDB == nil) {
            NSString *dbPath = [NSHomeDirectory() stringByAppendingFormat:@"/%@",[AccountModel qw_getLocalModel].USERID];
            accountDB = [FMDatabase databaseWithPath:dbPath];
            if ([accountDB open]) {
                DebugLog(@"Database open succeed");
            }else{
                DebugLog(@"Database open failed");
            }
        }
    }
    return accountDB;
}
// 因为FMDB并不是线程安全的，所以建立dbQueue来进行线程操作
static FMDatabaseQueue *_dbQueue = nil;
+ (FMDatabaseQueue *)dbQueue {
    if (_dbQueue == nil) {
        // dbPath和db的path相同，需要先建立数据库，才能够成功创建dbQueue；
        NSString *dbPath = [NSHomeDirectory() stringByAppendingFormat:@"/%@",[AccountModel qw_getLocalModel].USERID];
        _dbQueue = [FMDatabaseQueue databaseQueueWithPath:dbPath];
    }
    return _dbQueue;
}

创建table，根据保存model的类名来创建不同的table

+ (BOOL)createTabelOfClass:(Class)tableClass {
    NSString *excuteStr = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS %@(id, content)", NSStringFromClass(tableClass)];
    return [[QWDBManager sharedDataBase] executeStatements:excuteStr];
}

3. 建立Catch

建立一个保存model id的数组，用来查询数据库中是否存在该model，减少内存的消耗

@property (nonatomic, strong) NSMutableArray *catchIds;

4. 数据存储，更新

向table中增加model(非线程安全的）

+ (BOOL)addNewModel:(PostModel *)model {
    NSString *addStr = [NSString stringWithFormat:@"INSERT INTO %@ VALUES(?,?)",NSStringFromClass(model.class)];
    BOOL ret = [[QWDBManager sharedDataBase] executeUpdate:addStr, [NSString stringWithFormat:@"%ld", (long)model.PostID], [model qw_dataOfModel]];
    if(ret){
        DebugLog(@"Add model succeed");
    }else{
        DebugLog(@"Add model failed");
    }
    return ret;
}

查询table中是否存在model（非线程安全）第三部分catch的存在就是为了替换掉这个操作，如果有删除model的需要，可以在查询完成后进行删除操作。

+ (BOOL)checkContainModel:(PostModel *)model {
    NSString *checkStr = [NSString stringWithFormat:@"SELECT id FROM %@ WHERE id = ?",NSStringFromClass(model.class)];
    FMResultSet *resultSet = [[QWDBManager sharedDataBase] executeQuery:checkStr, [NSString stringWithFormat:@"%ld",(long)model.PostID]];
    BOOL ret = [resultSet next];
    [resultSet close];
    return ret;
}

更新model内容（非线程安全）

+ (BOOL)updateModel:(PostModel *)model {
    BOOL check = [QWDBManager checkContainModel:model];
    if (check) {
        NSString *updateStr = [NSString stringWithFormat:@"UPDATE %@ SET content = ? WHERE id = %ld",NSStringFromClass(model.class), (long)model.PostID];
        BOOL ret = [[QWDBManager sharedDataBase] executeUpdate:updateStr, [model qw_dataOfModel]];
        ret ? DebugLog(@"Update succeed") : DebugLog(@"Update failed");
        return ret;
    }
    return [QWDBManager addNewModel:model];
}

** 实际项目中model一般都是网络请求到的数据转换而来的，所以涉及到线程操作，而上面这部分操作都不是线程安全的，所以推荐使用下面的这些方法。**

// 更新model的数组
+ (void)async_updateModels:(NSArray *)models {
    [QWDBManager.dbQueue inDatabase:^(FMDatabase *db) {
        [models enumerateObjectsUsingBlock:^(PostModel *obj, NSUInteger idx, BOOL * _Nonnull stop) {
            // 检查catch数组中是否存在model id
            if ([[QWDBManager shareInstance].catchIds containsObject:@(obj.PostID)]) {
                [QWDBManager updateModel:obj inDb:db];
            }else{
                if ([QWDBManager addModels:obj toBb:db]) [[QWDBManager shareInstance].catchIds addObject:@(obj.PostID)]; // 不存在时，将model id 添加到缓存中
            }
            if (stop) {
                // 更新缓存数据
                [[NSUserDefaults standardUserDefaults] setObject:[QWDBManager shareInstance].catchIds forKey:@"CatchModelIdsKey"];
            }
        }];
    }];
}

+ (BOOL)updateModel:(PostModel *)model inDb:(FMDatabase *)db {
    NSString *updateStr = [NSString stringWithFormat:@"UPDATE %@ SET content = ? WHERE id = %ld",NSStringFromClass(model.class), (long)model.PostID];
    BOOL ret = [db executeUpdate:updateStr, [model qw_dataOfModel]];
    if (ret) {
        DebugLog(@"Update model:%ld succeed", (long)model.PostID);
    }else{
        DebugLog(@"Update model:%ld failed", (long)model.PostID);
    }
    return ret;
}

+ (BOOL)addModels:(PostModel *)model toBb:(FMDatabase *)db {
    NSString *addStr = [NSString stringWithFormat:@"INSERT INTO %@ VALUES(?,?)",NSStringFromClass(model.class)];
    BOOL ret = [db executeUpdate:addStr, [NSString stringWithFormat:@"%ld", (long)model.PostID], [model qw_dataOfModel]];
    if (ret) {
        DebugLog(@"Add model:%ld succeed", (long)model.PostID);
    }else{
        DebugLog(@"Add model:%ld failed", (long)model.PostID);
    }
    return ret;
}

恩！大致就这样，最后贴个demo地址：QWPapapa , ** 有问题留言**。