Module: PgEasyReplicate::DDLManager

Extended by:
Helper
Defined in:
lib/pg_easy_replicate/ddl_manager.rb

Class Method Summary collapse

Methods included from Helper

abort_with, connection_info, convert_to_array, db_name, db_user, determine_tables, internal_schema_name, internal_user_name, list_all_tables, logger, publication_name, quote_ident, restore_connections_on_source_db, secondary_source_db_url, source_db_url, subscription_name, target_db_url, test_env?, underscore, validate_table_lists

Class Method Details

.apply_all_ddl_changes(group_name:, source_conn_string: source_db_url, target_conn_string: target_db_url, schema: "public") ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/pg_easy_replicate/ddl_manager.rb', line 43

def apply_all_ddl_changes(
  group_name:, source_conn_string: source_db_url,
  target_conn_string: target_db_url,
  schema: "public"
)
  DDLAudit.apply_all_changes(
    source_conn_string,
    target_conn_string,
    group_name,
  )
end

.apply_ddl_change(group_name:, id:, source_conn_string: source_db_url, target_conn_string: target_db_url, schema: "public") ⇒ Object 



30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/pg_easy_replicate/ddl_manager.rb', line 30

def apply_ddl_change(
  group_name:, id:, source_conn_string: source_db_url,
  target_conn_string: target_db_url,
  schema: "public"
)
  DDLAudit.apply_change(
    source_conn_string,
    target_conn_string,
    group_name,
    id,
  )
end

.cleanup_ddl_tracking(group_name:, conn_string: source_db_url, schema: "public") ⇒ Object 



15
16
17
18
19
20
 
# File 'lib/pg_easy_replicate/ddl_manager.rb', line 15

def cleanup_ddl_tracking(
  group_name:, conn_string: source_db_url,
  schema: "public"
)
  DDLAudit.drop(group_name)
end

.list_ddl_changes(group_name:, conn_string: source_db_url, schema: "public", limit: 100) ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/pg_easy_replicate/ddl_manager.rb', line 22

def list_ddl_changes(
  group_name:, conn_string: source_db_url,
  schema: "public",
  limit: 100
)
  DDLAudit.list_changes(group_name, limit: limit)
end

.setup_ddl_tracking(group_name:, conn_string: source_db_url, schema: "public") ⇒ Object 



8
9
10
11
12
13
 
# File 'lib/pg_easy_replicate/ddl_manager.rb', line 8

def setup_ddl_tracking(
  group_name:, conn_string: source_db_url,
  schema: "public"
)
  DDLAudit.setup(group_name)
end