Contents

class Baza::Driver::Sqlite3::UnbufferedResult
  def initialize(driver, statement)
    @statement = statement
    @statement.execute
    @columns = statement.columns.map { |column| column.to_sym }
  end

  def fetch
    return nil if @closed

    array = @statement.step

    if @statement.done?
      close
      return nil
    end

    return Hash[*@columns.zip(array).flatten] if array
  end

  def each
    while data = fetch
      yield data
    end
  end

private

  def close
    @statement.close
    @closed = true
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
baza-0.0.19	lib/baza/drivers/sqlite3/unbuffered_result.rb
baza-0.0.18	lib/baza/drivers/sqlite3/unbuffered_result.rb