def import(csv)
    raw_connection.exec("COPY emails(contact_id, to_address, email_subject_id, generation_id, email_template_id, name) FROM STDIN WITH CSV HEADER")
    raw_connection.put_copy_data(csv)
    raw_connection.put_copy_end
  end