Class: Sequel::Postgres::Adapter

Inherits:
Object
  • Object
show all
Defined in:
lib/stack-service-base/fiber_pool.rb

Instance Method Summary collapse

Instance Method Details

#execute_query(sql, args) ⇒ Object 



101
102
103
104
105
106
107
108
109
 
# File 'lib/stack-service-base/fiber_pool.rb', line 101

def execute_query(sql, args)
  $stdout.puts "F:#{Fiber.current.__id__} : T:#{Thread.current.__id__} : A:#{self.__id__} : #{sql[0..60]}" unless defined? PERFORMANCE
  # log "query: #{sql.slice(0, 60)}"
  @db.log_connection_yield(sql, self, args){args ? async_exec_params(sql, args) : async_exec(sql)}
rescue => e
  # log "Error: #{e.message}"
  $stdout.puts e.message
  raise
end