Sqlite DB Migration (React-native)

react-native-sqlite-migrations.js

  /**
   * extend this to make new migrations
   */
import * as Sentry from "@sentry/react-native";
  
export class RNSqliteMigration {
    constructor(db, sql, version) {
      this.version = version;
      this._db = db;
      this._sql = sql;
    }
  
    execute(){
      function exec(tx, sql) {
        tx.executeSql(sql);
      }

      function migrateV0toV1(tx){
          if (Array.isArray(this._sql)) {
            this._sql.forEach(s => exec(tx,s));
          } else {
            exec(tx,this._sql);
          }
      }
      
      try{
      this._db.transaction(txn => {
        txn.executeSql("SELECT version FROM schema_migrations LIMIT 1", [], (tx, result) => {
            version = (result.rows.raw()).length;
          while(version < this.version) {
            switch(version){
                case 0: migrateV0toV1(tx); break; 
                /* you can have more migration based on the version */
                // case 1: migrateV1toV2(tx); break; 
            }
            version = this.version;
            tx.executeSql('INSERT INTO schema_migrations (version) VALUES (:version)', [this.version]);
          }
        });
      }, error => {
        Sentry.captureException(error, { logger: 'sqlite.migrations' });
      });
    }catch(error){
        console.log("catch error ",error)
    }
  }
}


//Usage

/* import the class `RNSqliteMigration` wherever you want to use */

const sql = [
            "UPDATE table_name SET lastSync=NULL where 1",
            "UPDATE TABLE table_name ADD COLUMN id TEXT",
            "CREATE TABLE IF NOT EXISTS table_name(id VARCHAR(255) NOT NULL UNIQUE PRIMARY KEY, code VARCHAR(20))"
            ];

     /*         OR          */

const sql = "UPDATE table_name SET lastSync=NULL where 1";

try{
   const migration = new RNSqliteMigration(this.db, sql, 1);
   migration.execute();
}
catch(error){
   console.log("Error of migration: ", error)
}