feat(TableService): CreateTable with default value options

Author: KirillKurdyukov

table/pom.xml

@@ -50,8 +50,9 @@
                 <configuration>
                     <environmentVariables>
                         <TESTCONTAINERS_REUSE_ENABLE>true</TESTCONTAINERS_REUSE_ENABLE>
-                        <YDB_DOCKER_IMAGE>ydbplatform/local-ydb:latest</YDB_DOCKER_IMAGE>
-                        <YDB_ENDPOINT>grpc://localhost:2136</YDB_ENDPOINT>
+                        <YDB_DOCKER_IMAGE>ydbplatform/local-ydb:trunk</YDB_DOCKER_IMAGE>
+                        <YDB_ENDPOINT>localhost:2136</YDB_ENDPOINT>
+                        <YDB_DATABASE>/local</YDB_DATABASE>
                     </environmentVariables>
                 </configuration>
             </plugin>

table/src/test/java/tech/ydb/table/integration/CreateTableTest.java

@@ -13,14 +13,10 @@
 import tech.ydb.table.description.TableDescription;
 import tech.ydb.table.impl.SimpleTableClient;
 import tech.ydb.table.rpc.grpc.GrpcTableRpc;
-import tech.ydb.table.settings.CreateTableSettings;
 import tech.ydb.table.values.PrimitiveType;
 import tech.ydb.table.values.PrimitiveValue;
 import tech.ydb.test.junit4.GrpcTransportRule;
 
-import java.time.Duration;
-import java.time.temporal.ChronoUnit;
-
 /**
  * @author Kirill Kurdyukov
  */
@@ -44,8 +40,7 @@ public void smallSerialTest() {
                 .setPrimaryKey("id")
                 .build();
 
-        Status createStatus = ctx.supplyStatus(session ->
-                session.createTable(tablePath, tableDescription, new CreateTableSettings())).join();
+        Status createStatus = ctx.supplyStatus(session -> session.createTable(tablePath, tableDescription)).join();
         Assert.assertTrue("Create table with small serial " + createStatus, createStatus.isSuccess());
 
         Result<TableDescription> describeResult = ctx.supplyResult(session -> session.describeTable(tablePath)).join();
@@ -66,7 +61,7 @@ public void serialTest() {
                 .build();
 
         Status createStatus = ctx.supplyStatus(session ->
-                session.createTable(tablePath, tableDescription, new CreateTableSettings())).join();
+                session.createTable(tablePath, tableDescription)).join();
         Assert.assertTrue("Create table with serial " + createStatus, createStatus.isSuccess());
 
         Result<TableDescription> describeResult = ctx.supplyResult(session -> session.describeTable(tablePath)).join();
@@ -89,7 +84,7 @@ public void bigSerialTest() {
                 .build();
 
         Status createStatus = ctx.supplyStatus(session ->
-                session.createTable(tablePath, tableDescription, new CreateTableSettings())).join();
+                session.createTable(tablePath, tableDescription)).join();
         Assert.assertTrue("Create table with big serial " + createStatus, createStatus.isSuccess());
 
         Result<TableDescription> describeResult = ctx.supplyResult(session -> session.describeTable(tablePath)).join();
@@ -112,23 +107,20 @@ public void defaultValueTest() {
                 .setPrimaryKey("id")
                 .build();
 
-        Status createStatus = ctx.supplyStatus(session ->
-                session.createTable(tablePath, tableDescription, new CreateTableSettings())).join();
+        Status createStatus = ctx.supplyStatus(session -> session.createTable(tablePath, tableDescription)).join();
         Assert.assertTrue("Create table with indexes " + createStatus, createStatus.isSuccess());
-
         Result<TableDescription> describeResult = ctx.supplyResult(session -> session.describeTable(tablePath)).join();
         Assert.assertTrue("Describe table with indexes " + describeResult.getStatus(), describeResult.isSuccess());
         TableColumn tableColumn = describeResult.getValue().getColumns().get(0);
         Assert.assertNull(tableColumn.getSequenceDescription());
         Assert.assertEquals("text", tableColumn.getLiteralDefaultValue().getText());
         Assert.assertEquals(PrimitiveType.Text, tableColumn.getType());
-        ctx.supplyStatus(session -> session.dropTable(tablePath)).join();
-
 
+        ctx.supplyStatus(session -> session.dropTable(tablePath)).join();
     }
 
     @Test
-    public void customSequenceDescriptionTest() throws InterruptedException {
+    public void customSequenceDescriptionTest() {
         String tablePath = ydbTransport.getDatabase() + "/default_value_table";
 
         TableDescription tableDescription = TableDescription.newBuilder()
@@ -145,7 +137,6 @@ public void customSequenceDescriptionTest() throws InterruptedException {
                 .setPrimaryKey("id")
                 .build();
 
-        Thread.sleep(10_000);
         Status createStatus = ctx.supplyStatus(session -> session.createTable(tablePath, tableDescription)).join();
         Assert.assertTrue("Create table with sequence description " + createStatus, createStatus.isSuccess());
         Result<TableDescription> describeResult = ctx.supplyResult(session -> session.describeTable(tablePath)).join();
@@ -162,24 +153,5 @@ public void customSequenceDescriptionTest() throws InterruptedException {
         Assert.assertEquals(2L, (long) sequenceDescription.getIncrement());
         Assert.assertEquals(12L, (long) sequenceDescription.getStartValue());
         ctx.supplyStatus(session -> session.dropTable(tablePath)).join();
-
-        createStatus = ctx.supplyStatus(session -> session.createTable(tablePath + "_copy", description)).join();
-        Assert.assertTrue("Create copy table with sequence description " + createStatus,
-                createStatus.isSuccess());
-        Result<TableDescription> describeResultCopy = ctx.supplyResult(session ->
-                session.describeTable(tablePath)).join();
-        Assert.assertTrue("Describe copy table with sequence description " + describeResultCopy.getStatus(),
-                describeResultCopy.isSuccess());
-        SequenceDescription sequenceDescriptionCopy = describeResultCopy.getValue()
-                .getColumns().get(0).getSequenceDescription();
-        Assert.assertNotNull(sequenceDescription);
-        Assert.assertEquals("custom_sequence_description", sequenceDescriptionCopy.getName());
-        Assert.assertEquals(Integer.MAX_VALUE, sequenceDescriptionCopy.getMaxValue().intValue());
-        Assert.assertEquals(10L, (long) sequenceDescriptionCopy.getMinValue());
-        Assert.assertEquals(5L, (long) sequenceDescriptionCopy.getCache());
-        Assert.assertEquals(true, sequenceDescriptionCopy.getCycle());
-        Assert.assertEquals(2L, (long) sequenceDescriptionCopy.getIncrement());
-        Assert.assertEquals(12L, (long) sequenceDescriptionCopy.getStartValue());
-        ctx.supplyStatus(session -> session.dropTable(tablePath + "_copy")).join();
     }
 }