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