Skip to content

Commit 9deef4f

Browse files
committed
Fix schema search path
1 parent 5a0ad8c commit 9deef4f

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

src/driver/sqlx_postgres.rs

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,15 @@ impl SqlxPostgresConnector {
7878
}
7979
let set_search_path_sql = options.schema_search_path.as_ref().map(|schema| {
8080
let mut string = "SET search_path = ".to_owned();
81-
for schema in schema.split(',') {
82-
write!(&mut string, "\"{schema}\"").unwrap();
81+
for (i, schema) in schema.split(',').enumerate() {
82+
if i > 0 {
83+
write!(&mut string, ",").unwrap();
84+
}
85+
if schema.starts_with('"') {
86+
write!(&mut string, "{schema}").unwrap();
87+
} else {
88+
write!(&mut string, "\"{schema}\"").unwrap();
89+
}
8390
}
8491
string
8592
});

0 commit comments

Comments
 (0)