Method: Dataflow::Adapters::MongoDbAdapter#restore

Defined in:
lib/dataflow/adapters/mongo_db_adapter.rb

#restore(filepath:, dataset_name:) ⇒ Object



239
240
241
242
243
244
245
246
247
# File 'lib/dataflow/adapters/mongo_db_adapter.rb', line 239

def restore(filepath:, dataset_name:)
  options = "--archive=#{filepath} --db=#{@settings.db_name} --collection=#{dataset_name} "
  options += "--host=#{@settings.db_host} " if @settings.db_host.present?
  options += "--port=#{@settings.db_port} " if @settings.db_port.present?
  options += "--username=#{@settings.db_user} " if @settings.db_user.present?
  options += "--password=#{@settings.db_password} " if @settings.db_password.present?

  `mongorestore #{options} --drop --gzip`
end