Skip to content

Commit a0559c0

Browse files
pashandor789Pavel Ivanov
andauthored
[PG Syntax] Added ydb pragma support (#2225)
Co-authored-by: Pavel Ivanov <pudge1000-7@mr-nvme-testing-11.search.yandex.net>
1 parent 275fd42 commit a0559c0

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

ydb/library/yql/sql/pg/pg_sql.cpp

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2169,7 +2169,7 @@ class TConverter : public IPGParseEvents {
21692169
AddError(TStringBuilder() << "VariableSetStmt, expected string literal for " << value->name << " option");
21702170
return nullptr;
21712171
}
2172-
} else if (name.StartsWith("dq.") || name.StartsWith("yt.") || name.StartsWith("s3.")) {
2172+
} else if (name.StartsWith("dq.") || name.StartsWith("yt.") || name.StartsWith("s3.") || name.StartsWith("ydb.")) {
21732173
if (ListLength(value->args) != 1) {
21742174
AddError(TStringBuilder() << "VariableSetStmt, expected 1 arg, but got: " << ListLength(value->args));
21752175
return nullptr;
@@ -2184,8 +2184,12 @@ class TConverter : public IPGParseEvents {
21842184
providerName = NYql::DqProviderName;
21852185
} else if (name.StartsWith("yt.")) {
21862186
providerName = NYql::YtProviderName;
2187-
} else {
2187+
} else if (name.StartsWith("s3.")) {
21882188
providerName = NYql::S3ProviderName;
2189+
} else if (name.StartsWith("ydb.")) {
2190+
providerName = NYql::YdbProviderName;
2191+
} else {
2192+
Y_ASSERT(0);
21892193
}
21902194

21912195
auto providerSource = L(A("DataSource"), QA(providerName), QA("$all"));

0 commit comments

Comments
 (0)