def create_change_log(database)
silence_ddl_notices(database) do
connection = session.send(database)
table_name = "#{options[:rep_prefix]}_pending_changes"
connection.create_table table_name
connection.add_column table_name, :change_table, :string
connection.add_column table_name, :change_key, :string
connection.add_column table_name, :change_new_key, :string
connection.add_column table_name, :change_type, :string
connection.add_column table_name, :change_time, :timestamp
connection.remove_column table_name, 'id'
connection.add_big_primary_key table_name, 'id'
end
end