Class: SchemaFerry::Source::MysqlReader

Inherits:
Object
  • Object
show all
Defined in:
lib/schema_ferry/source/mysql_reader.rb

Instance Method Summary collapse

Constructor Details

#initialize(url) ⇒ MysqlReader

Returns a new instance of MysqlReader.



6
7
8
 
# File 'lib/schema_ferry/source/mysql_reader.rb', line 6

def initialize(url)
  @url = url
end

Instance Method Details

#read_all ⇒ Object 



10
11
12
13
14
15
16
17
18
 
# File 'lib/schema_ferry/source/mysql_reader.rb', line 10

def read_all
  ConnectionRegistry.with_connection(@url) do |conn|
    conn.tables.sort.map { |table_name| read_table(conn, table_name) }
  end
rescue ConnectionError
  raise
rescue StandardError => e
  raise ReadError, e.message
end