Class: ActiveRecord::ConnectionAdapters::OracleEnhancedJDBCConnection::Cursor

Inherits:
Object
  • Object
show all
Defined in:
lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb

Instance Method Summary collapse

Constructor Details

#initialize(connection, raw_statement) ⇒ Cursor

Returns a new instance of Cursor.



295
296
297
298
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 295

def initialize(connection, raw_statement)
  @connection = connection
  @raw_statement = raw_statement
end

Instance Method Details

#bind_param(position, value, col_type = nil) ⇒ Object 



300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 300

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 



336
337
338
339
340
341
342
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 336

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 



393
394
395
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 393

def close
  @raw_statement.close
end

#column_names ⇒ Object Also known as: get_col_names 



361
362
363
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 361

def column_names
  @column_names ||= (1..metadata.getColumnCount).map{|i| metadata.getColumnName(i)}
end

#column_types ⇒ Object 



357
358
359
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 357

def column_types
  @column_types ||= (1..metadata.getColumnCount).map{|i| metadata.getColumnTypeName(i).to_sym}
end

#exec ⇒ Object 



344
345
346
347
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 344

def exec
  @raw_result_set = @raw_statement.executeQuery
  true
end

#exec_update ⇒ Object 



349
350
351
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 349

def exec_update
  @raw_statement.executeUpdate
end

#fetch(options = {}) ⇒ Object 



366
367
368
369
370
371
372
373
374
375
376
377
378
379
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 366

def fetch(options={})
  if @raw_result_set.next
    get_lob_value = options[: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 



381
382
383
384
385
386
387
388
389
390
391
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 381

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 



353
354
355
 
# File 'lib/active_record/connection_adapters/oracle_enhanced_jdbc_connection.rb', line 353

def metadata
  @metadata ||= @raw_result_set.getMetaData
end