Sha256: 74ffc95c139b189464a4b6ed02e8671855bc1bbc2b294c066a5c60194394130b
Contents?: true
Size: 1.85 KB
Versions: 9
Compression:
Stored size: 1.85 KB
Contents
module Sequel
module JDBC
# Database and Dataset support for AS400 databases accessed via JDBC.
module AS400
# Instance methods for AS400 Database objects accessed via JDBC.
module DatabaseMethods
# AS400 uses the :as400 database type.
def database_type
:as400
end
# Return Sequel::JDBC::AS400::Dataset object with the given opts.
def dataset(opts=nil)
Sequel::JDBC::AS400::Dataset.new(self, opts)
end
# TODO: Fix for AS400
def last_insert_id(conn, opts={})
nil
end
end
# Dataset class for AS400 datasets accessed via JDBC.
class Dataset < JDBC::Dataset
WILDCARD = Sequel::LiteralString.new('*').freeze
# AS400 needs to use a couple of subselects for all limits and offsets.
def select_sql
return super unless l = @opts[:limit]
o = @opts[:offset] || 0
order = @opts[:order]
dsa1 = dataset_alias(1)
dsa2 = dataset_alias(2)
rn = row_number_column
irn = Sequel::SQL::Identifier.new(rn).qualify(dsa2)
subselect_sql(unlimited.
from_self(:alias=>dsa1).
select_more(Sequel::SQL::QualifiedIdentifier.new(dsa1, WILDCARD),
Sequel::SQL::WindowFunction.new(SQL::Function.new(:ROW_NUMBER), Sequel::SQL::Window.new(:order=>order)).as(rn)).
from_self(:alias=>dsa2).
select(Sequel::SQL::QualifiedIdentifier.new(dsa2, WILDCARD)).
where((irn > o) & (irn <= l + o)))
end
def supports_window_functions?
true
end
private
# The alias to use for the row_number column when emulating LIMIT and OFFSET
def row_number_column
:x_sequel_row_number_x
end
end
end
end
end
Version data entries
9 entries across 9 versions & 2 rubygems