Class: PLSQL::OCIConnection::Cursor
Overview
Constant Summary
collapse
- @@open_cursors =
[]
Instance Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
#fetch_all, #fetch_hash, #fetch_hash_all
Constructor Details
#initialize(conn, raw_cursor) ⇒ Cursor
Returns a new instance of Cursor.
75
76
77
78
79
|
# File 'lib/plsql/oci_connection.rb', line 75
def initialize(conn, raw_cursor)
@connection = conn
@raw_cursor = raw_cursor
@@open_cursors.push self
end
|
Instance Attribute Details
#raw_cursor ⇒ Object
Returns the value of attribute raw_cursor.
73
74
75
|
# File 'lib/plsql/oci_connection.rb', line 73
def raw_cursor
@raw_cursor
end
|
Class Method Details
.new_from_parse(conn, sql) ⇒ Object
81
82
83
84
|
# File 'lib/plsql/oci_connection.rb', line 81
def self.new_from_parse(conn, sql)
raw_cursor = conn.raw_connection.parse(sql)
self.new(conn, raw_cursor)
end
|
.new_from_query(conn, sql, bindvars = [], options = {}) ⇒ Object
86
87
88
89
90
91
92
93
|
# File 'lib/plsql/oci_connection.rb', line 86
def self.new_from_query(conn, sql, bindvars=[], options={})
cursor = new_from_parse(conn, sql)
if prefetch_rows = options[:prefetch_rows]
cursor.prefetch_rows = prefetch_rows
end
cursor.exec(*bindvars)
cursor
end
|
Instance Method Details
#[](key) ⇒ Object
109
110
111
|
# File 'lib/plsql/oci_connection.rb', line 109
def [](key)
@connection.ora_value_to_ruby_value(@raw_cursor[key])
end
|
#bind_param(arg, value, metadata) ⇒ Object
99
100
101
102
103
|
# File 'lib/plsql/oci_connection.rb', line 99
def bind_param(arg, value, metadata)
type, length = @connection.plsql_to_ruby_data_type(metadata)
ora_value = @connection.ruby_value_to_ora_value(value, type)
@raw_cursor.bind_param(arg, ora_value, type, length)
end
|
#close ⇒ Object
126
127
128
129
130
131
132
|
# File 'lib/plsql/oci_connection.rb', line 126
def close
while (open_cursor = @@open_cursors.pop) && !open_cursor.equal?(self)
open_cursor.close_raw_cursor
end
close_raw_cursor
end
|
#close_raw_cursor ⇒ Object
122
123
124
|
# File 'lib/plsql/oci_connection.rb', line 122
def close_raw_cursor
@raw_cursor.close
end
|
#exec(*bindvars) ⇒ Object
105
106
107
|
# File 'lib/plsql/oci_connection.rb', line 105
def exec(*bindvars)
@raw_cursor.exec(*bindvars)
end
|
#fetch ⇒ Object
113
114
115
116
|
# File 'lib/plsql/oci_connection.rb', line 113
def fetch
row = @raw_cursor.fetch
row && row.map{|v| @connection.ora_value_to_ruby_value(v)}
end
|
#fields ⇒ Object
118
119
120
|
# File 'lib/plsql/oci_connection.rb', line 118
def fields
@fields ||= @raw_cursor.get_col_names.map{|c| c.downcase.to_sym}
end
|
#prefetch_rows=(value) ⇒ Object
95
96
97
|
# File 'lib/plsql/oci_connection.rb', line 95
def prefetch_rows=(value)
@raw_cursor.prefetch_rows = value
end
|