欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  移动技术

iOS - FMDB事务操作SQLite数据库

程序员文章站 2022-03-09 22:37:15
批量操作的时候,我们经常会用到事务处理。事务是访问并可能更新数据库各种数据项的数据单元(unit),是恢复和并发的控制的基本单位。 事务具有四个属性。 - 原子性(atomicity):一个事务是一...

批量操作的时候,我们经常会用到事务处理。事务是访问并可能更新数据库各种数据项的数据单元(unit),是恢复和并发的控制的基本单位。

事务具有四个属性。
- 原子性(atomicity):一个事务是一个不可分割的工作单位,事务中包括的诸操作要么都做,要么都不做。
- 一致性(consistency):事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
- 隔离性(isolation):一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
- 持久性(durability):持续性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。

sqlite支持事务,fmdb也对事务进行了很好的封装。

事务形成的sql语句
触发事务:begin transaction
提交事务:commit transaction
回滚事务:rollback transaction

sqlite本身是支持事务操作的,fmdb作为sqlite的上层封装也对事务进行了支持,那么说了这么多给不了解“事务”这个词的同学解释一下吧:通常一次 sqlite3_exec 就是一次事务,假如你要对数据库中的stutent表插入新数据,那么该事务的具体过程是:开始新事物->插入数据->提交事务,那么当我们要往该表内插入500条数据,如果按常规操作处理就要执行500次“开始新事物->插入数据->提交事务”的过程。

具体使用fmdb操作事务的方法:


//数据库对象
static fmdatabase *_db;

/** 用户数据库保存路径 */
#define kvideogatherdbfilepath [[nssearchpathfordirectoriesindomains(nsdocumentdirectory, nsuserdomainmask, yes) lastobject] stringbyappendingpathcomponent:@"videogatherdb.sqlite"]

+(void)syschronizedatawitharr:(nsarray *)dataarr{
    _db = [fmdatabase databasewithpath:kvideogatherdbfilepath];
    if ([_db open]) {
        [_db begintransaction];
        bool isrollback = no;
        @try {
            //先清空当前表中数据!
            bool successdelete =  [_db executeupdate:@"delete from t_product"];
            if (successdelete) {
                for (nsdictionary *productdict in dataarr) {
                    nsstring *nsr_name = [productdict objectforkey:@"nsr_name"];
                    nsstring *org_id = [productdict objectforkey:@"org_id"];
                    nsstring *nsrsbh =  [productdict objectforkey:@"nsrsbh"];
                    if (![_db executeupdate:@"insert into t_product (nsr_name, org_id, nsrsbh) values (?,?,?)",nsr_name, org_id, nsrsbh]) {
                        nslog(@"%@",[_db lasterror]);
                        break;
                    }
                }
            }
            nslog(@"产品表信息插入成功!");
            dispatch_async(kmainqueue, ^{

                [videogathertool productdatatosuccess];
                if (![videogathertool sysdataissuccess]) {
                    dispatch_after(dispatch_time(dispatch_time_now, (int64_t)(0.8 * nsec_per_sec)), dispatch_get_main_queue(), ^{
                        [svprogresshud showwithstatus:@"正在同步云端数据,请保持网络畅通!"];

                    });
                }else{
                    dispatch_after(dispatch_time(dispatch_time_now, (int64_t)(1 * nsec_per_sec)), dispatch_get_main_queue(), ^{
                        [svprogresshud showsuccesswithstatus:@"云端数据同步完成!"];
                        [svprogresshud dismisswithdelay:0.5];
                        [[nsuserdefaults standarduserdefaults] setbool:yes forkey:@"kisloginsysdata"];
                    });
                }
            });
        } @catch (nsexception *exception) {
            isrollback = yes;
            [_db rollback];
        } @finally {
            if (!isrollback) {
                [_db commit];
            }
        }
    }
}