Class: KnjDB_mysql_unbuffered_result

Inherits:

Object

• Object
• KnjDB_mysql_unbuffered_result

Defined in:

lib/knj/knjdb/drivers/mysql/knjdb_mysql.rb

Instance Method Summary

• #each ⇒ Object
• #fetch ⇒ Object
• #initialize(conn, opts, result) ⇒ KnjDB_mysql_unbuffered_result constructor

  A new instance of KnjDB_mysql_unbuffered_result.

• #load_keys ⇒ Object

Constructor Details

#initialize(conn, opts, result) ⇒ KnjDB_mysql_unbuffered_result

Returns a new instance of KnjDB_mysql_unbuffered_result.

# File 'lib/knj/knjdb/drivers/mysql/knjdb_mysql.rb', line 374

def initialize(conn, opts, result)
  @conn = conn
  @result = result
  
  if !opts.key?(:result) or opts[:result] == "hash"
    @as_hash = true
  elsif opts[:result] == "array"
    @as_hash = false
  else
    raise "Unknown type of result: '#{opts[:result]}'."
  end
end

Instance Method Details

#each ⇒ Object

# File 'lib/knj/knjdb/drivers/mysql/knjdb_mysql.rb', line 434

def each
  while data = self.fetch
    yield(data)
  end
end

#fetch ⇒ Object

# File 'lib/knj/knjdb/drivers/mysql/knjdb_mysql.rb', line 395

def fetch
  if @enum
    begin
      ret = @enum.next
    rescue StopIteration
      @enum = nil
      @res = nil
    end
  end
  
  if !ret and !@res and !@enum
    begin
      @res = @conn.use_result
      @enum = @res.to_enum
      ret = @enum.next
    rescue Mysql::Error
      #Reset it to run non-unbuffered again and then return false.
      @conn.query_with_result = true
      return false
    rescue StopIteration
      sleep 0.1
      retry
    end
  end
  
  if !@as_hash
    return ret
  else
    self.load_keys if !@keys
    
    ret_h = {}
    @keys.each_index do |key_no|
      ret_h[@keys[key_no]] = ret[key_no]
    end
    
    return ret_h
  end
end

#load_keys ⇒ Object

# File 'lib/knj/knjdb/drivers/mysql/knjdb_mysql.rb', line 387

def load_keys
  @keys = []
  keys = @res.fetch_fields
  keys.each do |key|
    @keys << key.name.to_sym
  end
end