IOS 数据库升级数据迁移的实例详解

2023-09-27 10:14:17 298

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*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删除表文件的大小不变的问题

如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

IOS 数据库升级数据迁移的实例详解

热门推荐

随机推荐