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