migrate<T extends Model> static method

Future<void> migrate<T extends Model>({ required T constructor(Map<String, dynamic>), Map<String, String>? columnDefinitions, })

Implementation

static Future<void> migrate<T extends Model>({required T Function(Map<String, dynamic>) constructor, Map<String, String>? columnDefinitions}) async {
  _jsonConstructors[T] = constructor;

  try {
    if (columnDefinitions != null && columnDefinitions.isNotEmpty) {
      final tableName = _getTableName<T>();
      final allColumns = {..._columnDefinitions, ...columnDefinitions};

      final columnsDef = allColumns.entries.map((e) => '${e.key} ${e.value}').join(', ');

      await _database.execute('''
      CREATE TABLE IF NOT EXISTS $tableName (
        $columnsDef
      )
    ''');

      // Performance indexes
      await _database.execute('''
      CREATE INDEX IF NOT EXISTS idx_${tableName}_uuid
      ON $tableName (uuid)
    ''');

      await _database.execute('''
      CREATE INDEX IF NOT EXISTS idx_${tableName}_created_at
      ON $tableName (created_at)
    ''');
    }
  }catch(e, s) {
    App().archeryLogger.error("Migration Error", {"origin": "PostgresModel.migrate", "error": e.toString(), "stack": s.toString()});
  }


}