iOS - FMDB事务操作SQLite数据库
程序员文章站
2022-06-23 15:40:24
批量操作的时候,我们经常会用到事务处理。事务是访问并可能更新数据库各种数据项的数据单元(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]; } } } }