Module: Sequel::ActiveRecordConnection::Postgres

Defined in:
lib/sequel/extensions/activerecord_connection/postgres.rb

Instance Method Summary collapse

Instance Method Details

#execute(sql, opts = OPTS) ⇒ Object



4
5
6
7
8
9
10
11
12
13
14
15
16
# File 'lib/sequel/extensions/activerecord_connection/postgres.rb', line 4

def execute(sql, opts=OPTS)
  result = activerecord_connection.execute(sql)

  if block_given?
    yield result
  else
    result.cmd_tuples
  end
rescue ActiveRecord::StatementInvalid => exception
  raise_error(exception.cause, classes: database_error_classes)
ensure
  result.clear if result
end