class Multiwoven::Integrations::Source::Oracle::Client

def query(connection, query)
  records = []
  query = reformat_query(query)
  cursor = connection.exec(query)
  columns = cursor.get_col_names
  while (row = cursor.fetch)
    data_hash = columns.zip(row).to_h
    records << RecordMessage.new(data: data_hash, emitted_at: Time.now.to_i).to_multiwoven_message
  end
  records
end