Class: ActiveRecord::ConnectionAdapters::RedshiftAdapter::StatementPool
- Inherits:
-
ConnectionAdapters::StatementPool
- Object
- ConnectionAdapters::StatementPool
- ActiveRecord::ConnectionAdapters::RedshiftAdapter::StatementPool
- Defined in:
- lib/active_record/connection_adapters/redshift_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.
469 470 471 472 473 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 469 def initialize(connection, max) super @counter = 0 @cache = Hash.new { |h,pid| h[pid] = {} } end |
Instance Method Details
#[](key) ⇒ Object
477 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 477 def [](key); cache[key]; end |
#[]=(sql, key) ⇒ Object
484 485 486 487 488 489 490 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 484 def []=(sql, key) while @max <= cache.size dealloc(cache.shift.last) end @counter += 1 cache[sql] = key end |
#clear ⇒ Object
492 493 494 495 496 497 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 492 def clear cache.each_value do |stmt_key| dealloc stmt_key end cache.clear end |
#delete(sql_key) ⇒ Object
499 500 501 502 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 499 def delete(sql_key) dealloc cache[sql_key] cache.delete sql_key end |
#each(&block) ⇒ Object
475 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 475 def each(&block); cache.each(&block); end |
#key?(key) ⇒ Boolean
476 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 476 def key?(key); cache.key?(key); end |
#length ⇒ Object
478 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 478 def length; cache.length; end |
#next_key ⇒ Object
480 481 482 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 480 def next_key "a#{@counter + 1}" end |