Method: EventSource::Postgres::Get::Last#get_record

Defined in:
lib/event_source/postgres/get/last.rb

#get_record(stream_name) ⇒ Object 



45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/event_source/postgres/get/last.rb', line 45

def get_record(stream_name)
  logger.trace { "Getting last record (Stream: #{stream_name})" }

  select_statement = SelectStatement.build(stream_name)

  records = session.execute(select_statement.sql)

  logger.debug { "Finished getting record (Stream: #{stream_name})" }

  return nil if records.ntuples == 0

  records[0]
end