FMDB封装

一些FMDB封装框架功能比较多,代码量也比较大,但是很多功能不常用,因而自行封装一个适用于手头项目的轻量级小框架。
因为项目需要在多线程下操作数据库,所以只基于FMDatabaseQueue进行了封装。

https://github.com/huixinHu/HXDB

  • FMDB简单二次封装
  • 线程安全
  • 支持事务操作
  • 支持模型存储,但不支持集合类型、自定义类类型属性等等。(支持NSString、NSNumber、NSInteger 、BOOL、int、float、 double、NSData等简单类型属性)

1.数据库的创建

+ (instancetype)shareDB;

+ (instancetype)shareDB:(NSString *)dbName;

+ (instancetype)shareDB:(NSString *)dbName dbPath:(NSString *)dbpath;

三个单例方法,dbName为数据库名,参数如果为nil,那么就会创建一个名为XiaoYa.sqlite的数据库文件;如果 dbpath 为子路径名,若参数为nil,那么就默认在NSDocumentDirectory下创建数据库文件。如使用shareDB方法创建,则默认在NSDocumentDirectory下创建XiaoYa.sqlite。
使用这三个方法中任意一个创建数据库,之后再使用三个方法中任意一个都会会的同一个实例。

@property (nonatomic ,strong) HXDBManager *hxdb;

self.hxdb = [HXDBManager shareDB];
self.hxdb = [HXDBManager shareDB:@"HXDB.sqlite"];
//在hxDataBasePath/hxDataBasePath路径下创建HXDB.sqlite
self.hxdb = [HXDBManager shareDB:@"HXDB.sqlite" dbPath:@"hxDataBasePath"];

2.切换数据库

考虑到有用户退出登录、切换到另一个用户账号的情况,每一个用户需要单独一份数据,所以需要切换数据库。

- (void)changeFilePath:(NSString *)path dbName:(NSString *)dbName;

path参数是文件子路径,dbName是数据库名。

[self.hxdb changeFilePath:[Utils HXNSStringMD5:appDelegate.userid] dbName:@"XiaoYa.sqlite"];

3.创建表

方式1:根据sql语句创建表

/**
根据sql语句创建表

 @param sql SQL语句
 @param tableName 表名
 @return 创建表是否成功
 */
- (BOOL)tableCreate:(NSString *)sql table:(NSString *)tableName;
[self.hxdb tableCreate:@"CREATE TABLE IF NOT EXISTS memberGroupRelation (memberId TEXT,groupId TEXT, FOREIGN KEY(groupId) REFERENCES groupTable(groupId) ON DELETE CASCADE);" table:@"memberGroupRelation"];

方式2:根据字典创建表
字典key:字段名,字典value:字段类型。可以指定主键字段名,如果不需要主键 pk 参数传入nil即可。

/**
 根据字典创建表

 @param tableName 表名
 @param dict 字典,key 字段名、value 字段类型
 @param pk 主键,可为nil
 @return 是否成功
 */
- (BOOL)createTable:(NSString *)tableName colDict:(NSDictionary *)dict primaryKey:(NSString *)pk;
[self.hxdb createTable:groupTable colDict:@{@"groupId":@"TEXT",@"groupName":@"TEXT",@"groupAvatarId":@"TEXT",@"numberOfMember":@"TEXT",@"groupManagerId":@"TEXT",@"deleteFlag":@"INTEGER"} primaryKey:@"groupId"];

方式3:根据模型创建表,字段名就是对应模型的属性名

/**
 根据模型类创建表

 @param tableName 表名
 @param cls 模型类
 @param pk 主键,可为nil
 @param colArr 模型中不需要作为表字段的属性
 @return 创建表是否成功
 */
- (BOOL)createTable:(NSString *)tableName modelClass:(Class)cls primaryKey:(NSString *)pk excludeProperty:(NSArray *)colArr;
模型类:
@interface Person : NSObject
@property (nonatomic, copy) NSString *name;
@property (nonatomic, strong) NSNumber *phone;
@property (nonatomic, strong) NSData *userData;
@property (nonatomic, assign) NSInteger identity;
@property (nonatomic, assign) BOOL sex;
@property (nonatomic, assign) int age;
@property (nonatomic, assign) float height;  //可能会丢失精度
@property (nonatomic, assign) double weight;

@property (nonatomic, strong)NSDictionary *testDic;

@end

创建表:
 [self.hxdb createTable:@"modelTable" modelClass:NSClassFromString(@"Person") primaryKey:@"identity" excludeProperty:nil];

要注意,NSDictionary这种集合类型的属性不会作为表字段,除此之外还有NSArray、NSSet等集合类型。

4.删除表

/**
 删除表

 @param tableName 表名
 @param block 删除失败回调
 */
- (void)dropTable:(NSString *)tableName callback:(void(^)(NSError *error ))block;
[self.hxdb dropTable:@"modelTable" callback:^(NSError *error) {
        NSLog(@"error");
    }];

5.0增删改数据

直接传入sql语句进行增删查改

/**
 直接传入sql语句进行增删查改

 @param sql SQL语句
 @param block 回调
 */
- (void)updateWithSqlStat:(NSString *)sql callback:(void(^)(NSError *error ))block;
//批量版本
- (void)updateWithSqlStatInTransaction:(NSArray <NSString *> *)sqlArr callback:(void(^)(NSError *error))block;

5.1插入数据

1.插入单个模型

/**
 插入单个模型

 @param tableName 表名
 @param model 模型对象
 @param colArr 模型中不需要插入到表的属性名集合
 @param block 回调
 */
- (void)insertTable:(NSString *)tableName model:(id)model excludeProperty:(NSArray *)colArr callback:(void(^)(NSError *error ))block;
Person *person = [[Person alloc] init];
    person.name = @"PersonName";
    person.phone = @(12345667890);
    person.userData = [@"testData" dataUsingEncoding:NSUTF8StringEncoding];
    person.identity = 60;
    person.sex = 1;
    person.age = 23;
    person.height = 170.1;
    person.weight = 233.33333;
    person.testDic = [NSDictionary dictionary];
//插入一个模型对象的数据,其中weight和height属性不需要被插入
    [self.hxdb insertTable:@"modelTable" model:person excludeProperty:@[@"height",@"weight"] callback:^(NSError *error) {
        NSLog(@"%@",error);
    }];

2.批量插入模型

/**
 批量插入模型

  @param tableName 表名
 @param modelArr 模型对象数组
 @param colArr 一一对应模型对象数组中的每一元素,模型对象中不需要插入到表的属性名集合。需要程序员自行管理一一对应的关系,如果某模型对象没有要剔除的属性,则对应的excludeArr为空数组即可;如果所有模型对象都不需要剔除某些属性,则excludeProperty传入nil即可。
 @param block (失败)回调
 */
- (void)insertTableInTransaction:(NSString *)tableName modelArr:(NSArray <id>*)modelArr excludeProperty:(NSArray <NSArray *>*)colArr callback:(void(^)(NSError *error ))block;
    //一组数据
    NSMutableArray *testModelArr = [NSMutableArray arrayWithCapacity:0];
//所有待插入模型对象中不需要插入到表的属性名集合
    NSMutableArray *exclude = [NSMutableArray arrayWithCapacity:0];
    for (int i = 0; i < 3; i++) {
        Person *person = [[Person alloc] init];
        person.name = @"PersonName";
        person.phone = @(12345667890);
        person.userData = [@"testData" dataUsingEncoding:NSUTF8StringEncoding];
        person.identity = arc4random() % 1000;
        person.sex = 1;
        person.age = 23;
        person.height = 170.1;
        person.weight = 233.33333;
        person.testDic = [NSDictionary dictionary];
        
        [testModelArr addObject:person];
        
        [exclude addObject:@[@"height",@"weight"]];
    }
    [self.hxdb insertTableInTransaction:@"modelTable" modelArr:testModelArr excludeProperty:exclude callback:^(NSError *error) {
        NSLog(@"%@",error);;
    }];

关于excludeProperty:需要程序员自行管理一一对应的关系,如果某模型对象没有要剔除的属性,则对应的excludeArr为空数组即可,比如[exclude addObject:@[]];;如果所有模型对象都不需要剔除某些属性,则excludeProperty传入nil即可。

3.插入单条记录

/**
 插入单条记录

 @param tableName 表名
 @param paraDict 待插入数据。字典key:字段名,value:字段值
 @param block 回调
 */
- (void)insertTable:(NSString *)tableName param:(NSDictionary *)paraDict callback:(void(^)(NSError *error ))block;
NSDictionary *paraDict = @{@"name":@"commet",@"phone":@"13535230987",@"identity":@"999"};
    
    [self.hxdb insertTable:@"modelTable" param:paraDict callback:^(NSError *error) {
        if(error) NSLog(@"插入表失败:%@",error);
    }];

4.批量插入记录

/**
 批量插入记录

 @param tableName 表名
 @param paraArr 待插入数据数组。数组每个元素是字典,字典构成同上。
 @param block 回调
 */
- (void)insertTableInTransaction:(NSString *)tableName paramArr:(NSArray <NSDictionary *>*)paraArr callback:(void(^)(NSError *error))block;

5.2更新数据

1.更新指定模型数据

/**
 更新单个模型

 @param tableName 表名
 @param model 模型对象
 @param colArr 模型中不需要更新的属性名集合
 @param where where子句字典。key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 */
- (void)updateTable:(NSString *)tableName model:(id)model excludeProperty:(NSArray *)colArr whereDict:(NSDictionary *)where callback:(void(^)(NSError *error ))block;

根据模型对象更新数据,其中name、userData、identity、age属性不需要更新。如果where传入nil,则对每条记录都进行更新。

//根据模型对象更新数据,其中name、userData、identity、age属性不需要更新
[self.hxdb updateTable:@"modelTable" model:person excludeProperty:@[@"name",@"userData",@"identity",@"age"] whereDict:@{@"where identity = ?" : @[@60]} callback:^(NSError *error) {
        NSLog(@"%@",error);
    }];

2.批量更新模型数据

/**
 批量更新模型

 @param tableName 表名
 @param modelArr 模型对象集合
 @param colArr 一一对应模型对象数组中的每一元素,模型对象中不需要更新的属性名集合
 @param whereArr where子句字典的集合。where子句字典 -- key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 */
- (void)updateTableInTransaction:(NSString *)tableName modelArr:(NSArray <id>*)modelArr excludeProperty:(NSArray <NSArray *>*)colArr whereArrs:(NSArray<NSDictionary *> *)whereArr callback:(void (^)(NSError *))block;

要注意此处where子句(字典)必须和模型一一对应且必须不能为空。由于这个方法是对同一个表进行批量更新,如果有其中一个没有where子句(就会更新整表),那么批量更新就没意义了

    NSMutableArray *testModelArr = [NSMutableArray arrayWithCapacity:0];
    NSMutableArray *exclude = [NSMutableArray arrayWithCapacity:0];
    NSMutableArray *whereArr = [NSMutableArray arrayWithCapacity:0];
    for (int i = 0; i < 3; i++) {
        Person *person = [[Person alloc] init];
        person.name = @"PersonName";
        person.phone = @(11111111);
        person.userData = [@"testData" dataUsingEncoding:NSUTF8StringEncoding];
        person.identity = i+1;
        person.sex = 0;
        person.age = 24;
        person.height = 170.1;
        person.weight = 233.33333;
        person.testDic = [NSDictionary dictionary];

        [testModelArr addObject:person];

        [exclude addObject:@[@"height",@"weight"]];
        [whereArr addObject:@{@"where identity = ?" : @[[NSNumber numberWithInteger:person.identity]]}];
    }

    //批量更新模型
    [self.hxdb updateTableInTransaction:@"modelTable" modelArr:testModelArr excludeProperty:exclude whereArrs:whereArr callback:^(NSError *error) {
        NSLog(@"%@",error);
    }];

3.更新单个记录

/**
 更新单个记录

 @param tableName 表名
 @param paraDict 待更新数据。字典key:字段名,value:字段值
 @param where where子句字典。key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 */
- (void)updateTable:(NSString *)tableName param:(NSDictionary *)paraDict whereDict:(NSDictionary *)where callback:(void(^)(NSError *error ))block;
//更新单个记录
    NSDictionary *paraDict = @{@"name":@"commet",@"phone":@"13535230987"};
    
    [self.hxdb updateTable:@"modelTable" param:paraDict whereDict:@{@"where identity = ?" : @[@1]} callback:^(NSError *error) {
        if(error) NSLog(@"%@",error);
    }];

4.批量更新记录

/**
 批量更新记录

 @param tableName 表名
 @param paraArr 待更新数据集合。数组每个元素是字典,字典构成同上
 @param whereArr where子句字典的集合。where子句字典 -- key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 */
- (void)updateTableInTransaction:(NSString *)tableName paramArr:(NSArray <NSDictionary *>*)paraArr whereArrs:(NSArray <NSDictionary *>*)whereArr callback:(void(^)(NSError *error))block;

5.3删除数据

1.删除指定数据

/**
 删除单条件记录

 @param tableName 表名
 @param where where子句字典。key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 */
- (void)deleteTable:(NSString *)tableName whereDict:(NSDictionary *)where callback:(void(^)(NSError *error))block;

如果where为空就删除整表数据

[self.hxdb deleteTable:@"modelTable" whereDict:@{@"where age = ?" : @[@24]} callback:^(NSError *error) {
        if(error) NSLog(@"%@",error);
    }];

2.批量删除数据

/**
 批量删除不同条件的记录

 @param tableName 表名
 @param whereArrs where子句字典的集合。where子句字典 -- key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 */
- (void)deleteTableInTransaction:(NSString *)tableName whereArrs:(NSArray <NSDictionary *>*)whereArrs callback:(void(^)(NSError *error))block;
    //批量删除
    NSMutableArray *deleteWhere = [NSMutableArray array];
    [deleteWhere addObject:@{@"where sex = ?" : @[@0]}];
    [deleteWhere addObject:@{@"where sex = ? and name = ?":@[@1,@"commet"]}];
    [deleteWhere addObject:@{@"where phone = ?" : @[@"305757732"]}];
    [self.hxdb deleteTableInTransaction:@"modelTable" whereArrs:deleteWhere callback:^(NSError *error) {
        
    }];

6.查询

1.根据条件查询有多少条记录

/**
 根据条件查询有多少条记录

 @param tableName 表名
 @param where where子句字典。key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @return 记录数目
 */
- (int)itemCountForTable:(NSString *)tableName whereDict:(NSDictionary *)where;
    int count = [self.hxdb itemCountForTable:@"modelTable" whereDict:@{@"where sex = ?" : @[@1]}];
    NSLog(@"count = %d",count);

2.根据模型类查询

/**
 根据条件查询模型

 @param tableName 表名
 @param cls 模型类
 @param colArr 模型中不需要被查询的属性名集合
 @param where where子句字典。key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 @return 查询结果
 */
- (NSMutableArray *)queryTable:(NSString *)tableName modelClass:(Class)cls excludeProperty:(NSArray *)colArr whereDict:(NSDictionary *)where callback:(void(^)(NSError *error))block;
    NSMutableArray *rsArr = [self.hxdb queryTable:@"modelTable" modelClass:NSClassFromString(@"Person") excludeProperty:nil whereDict:nil callback:^(NSError *error) {
        
    }];
    NSLog(@"rs:%@",rsArr);

3.根据条件查询

/**
 根据条件查询

 @param tableName 表名
 @param columnDict 查询字段。字典:key 字段名,value 字段对应的sql数据类型
 @param where where子句字典。key:where子句遵循绑定语法,value:绑定值数组。比如“where name = 'John' AND age = '17'” -> @{@"WHERE name = ? AND age = ?":@[@"John",@"17"]}。要保证where字典有且仅有一组key-value
 @param block 回调
 @return 查询结果
 */
- (NSMutableArray *)queryTable:(NSString *)tableName columns:(NSDictionary *)columnDict whereDict:(NSDictionary *)where callback:(void(^)(NSError *error))block;
  1. 查询整表
/**
 查询整表

 @param tableName 表名
 @param block 回调
 @return 查询结果
 */
- (NSMutableArray *)queryAll:(NSString *)tableName callback:(void(^)(NSError *error))block;

其他

一般为了防止ui卡死,把数据库操作放在异步线程。比如:

dispatch_async(dispatch_get_global_queue(0, 0), ^{
        NSMutableArray *rsArr = [self.hxdb queryTable:@"modelTable" modelClass:NSClassFromString(@"Person") excludeProperty:nil whereDict:nil callback:^(NSError *error) {
            
        }];
        NSLog(@"rs:%@",rsArr);
    });

github地址:https://github.com/huixinHu/HXDB

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,884评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,347评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,435评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,509评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,611评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,837评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,987评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,730评论 0 267
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,194评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,525评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,664评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,334评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,944评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,764评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,997评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,389评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,554评论 2 349

推荐阅读更多精彩内容