Use db user when adding tables to replication (#130)

shayonj · web-flow · commit f52edd437efe · 2024-06-04T09:14:18.000-04:00
diff --git a/lib/pg_easy_replicate/orchestrate.rb b/lib/pg_easy_replicate/orchestrate.rb
@@ -106,6 +106,7 @@ def add_tables_to_publication(
                         ADD TABLE #{quote_ident(table_name)}",
             connection_url: conn_string,
             schema: schema,
+            user: db_user(conn_string),
           )
         end
       rescue => e

Original file line number	Diff line number	Diff line change
`@@ -106,6 +106,7 @@ def add_tables_to_publication(`
`106`	`106`	`ADD TABLE #{quote_ident(table_name)}",`
`107`	`107`	`connection_url: conn_string,`
`108`	`108`	`schema: schema,`
	`109`	`+ user: db_user(conn_string),`
`109`	`110`	`)`
`110`	`111`	`end`
`111`	`112`	`rescue => e`