module ActiveQuery

Constants

VERSION

Attributes

config[W]

Public Class Methods

async_run(query) { |row| ... } click to toggle source

async_exec(sql) {|pg_result| block } This function has the same behavior as sync_exec, but is implemented using the asynchronous command processing API of libpq.

# File lib/active_query.rb, line 52
def self.async_run(query, &block)
  con_str = ActiveQuery.config.connection
 
  if query.is_a? Symbol
    query = self.send(query)
  end

  PostgresqlAdapter.open(con_str) do |conn| 
    conn.send_query(query)
    conn.set_single_row_mode
    conn.get_result.stream_each do |row|
       yield(row)
    end
  end
end
config() click to toggle source 
# File lib/active_query.rb, line 17
def self.config
  @config ||= Configuration.new
end
configure() { |config| ... } click to toggle source 
# File lib/active_query.rb, line 25
def self.configure
  yield(config)
end
reset() click to toggle source 
# File lib/active_query.rb, line 21
def self.reset
  @config = Configuration.new
end
run(query) click to toggle source

WIP runners… Full-Scan

# File lib/active_query.rb, line 31
def self.run(query)
  if query.is_a? Symbol
    query = self.send(query)
  end
  con_str = ActiveQuery.config.connection
  PostgresqlAdapter.open(con_str) { |c| c.exec(query) }
end
run_params(query, params) click to toggle source 
# File lib/active_query.rb, line 39
def self.run_params(query, params)
  if query.is_a? Symbol
    query = self.send(query)
  end
  con_str = ActiveQuery.config.connection
  PostgresqlAdapter.open(con_str) do |conn| 
    conn.exec_params(query, params) 
  end
end