class Sequel::Rbhive::Dataset

Constants

APOS
STRING_ESCAPES
STRING_ESCAPE_RE

Public Instance Methods

fetch_rows(sql) { |row| ... } click to toggle source
    # File lib/sequel/adapters/rbhive.rb
155 def fetch_rows(sql)
156   execute(sql) do |conn, result|
157     op_handle = result.operationHandle
158     columns, type_nums = conn.get_column_info(op_handle)
159     self.columns = columns.map!{|c| output_identifier(c)}
160     conversion_procs = db.conversion_procs
161     convertors = conversion_procs.values_at(*type_nums)
162     #cursor.typecast_map['timestamp'] = db.method(:to_application_timestamp)
163     conn.yield_hash_rows(op_handle, columns, convertors) do |row|
164       yield row
165     end
166   end
167 end

Private Instance Methods

literal_string_append(sql, s) click to toggle source
    # File lib/sequel/adapters/rbhive.rb
171 def literal_string_append(sql, s)
172   sql << APOS << s.to_s.gsub(STRING_ESCAPE_RE){|m| STRING_ESCAPES[m]} << APOS
173 end