Module: ActiveRecord::ConnectionAdapters::QueryCache::ConnectionPoolConfiguration

Included in:
ConnectionPool
Defined in:
activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb

Overview

:nodoc:

Instance Method Summary collapse

Instance Method Details

#checkout_and_verify(connection) ⇒ Object 



150
151
152
153
154
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 150

def checkout_and_verify(connection)
  super
  connection.query_cache ||= query_cache
  connection
end

#clear_query_cache ⇒ Object 



195
196
197
198
199
200
201
202
203
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 195

def clear_query_cache
  if @pinned_connection
    # With transactional fixtures, and especially systems test
    # another thread may use the same connection, but with a different
    # query cache. So we must clear them all.
    @query_cache_version.increment
  end
  query_cache.clear
end

#dirties_query_cache ⇒ Object 



191
192
193
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 191

def dirties_query_cache
  query_cache.dirties
end

#disable_query_cache(dirties: true) ⇒ Object

Disable the query cache within the block.



157
158
159
160
161
162
163
164
165
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 157

def disable_query_cache(dirties: true)
  cache = query_cache
  old_enabled, cache.enabled, old_dirties, cache.dirties = cache.enabled, false, cache.dirties, dirties
  begin
    yield
  ensure
    cache.enabled, cache.dirties = old_enabled, old_dirties
  end
end

#disable_query_cache! ⇒ Object 



182
183
184
185
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 182

def disable_query_cache!
  query_cache.enabled = false
  query_cache.dirties = true
end

#enable_query_cache ⇒ Object 



167
168
169
170
171
172
173
174
175
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 167

def enable_query_cache
  cache = query_cache
  old_enabled, cache.enabled, old_dirties, cache.dirties = cache.enabled, true, cache.dirties, true
  begin
    yield
  ensure
    cache.enabled, cache.dirties = old_enabled, old_dirties
  end
end

#enable_query_cache! ⇒ Object 



177
178
179
180
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 177

def enable_query_cache!
  query_cache.enabled = true
  query_cache.dirties = true
end

#initialize ⇒ Object 



135
136
137
138
139
140
141
142
143
144
145
146
147
148
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 135

def initialize(...)
  super
  @query_cache_version = Concurrent::AtomicFixnum.new
  @thread_query_caches = QueryCacheRegistry.new
  @query_cache_max_size = \
    case query_cache = db_config&.query_cache
    when 0, false
      nil
    when Integer
      query_cache
    when nil
      DEFAULT_SIZE
    end
end

#query_cache ⇒ Object 



205
206
207
208
209
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 205

def query_cache
  @thread_query_caches.compute_if_absent(ActiveSupport::IsolatedExecutionState.context) do
    Store.new(@query_cache_version, @query_cache_max_size)
  end
end

#query_cache_enabled ⇒ Object 



187
188
189
 
# File 'activerecord/lib/active_record/connection_adapters/abstract/query_cache.rb', line 187

def query_cache_enabled
  query_cache.enabled
end