Module: Stagehand::Connection::AdapterExtensions

Defined in:
lib/stagehand/connection_adapter_extensions.rb

Instance Method Summary collapse

Instance Method Details

#exec_delete ⇒ Object 



46
47
48
49
 
# File 'lib/stagehand/connection_adapter_extensions.rb', line 46

def exec_delete(*)
  handle_readonly_writes!
  super
end

#exec_insert ⇒ Object 



36
37
38
39
 
# File 'lib/stagehand/connection_adapter_extensions.rb', line 36

def exec_insert(*)
  handle_readonly_writes!
  super
end

#exec_update ⇒ Object 



41
42
43
44
 
# File 'lib/stagehand/connection_adapter_extensions.rb', line 41

def exec_update(*)
  handle_readonly_writes!
  super
end

#prefix_table_name_with_database?(table_name) ⇒ Boolean

Returns:

  • (Boolean) 


28
29
30
31
32
33
34
 
# File 'lib/stagehand/connection_adapter_extensions.rb', line 28

def prefix_table_name_with_database?(table_name)
  return false if Configuration.single_connection?
  return false unless Database.connected_to_production?
  return false if Connection.allow_unsynced_production_writes?
  return false unless Configuration.staging_model_tables.include?(table_name)
  true
end

#quote_table_name(table_name) ⇒ Object 



20
21
22
23
24
25
26
 
# File 'lib/stagehand/connection_adapter_extensions.rb', line 20

def quote_table_name(table_name)
  if prefix_table_name_with_database?(table_name)
    super("#{Stagehand::Database.staging_database_name}.#{table_name}")
  else
    super
  end
end