module Sequel::ServerBlock
Public Class Methods
extended(db)
click to toggle source
Enable the server block on the connection pool, choosing the correct extension depending on whether the connection pool is threaded or not. Also defines the with_server
method on the receiver for easy use.
# File lib/sequel/extensions/server_block.rb 70 def self.extended(db) 71 pool = db.pool 72 if defined?(ShardedThreadedConnectionPool) && pool.is_a?(ShardedThreadedConnectionPool) 73 pool.extend(ThreadedServerBlock) 74 pool.instance_variable_set(:@default_servers, {}) 75 else 76 pool.extend(UnthreadedServerBlock) 77 pool.instance_variable_set(:@default_servers, []) 78 end 79 end
Public Instance Methods
with_server(default_server, read_only_server=default_server, &block)
click to toggle source
Delegate to the connection pool
# File lib/sequel/extensions/server_block.rb 82 def with_server(default_server, read_only_server=default_server, &block) 83 pool.with_server(default_server, read_only_server, &block) 84 end