Method: PgSync::Sync#confirm_tables_exist

Defined in:
lib/pgsync/sync.rb

#confirm_tables_exist(data_source, tables, description) ⇒ Object



90
91
92
93
94
95
96
97
98
# File 'lib/pgsync/sync.rb', line 90

def confirm_tables_exist(data_source, tables, description)
  tables.keys.each do |table|
    unless data_source.table_exists?(table)
      raise Error, "Table does not exist in #{description}: #{table}"
    end
  end
ensure
  data_source.close
end