Module: ConnectionManager::AbstractAdapterHelper

Defined in:
lib/connection_manager/helpers/abstract_adapter_helper.rb

Instance Method Summary collapse

Instance Method Details

#config ⇒ Object 



3
4
5
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 3

def config
  @config
end

#cross_database_support? ⇒ Boolean Also known as: cross_schema_support?

Determines if connection supports cross database queries

Returns:

  • (Boolean) 


8
9
10
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 8

def cross_database_support?
 (@config[:cross_database_support] || @config[:adapter].match(/(mysql)|(postgres)|(sqlserver)/i)) 
end

#database_name ⇒ Object 



25
26
27
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 25

def database_name
  @config[:database]
end

#master_keys ⇒ Object 



40
41
42
43
44
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 40

def master_keys
  master_keys = []
  master_keys = @config[:masters].collect{|r| r.to_sym} if @config[:masters]
  master_keys
end

#readonly? ⇒ Boolean

Returns:

  • (Boolean) 


17
18
19
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 17

def readonly?
  (@config[:readonly] == true)
end

#replicated? ⇒ Boolean

Returns:

  • (Boolean) 


21
22
23
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 21

def replicated?
  (!slave_keys.blank? || !master_keys.blank?)
end

#replication_keys(type = :slaves) ⇒ Object 



29
30
31
32
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 29

def replication_keys(type=:slaves)
  return slave_keys if type == :slaves
  master_keys
end

#slave_keys ⇒ Object 



34
35
36
37
38
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 34

def slave_keys
  slave_keys = []
  slave_keys = @config[:slaves].collect{|r| r.to_sym} if @config[:slaves]
  slave_keys  
end

#using_em_adapter? ⇒ Boolean

Returns:

  • (Boolean) 


13
14
15
 
# File 'lib/connection_manager/helpers/abstract_adapter_helper.rb', line 13

def using_em_adapter?
  (@config[:adapter].match(/^em\_/) && defined?(EM) && EM::reactor_running?)
end