iOS下FMDB的多线程操作（一）

2024-06-13 06:32
文章标签 操作 多线程 ios fmdb

本文主要是介绍iOS下FMDB的多线程操作（一），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

iOS中一些时间比较长的操作都应该放在子线程中，以避免UI的卡顿。而sqlite 是非线程安全的，故在多线程中不能共用同一个数据库连接，否则会导致EXC_BAD_ACCESS。所以我们可以在子线程中创建一个新的db连接（新建一个db对象），然后再操作数据库。

如果选择FMDB，除了以上所说的方式外，还可以利用FMDatabaseQueue来解决多线程问题。

关于FMDB的使用网上教程比较多，内容基本都是与唐巧的这篇http://www.devtang.com/blog/2012/04/22/use-fmdb/差不多

这里记录一下多线程下的使用。

方式一：采用每次新建db的方式

db路径我是写了一个方法

+ (NSString *)getDBPath
{NSString* docsdir = [NSSearchPathForDirectoriesInDomains( NSDocumentDirectory, NSUserDomainMask, YES) lastObject];NSFileManager *filemanage = [NSFileManager defaultManager];docsdir = [docsdir stringByAppendingPathComponent:@"FMDBDemo"];BOOL isDir;BOOL exit =[filemanage fileExistsAtPath:docsdir isDirectory:&isDir];if (!exit || !isDir) {[filemanage createDirectoryAtPath:docsdir withIntermediateDirectories:YES attributes:nil error:nil];}NSString *dbpath = [docsdir stringByAppendingPathComponent:@"myDB.sqlite"];return dbpath;
}

1、创建数据库表

/** 创建表 */
+ (BOOL)createUserTableByDB
{FMDatabase *db = [FMDatabase databaseWithPath:[self getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return NO;}NSString *sql = @"CREATE TABLE IF NOT EXISTS User(ID INTEGER PRIMARY KEY, name TEXT, age INTEGER, ID_No TEXT);";BOOL res = [db executeUpdate:sql];if (res) {NSLog(@"创建表格成功");}else {NSLog(@"创建表格失败");}return res;
}
2、插入数据

插入数据，我分了两种情形，一种是单条插入，一种是利用事务（利用事务插入多条时，时间会快很多，而且有任何一条插入失败，则不会提交到数据库）

/** 保存单个对象 */
- (BOOL)saveByDB
{FMDatabase *db = [FMDatabase databaseWithPath:[User getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return NO;}NSString *sql = [NSString stringWithFormat:@"INSERT INTO User(name, age, ID_No) VALUES ('%@', '%d', '%@');", self.name, self.age, self.ID_no];BOOL res = [db executeUpdate:sql];[db close];if (res) {NSLog(@"插入数据成功");}else {NSLog(@"插入数据失败");}return res;
}/** 批量保存用户对象 */
+ (BOOL)saveObjectsByDB:(NSArray *)array
{FMDatabase *db = [FMDatabase databaseWithPath:[self getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return NO;}[db beginTransaction];BOOL isRollBack = NO;@try {for (User *user in array) {NSString *sql = [NSString stringWithFormat:@"INSERT INTO User(name, age, ID_No) VALUES ('%@', '%d', '%@');", user.name, user.age, user.ID_no];BOOL res = [db executeUpdate:sql];if (!res) {NSLog(@"db事务插入失败");}else {NSLog(@"db事务插入成功");}}}@catch (NSException *exception) {isRollBack = YES;[db rollback];}@finally {if (!isRollBack) {[db commit];}}[db close];return !isRollBack;
}

更新与删除也分两种情形，与插入类似。

3、更新数据

/** 更新单个对象 */
- (BOOL)updateByDB
{FMDatabase *db = [FMDatabase databaseWithPath:[User getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return NO;}NSString *sql = [NSString stringWithFormat:@"UPDATE User SET name = '%@',age = '%d',ID_no = '%@' WHERE ID = '%d';", self.name, self.age, self.ID_no, self.ID];BOOL res = [db executeUpdate:sql];[db close];if (res) {NSLog(@"插入数据成功");}else {NSLog(@"插入数据失败");}return res;
}/** 批量更新用户对象*/
+ (BOOL)updateObjectsByDB:(NSArray *)array
{FMDatabase *db = [FMDatabase databaseWithPath:[User getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return NO;}[db beginTransaction];BOOL isRollBack = NO;@try {for (User *user in array) {NSString *sql = [NSString stringWithFormat:@"UPDATE User SET name = '%@',age = '%d',ID_no = '%@' WHERE ID = '%d';", user.name, user.age, user.ID_no, user.ID];BOOL res = [db executeUpdate:sql];if (!res) {NSLog(@"db事务更新失败");}else {NSLog(@"db事务更新成功");}}}@catch (NSException *exception) {isRollBack = YES;[db rollback];}@finally {if (!isRollBack) {[db commit];}}[db close];return !isRollBack;
}
4、删除数据 
/** 删除单个对象 */
- (BOOL)deleteObjectByDB
{FMDatabase *db = [FMDatabase databaseWithPath:[User getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return NO;}NSString *sql = [NSString stringWithFormat:@"DELETE FROM User WHERE ID = '%d'",self.ID];BOOL res = [db executeUpdate:sql];[db close];if (res) {NSLog(@"删除数据成功");}else {NSLog(@"删除数据失败");}return res;
}/** 批量删除用户对象 */
+ (BOOL)deleteObjectsByDB:(NSArray *)array
{FMDatabase *db = [FMDatabase databaseWithPath:[self getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return NO;}[db beginTransaction];BOOL isRollBack = NO;@try {for (User *user in array) {NSString *sql = [NSString stringWithFormat:@"DELETE FROM User WHERE ID = '%d'",user.ID];BOOL res = [db executeUpdate:sql];if (!res) {NSLog(@"db事务删除失败");}else {NSLog(@"db事务删除成功");}}}@catch (NSException *exception) {isRollBack = YES;[db rollback];}@finally {if (!isRollBack) {[db commit];}}[db close];return !isRollBack;
}

5、查询数据

查询就比较简单了。

/** 查询全部用户 */
+ (NSArray *)findAllByDB
{FMDatabase *db = [FMDatabase databaseWithPath:[self getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return nil;}NSMutableArray *users = [[NSMutableArray alloc] init];NSString *sql = @"SELECT * FROM User";FMResultSet *resultSet = [db executeQuery:sql];while ([resultSet next]) {User *user = [[User alloc] init];user.ID = [resultSet intForColumn:@"ID"];user.name = [resultSet stringForColumn:@"name"];user.age = [resultSet intForColumn:@"age"];user.ID_no = [resultSet stringForColumn:@"ID_no"];[users addObject:user];[user release];}NSLog(@"查询全部成功");return [users autorelease];
}/** 查找某个用户 */
+ (instancetype)findFirstBySqlByDB:(NSString *)sql
{User *user = nil;NSArray *users = [self findBySqlByDB:sql];if (users.count > 0) {user = [users firstObject];}return user;
}/** 查找用户 */
+ (NSArray *)findBySqlByDB:(NSString *)sql
{FMDatabase *db = [FMDatabase databaseWithPath:[self getDBPath]];if (![db open]) {NSLog(@"数据库打开失败!");return nil;}NSMutableArray *users = [[NSMutableArray alloc] init];NSString *select = @"SELECT * FROM User ";if (sql) {select = [select stringByAppendingString:sql];}FMResultSet *resultSet = [db executeQuery:select];while ([resultSet next]) {User *user = [[User alloc] init];user.ID = [resultSet intForColumn:@"ID"];user.name = [resultSet stringForColumn:@"name"];user.age = [resultSet intForColumn:@"age"];user.ID_no = [resultSet stringForColumn:@"ID_no"];[users addObject:user];[user release];}NSLog(@"条件查询成功");return [users autorelease];
}

而多线程下的调用方式是这样的，其中上面的所有方法都是在对象类User中。

/** 用db插入User数据*/
- (IBAction)dbInsertData:(id)sender {//多线程插入数据for (int i = 0; i < 5; i++) {dispatch_async(dispatch_get_global_queue(0, 0), ^{User *user = [[User alloc] init];user.name = @"dbName一";user.ID_no = [NSString stringWithFormat:@"%d",55555+i];user.age = 555+i;[user saveByDB];});}//利用事务插入数据dispatch_async(dispatch_get_global_queue(0, 0), ^{NSMutableArray *array = [NSMutableArray array];for (int i = 0; i < 5; i++) {User *user = [[User alloc] init];user.name = @"db事务";user.ID_no = [NSString stringWithFormat:@"%d",66666+i];user.age = 66+i;[array addObject:user];[user release];}[User saveObjectsByDB:array];});
}


这篇关于iOS下FMDB的多线程操作（一）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1056533。

相关文章

Python操作PDF文档的主流库使用指南

Python操作PDF文档的主流库使用指南

《Python操作PDF文档的主流库使用指南》PDF因其跨平台、格式固定的特性成为文档交换的标准,然而,由于其复杂的内部结构,程序化操作PDF一直是个挑战,本文主要为大家整理了Python操作PD... 目录一、 基础操作1.PyPDF2 (及其继任者 pypdf)2.PyMuPDF / fitz3.Fre
阅读更多...
Python对接支付宝支付之使用AliPay实现的详细操作指南

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali
阅读更多...
MySQL 强制使用特定索引的操作

MySQL 强制使用特定索引的操作

《MySQL强制使用特定索引的操作》MySQL可通过FORCEINDEX、USEINDEX等语法强制查询使用特定索引,但优化器可能不采纳,需结合EXPLAIN分析执行计划,避免性能下降,注意版本差异... 目录1. 使用FORCE INDEX语法2. 使用USE INDEX语法3. 使用IGNORE IND
阅读更多...
RabbitMQ消费端单线程与多线程案例讲解

RabbitMQ消费端单线程与多线程案例讲解

《RabbitMQ消费端单线程与多线程案例讲解》文章解析RabbitMQ消费端单线程与多线程处理机制,说明concurrency控制消费者数量,max-concurrency控制最大线程数,prefe... 目录 一、基础概念详细解释：举个例子：✅ 单消费者 + 单线程消费❌ 单消费者 + 多线程消费❌ 多
阅读更多...
Python使用openpyxl读取Excel的操作详解

Python使用openpyxl读取Excel的操作详解

《Python使用openpyxl读取Excel的操作详解》本文介绍了使用Python的openpyxl库进行Excel文件的创建、读写、数据操作、工作簿与工作表管理,包括创建工作簿、加载工作簿、操作... 目录1 概述1.1 图示1.2 安装第三方库2 工作簿 workbook2.1 创建：Workboo
阅读更多...
Ubuntu 24.04启用root图形登录的操作流程

Ubuntu 24.04启用root图形登录的操作流程

《Ubuntu24.04启用root图形登录的操作流程》Ubuntu默认禁用root账户的图形与SSH登录,这是为了安全,但在某些场景你可能需要直接用root登录GNOME桌面,本文以Ubuntu2... 目录一、前言二、准备工作三、设置 root 密码四、启用图形界面 root 登录1. 修改 GDM 配
阅读更多...
JSONArray在Java中的应用操作实例

JSONArray在Java中的应用操作实例

《JSONArray在Java中的应用操作实例》JSONArray是org.json库用于处理JSON数组的类,可将Java对象（Map/List）转换为JSON格式,提供增删改查等操作,适用于前后端... 目录1. jsONArray定义与功能1.1 JSONArray概念阐释1.1.1 什么是JSONA
阅读更多...
Javaee多线程之进程和线程之间的区别和联系(最新整理)

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab
阅读更多...
Java操作Word文档的全面指南

Java操作Word文档的全面指南

《Java操作Word文档的全面指南》在Java开发中,操作Word文档是常见的业务需求,广泛应用于合同生成、报表输出、通知发布、法律文书生成、病历模板填写等场景,本文将全面介绍Java操作Word文... 目录简介段落页头与页脚页码表格图片批注文本框目录图表简介Word编程最重要的类是org.apach
阅读更多...
Python实现对阿里云OSS对象存储的操作详解

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2