Added test: Alter compression for ColumnTable in TableStore (#9781)

ydb-platform · Sep 26, 2024 · 48dc88f · 48dc88f
1 parent 6bec40a
commit 48dc88f
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/ydb/core/kqp/ut/olap/compression_ut.cpp b/ydb/core/kqp/ut/olap/compression_ut.cpp
@@ -45,5 +45,23 @@ Y_UNIT_TEST_SUITE(KqpOlapCompression) {
         testHelper.CreateTable(testTableStore);
         testHelper.SetCompression(testTableStore, "pk_int", compression);
     }
+
+    Y_UNIT_TEST(TestAlterCompressionTableInTableStore) {
+        TKikimrSettings settings = TKikimrSettings().SetWithSampleTables(false);
+        TTestHelper testHelper(settings);
+        TVector<TTestHelper::TColumnSchema> schema = {
+            TTestHelper::TColumnSchema().SetName("pk_int").SetType(NScheme::NTypeIds::Uint64).SetNullable(false)
+        };
+        TTestHelper::TCompression compression = TTestHelper::TCompression().SetType(arrow::Compression::type::ZSTD);
+
+        TTestHelper::TColumnTableStore testTableStore;
+        testTableStore.SetName("/Root/TableStoreTest").SetPrimaryKey({ "pk_int" }).SetSchema(schema);
+        testHelper.CreateTable(testTableStore);
+
+        TTestHelper::TColumnTable testTable;
+        testTable.SetName("/Root/TableStoreTest/ColumnTableTest").SetPrimaryKey({ "pk_int" }).SetSharding({ "pk_int" }).SetSchema(schema);
+        testHelper.CreateTable(testTable);
+        testHelper.SetCompression(testTable, "pk_int", compression, NYdb::EStatus::SCHEME_ERROR);
+    }
 }
 }