Class: Flydata::SourcePostgresql::ParseDumpAndSend

Inherits:
Flydata::Source::ParseDumpAndSend show all
Includes:
PostgresqlComponent
Defined in:
lib/flydata/source_postgresql/parse_dump_and_send.rb

Instance Method Summary collapse

Methods included from PostgresqlComponent

#de_prefs

Methods inherited from Flydata::Source::ParseDumpAndSend

inherited

Methods inherited from Flydata::Source::Component

#initialize

Constructor Details

This class inherits a constructor from Flydata::Source::Component

Instance Method Details

#parse_dump(dump_pos_info, dmpio, create_table_block, insert_record_block, check_point_block) ⇒ Object

dump format dump file is in msgpack. Each table data starts with a source table hash followed by row arrays.

“columns”=>{“id”=>{“column_name”=>“id”, “format_type”=>“bigint”, “name”=>“format_type”=>“character varying”, “another_id”=>“format_type”=>“integer”}}

“2”, “hay”, “1”
“3”, “hoe”, “2” 


22
23
24
25
26
27
 
# File 'lib/flydata/source_postgresql/parse_dump_and_send.rb', line 22

def parse_dump(dump_pos_info, dmpio, create_table_block, insert_record_block,
               check_point_block)
  parser = DumpParser.new(dump_pos_info, dmpio, create_table_block,
                          insert_record_block, check_point_block)
  parser.parse_all
end

#value_converters ⇒ Object 



11
12
13
 
# File 'lib/flydata/source_postgresql/parse_dump_and_send.rb', line 11

def value_converters
  FlydataCore::TableDef::PostgresqlTableDef::VALUE_CONVERTERS
end