IOS 之使用FMDB进行SQLite数据库操作——表的创建与修改，以及数据的增删改查和多线程操作数据库
2015-12-14 17:05
1251 查看
因为IOS中的数据库API在使用上非常复杂繁琐，我们在对SQLite数据库进行操作时通常使用第三方封装的库FMDB
FMDB同时兼容ARC和非ARC工程，会自动根据工程配置来调整相关的内存管理代码。
FMDB常用类：
FMDatabase：一个单一的SQLite数据库，用于执行SQL语句。
FMResultSet：执行一个FMDatabase结果集。
FMDatabaseQueue：在多个线程中执行查询和更新时会用到这个类。
在使用之前先将FMDB的包拖进工程，然后一定要把libsqlite3.0.dylib依赖包导入。如下图所示：
然后新建pch文件 将FMDB的头文件导入即可使用：
为了方便打开查看数据库文件，先下载MesaSQLite工具并打开。
知识点一：数据库文件的创建
首先根据需求把数据库文件存到沙盒目录下的某个路径。
注意：
1、当给定路径的数据库文件不存在时，FMDB会自动创建一个
2、如果传入的数据库路径是一个空串：即@"", 则FMDB会在临时文件目录下创建这个数据库，数据库断开连接时，数据库文件会被删除。
3、如果数据库路径是NULL，则它会建立一个在内存中的数据库，当数据库断开连接时，数据库文件会被删除。
知识点二：数据库的打开和关闭以及表格的创建。
知识点三：表格数据的增删改查。
知识点四：多线程操作数据库。
新建工程如下：
新建pch文件 编辑如下：
[objc] view
plaincopy
//
// PrefixHeader.pch
// 数据库SQLite语句增删改查+++
//
// Created by apple on 15/9/29.
// Copyright (c) 2015年 LiuXun. All rights reserved.
//
#ifndef ___SQLite__________PrefixHeader_pch
#define ___SQLite__________PrefixHeader_pch
#import "AppDelegate.h"
#import "ViewController.h"
#import "FMDatabase.h"
#import "FMDatabaseQueue.h"
#endif
编辑控制器的.m文件如下：
[objc] view
plaincopy
//
// ViewController.m
// 数据库SQLite语句增删改查+++
//
// Created by apple on 15/9/29.
// Copyright (c) 2015年 LiuXun. All rights reserved.
//
#import "ViewController.h"
#import "FMDatabase.h"
#define TABLENAME @"tableName"
#define ID @"id"
#define NAME @"name"
#define AGE @"age"
#define ADDRESS @"address"
@interface ViewController ()
@end
@implementation ViewController
- (void)viewDidLoad {
[super viewDidLoad];
/*创建数据库路径*/
NSArray *path = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES);
NSString *documentDirectory = [path objectAtIndex:0];
NSString *dbPath = [documentDirectory stringByAppendingPathComponent:@"test.db"];
NSLog(@"dbPath= %@",dbPath);
/*连接数据库——连接数据库，并没有创建数据库文件，直到打开成功才算真正创建*/
FMDatabase *db = [FMDatabase databaseWithPath:dbPath];
/*=====================================================================*/
/*创建表*/
if ([db open]) {
NSString *sqlCreateTable = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@' ('%@' INTEGER PRIMARY KEY AUTOINCREMENT, '%@' TEXT, '%@' INTEGER, '%@' TEXT)",TABLENAME,ID,NAME,AGE,ADDRESS];
BOOL res = [db executeUpdate:sqlCreateTable];
if (!res) {
NSLog(@"error when creating db table %@",TABLENAME);
}else
{
NSLog(@"success when creating db table %@",TABLENAME);
}
[db close];
}
/*增删改查——增加数据*/
if ([db open]) { // 第一种：方式全部用字符串拼接NSString类型的SQL语句
NSString *insertSql1 = [NSString stringWithFormat:
@"INSERT INTO '%@' ('%@', '%@', '%@') VALUES ('%@', '%@', '%@')",
TABLENAME, NAME, AGE, ADDRESS, @"张三", @"13", @"济南"];
BOOL res1 = [db executeUpdate:insertSql1];
NSString *insertSql2 = [NSString stringWithFormat:@"INSERT INTO '%@' ('%@','%@','%@') VALUES ('%@','%@','%@')",TABLENAME,NAME,AGE,ADDRESS,@"李四",@"18",@"广州"];
BOOL res2 = [db executeUpdate:insertSql2];
if (res1) {
NSLog(@"insert 1 scucess");
}
else{
NSLog(@"insert 1 failure");
}
if (res2) {
NSLog(@"insert 2 scucess");
}
else{
NSLog(@"insert 2 failure");
}
[db close];
}
/*增删改查——修改数据*/
if ([db open]) { // 可以用任意类型的变量来拼接OC 字符串来作为数据库查询语句
NSString *updateSql = [NSString stringWithFormat:@" UPDATE %@ SET %@= %d WHERE %@ = %d ",TABLENAME,AGE, 40,AGE,13];
BOOL res = [db executeUpdate:updateSql];
if (res) {
NSLog(@"update success");
}
else
{
NSLog(@"update Failure");
}
[db close];
}
/*增删改查——删除数据*/
if ([db open]) { // 第三种：不拼接NSString字符串，直接写语句
/*
必须注意：此种方式只有变量值可以用？来替代，别的（如表名，键名都必须直接写在前面不能用格式化的方法来操作）
*/
BOOL res = [db executeUpdate:@"DELETE FROM TABLENAME WHERE NAME = ?",@"张三"];
if (res) {
NSLog(@"delete success");
}
else
{
NSLog(@"delete Failure");
}
[db close];
}
/*数据库查询操作*/
if ([db open]) { // 查询操作使用executeQuery，并涉及到了FMResultSet
NSString *sql = [NSString stringWithFormat:@"SELECT * FROM %@ ORDER BY %@ DESC",TABLENAME,ID]; // 按照ID号降序排列,如果只有order by默认是升序的 等同于ASC
FMResultSet * rs = [db executeQuery:sql];
while ([rs next]) {
int Id = [rs intForColumn:ID];
NSString *name = [rs stringForColumn:NAME];
NSString *age = [rs stringForColumn:AGE]; // 数值和NSString类型能自动进行转换，不会出错
NSString *address = [rs stringForColumn:ADDRESS];
NSLog(@"id= %d name=%@ age=%@ address=%@",Id,name,age,address);
}
[db close];
}
/*增加指定列的操作*/
if ([db open]) {
NSString * sqlDropColumn = [NSString stringWithFormat:@"ALTER TABLE %@ ADD COLUMN %@",TABLENAME,@"XXXXX"]; // 当XXXXX存在时就不会在执行添加操作
BOOL res = [db executeUpdate:sqlDropColumn];
if (res) {
NSLog(@"ADD column success");
}
else
{
NSLog(@"ADD column Failure");
}
[db close];
}
/*重命名指定表*/
if ([db open]) {
NSString *sqlRenamColumn = [NSString stringWithFormat:@"ALTER TABLE %@ RENAME TO %@",TABLENAME,TABLENAME]; //TABLENAME可以用 @"renamTabNam"替换，但为了调试方便重命名为原名
BOOL res = [db executeUpdate:sqlRenamColumn];
if (res) {
NSLog(@"Rename column success");
}
else
{
NSLog(@"Rename column Failure");
}
[db close];
}
/*删除表的操作*/
// if ([db open]) {
// NSString *sqlDrop = [NSString stringWithFormat:@"DROP TABLE %@",TABLENAME];
// BOOL res = [db executeUpdate:sqlDrop];
// if (res) {
// NSLog(@"Drop table success");
// }
// else
// {
// NSLog(@"Drop table Failure");
// }
// [db close];
// }
/*=====================================================================*/
/*数据库多线程操作*/
/**
*如果应用中使用了多线程操作数据库，那么就需要使用FMDatabaseQueue来保证线程安全了。 应用中不可在多个线程中共同使用一个FMDatabase对象操作数据库，这样会引起数据库数据混乱。 为了多线程操作数据库安全，FMDB使用了FMDatabaseQueue，使用FMDatabaseQueue很简单，首先用一个数据库文件地址来初使化FMDatabaseQueue，然后就可以将一个闭包(block)传入inDatabase方法中。 在闭包中操作数据库，而不直接参与FMDatabase的管理。
*/
// 创建数据库线程队列
FMDatabaseQueue *queue = [FMDatabaseQueue databaseQueueWithPath:dbPath];
dispatch_queue_t q1 = dispatch_queue_create("queue1", NULL); // 创建第一个线程
dispatch_queue_t q2 = dispatch_queue_create("queue2", NULL); // 创建第二个线程
dispatch_async(q1, ^{ // 表示线程q1同步执行——即按先后顺序执行块内的操作，前一个操作完毕再执行下一个操作
for (int i=0; i<50; i++) {
[queue inDatabase:^(FMDatabase *db) {
NSString *insertsql1 = [NSString stringWithFormat:@"INSERT INTO %@ (%@ ,%@,%@) VALUES (?,?,?)",TABLENAME,NAME,AGE,ADDRESS];
NSString *name = [NSString stringWithFormat:@"Jack %d",i];
NSString *age = [NSString stringWithFormat:@"%d",i+10];
BOOL res = [db executeUpdate:insertsql1,name,age,@"上海"];
if (res) {
NSLog(@"线程一 第%d次insert success",i);
}else
{
NSLog(@"线程一 第%d次insert Failure",i);
}
}];
}
});
dispatch_async(q2, ^{
for (int i=0; i<50; i++) {
[queue inDatabase:^(FMDatabase *db) {
NSString *insertsql2 = [NSString stringWithFormat:@"INSERT INTO %@ (%@, %@,%@) VALUES (?,?,?)",TABLENAME,NAME,AGE,ADDRESS];
NSString *name = [NSString stringWithFormat:@"TOM %d",i];
NSString *age = [NSString stringWithFormat:@"%d",i+10];
BOOL res = [db executeUpdate:insertsql2,name,age,@"北京"];
if (res) {
NSLog(@"线程二 第%d次insert success",i);
}else
{
NSLog(@"线程二 第%d次insert Failure",i);
}
}];
}
});
}
- (void)didReceiveMemoryWarning {
[super didReceiveMemoryWarning];
}
@end
打开沙盒 找到数据库文件如下：
双击数据库文件，便在MesaSQLite工具中打开，结果如下：
FMDB同时兼容ARC和非ARC工程，会自动根据工程配置来调整相关的内存管理代码。
FMDB常用类：
FMDatabase：一个单一的SQLite数据库，用于执行SQL语句。
FMResultSet：执行一个FMDatabase结果集。
FMDatabaseQueue：在多个线程中执行查询和更新时会用到这个类。
在使用之前先将FMDB的包拖进工程，然后一定要把libsqlite3.0.dylib依赖包导入。如下图所示：
然后新建pch文件 将FMDB的头文件导入即可使用：
为了方便打开查看数据库文件，先下载MesaSQLite工具并打开。
知识点一：数据库文件的创建
首先根据需求把数据库文件存到沙盒目录下的某个路径。
注意：
1、当给定路径的数据库文件不存在时，FMDB会自动创建一个
2、如果传入的数据库路径是一个空串：即@"", 则FMDB会在临时文件目录下创建这个数据库，数据库断开连接时，数据库文件会被删除。
3、如果数据库路径是NULL，则它会建立一个在内存中的数据库，当数据库断开连接时，数据库文件会被删除。
知识点二：数据库的打开和关闭以及表格的创建。
知识点三：表格数据的增删改查。
知识点四：多线程操作数据库。
新建工程如下：
新建pch文件 编辑如下：
[objc] view
plaincopy
//
// PrefixHeader.pch
// 数据库SQLite语句增删改查+++
//
// Created by apple on 15/9/29.
// Copyright (c) 2015年 LiuXun. All rights reserved.
//
#ifndef ___SQLite__________PrefixHeader_pch
#define ___SQLite__________PrefixHeader_pch
#import "AppDelegate.h"
#import "ViewController.h"
#import "FMDatabase.h"
#import "FMDatabaseQueue.h"
#endif
编辑控制器的.m文件如下：
[objc] view
plaincopy
//
// ViewController.m
// 数据库SQLite语句增删改查+++
//
// Created by apple on 15/9/29.
// Copyright (c) 2015年 LiuXun. All rights reserved.
//
#import "ViewController.h"
#import "FMDatabase.h"
#define TABLENAME @"tableName"
#define ID @"id"
#define NAME @"name"
#define AGE @"age"
#define ADDRESS @"address"
@interface ViewController ()
@end
@implementation ViewController
- (void)viewDidLoad {
[super viewDidLoad];
/*创建数据库路径*/
NSArray *path = NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES);
NSString *documentDirectory = [path objectAtIndex:0];
NSString *dbPath = [documentDirectory stringByAppendingPathComponent:@"test.db"];
NSLog(@"dbPath= %@",dbPath);
/*连接数据库——连接数据库，并没有创建数据库文件，直到打开成功才算真正创建*/
FMDatabase *db = [FMDatabase databaseWithPath:dbPath];
/*=====================================================================*/
/*创建表*/
if ([db open]) {
NSString *sqlCreateTable = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@' ('%@' INTEGER PRIMARY KEY AUTOINCREMENT, '%@' TEXT, '%@' INTEGER, '%@' TEXT)",TABLENAME,ID,NAME,AGE,ADDRESS];
BOOL res = [db executeUpdate:sqlCreateTable];
if (!res) {
NSLog(@"error when creating db table %@",TABLENAME);
}else
{
NSLog(@"success when creating db table %@",TABLENAME);
}
[db close];
}
/*增删改查——增加数据*/
if ([db open]) { // 第一种：方式全部用字符串拼接NSString类型的SQL语句
NSString *insertSql1 = [NSString stringWithFormat:
@"INSERT INTO '%@' ('%@', '%@', '%@') VALUES ('%@', '%@', '%@')",
TABLENAME, NAME, AGE, ADDRESS, @"张三", @"13", @"济南"];
BOOL res1 = [db executeUpdate:insertSql1];
NSString *insertSql2 = [NSString stringWithFormat:@"INSERT INTO '%@' ('%@','%@','%@') VALUES ('%@','%@','%@')",TABLENAME,NAME,AGE,ADDRESS,@"李四",@"18",@"广州"];
BOOL res2 = [db executeUpdate:insertSql2];
if (res1) {
NSLog(@"insert 1 scucess");
}
else{
NSLog(@"insert 1 failure");
}
if (res2) {
NSLog(@"insert 2 scucess");
}
else{
NSLog(@"insert 2 failure");
}
[db close];
}
/*增删改查——修改数据*/
if ([db open]) { // 可以用任意类型的变量来拼接OC 字符串来作为数据库查询语句
NSString *updateSql = [NSString stringWithFormat:@" UPDATE %@ SET %@= %d WHERE %@ = %d ",TABLENAME,AGE, 40,AGE,13];
BOOL res = [db executeUpdate:updateSql];
if (res) {
NSLog(@"update success");
}
else
{
NSLog(@"update Failure");
}
[db close];
}
/*增删改查——删除数据*/
if ([db open]) { // 第三种：不拼接NSString字符串，直接写语句
/*
必须注意：此种方式只有变量值可以用？来替代，别的（如表名，键名都必须直接写在前面不能用格式化的方法来操作）
*/
BOOL res = [db executeUpdate:@"DELETE FROM TABLENAME WHERE NAME = ?",@"张三"];
if (res) {
NSLog(@"delete success");
}
else
{
NSLog(@"delete Failure");
}
[db close];
}
/*数据库查询操作*/
if ([db open]) { // 查询操作使用executeQuery，并涉及到了FMResultSet
NSString *sql = [NSString stringWithFormat:@"SELECT * FROM %@ ORDER BY %@ DESC",TABLENAME,ID]; // 按照ID号降序排列,如果只有order by默认是升序的 等同于ASC
FMResultSet * rs = [db executeQuery:sql];
while ([rs next]) {
int Id = [rs intForColumn:ID];
NSString *name = [rs stringForColumn:NAME];
NSString *age = [rs stringForColumn:AGE]; // 数值和NSString类型能自动进行转换，不会出错
NSString *address = [rs stringForColumn:ADDRESS];
NSLog(@"id= %d name=%@ age=%@ address=%@",Id,name,age,address);
}
[db close];
}
/*增加指定列的操作*/
if ([db open]) {
NSString * sqlDropColumn = [NSString stringWithFormat:@"ALTER TABLE %@ ADD COLUMN %@",TABLENAME,@"XXXXX"]; // 当XXXXX存在时就不会在执行添加操作
BOOL res = [db executeUpdate:sqlDropColumn];
if (res) {
NSLog(@"ADD column success");
}
else
{
NSLog(@"ADD column Failure");
}
[db close];
}
/*重命名指定表*/
if ([db open]) {
NSString *sqlRenamColumn = [NSString stringWithFormat:@"ALTER TABLE %@ RENAME TO %@",TABLENAME,TABLENAME]; //TABLENAME可以用 @"renamTabNam"替换，但为了调试方便重命名为原名
BOOL res = [db executeUpdate:sqlRenamColumn];
if (res) {
NSLog(@"Rename column success");
}
else
{
NSLog(@"Rename column Failure");
}
[db close];
}
/*删除表的操作*/
// if ([db open]) {
// NSString *sqlDrop = [NSString stringWithFormat:@"DROP TABLE %@",TABLENAME];
// BOOL res = [db executeUpdate:sqlDrop];
// if (res) {
// NSLog(@"Drop table success");
// }
// else
// {
// NSLog(@"Drop table Failure");
// }
// [db close];
// }
/*=====================================================================*/
/*数据库多线程操作*/
/**
*如果应用中使用了多线程操作数据库，那么就需要使用FMDatabaseQueue来保证线程安全了。 应用中不可在多个线程中共同使用一个FMDatabase对象操作数据库，这样会引起数据库数据混乱。 为了多线程操作数据库安全，FMDB使用了FMDatabaseQueue，使用FMDatabaseQueue很简单，首先用一个数据库文件地址来初使化FMDatabaseQueue，然后就可以将一个闭包(block)传入inDatabase方法中。 在闭包中操作数据库，而不直接参与FMDatabase的管理。
*/
// 创建数据库线程队列
FMDatabaseQueue *queue = [FMDatabaseQueue databaseQueueWithPath:dbPath];
dispatch_queue_t q1 = dispatch_queue_create("queue1", NULL); // 创建第一个线程
dispatch_queue_t q2 = dispatch_queue_create("queue2", NULL); // 创建第二个线程
dispatch_async(q1, ^{ // 表示线程q1同步执行——即按先后顺序执行块内的操作，前一个操作完毕再执行下一个操作
for (int i=0; i<50; i++) {
[queue inDatabase:^(FMDatabase *db) {
NSString *insertsql1 = [NSString stringWithFormat:@"INSERT INTO %@ (%@ ,%@,%@) VALUES (?,?,?)",TABLENAME,NAME,AGE,ADDRESS];
NSString *name = [NSString stringWithFormat:@"Jack %d",i];
NSString *age = [NSString stringWithFormat:@"%d",i+10];
BOOL res = [db executeUpdate:insertsql1,name,age,@"上海"];
if (res) {
NSLog(@"线程一 第%d次insert success",i);
}else
{
NSLog(@"线程一 第%d次insert Failure",i);
}
}];
}
});
dispatch_async(q2, ^{
for (int i=0; i<50; i++) {
[queue inDatabase:^(FMDatabase *db) {
NSString *insertsql2 = [NSString stringWithFormat:@"INSERT INTO %@ (%@, %@,%@) VALUES (?,?,?)",TABLENAME,NAME,AGE,ADDRESS];
NSString *name = [NSString stringWithFormat:@"TOM %d",i];
NSString *age = [NSString stringWithFormat:@"%d",i+10];
BOOL res = [db executeUpdate:insertsql2,name,age,@"北京"];
if (res) {
NSLog(@"线程二 第%d次insert success",i);
}else
{
NSLog(@"线程二 第%d次insert Failure",i);
}
}];
}
});
}
- (void)didReceiveMemoryWarning {
[super didReceiveMemoryWarning];
}
@end
打开沙盒 找到数据库文件如下：
双击数据库文件，便在MesaSQLite工具中打开，结果如下：
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- mysql主从切换步骤
- MySQL5.6 ALTER TABLE 分析和测试
- ORACLE多表关联UPDATE 语句
- sql之left join、right join、inner join的区别
- Solr 5.2.1 部署并索引Mysql数据库
- 常用的SQL语句
- Redis
- mysql 主从复制及相关故障说明
- sqlserver里面使用in查询与表join查询的区别
- Oracle12c新特性之基本操作
- sql 去重
- MySql的字符串“=”查询优化
- sql server 日期相关操作
- linq to sql 上传，显示图片
- MySQL存储过程及触发器
- sqlldr常规应用 (总结篇)
- Navicat 链接虚拟机MySQL失败(GRANT ALL PRIVILEGES)
- sql server case when 判断为空
- oracle数据库rman备份计划及恢复
- SqlServer中wait type类型及说明