rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-15 09:22:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix construction of database URL

Browse Source
This commit is contained in:
Konstantin Knizhnik
2023-11-17 12:05:14 +01:00
parent 71bd53c646
commit ba3480a568
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
compute_tools/src/spec.rs
View File

@@ -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)?;
}