Class: ActiveRecord::ConnectionAdapters::PostgreSQLAdapter::StatementPool
- Inherits:
-
StatementPool
- Object
- StatementPool
- ActiveRecord::ConnectionAdapters::PostgreSQLAdapter::StatementPool
- Defined in:
- lib/active_record/connection_adapters/postgresql_adapter.rb
Instance Method Summary collapse
- #[](key) ⇒ Object
- #[]=(sql, key) ⇒ Object
- #clear ⇒ Object
- #delete(sql_key) ⇒ Object
- #each(&block) ⇒ Object
-
#initialize(connection, max) ⇒ StatementPool
constructor
A new instance of StatementPool.
- #key?(key) ⇒ Boolean
- #length ⇒ Object
- #next_key ⇒ Object
Constructor Details
#initialize(connection, max) ⇒ StatementPool
Returns a new instance of StatementPool.
475 476 477 478 479 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 475 def initialize(connection, max) super @counter = 0 @cache = Hash.new { |h,pid| h[pid] = {} } end |
Instance Method Details
#[](key) ⇒ Object
483 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 483 def [](key); cache[key]; end |
#[]=(sql, key) ⇒ Object
490 491 492 493 494 495 496 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 490 def []=(sql, key) while @max <= cache.size dealloc(cache.shift.last) end @counter += 1 cache[sql] = key end |
#clear ⇒ Object
498 499 500 501 502 503 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 498 def clear cache.each_value do |stmt_key| dealloc stmt_key end cache.clear end |
#delete(sql_key) ⇒ Object
505 506 507 508 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 505 def delete(sql_key) dealloc cache[sql_key] cache.delete sql_key end |
#each(&block) ⇒ Object
481 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 481 def each(&block); cache.each(&block); end |
#key?(key) ⇒ Boolean
482 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 482 def key?(key); cache.key?(key); end |
#length ⇒ Object
484 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 484 def length; cache.length; end |
#next_key ⇒ Object
486 487 488 |
# File 'lib/active_record/connection_adapters/postgresql_adapter.rb', line 486 def next_key "a#{@counter + 1}" end |