Class: ActiveRecord::ConnectionAdapters::OracleEnhancedJDBCConnection::Cursor
- Inherits:
-
Object
- Object
- ActiveRecord::ConnectionAdapters::OracleEnhancedJDBCConnection::Cursor
- Defined in:
- lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb
Instance Method Summary collapse
- #bind_param(position, value, col_type = nil) ⇒ Object
- #bind_returning_param(position, bind_type) ⇒ Object
- #close ⇒ Object
- #column_names ⇒ Object (also: #get_col_names)
- #column_types ⇒ Object
- #exec ⇒ Object
- #exec_update ⇒ Object
- #fetch(options = {}) ⇒ Object
- #get_returning_param(position, type) ⇒ Object
-
#initialize(connection, raw_statement) ⇒ Cursor
constructor
A new instance of Cursor.
- #metadata ⇒ Object
Constructor Details
#initialize(connection, raw_statement) ⇒ Cursor
Returns a new instance of Cursor.
307 308 309 310 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 307 def initialize(connection, raw_statement) @connection = connection @raw_statement = raw_statement end |
Instance Method Details
#bind_param(position, value, col_type = nil) ⇒ Object
312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 312 def bind_param(position, value, col_type = nil) java_value = ruby_to_java_value(value, col_type) case value when Integer @raw_statement.setLong(position, java_value) when Float @raw_statement.setFloat(position, java_value) when BigDecimal @raw_statement.setBigDecimal(position, java_value) when String case col_type when :text @raw_statement.setClob(position, java_value) when :binary @raw_statement.setBlob(position, java_value) when :raw @raw_statement.setString(position, OracleEnhancedAdapter.encode_raw(java_value)) when :decimal @raw_statement.setBigDecimal(position, java_value) else @raw_statement.setString(position, java_value) end when Date, DateTime @raw_statement.setDATE(position, java_value) when Time @raw_statement.setTimestamp(position, java_value) when NilClass # TODO: currently nil is always bound as NULL with VARCHAR type. # When nils will actually be used by ActiveRecord as bound parameters # then need to pass actual column type. @raw_statement.setNull(position, java.sql.Types::VARCHAR) else raise ArgumentError, "Don't know how to bind variable with type #{value.class}" end end |
#bind_returning_param(position, bind_type) ⇒ Object
348 349 350 351 352 353 354 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 348 def bind_returning_param(position, bind_type) @returning_positions ||= [] @returning_positions << position if bind_type == Integer @raw_statement.registerReturnParameter(position, java.sql.Types::BIGINT) end end |
#close ⇒ Object
405 406 407 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 405 def close @raw_statement.close end |
#column_names ⇒ Object Also known as: get_col_names
373 374 375 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 373 def column_names @column_names ||= (1...getColumnCount).map{|i| .getColumnName(i)} end |
#column_types ⇒ Object
369 370 371 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 369 def column_types @column_types ||= (1...getColumnCount).map{|i| .getColumnTypeName(i).to_sym} end |
#exec ⇒ Object
356 357 358 359 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 356 def exec @raw_result_set = @raw_statement.executeQuery true end |
#exec_update ⇒ Object
361 362 363 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 361 def exec_update @raw_statement.executeUpdate end |
#fetch(options = {}) ⇒ Object
378 379 380 381 382 383 384 385 386 387 388 389 390 391 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 378 def fetch(={}) if @raw_result_set.next get_lob_value = [:get_lob_value] row_values = [] column_types.each_with_index do |column_type, i| row_values << @connection.get_ruby_value_from_result_set(@raw_result_set, i+1, column_type, get_lob_value) end row_values else @raw_result_set.close nil end end |
#get_returning_param(position, type) ⇒ Object
393 394 395 396 397 398 399 400 401 402 403 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 393 def get_returning_param(position, type) rs_position = @returning_positions.index(position) + 1 rs = @raw_statement.getReturnResultSet if rs.next # Assuming that primary key will not be larger as long max value returning_id = rs.getLong(rs_position) rs.wasNull ? nil : returning_id else nil end end |
#metadata ⇒ Object
365 366 367 |
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 365 def @metadata ||= @raw_result_set.getMetaData end |