Sha256: 1c3d60095e569f61781f9e0e055c99cf6b7759128e9c79f97bbd7ca5e19ea5ea
Contents?: true
Size: 1.43 KB
Versions: 14
Compression:
Stored size: 1.43 KB
Contents
require 'informix' Sequel.require 'adapters/shared/informix' module Sequel module Informix class Database < Sequel::Database include DatabaseMethods set_adapter_scheme :informix def connect(server) opts = server_opts(server) ::Informix.connect(opts[:database], opts[:user], opts[:password]) end # Returns number of rows affected def execute_dui(sql, opts={}) synchronize(opts[:server]){|c| log_yield(sql){c.immediate(sql)}} end alias_method :do, :execute_dui def execute(sql, opts={}) synchronize(opts[:server]){|c| yield log_yield(sql){c.cursor(sql)}} end alias_method :query, :execute private def disconnect_connection(c) c.close end end class Dataset < Sequel::Dataset include DatasetMethods Database::DatasetClass = self def fetch_rows(sql) execute(sql) do |cursor| begin col_map = nil cursor.open.each_hash do |h| unless col_map col_map = {} @columns = h.keys.map{|k| col_map[k] = output_identifier(k)} end h2 = {} h.each{|k,v| h2[col_map[k]||k] = v} yield h2 end ensure cursor.respond_to?(:free) ? cursor.free : cursor.drop end end self end end end end
Version data entries
14 entries across 14 versions & 1 rubygems