IOS 数据库升级数据迁移的实例详解
IOS数据库升级数据迁移的实例详解
概要:
很久以前就遇到过数据库版本升级的引用场景,当时的做法是简单的删除旧的数据库文件,重建数据库和表结构,这种暴力升级的方式会导致旧的数据的丢失,现在看来这并不不是一个优雅的解决方案,现在一个新的项目中又使用到了数据库,我不得不重新考虑这个问题,我希望用一种比较优雅的方式去解决这个问题,以后我们还会遇到类似的场景,我们都想做的更好不是吗?
理想的情况是:数据库升级,表结构、主键和约束有变化,新的表结构建立之后会自动的从旧的表检索数据,相同的字段进行映射迁移数据,而绝大多数的业务场景下的数据库版本升级是只涉及到字段的增减、修改主键约束,所以下面要实现的方案也是从最基本的、最常用的业务场景去做一个实现,至于更加复杂的场景,可以在此基础上进行扩展,达到符合自己的预期的。
选型定型
网上搜索了下,并没有数据库升级数据迁移简单完整的解决方案,找到了一些思路
1.清除旧的数据,重建表
优点:简单
缺点:数据丢失
2.在已有表的基础上对表结构进行修改
优点:能够保留数据
缺点:规则比较繁琐,要建立一个数据库的字段配置文件,然后读取配置文件,执行SQL修改表结构、约束和主键等等,涉及到跨多个版本的数据库升级就变得繁琐并且麻烦了
3.创建临时表,把旧的数据拷贝到临时表,然后删除旧的数据表并且把临时表设置为数据表。
优点:能够保留数据,支持表结构的修改,约束、主键的变更,实现起来比较简单
缺点:实现的步骤比较多
综合考虑,第三种方法是一个比较靠谱的方案。
主要步骤
根据这个思路,分析了一下数据库升级了主要步骤大概如下:
- 获取数据库中旧的表
- 修改表名,添加后缀“_bak”,把旧的表当做备份表
- 创建新的表
- 获取新创建的表
- 遍历旧的表和新表,对比取出需要迁移的表的字段
- 数据迁移处理
- 删除备份表
使用到的SQL语句分析
这些操作都是和数据库操作有关系的,所以问题的关键是对应步骤的SQL语句了,下面分析下用到的主要的SQL语句:
获取数据库中旧的表
SELECT*fromsqlite_masterWHEREtype='table'
结果如下,可以看到有type|name|tbl_name|rootpage|sql这些数据库字段,我们只要用到name也就是数据库名称这个字段就行了
sqlite>SELECT*fromsqlite_masterWHEREtype='table' ...>; +-------+---------------+---------------+----------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ |type|name|tbl_name|rootpage|sql| +-------+---------------+---------------+----------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ |table|t_message_bak|t_message_bak|2|CREATETABLE"t_message_bak"(messageIDTEXT,messageTypeINTEGER,messageJsonContentTEXT,retriveTimeStringINTEGER,postTimeStringINTEGER,readStateINTEGER,PRIMARYKEY(messageID))| |table|t_message|t_message|4|CREATETABLEt_message( messageIDTEXT, messageTypeINTEGER, messageJsonContentTEXT, retriveTimeStringINTEGER, postTimeStringINTEGER, readStateINTEGER, addColumnINTEGER, PRIMARYKEY(messageID) )| +-------+---------------+---------------+----------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ 2行于数据集(0.03秒)
修改表名,添加后缀“_bak”,把旧的表当做备份表
--把t_message表修改为t_message_bak表 ALTERTABLEt_messageRENAMETOt_message_bak
获取表字段信息
--获取t_message_bak表的字段信息 PRAGMAtable_info('t_message_bak')
获取到的表字段信息如下,可以看到有|cid|name|type|notnull|dflt_value|pk|这些数据库字段,我们只要用到name也就是字段名称这个字段就行了
sqlite>PRAGMAtable_info('t_message_bak'); +------+--------------------+---------+---------+------------+------+ |cid|name|type|notnull|dflt_value|pk| +------+--------------------+---------+---------+------------+------+ |0|messageID|TEXT|0|NULL|1| |1|messageType|INTEGER|0|NULL|0| |2|messageJsonContent|TEXT|0|NULL|0| |3|retriveTimeString|INTEGER|0|NULL|0| |4|postTimeString|INTEGER|0|NULL|0| |5|readState|INTEGER|0|NULL|0| +------+--------------------+---------+---------+------------+------+ 6行于数据集(0.01秒)
使用子查询进行数据迁移处理
INSERTINTOt_message(messageID,messageType,messageJsonContent,retriveTimeString, postTimeString,readState)SELECTmessageID,messageType,messageJsonContent,retriveTimeString, postTimeString,readStateFROMt_message_bak
把t_message_bak表中的messageID,messageType,messageJsonContent,retriveTimeString,postTimeString,readState这些字段的值复制到t_message表中
代码实现
接下来就到了代码的实现步骤了
//创建新的临时表,把数据导入临时表,然后用临时表替换原表 -(void)baseDBVersionControl{ NSString*version_old=ValueOrEmpty(MMUserDefault.dbVersion); NSString*version_new=[NSStringstringWithFormat:@"%@",DB_Version]; NSLog(@"dbVersionControlbefore:%@after:%@",version_old,version_new); //数据库版本升级 if(version_old!=nil&&![version_newisEqualToString:version_old]){ //获取数据库中旧的表 NSArray*existsTables=[selfsqliteExistsTables]; NSMutableArray*tmpExistsTables=[NSMutableArrayarray]; //修改表名,添加后缀“_bak”,把旧的表当做备份表 for(NSString*tablenameinexistsTables){ [tmpExistsTablesaddObject:[NSStringstringWithFormat:@"%@_bak",tablename]]; [self.databaseQueueinDatabase:^(FMDatabase*db){ NSString*sql=[NSStringstringWithFormat:@"ALTERTABLE%@RENAMETO%@_bak",tablename,tablename]; [dbexecuteUpdate:sql]; }]; } existsTables=tmpExistsTables; //创建新的表 [selfinitTables]; //获取新创建的表 NSArray*newAddedTables=[selfsqliteNewAddedTables]; //遍历旧的表和新表,对比取出需要迁移的表的字段 NSDictionary*migrationInfos=[selfgenerateMigrationInfosWithOldTables:existsTablesnewTables:newAddedTables]; //数据迁移处理 [migrationInfosenumerateKeysAndObjectsUsingBlock:^(NSString*newTableName,NSArray*publicColumns,BOOL*_Nonnullstop){ NSMutableString*colunmsString=[NSMutableStringnew]; for(inti=0;i*migrationInfos=[NSMutableDictionarydictionary]; for(NSString*newTableNameinnewTables){ NSString*oldTableName=[NSStringstringWithFormat:@"%@_bak",newTableName]; if([oldTablescontainsObject:oldTableName]){ //获取表数据库字段信息 NSArray*oldTableColumns=[selfsqliteTableColumnsWithTableName:oldTableName]; NSArray*newTableColumns=[selfsqliteTableColumnsWithTableName:newTableName]; NSArray*publicColumns=[selfpublicColumnsWithOldTableColumns:oldTableColumnsnewTableColumns:newTableColumns]; if(publicColumns.count>0){ [migrationInfossetObject:publicColumnsforKey:newTableName]; } } } returnmigrationInfos; } -(NSArray*)publicColumnsWithOldTableColumns:(NSArray*)oldTableColumnsnewTableColumns:(NSArray*)newTableColumns{ NSMutableArray*publicColumns=[NSMutableArrayarray]; for(NSString*oldTableColumninoldTableColumns){ if([newTableColumnscontainsObject:oldTableColumn]){ [publicColumnsaddObject:oldTableColumn]; } } returnpublicColumns; } -(NSArray*)sqliteTableColumnsWithTableName:(NSString*)tableName{ __blockNSMutableArray *tableColumes=[NSMutableArrayarray]; [self.databaseQueueinDatabase:^(FMDatabase*db){ NSString*sql=[NSStringstringWithFormat:@"PRAGMAtable_info('%@')",tableName]; FMResultSet*rs=[dbexecuteQuery:sql]; while([rsnext]){ NSString*columnName=[rsstringForColumn:@"name"]; [tableColumesaddObject:columnName]; } }]; returntableColumes; } -(NSArray*)sqliteExistsTables{ __blockNSMutableArray *existsTables=[NSMutableArrayarray]; [self.databaseQueueinDatabase:^(FMDatabase*db){ NSString*sql=@"SELECT*fromsqlite_masterWHEREtype='table'"; FMResultSet*rs=[dbexecuteQuery:sql]; while([rsnext]){ NSString*tablename=[rsstringForColumn:@"name"]; [existsTablesaddObject:tablename]; } }]; returnexistsTables; } -(NSArray*)sqliteNewAddedTables{ __blockNSMutableArray *newAddedTables=[NSMutableArrayarray]; [self.databaseQueueinDatabase:^(FMDatabase*db){ NSString*sql=@"SELECT*fromsqlite_masterWHEREtype='table'ANDnameNOTLIKE'%_bak'"; FMResultSet*rs=[dbexecuteQuery:sql]; while([rsnext]){ NSString*tablename=[rsstringForColumn:@"name"]; [newAddedTablesaddObject:tablename]; } }]; returnnewAddedTables; }
问题
sqlite删除表文件的大小不变的问题
如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!