一、SQLite3

首先要添加库文件libsqlite3.dylib和导入主头文件#import <sqlite3.h>

sqlite3_open()

根据文件路径打开数据库，如果不存在，则会创建一个新的数据库

    sqlite3 *db = NULL;
    NSString *path = [NSSearchPathForDirectoriesInDomains(NSDocumentDirectory, NSUserDomainMask, YES).lastObject stringByAppendingPathComponent:@"demo.sqlite"];
    /** 
     * filename: 数据库文件的存放路径
     * ppDb: 一个打开的数据库实例
     * sqlite3_open()会返回一个int类型的值, 这个值代表着打开数据库是否成功，如果result等于常量SQLITE_OK，则表示成功打开数据库
     */
    int result = sqlite3_open(path.UTF8String, &db);
    if (result == SQLITE_OK) {
        NSLog(@"--数据库打开成功--%@",path);
    }

sqlite3_exec()

sqlite3_exec()可以执行任何SQL语句，比如创表、更新、插入和删除操作。但是一般不用它执行查询语句，因为它不会返回查询到的数据

    //建表
    NSString *sql = @"create table if not exists t_student(id integer primary key autoincrement, name test, age integer);";
    //插入数据
    //NSString *sql = @"insert into t_student(name,age) values ('lisi',12)";
    char *error = nil;
    /** 
     * sqlite3*： 需要执行sql语句的数据库
     * const char *sql：需要执行的sql语句
     * int (*callback)(void*,int,char**,char**)：执行完sql语句之后的回调方法
     * void *：回调方法的参数
     * char **errmsg ：错误信息
     */
    int execResult = sqlite3_exec(db, [sql UTF8String], NULL, NULL, &error);
    if (execResult == SQLITE_OK) {
        NSLog(@"成功");
    }

带占位符插入数据

    //插入语句
    NSString *sql = @"insert into t_student(name,age) values (?,?)";
    NSArray *args = @[@"wanger",@(23)];
    sqlite3_stmt *stmt = nil;
    //sqlite3_prepare_v2()返回值等于SQLITE_OK，说明SQL语句已经准备成功，没有语法问题
    int result = (sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil));
    if (result == SQLITE_OK) {
        NSLog(@"");
    }
    for (int i = 0; i<args.count; i++) {
        NSObject *objc = args[i];
        if ([objc isKindOfClass:[NSNumber class]]) {
            NSNumber *number = ( NSNumber *)objc;
            if (strcmp([number objCType], @encode(int))) {
                sqlite3_bind_int(stmt, i + 1, number.intValue);
            }else if(strcmp([(NSNumber *)objc objCType], @encode(float))) {
                sqlite3_bind_double(stmt, i + 1, number.doubleValue);
            }else if(strcmp([(NSNumber *)objc objCType], @encode(double))) {
                sqlite3_bind_double(stmt, i + 1, number.doubleValue);
            }
        }else if([objc isKindOfClass:[NSString class]]){
            NSString *str = (NSString *)objc;
            /**
             sqlite3_stmt*,
             int：占位符的位置，第一个占位符的位置是1，不是0
             const char*：占位符要绑定的值
             int：在第3个参数中所传递数据的长度，对于C字符串，可以传递-1代替字符串的长度
             void(*)(void*)：一个可选的函数回调，一般用于在语句执行后完成内存清理工作
             */
            sqlite3_bind_text(stmt, i + 1, [str UTF8String], -1, SQLITE_TRANSIENT);
        }
    }
    /**
     执行SQL语句，返回SQLITE_DONE代表成功执行完毕
     */
    sqlite3_step(stmt);
    /**
     重置sqlite3_stmt *对象,返回SQLITE_OK代表重置成功
     */
    sqlite3_reset(stmt);
    /**
     销毁sqlite3_stmt *对象,返回SQLITE_OK代表销毁成功
     */
    sqlite3_finalize(stmt);

查询数据

    //查询语句
    NSString *sql = @"select id, name, age from t_student;";
    sqlite3_stmt *stmt = nil;
    //sqlite3_prepare_v2()返回值等于SQLITE_OK，说明SQL语句已经准备成功，没有语法问题
    int result = (sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil));
    if (result == SQLITE_OK) {
        NSLog(@"");
    }
    
    NSMutableArray *arrM = [NSMutableArray array];
    //sqlite3_step()返回SQLITE_ROW代表遍历到一条新记录
    while (sqlite3_step(stmt) == SQLITE_ROW) {
        // 从stmt中取出提取到的数据
        //获得一条数据中字段的个数
        int count = sqlite3_column_count(stmt);
        NSMutableDictionary *record = [NSMutableDictionary dictionary];
        for (int i = 0; i < count; i++) {
            //取得key值
            const char *cName = sqlite3_column_name(stmt, i);
            NSString *name = [NSString stringWithCString:cName encoding:NSUTF8StringEncoding];
            //获得value的类型
            int type = sqlite3_column_type(stmt, i);
            switch (type) {
                case SQLITE_INTEGER:
                {
                    int number = sqlite3_column_int(stmt, i);
                    record[name] = @(number);
                    break;
                }
                case SQLITE_FLOAT:
                {
                    double doubleValue = sqlite3_column_double(stmt, i);
                    record[name] = @(doubleValue);
                }
                    break;
                case SQLITE3_TEXT:
                {
                    const char *textValue = sqlite3_column_text(stmt, i);
                    NSString *text = [NSString stringWithCString:textValue encoding:NSUTF8StringEncoding];
                    record[name] = text;
                }
                    break;
                case SQLITE_NULL:
                    record[name] = [NSNull new];
                    break;
                default:
                    break;
            }
        }
        [arrM addObject:record];
    }

事务

• 如果使用 sqlite3_exec 或者, sqlite3_step()来执行sql语句, 会自动开启一个"事务", 然后, 自动提交"事务"
• 只需要手动开启事务, 手动提交事务, 这时候, 函数内部, 就不会自动开启 和提交事务，大大提高了数据库操作的效率

开启事务：begin transaction;
回滚事务：rollback;
提交事务：commit;

    //查询语句
    NSString *sql = @"insert into t_student(name,age) values (?,?)";
    NSArray *args = @[@"wanger",@(23)];
    sqlite3_stmt *stmt = nil;
    //sqlite3_prepare_v2()返回值等于SQLITE_OK，说明SQL语句已经准备成功，没有语法问题
    int result = (sqlite3_prepare_v2(db, [sql UTF8String], -1, &stmt, nil));
    if (result == SQLITE_OK) {
        NSLog(@"");
    }
    
    /** 开启事务 */
    NSString *beginSql = @"BEGIN TRANSACTION";
    sqlite3_exec(db, beginSql.UTF8String, nil, nil, nil);
    
    for (int i = 0; i< 1000000; i++) {
        for (int i = 0; i<args.count; i++) {
            NSObject *objc = args[i];
            if ([objc isKindOfClass:[NSNumber class]]) {
                NSNumber *number = ( NSNumber *)objc;
                if (strcmp([number objCType], @encode(int))) {
                    sqlite3_bind_int(stmt, i + 1, number.intValue);
                }else if(strcmp([(NSNumber *)objc objCType], @encode(float))) {
                    sqlite3_bind_double(stmt, i + 1, number.doubleValue);
                }else if(strcmp([(NSNumber *)objc objCType], @encode(double))) {
                    sqlite3_bind_double(stmt, i + 1, number.doubleValue);
                }
            }else if([objc isKindOfClass:[NSString class]]){
                NSString *str = (NSString *)objc;
                /**
                 sqlite3_stmt*,
                 int：占位符的位置，第一个占位符的位置是1，不是0
                 const char*：占位符要绑定的值
                 int：在第3个参数中所传递数据的长度，对于C字符串，可以传递-1代替字符串的长度
                 void(*)(void*)：一个可选的函数回调，一般用于在语句执行后完成内存清理工作
                 */
                sqlite3_bind_text(stmt, i + 1, [str UTF8String], -1, SQLITE_TRANSIENT);
            }
        }
        /**
         执行SQL语句，返回SQLITE_DONE代表成功执行完毕
         */
        sqlite3_step(stmt);
        /**
         重置sqlite3_stmt *对象,返回SQLITE_OK代表重置成功
         */
        sqlite3_reset(stmt);

    }
    
    /** 提交事务 */
    NSString *commitsql = @"COMMIT TRANSACTION";
    int commitResult = sqlite3_exec(db, commitsql.UTF8String, nil, nil, nil);
    if (commitResult == SQLITE_OK) {
        NSLog(@"--成功");
    }
    
    /**
     销毁sqlite3_stmt *对象,返回SQLITE_OK代表销毁成功
     */
    sqlite3_finalize(stmt);

    /** 开启事务 */
    NSString *sql = @"BEGIN TRANSACTION";
    int result = sqlite3_exec(db, sql.UTF8String, nil, nil, nil);
    if (result == SQLITE_OK) {
        NSString *sql1 = @"update t_stu set money = money - 10 where name = 'zhangsan'";
        NSString *sql2 = @"update t_stu set money = money + 10 where name = 'lisi'";
        int result1 = sqlite3_exec(db, sql1.UTF8String, NULL, NULL, NULL);
        int result2 = sqlite3_exec(db, sql2.UTF8String, NULL, NULL, NULL);
        
        if (result1 == SQLITE_OK && result2 == SQLITE_OK) {
            /** 提交事务 */
            NSString *commitsql = @"COMMIT TRANSACTION";
            sqlite3_exec(db, commitsql.UTF8String, nil, nil, nil);
        }else{
            /** 回滚事务 */
            NSString *commitsql = @"ROLLBACK TRANSACTION";
            sqlite3_exec(db, commitsql.UTF8String, nil, nil, nil);
        }
    }