1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
require 'informix'
module Sequel
module Informix
class Database < Sequel::Database
set_adapter_scheme :informix
# AUTO_INCREMENT = 'IDENTITY(1,1)'.freeze
#
# def auto_increment_sql
# AUTO_INCREMENT
# end
def connect
::Informix.connect(@opts[:database], @opts[:user], @opts[:password])
end
def disconnect
@pool.disconnect {|c| c.close}
end
def dataset(opts = nil)
Sequel::Informix::Dataset.new(self, opts)
end
# Returns number of rows affected
def execute(sql)
@logger.info(sql) if @logger
@pool.hold {|c| c.immediate(sql)}
end
alias_method :do, :execute
def query(sql, &block)
@logger.info(sql) if @logger
@pool.hold {|c| block[c.cursor(sql)]}
end
end
class Dataset < Sequel::Dataset
def literal(v)
case v
when Time
literal(v.iso8601)
else
super
end
end
def select_sql(opts = nil)
limit = opts.delete(:limit)
offset = opts.delete(:offset)
sql = super
if limit
limit = "FIRST #{limit}"
offset = offset ? "SKIP #{offset}" : ""
sql.sub!(/^select /i,"SELECT #{offset} #{limit} ")
end
sql
end
def fetch_rows(sql, &block)
@db.synchronize do
@db.query(sql) do |cursor|
begin
cursor.open.each_hash(&block)
ensure
cursor.drop
end
end
end
self
end
def insert(*values)
@db.do insert_sql(*values)
end
def update(*args, &block)
@db.do update_sql(*args, &block)
end
def delete(opts = nil)
@db.do delete_sql(opts)
end
end
end
end
|
