Detailliertes Beispiel für die Datenmigration bei einem IOS-Datenbank-Upgrade

SELECT * von sqlite_master WHERE Typ = "Tabelle"

sqlite> SELECT * from sqlite_master WHERE Typ='Tabelle'
 ...> ;
+----------+------------------+-----------+----------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Typ | Name | Tabellenname | Stammseite | SQL |
+----------+------------------+-----------+----------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Tabelle | t_message_bak | t_message_bak | 2 | TABELLE "t_message_bak" ERSTELLEN (Nachrichten-ID TEXT, Nachrichtentyp INTEGER, Nachrichten-Json-Inhalt TEXT, Zeitzeichenfolge abrufen INTEGER, Zeitzeichenfolge posten INTEGER, Status lesen INTEGER, PRIMÄRSCHLÜSSEL(Nachrichten-ID)) |
| Tabelle | t_Nachricht | t_Nachricht | 4 | TABELLE ERSTELLEN t_Nachricht (
 Nachrichten-ID TEXT, 
 Nachrichtentyp INTEGER,
 messageJsonContent TEXT, 
 retriveTimeString INTEGER, 
 postTimeString INTEGER, 
 Lesestatus INTEGER, 
 Spalte hinzufügen INTEGER,
 PRIMARY KEY(Nachrichten-ID)
) |
+----------+------------------+-----------+----------+---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
2 Zeilen im Datensatz (0,03 Sekunden)

-- Ändert die Tabelle t_message in die Tabelle t_message_bak ALTER TABLE t_message RENAME TO t_message_bak

-- Holen Sie sich die Feldinformationen der Tabelle t_message_bak PRAGMA table_info('t_message_bak')

sqlite> PRAGMA table_info('t_message_bak');
+------+--------------------+---------+---------+------------+------+
| cid | Name | Typ | nicht null | dflt_value | pk |
+------+--------------------+---------+---------+------------+------+
| 0 | Nachrichten-ID | TEXT | 0 | NULL | 1 |
| 1 | Nachrichtentyp | INTEGER | 0 | NULL | 0 |
| 2 | messageJsonContent | TEXT | 0 | NULL | 0 |
| 3 | retriveTimeString | INTEGER | 0 | NULL | 0 |
| 4 | postTimeString | INTEGER | 0 | NULL | 0 |
| 5 | Lesestatus | INTEGER | 0 | NULL | 0 |
+------+--------------------+---------+---------+------------+------+
6 Zeilen im Datensatz (0,01 Sekunden)

INSERT INTO t_message(Nachrichten-ID, Nachrichtentyp, Nachrichten-JSON-Inhalt, Zeitzeichenfolge abrufen,
 postTimeString, readState) SELECT Nachrichten-ID, Nachrichtentyp, Nachrichten-Json-Inhalt, retriveTimeString,
 postTimeString, readState VON t_message_bak

// Eine neue temporäre Tabelle erstellen, die Daten in die temporäre Tabelle importieren und dann die Originaltabelle durch die temporäre Tabelle ersetzen - (void)baseDBVersionControl {
 NSString * version_alt = ValueOrEmpty(MMUserDefault.dbVersion);
 NSString * version_new = [NSString stringWithFormat:@"%@", DB_Version];
 NSLog(@"dbVersionControl vor: %@ nach: %@",version_alt,version_neu);

 // Upgrade der Datenbankversion if (version_old != nil && ![version_new isEqualToString:version_old]) {

  // Holen Sie die alten Tabellen in der Datenbank NSArray* existsTables = [self sqliteExistsTables];
  NSMutableArray* tmpExistsTables = [NSMutableArray-Array];

  // Ändern Sie den Tabellennamen, fügen Sie das Suffix „_bak“ hinzu und verwenden Sie die alte Tabelle als Sicherungstabelle für (NSString* tablename in existsTables) {
   [tmpExistsTables addObject:[NSString stringWithFormat:@"%@_bak", Tabellenname]];
   [self.databaseQueue inDatabase:^(FMDatabase *db) {
    NSString* sql = [NSString stringWithFormat:@"ALTER TABLE %@ RENAME TO %@_bak", Tabellenname, Tabellenname];
    [db ausführenUpdate:sql];
   }];
  }
  existsTables = tmpExistsTables;

  // Eine neue Tabelle erstellen [self initTables];

  // Holen Sie die neu erstellte Tabelle NSArray* newAddedTables = [self sqliteNewAddedTables];

  // Die alte und die neue Tabelle durchlaufen, die Felder der Tabelle vergleichen und extrahieren, die migriert werden müssen NSDictionary* migrationInfos = [self generateMigrationInfosWithOldTables:existsTables newTables:newAddedTables];

  // Datenmigration wird verarbeitet [migrationInfos enumerateKeysAndObjectsUsingBlock:^(NSString* newTableName, NSArray* publicColumns, BOOL * _Nonnull stop) {
   NSMutableString* colunmsString = [NSMutableString neu];
   für (int i = 0; i<publicColumns.count; i++) {
    [SpaltenString appendString:öffentlicheSpalten[i]];
    wenn (i != publicColumns.count-1) {
     [Spaltenzeichenfolge Anfügezeichenfolge:@", "];
    }
   }
   NSMutableString* sql = [NSMutableString neu];
   [sql anhängenString:@"INSERT INTO "];
   [sql appendString:neuerTabellenname];
   [sql anhängenString:@"("];
   [sql anhängenString:SpaltenString];
   [sql anhängenString:@")"];
   [sql Anfügezeichenfolge:@" AUSWÄHLEN "];
   [sql anhängenString:SpaltenString];
   [sql anhängenString:@" FROM "];
   [sql appendFormat:@"%@_bak", neuerTabellenname];

   [self.databaseQueue inDatabase:^(FMDatabase *db) {
    [db ausführenUpdate:sql];
   }];
  }];

  // Lösche die Backup-Tabelle [self.databaseQueue inDatabase:^(FMDatabase *db) {
   [db beginTransaktion];
   für (NSString* alterTabellenname in existierTabellen) {
    NSString* sql = [NSString stringWithFormat:@"DROP TABLE IF EXISTS %@", alterTabellenname];
    [db ausführenUpdate:sql];
   }
   [Datenbank-Commit];
  }];

  MMUserDefault.dbVersion = version_new;

 } anders {
  MMUserDefault.dbVersion = version_new;
 }
}

- (NSDictionary*)generateMigrationInfosWithOldTables:(NSArray*)oldTables newTables:(NSArray*)newTables {
 NSMutableDictionary<NSString*, NSArray* >* migrationInfos = [NSMutableDictionary-Wörterbuch];
 für (NSString* neuerTabellenname in neueTabellen) {
  NSString* alterTabellenname = [NSString stringWithFormat:@"%@_bak", neuerTabellenname];
  if ([alteTabellen enthältObjekt:alterTabellenname]) {
   //Feldinformationen der Tabellendatenbank abrufen NSArray* oldTableColumns = [self sqliteTableColumnsWithTableName:oldTableName];
   NSArray* neueTabellenspalten = [self sqliteTableColumnsWithTableName:neuerTabellenname];
   NSArray* publicColumns = [self publicColumnsWithOldTableColumns:alteTableColumns newTableColumns:neueTableColumns];

   wenn (publicColumns.count > 0) {
    [migrationInfos setObject:publicColumns fürKey:newTableName];
   }
  }
 }
 Migrationsinformationen zurückgeben;
}

- (NSArray*)publicColumnsWithOldTableColumns:(NSArray*)oldTableColumns newTableColumns:(NSArray*)newTableColumns {
 NSMutableArray* publicColumns = [NSMutableArray-Array];
 für (NSString* alteTabellenspalte in alteTabellenspalten) {
  if ([neueTabellenspalten enthältObjekt:alteTabellenspalte]) {
   [publicColumns addObject:alteTabellenspalte];
  }
 }
 öffentliche Spalten zurückgeben;
}

- (NSArray*)sqliteTableColumnsWithTableName:(NSString*)tableName {
 __block NSMutableArray<NSString*>* tableColumes = [NSMutableArray-Array];
 [self.databaseQueue inDatabase:^(FMDatabase *db) {
  NSString* sql = [NSString stringWithFormat:@"PRAGMA table_info('%@')", Tabellenname];
  FMResultSet *rs = [db ausführenAbfrage:sql];
  während ([rs weiter]) {
   NSString* Spaltenname = [rs Zeichenfolge für Spalte:@"Name"];
   [Tabellenspalten addObject:Spaltenname];
  }
 }];
 gibt Tabellenspalten zurück;
}

- (NSArray*)sqliteExistsTables {
 __block NSMutableArray<NSString*>* existsTables = [NSMutableArray-Array];
 [self.databaseQueue inDatabase:^(FMDatabase *db) {
  NSString* sql = @"SELECT * from sqlite_master WHERE Typ='Tabelle'";
  FMResultSet *rs = [db ausführenAbfrage:sql];
  während ([rs weiter]) {
   NSString* Tabellenname = [rs stringForColumn:@"name"];
   [existsTables addObject:Tabellenname];
  }
 }];
 gibt existiereTabellen zurück;
}

- (NSArray*)sqliteNewAddedTables {
 __block NSMutableArray<NSString*>* newAddedTables = [NSMutableArray-Array];
 [self.databaseQueue inDatabase:^(FMDatabase *db) {
  NSString* sql = @"SELECT * from sqlite_master WHERE Typ='Tabelle' UND Name NICHT WIE '%_bak'";
  FMResultSet *rs = [db ausführenAbfrage:sql];
  während ([rs weiter]) {
   NSString* Tabellenname = [rs stringForColumn:@"name"];
   [newAddedTables addObject:Tabellenname];
  }
 }];
 gibt neue hinzugefügte Tabellen zurück;
}