class Bricolage::PostgresConnection::Cursor

Attributes

name[R]

Public Class Methods

new(name, conn, logger) click to toggle source
# File lib/bricolage/postgresconnection.rb, line 223
def initialize(name, conn, logger)
  @name = name
  @conn = conn
  @logger = logger
end

Public Instance Methods

each_result_set(fetch_size = 5000) { |rs| ... } click to toggle source
# File lib/bricolage/postgresconnection.rb, line 231
def each_result_set(fetch_size = 5000)
  while true
    @conn.execute_query("fetch #{fetch_size} in #{@name}") {|rs|
      return if rs.values.empty?
      yield rs
    }
  end
end