From ba3480a5688d19a9968f2e2d98bbb27e2eb62c12 Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Fri, 17 Nov 2023 12:05:14 +0100 Subject: [PATCH] Fix construction of database URL --- compute_tools/src/spec.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/compute_tools/src/spec.rs b/compute_tools/src/spec.rs index 34b057e270..6ee4d27905 100644 --- a/compute_tools/src/spec.rs +++ b/compute_tools/src/spec.rs @@ -423,7 +423,11 @@ pub fn handle_merge(client: &mut Client, dst_connstr: &str, src_connstr: &str) - src_conf.dbname(&db.name); let mut sub_client = dst_conf.connect(NoTls)?; - let create_sub = format!("create subscription sub_merge connection '{}' publication pub_merge with (create_slot=false, slot_name=merge_slot_{}, copy_data=false)", str::replace(src_connstr, "'", "''"), &db.name); + let mut connstr_parts: Vec<&str> = src_connstr.split('/').collect(); + connstr_parts.pop(); + connstr_parts.push(&db.name); + let connstr = connstr_parts.join("/"); + let create_sub = format!("create subscription sub_merge connection '{}' publication pub_merge with (create_slot=false, slot_name=merge_slot_{}, copy_data=false)", connstr, &db.name); sub_client.simple_query(&create_sub)?; }