Method: RR::ReplicationInitializer#ensure_activity_markers

Defined in:
lib/rubyrep/replication_initializer.rb

#ensure_activity_markers ⇒ Object

Checks in both databases, if the activity marker tables exist and if not, creates them.



193
194
195
196
197
198
199
200
201
202
203
204
205
 
# File 'lib/rubyrep/replication_initializer.rb', line 193

def ensure_activity_markers
  table_name = "#{options[:rep_prefix]}_running_flags"
  [:left, :right].each do |database|
    connection = session.send(database)
    unless connection.tables.include? table_name
      silence_ddl_notices(database) do
        connection.create_table table_name
        connection.add_column table_name, :active, :integer
        connection.remove_column table_name, 'id'
      end
    end
  end
end