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 



103
104
105
106
107
108
109
110
111
112
113
 
# File 'lib/stack-service-base/fiber_pool.rb', line 103

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