IOS数据库升级数据迁移的示例分析

2025-03-25 技术教程

这篇文章主要介绍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')

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<publicColumns.count;i++){[colunmsStringappendString:publicColumns[i]];if(i!=publicColumns.count-1){[colunmsStringappendString:@","];}}NSMutableString*sql=[NSMutableStringnew];[sqlappendString:@"INSERTINTO"];[sqlappendString:newTableName];[sqlappendString:@"("];[sqlappendString:colunmsString];[sqlappendString:@")"];[sqlappendString:@"SELECT"];[sqlappendString:colunmsString];[sqlappendString:@"FROM"];[sqlappendFormat:@"%@_bak",newTableName];[self.databaseQueueinDatabase:^(FMDatabase*db){[dbexecuteUpdate:sql];}];}];//删除备份表[self.databaseQueueinDatabase:^(FMDatabase*db){[dbbeginTransaction];for(NSString*oldTableNameinexistsTables){NSString*sql=[NSStringstringWithFormat:@"DROPTABLEIFEXISTS%@",oldTableName];[dbexecuteUpdate:sql];}[dbcommit];}];MMUserDefault.dbVersion=version_new;}else{MMUserDefault.dbVersion=version_new;}}-(NSDictionary*)generateMigrationInfosWithOldTables:(NSArray*)oldTablesnewTables:(NSArray*)newTables{NSMutableDictionary<NSString*,NSArray*>*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<NSString*>*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<NSString*>*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<NSString*>*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;}

以上是“IOS数据库升级数据迁移的示例分析”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注亿速云行业资讯频道！