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

Version Path
sequel-3.40.0 lib/sequel/adapters/informix.rb
sequel-3.39.0 lib/sequel/adapters/informix.rb
sequel-3.38.0 lib/sequel/adapters/informix.rb
sequel-3.37.0 lib/sequel/adapters/informix.rb
sequel-3.36.1 lib/sequel/adapters/informix.rb
sequel-3.36.0 lib/sequel/adapters/informix.rb
sequel-3.35.0 lib/sequel/adapters/informix.rb
sequel-3.34.1 lib/sequel/adapters/informix.rb
sequel-3.34.0 lib/sequel/adapters/informix.rb
sequel-3.33.0 lib/sequel/adapters/informix.rb
sequel-3.32.0 lib/sequel/adapters/informix.rb
sequel-3.31.0 lib/sequel/adapters/informix.rb
sequel-3.30.0 lib/sequel/adapters/informix.rb
sequel-3.29.0 lib/sequel/adapters/informix.rb