Method: Oculus::Connection::Mysql2#execute

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

#execute(sql) ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/oculus/connection/mysql2.rb', line 10

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