IOSデータベースアップグレードデータ移行の詳細な例

sqlite_master から * を選択 WHERE type='table'

sqlite> SELECT * from sqlite_master WHERE type='table'
 ...> ;
+-------+---------------+---------------+----------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| タイプ | 名前 | tbl_name | ルートページ | sql |
+-------+---------------+---------------+----------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| テーブル | t_message_bak | t_message_bak | 2 | テーブル「t_message_bak」を作成します (messageID TEXT、messageType INTEGER、messageJsonContent TEXT、retriveTimeString INTEGER、postTimeString INTEGER、readState INTEGER、PRIMARY KEY(messageID)) |
| テーブル | t_message | t_message | 4 | CREATE TABLE t_message (
 メッセージIDテキスト、 
 メッセージタイプ INTEGER、
 messageJsonContent テキスト、 
 取得時間文字列 INTEGER、 
 postTimeString INTEGER、 
 読み取り状態 INTEGER、 
 列の追加 INTEGER、
 主キー(メッセージID)
) |
+-------+---------------+---------------+----------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
データセット内の 2 行 (0.03 秒)

-- t_message テーブルを t_message_bak テーブルに変更します ALTER TABLE t_message RENAME TO t_message_bak

-- t_message_bak テーブルのフィールド情報を取得します。PRAGMA table_info('t_message_bak')

sqlite> プラグマ table_info('t_message_bak');
+------+--------------------+----------+----------+----------+------+
| cid | 名前 | タイプ | notnull | dflt_value | pk |
+------+--------------------+----------+----------+----------+------+
| 0 | メッセージID | テキスト | 0 | NULL | 1 |
| 1 | メッセージタイプ | INTEGER | 0 | NULL | 0 |
| 2 | messageJsonContent | テキスト | 0 | NULL | 0 |
| 3 | 取得時間文字列 | INTEGER | 0 | NULL | 0 |
| 4 | postTimeString | INTEGER | 0 | NULL | 0 |
| 5 | 読み取り状態 | 整数 | 0 | NULL | 0 |
+------+--------------------+----------+----------+----------+------+
データセットの6行（0.01秒）

t_messageに挿入(メッセージID、メッセージタイプ、メッセージJsonContent、取得時間文字列、
 postTimeString、readState) SELECT messageID、messageType、messageJsonContent、retriveTimeString、
 postTimeString、t_message_bak からの readState

// 新しい一時テーブルを作成し、データを一時テーブルにインポートし、元のテーブルを一時テーブルに置き換えます - (void)baseDBVersionControl {
 NSString * version_old = ValueOrEmpty(MMUserDefault.dbVersion);
 NSString * version_new = [NSString stringWithFormat:@"%@", DB_Version];
 NSLog(@"dbVersionControl 前: %@ 後: %@",version_old,version_new);

 // データベースバージョンのアップグレード if (version_old != nil && ![version_new isEqualToString:version_old]) {

  // データベース内の古いテーブルを取得します NSArray* existsTables = [self sqliteExistsTables];
  NSMutableArray* tmpExistsTables = [NSMutableArray 配列];

  // テーブル名を変更し、サフィックス「_bak」を追加し、古いテーブルをバックアップテーブルとして使用します (NSString* tablename in existsTables) {
   [tmpExistsTables addObject:[NSString stringWithFormat:@"%@_bak", テーブル名]];
   [self.databaseQueue inDatabase:^(FMDatabase *db) {
    NSString* sql = [NSString stringWithFormat:@"ALTER TABLE %@ RENAME TO %@_bak", テーブル名, テーブル名];
    [db 実行更新:sql];
   }];
  }
  存在するテーブル = tmpExistsTables;

  // 新しいテーブルを作成します [self initTables];

  // 新しく作成されたテーブルを取得します NSArray* newAddedTables = [self sqliteNewAddedTables];

  // 古いテーブルと新しいテーブルを走査し、移行する必要があるテーブルのフィールドを比較して抽出します NSDictionary* migrationInfos = [self generateMigrationInfosWithOldTables:existsTables newTables:newAddedTables];

  // データ移行処理 [migrationInfos enumerateKeysAndObjectsUsingBlock:^(NSString* newTableName, NSArray* publicColumns, BOOL * _Nonnull stop) {
   NSMutableString* 列文字列 = [NSMutableString new];
   (int i = 0; i<publicColumns.count; i++) の場合 {
    [列文字列 appendString:publicColumns[i]];
    if (i != publicColumns.count-1) {
     [列文字列追加文字列:@", "];
    }
   }
   NSMutableString* sql = [NSMutableString new];
   [sql appendString:@"INSERT INTO "];
   [sql 追加文字列:新しいテーブル名];
   [sql 追加文字列:@"("];
   [sql 追加文字列:列文字列];
   [sql 追加文字列:@")"];
   [sql 追加文字列:@" SELECT "];
   [sql 追加文字列:列文字列];
   [sql appendString:@" FROM "];
   [sql 追加フォーマット:@"%@_bak", 新しいテーブル名];

   [self.databaseQueue inDatabase:^(FMDatabase *db) {
    [db 実行更新:sql];
   }];
  }];

  // バックアップテーブルを削除します [self.databaseQueue inDatabase:^(FMDatabase *db) {
   [db トランザクション開始];
   (NSString* oldTableName in existsTables) の場合 {
    NSString* sql = [NSString stringWithFormat:@"存在する場合はテーブルを削除 %@", oldTableName];
    [db 実行更新:sql];
   }
   [dbコミット];
  }];

  MMUserDefault.dbVersion = version_new;

 } それ以外 {
  MMUserDefault.dbVersion = version_new;
 }
}

- (NSDictionary*)generateMigrationInfosWithOldTables:(NSArray*)oldTables newTables:(NSArray*)newTables {
 NSMutableDictionary<NSString*, NSArray* >* migrationInfos = [NSMutableDictionary 辞書];
 (NSString* newTableName in newTables) の場合 {
  NSString* oldTableName = [NSString stringWithFormat:@"%@_bak", newTableName];
  if ([oldTables containsObject:oldTableName]) {
   // テーブルデータベースフィールド情報を取得します NSArray* oldTableColumns = [self sqliteTableColumnsWithTableName:oldTableName];
   NSArray* newTableColumns = [self sqliteTableColumnsWithTableName:newTableName];
   NSArray* publicColumns = [self publicColumnsWithOldTableColumns:oldTableColumns newTableColumns:newTableColumns];

   （publicColumns.count > 0）の場合{
    [migrationInfos setObject:publicColumns forKey:newTableName];
   }
  }
 }
 移行情報を返します。
}

- (NSArray*)publicColumnsWithOldTableColumns:(NSArray*)oldTableColumns newTableColumns:(NSArray*)newTableColumns {
 NSMutableArray* publicColumns = [NSMutableArray 配列];
 (NSString* oldTableColumn in oldTableColumns) の場合 {
  if ([newTableColumns containsObject:oldTableColumn]) {
   [publicColumns addObject:oldTableColumn];
  }
 }
 publicColumns を返します。
}

- (NSArray*)sqliteTableColumnsWithTableName:(NSString*)テーブル名 {
 __block NSMutableArray<NSString*>* tableColumes = [NSMutableArray 配列];
 [self.databaseQueue inDatabase:^(FMDatabase *db) {
  NSString* sql = [NSString stringWithFormat:@"PRAGMA table_info('%@')", tableName];
  FMResultSet *rs = [db executeQuery:sql];
  while ([rs next]) {
   NSString* columnName = [rs stringForColumn:@"name"];
   [tableColumes addObject:列名];
  }
 }];
 tableColumes を返します。
}

- (NSArray*)sqliteExistsTables {
 __block NSMutableArray<NSString*>* existsTables = [NSMutableArray 配列];
 [self.databaseQueue inDatabase:^(FMDatabase *db) {
  NSString* sql = @"sqlite_master から * を選択し、 type='table' を指定します";
  FMResultSet *rs = [db executeQuery:sql];
  while ([rs next]) {
   NSString* テーブル名 = [rs stringForColumn:@"name"];
   [existsTables addObject:テーブル名];
  }
 }];
 existsTables を返します。
}

- (NSArray*)sqlite新しく追加されたテーブル{
 __block NSMutableArray<NSString*>* newAddedTables = [NSMutableArray 配列];
 [self.databaseQueue inDatabase:^(FMDatabase *db) {
  NSString* sql = @"sqlite_master から * を選択し、type='table' かつ name が '%_bak' ではない場合";
  FMResultSet *rs = [db executeQuery:sql];
  while ([rs next]) {
   NSString* テーブル名 = [rs stringForColumn:@"name"];
   [newAddedTables addObject:テーブル名];
  }
 }];
 newAddedTablesを返します。
}