diff options
| author | hcpp <hcpp@ydb.tech> | 2023-10-06 16:00:28 +0300 |
|---|---|---|
| committer | hcpp <hcpp@ydb.tech> | 2023-10-06 17:14:54 +0300 |
| commit | 6fa91d4cc4961096bd58b6f1c8fe515b1583a453 (patch) | |
| tree | 8cc1bb20ccd4ba443d9dd0c4943c1be4a8a98562 | |
| parent | dbcf1188f7691e2f90fa9017c827d866c5cae96a (diff) | |
| download | ydb-6fa91d4cc4961096bd58b6f1c8fe515b1583a453.tar.gz | |
pg schema for fq proxy
| -rw-r--r-- | ydb/core/fq/libs/control_plane_proxy/actors/query_utils.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/fq/libs/control_plane_proxy/actors/query_utils.cpp b/ydb/core/fq/libs/control_plane_proxy/actors/query_utils.cpp index a7130394899..eb1625d6acd 100644 --- a/ydb/core/fq/libs/control_plane_proxy/actors/query_utils.cpp +++ b/ydb/core/fq/libs/control_plane_proxy/actors/query_utils.cpp @@ -205,6 +205,7 @@ TString MakeCreateExternalDataSourceQuery( case FederatedQuery::ConnectionSetting::kMonitoring: break; case FederatedQuery::ConnectionSetting::kPostgresqlCluster: + const auto schema = connectionContent.setting().postgresql_cluster().schema(); properties = fmt::format( R"( SOURCE_TYPE="PostgreSQL", @@ -212,9 +213,11 @@ TString MakeCreateExternalDataSourceQuery( DATABASE_NAME={database_name}, PROTOCOL="NATIVE", USE_TLS="true" + {schema} )", "mdb_cluster_id"_a = EncloseAndEscapeString(connectionContent.setting().postgresql_cluster().database_id(), '"'), - "database_name"_a = EncloseAndEscapeString(connectionContent.setting().postgresql_cluster().database_name(), '"')); + "database_name"_a = EncloseAndEscapeString(connectionContent.setting().postgresql_cluster().database_name(), '"'), + "schema"_a = schema ? ", SCHEMA=" + EncloseAndEscapeString(schema, '"') : TString{}); break; } |