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。

相关文章

安卓链接正常显示，ios#符被转义%23导致链接访问404

安卓链接正常显示，ios#符被转义%23导致链接访问404

原因分析： url中含有特殊字符 中文未编码 都有可能导致URL转换失败，所以需要对url编码处理  如下： guard let allowUrl = webUrl.addingPercentEncoding(withAllowedCharacters: .urlQueryAllowed) else {return} 后面发现当url中有#号时，会被误伤转义为%23，导致链接无法访问
阅读更多...
多线程解析报表

多线程解析报表

假如有这样一个需求，当我们需要解析一个Excel里多个sheet的数据时，可以考虑使用多线程，每个线程解析一个sheet里的数据，等到所有的sheet都解析完之后，程序需要提示解析完成。 Way1 join import java.time.LocalTime;public class Main {public static void main(String[] args) thro
阅读更多...
【iOS】MVC模式

【iOS】MVC模式

MVC模式 MVC模式MVC模式demo MVC模式 MVC模式全称为model(模型)view(视图)controller(控制器)，他分为三个不同的层分别负责不同的职责。 View：该层用于存放视图，该层中我们可以对页面及控件进行布局。Model：模型一般都拥有很好的可复用性，在该层中，我们可以统一管理一些数据。Controlller：该层充当一个CPU的功能，即该应用程序
阅读更多...
动手学深度学习【数据操作+数据预处理】

动手学深度学习【数据操作+数据预处理】

import osos.makedirs(os.path.join('.', 'data'), exist_ok=True)data_file = os.path.join('.', 'data', 'house_tiny.csv')with open(data_file, 'w') as f:f.write('NumRooms,Alley,Price\n') # 列名f.write('NA
阅读更多...
线程的四种操作

线程的四种操作

所属专栏：Java学习        1. 线程的开启 start和run的区别： run：描述了线程要执行的任务，也可以称为线程的入口 start：调用系统函数，真正的在系统内核中创建线程（创建PCB，加入到链表中），此处的start会根据不同的系统，分别调用不同的api，创建好之后的线程，再单独去执行run（所以说，start的本质是调用系统api，系统的api
阅读更多...
Java 多线程概述

Java 多线程概述

多线程技术概述   1.线程与进程 进程：内存中运行的应用程序，每个进程都拥有一个独立的内存空间。线程：是进程中的一个执行路径，共享一个内存空间，线程之间可以自由切换、并发执行，一个进程最少有一个线程，线程实际数是在进程基础之上的进一步划分，一个进程启动之后，进程之中的若干执行路径又可以划分成若干个线程 2.线程的调度 分时调度：所有线程轮流使用CPU的使用权，平均分配时间抢占式调度
阅读更多...
Java 多线程的基本方式

Java 多线程的基本方式

Java 多线程的基本方式 基础实现两种方式： 通过实现Callable 接口方式（可得到返回值)：
阅读更多...
Java IO 操作——个人理解

Java IO 操作——个人理解

之前一直Java的IO操作一知半解。今天看到一个便文章觉得很有道理（ 原文章），记录一下。 首先，理解Java的IO操作到底操作的什么内容，过程又是怎么样子。          数据来源的操作： 来源有文件，网络数据。使用File类和Sockets等。这里操作的是数据本身，1,0结构。    File file = new File("path");   字
阅读更多...
MySQL——表操作

MySQL——表操作

目录 一、创建表 二、查看表 2.1 查看表中某成员的数据 2.2 查看整个表中的表成员 2.3 查看创建表时的句柄 三、修改表 alter 3.1 重命名 rename 3.2 新增一列 add 3.3 更改列属性 modify 3.4 更改列名称 change 3.5 删除某列 上一篇博客介绍了库的操作，接下来来看一下表的相关操作。 一、创建表 create
阅读更多...
JAVA- 多线程

JAVA- 多线程

一，多线程的概念 1.并行与并发 并行：多个任务在同一时刻在cpu 上同时执行并发：多个任务在同一时刻在cpu 上交替执行 2.进程与线程 进程：就是操作系统中正在运行的一个应用程序。所以进程也就是“正在进行的程序”。（Windows系统中,我们可以在任务管理器中看 到进程） 线程：是程序运行的基本执行单元。当操作系统执行一个程序时， 会在系统中建立一个进程，该进程必须至少建立一个线
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2