Method: Sequel::Trilogy::Database#execute

Defined in:
lib/sequel/adapters/trilogy.rb

#execute(sql, opts) ⇒ Object

Execute the given SQL on the given connection and yield the result.



33
34
35
36
37
38
39
40
41
42
# File 'lib/sequel/adapters/trilogy.rb', line 33

def execute(sql, opts)
  r = synchronize(opts[:server]) do |conn|
    log_connection_yield((log_sql = opts[:log_sql]) ? sql + log_sql : sql, conn) do
      conn.query_with_flags(sql, timezone.nil? || timezone == :local ? LOCAL_TIME_QUERY_FLAGS : QUERY_FLAGS)
    end
  end
  yield r
rescue ::Trilogy::Error => e
  raise_error(e)
end