123456789_123456789_123456789_123456789_123456789_

Class: ActiveRecord::ConnectionAdapters::PostgreSQLAdapter::StatementPool

Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, ::ActiveRecord::ConnectionAdapters::StatementPool
Instance Chain:
self, ::ActiveRecord::ConnectionAdapters::StatementPool, ::Enumerable
Inherits: ActiveRecord::ConnectionAdapters::StatementPool
Defined in: activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb

Class Method Summary

::ActiveRecord::ConnectionAdapters::StatementPool - Inherited

.new

Instance Attribute Summary

::Enumerable - Included

#many?

Returns true if the enumerable has more than 1 element.

Instance Method Summary

::ActiveRecord::ConnectionAdapters::StatementPool - Inherited

#[], #[]=, #clear, #delete, #each, #key?, #length

::Enumerable - Included

#exclude?

The negative of the Enumerable#include?.
#index_by

Convert an enumerable to a hash.
#sum

Calculates a sum from the elements.

Constructor Details

.new(connection, max) ⇒ StatementPool

[ GitHub ] 

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 173



def initialize(connection, max)
  super
  @counter = 0
  @cache   = Hash.new { |h,pid| h[pid] = {} }
end


  







Instance Method Details



  

    #[](key)  
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 181



def [](key);      cache[key]; end


  








  

    #[]=(sql, key)  
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 188



def []=(sql, key)
  while @max <= cache.size
    dealloc(cache.shift.last)
  end
  @counter += 1
  cache[sql] = key
end


  








  

    #clear  
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 196



def clear
  cache.each_value do |stmt_key|
    dealloc stmt_key
  end
  cache.clear
end


  








  

    #delete(sql_key)  
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 203



def delete(sql_key)
  dealloc cache[sql_key]
  cache.delete sql_key
end


  








  

    #each(&block)  
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 179



def each(&block); cache.each(&block); end


  








  

    #key?(key)  ⇒ Boolean 
  



  

    
  





  


  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 180



def key?(key);    cache.key?(key); end


  








  

    #length  
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 182



def length;       cache.length; end


  








  

    #next_key  
  

  [ GitHub ]


  

  


# File 'activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb', line 184



def next_key
  "a#{@counter + 1}"
end