Method: Oculus::Connection::Postgres#execute

Defined in:
lib/oculus/connection/postgres.rb

#execute(sql) ⇒ Object



15
16
17
18
19
20
# File 'lib/oculus/connection/postgres.rb', line 15

def execute(sql)
  results = @connection.exec(sql)
  [results.fields] + results.values if results
rescue ::PG::Error => e
  raise Connection::Error.new(e.message)
end