时间:2021-07-01 10:21:17 帮助过:2人阅读
/* 打开数据库 */
- (void)openDatabase:(NSString *)dbname
{
//生成沙盒文件路径
NSString *directory = [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory,NSUserDomainMask,YES) lastObject];
NSString *filePath = [directory stringByAppendingPathComponent:dbname];
//打开数据库,如果数据库存在直接打开,如果数据库不存在,创建并打开
int result = sqlite3_open(filePath.UTF8String, &_database);
if (result == SQLITE_OK) {
NSLog(@"Open Database Success");
} else {
NSLog(@"Open Database Fail");
}
}
/* 执行没有返回的SQL语句 */
int sqlite3_exec(
sqlite3 *db, /* 数据库句柄 */
const char *sql, /* SQL语句(UTF-8) */
int (*callback)(void*,int,char**,char**), /* 回调的C函数指针 */
void *arg, /* 回调函数的第一个参数 */
char **errmsg /* 返回的错误信息 */
);
/* 执行没有返回值的SQL语句 */
- (void)executeNonQuery:(NSString *)sql
{
if (!_database) {
return;
}
char *error;
//执行没有返回值的SQL语句
int result = sqlite3_exec(_database, sql.UTF8String, NULL, NULL, &error);
if (result == SQLITE_OK) {
NSLog(@"Execute SQL Query Success");
} else {
NSLog(@"Execute SQL Query Fail error : %s",error);
}
}
/* 执行有返回结果的SQL语句 */
int sqlite3_prepare_v2(
sqlite3 *db, /* 数据库句柄 */
const char *zSql, /* SQL语句(UTF-8) */
int nByte, /* SQL语句最大长度,-1表示SQL支持的最大长度 */
sqlite3_stmt **ppStmt, /* 返回的查询结果 */
const char **pzTail /* 返回的失败信息*/
);
#pragma mark - 定位记录的方法
/* 在查询结果中定位到一条记录 */
int sqlite3_step(sqlite3_stmt *stmt);
/* 获取当前定位记录的字段名称数目 */
int sqlite3_column_count(sqlite3_stmt *stmt);
/* 获取当前定位记录的第几个字段名称 */
const char * sqlite3_column_name(sqlite3_stmt *stmt, int iCol);
# pragma mark - 获取字段值的方法
/* 获取二进制数据 */
const void * sqlite3_column_blob(sqlite3_stmt *stmt, int iCol);
/* 获取浮点型数据 */
double sqlite3_column_double(sqlite3_stmt *stmt, int iCol);
/* 获取整数数据 */
int sqlite3_column_int(sqlite3_stmt *stmt, int iCol);
/* 获取文本数据 */
const unsigned char * sqlite3_column_text(sqlite3_stmt *stmt, int iCol);
/* 执行有返回值的SQL语句 */
- (NSArray *)executeQuery:(NSString *)sql
{
if (!_database) {
return nil;
}
NSMutableArray *array = [NSMutableArray array];
sqlite3_stmt *stmt; //保存查询结果
//执行SQL语句,返回结果保存在stmt中
int result = sqlite3_prepare_v2(_database, sql.UTF8String, -1, &stmt, NULL);
if (result == SQLITE_OK) {
//每次从stmt中获取一条记录,成功返回SQLITE_ROW,直到全部获取完成,就会返回SQLITE_DONE
while( SQLITE_ROW == sqlite3_step(stmt)) {
//获取一条记录有多少列
int columnCount = sqlite3_column_count(stmt);
//保存一条记录为一个字典
NSMutableDictionary *dict = [NSMutableDictionary dictionary];
for (int i = 0; i < columnCount; i++) {
//获取第i列的字段名称
const char *name = sqlite3_column_name(stmt, i);
//获取第i列的字段值
const unsigned char *value = sqlite3_column_text(stmt, i);
//保存进字典
NSString *nameStr = [NSString stringWithUTF8String:name];
NSString *valueStr = [NSString stringWithUTF8String:(const char *)value];
dict[nameStr] = valueStr;
}
[array addObject:dict];//添加当前记录的字典存储
}
sqlite3_finalize(stmt);//stmt需要手动释放内存
stmt = NULL;
NSLog(@"Query Stmt Success");
return array;
}
NSLog(@"Query Stmt Fail");
return nil;
}
/* 关闭数据库 */
int sqlite3_close(sqlite3 *db);
/* 关闭数据库 */
- (void)closeDatabase
{
//关闭数据库
int result = sqlite3_close(_database);
if (result == SQLITE_OK) {
NSLog(@"Close Database Success");
_database = NULL;
} else {
NSLog(@"Close Database Fail");
}
}
除了使用libsqlite库里的C语言函数还无法完成对数据库操作,还需要使用到SQL语句,就是一门控制数据库的语言【一个大知识】。
- 创建表:
create table 表名称(字段1,字段2,……,字段n,[表级约束])[TYPE=表类型];
- 插入记录:
insert into 表名(字段1,……,字段n) values (值1,……,值n);
- 删除记录:
delete from 表名 where 条件表达式;
- 修改记录:
update 表名 set 字段名1=值1,……,字段名n=值n where 条件表达式;
- 查看记录:
select 字段1,……,字段n from 表名 where 条件表达式;
/* 结合SQL语句,操作数据库 */
- (void)sqlite3Test{
//打开SQlite数据库
[self openDatabase:@"sqlite3_database.db"];
//在数据库中创建表
[self executeNonQuery:@"create table mytable(num varchar(7),name varchar(7),sex char(1),primary key(num));"];
//在表中插入记录
[self executeNonQuery:@"insert into mytable(num,name,sex) values (0,‘liuting‘,‘m‘);"];
[self executeNonQuery:@"insert into mytable(num,name,sex) values (1,‘zhangsan‘,‘f‘);"];
[self executeNonQuery:@"insert into mytable(num,name,sex) values (2,‘lisi‘,‘m‘);"];
[self executeNonQuery:@"insert into mytable(num,name,sex) values (3,‘wangwu‘,‘f‘);"];
[self executeNonQuery:@"insert into mytable(num,name,sex) values (4,‘xiaoming‘,‘m‘);"];
//读取数据库的表中数据
NSArray* result = [self executeQuery:@"select num,name,sex from mytable;"];
if (result) {
for (NSDictionary *row in result) {
NSString *num = row[@"num"];
NSString *name = row[@"name"];
NSString *sex = row[@"sex"];
NSLog(@"Read Database : num=%@, name=%@, sex=%@",num,name,sex);
}
}
[self closeDatabase];
}
/* 修改一下,把原来存在的数据库文件删除掉,再创建并打开数据库 */
- (void)openDatabase:(NSString *)dbname
{
//生成沙盒文件路径
NSString *directory = [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory,NSUserDomainMask,YES) lastObject];
NSString *filePath = [directory stringByAppendingPathComponent:dbname];
//判断该文件在不在
NSFileManager *manager = [NSFileManager defaultManager];
if ([manager fileExistsAtPath:filePath]){
//文件存在,就删除掉
[manager removeItemAtPath:filePath error:NULL];
}
//打开数据库,保持sqlite3数据库对象_database,返回值判别是否打开成功
int result = sqlite3_open(filePath.UTF8String, &_database);
if (result == SQLITE_OK) {
NSLog(@"Open Database Success");
} else {
NSLog(@"Open Database Fail");
}
}
数据库SQLite
标签: