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 153 def fetch_rows(sql) 154 execute(sql) do |conn, result| 155 op_handle = result.operationHandle 156 columns, type_nums = conn.get_column_info(op_handle) 157 @columns = columns.map!{|c| output_identifier(c)} 158 conversion_procs = db.conversion_procs 159 convertors = conversion_procs.values_at(*type_nums) 160 #cursor.typecast_map['timestamp'] = db.method(:to_application_timestamp) 161 conn.yield_hash_rows(op_handle, columns, convertors) do |row| 162 yield row 163 end 164 end 165 end
Private Instance Methods
literal_string_append(sql, s)
click to toggle source
# File lib/sequel/adapters/rbhive.rb 169 def literal_string_append(sql, s) 170 sql << APOS << s.to_s.gsub(STRING_ESCAPE_RE){|m| STRING_ESCAPES[m]} << APOS 171 end