Skip to content

Commit 808cff9

Browse files
authored
Long domain name (#9108)
1 parent bea5f8c commit 808cff9

File tree

1 file changed

+28
-1
lines changed

1 file changed

+28
-1
lines changed

ydb/core/kqp/ut/pg/kqp_pg_ut.cpp

Lines changed: 28 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4151,7 +4151,34 @@ Y_UNIT_TEST_SUITE(KqpPg) {
41514151
UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString());
41524152
CompareYson(R"([])", FormatResultSetYson(result.GetResultSet(0)));
41534153
}
4154-
}
4154+
}
4155+
4156+
Y_UNIT_TEST(LongDomainName) {
4157+
NKikimrConfig::TAppConfig appConfig;
4158+
appConfig.MutableTableServiceConfig()->SetEnablePreparedDdl(true);
4159+
auto setting = NKikimrKqp::TKqpSetting();
4160+
auto serverSettings = TKikimrSettings()
4161+
.SetAppConfig(appConfig)
4162+
.SetKqpSettings({setting})
4163+
.SetDomainRoot(std::string(65, 'a'));
4164+
TKikimrRunner kikimr(serverSettings.SetWithSampleTables(false));
4165+
auto db = kikimr.GetQueryClient();
4166+
auto settings = NYdb::NQuery::TExecuteQuerySettings().Syntax(NYdb::NQuery::ESyntax::Pg);
4167+
{
4168+
auto result = db.ExecuteQuery(R"(
4169+
CREATE TABLE t (id INT PRIMARY KEY, data1 UUID[]);
4170+
)", NYdb::NQuery::TTxControl::NoTx(), settings).ExtractValueSync();
4171+
UNIT_ASSERT_C(result.IsSuccess(), result.GetIssues().ToString());
4172+
}
4173+
4174+
{
4175+
const auto query = Q_(R"(
4176+
SELECT * FROM t;
4177+
)");
4178+
auto result = db.ExecuteQuery(query, NYdb::NQuery::TTxControl::BeginTx().CommitTx(), settings).ExtractValueSync();
4179+
UNIT_ASSERT_C(result.IsSuccess(), result.GetIssues().ToString());
4180+
}
4181+
}
41554182
}
41564183

41574184
} // namespace NKqp

0 commit comments

Comments
 (0)