Class: Hyrax::Works::MigrationService

Inherits:
Object
  • Object
show all
Defined in:
app/services/hyrax/works/migration_service.rb

Class Method Summary collapse

Class Method Details

.migrate_data(predicate_from, predicate_to, work) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Migrate data

API:

  • private



25
26
27
28
29
30
31
 
# File 'app/services/hyrax/works/migration_service.rb', line 25

def self.migrate_data(predicate_from, predicate_to, work)
  orm = Ldp::Orm.new(work.ldp_source)
  orm.value(predicate_from).each { |val| orm.graph.insert([orm.resource.subject_uri, predicate_to, val.to_s]) }
  orm.graph.delete([orm.resource.subject_uri, predicate_from, nil])
  orm.save
  Hyrax.logger.info " Data migrated from #{predicate_from} to #{predicate_to} - id: #{work.id}"
end

.migrate_predicate(predicate_from, predicate_to, works_to_update = ActiveFedora::Base.all) ⇒ Object

Migrate data stored in FCrepo from one predicate to another

The main use case is where the predicate used for a specific property is changed.
Data already stored in Fedora under the original predicate needs to be transfered
and the original data cleaned up.

API:

  • public



11
12
13
14
15
16
17
18
19
20
 
# File 'app/services/hyrax/works/migration_service.rb', line 11

def self.migrate_predicate(predicate_from, predicate_to, works_to_update = ActiveFedora::Base.all)
  migrated = 0
  Hyrax.logger.info "*** Migrating #{predicate_from} to #{predicate_to} in #{works_to_update.count} works"
  works_to_update.each do |work|
    next unless work.ldp_source.content.include?(predicate_from.to_s)
    migrate_data(predicate_from, predicate_to, work)
    migrated += 1
  end
  Hyrax.logger.info "--- Migration Complete (#{migrated} migrated)"
end