Class: ActiveRecord::ConnectionAdapters::MysqlAdapter::StatementPool

Inherits:

StatementPool

• Object
• StatementPool
• ActiveRecord::ConnectionAdapters::MysqlAdapter::StatementPool

show all

Defined in:

activerecord/lib/active_record/connection_adapters/mysql_adapter.rb

Instance Method Summary (collapse)

• - (Object) [](key)
• - (Object) []=(sql, key)
• - (Object) clear
• - (Object) delete(key)
• - (Object) each(&block)
• - (StatementPool) initialize(connection, max = 1000) constructor

  A new instance of StatementPool.

• - (Boolean) key?(key)
• - (Object) length

Methods included from Enumerable

#as_json, #each_with_object, #exclude?, #group_by, #index_by, #many?, #sum

95
96
97
98

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 95

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

102

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 102

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

106
107
108
109
110
111

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 106

def []=(sql, key)
  while @max <= cache.size
    cache.shift.last[:stmt].close
  end
  cache[sql] = key
end

113
114
115
116
117
118

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 113

def clear
  cache.values.each do |hash|
    hash[:stmt].close
  end
  cache.clear
end

104

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 104

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

100

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 100

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

101

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 101

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

103

# File 'activerecord/lib/active_record/connection_adapters/mysql_adapter.rb', line 103

def length;       cache.length; end