Simple test

Author: Torch3333

integration-test/src/main/java/com/scalar/db/api/DistributedStorageColumnValueIntegrationTestBase.java

@@ -183,78 +183,78 @@ public void insert_largeBlobData_ShouldWorkCorrectly(int blobSize, String humanR
     }
   }
 
-  @ParameterizedTest()
-  @MethodSource("blobSizes")
-  public void insertSimple_largeBlobData_ShouldWorkCorrectly(int blobSize, String humanReadableSize)
-      throws ExecutionException {
-    String tbleName = "e2e_simple";
-    try {
-      // Arrange
-      TableMetadata.Builder metadata =
-          TableMetadata.newBuilder()
-              .addColumn(COL_NAME1, DataType.INT)
-              .addColumn(COL_NAME2, DataType.BLOB)
-              .addPartitionKey(COL_NAME1);
-
-      admin.createTable(namespace, tbleName, metadata.build(), true, getCreationOptions());
-      admin.truncateTable(namespace, tbleName);
-      Thread.sleep(3000);
-      byte[] blobData = createLargeBlob(blobSize);
-      Put put =
-          Put.newBuilder()
-              .namespace(namespace)
-              .table(tbleName)
-              .partitionKey(Key.ofInt(COL_NAME1, 1))
-              .blobValue(COL_NAME2, blobData)
-              .build();
-
-      // Act
-      storage.put(put);
-
-      // Assert
-      Optional<Result> optionalResult =
-          storage.get(
-              Get.newBuilder()
-                  .namespace(namespace)
-                  .table(tbleName)
-                  .partitionKey(Key.ofInt(COL_NAME1, 1))
-                  .build());
-      assertThat(optionalResult).isPresent();
-      Result result = optionalResult.get();
-      assertThat(result.getColumns().get(COL_NAME2).getBlobValueAsBytes()).isEqualTo(blobData);
-    } catch (InterruptedException e) {
-      throw new RuntimeException(e);
-    } finally {
-      try {
-        admin.dropTable(namespace, tbleName, true);
-      } catch (Exception e) {
-        logger.warn("Failed to drop table", e);
-      }
-    }
-  }
+//  @ParameterizedTest()
+//  @MethodSource("blobSizes")
+//  public void insertSimple_largeBlobData_ShouldWorkCorrectly(int blobSize, String humanReadableSize)
+//      throws ExecutionException {
+//    String tbleName = "e2e_simple";
+//    try {
+//      // Arrange
+//      TableMetadata.Builder metadata =
+//          TableMetadata.newBuilder()
+//              .addColumn(COL_NAME1, DataType.INT)
+//              .addColumn(COL_NAME2, DataType.BLOB)
+//              .addPartitionKey(COL_NAME1);
+//
+//      admin.createTable(namespace, tbleName, metadata.build(), true, getCreationOptions());
+//      admin.truncateTable(namespace, tbleName);
+//      Thread.sleep(3000);
+//      byte[] blobData = createLargeBlob(blobSize);
+//      Put put =
+//          Put.newBuilder()
+//              .namespace(namespace)
+//              .table(tbleName)
+//              .partitionKey(Key.ofInt(COL_NAME1, 1))
+//              .blobValue(COL_NAME2, blobData)
+//              .build();
+//
+//      // Act
+//      storage.put(put);
+//
+//      // Assert
+//      Optional<Result> optionalResult =
+//          storage.get(
+//              Get.newBuilder()
+//                  .namespace(namespace)
+//                  .table(tbleName)
+//                  .partitionKey(Key.ofInt(COL_NAME1, 1))
+//                  .build());
+//      assertThat(optionalResult).isPresent();
+//      Result result = optionalResult.get();
+//      assertThat(result.getColumns().get(COL_NAME2).getBlobValueAsBytes()).isEqualTo(blobData);
+//    } catch (InterruptedException e) {
+//      throw new RuntimeException(e);
+//    } finally {
+//      try {
+//        admin.dropTable(namespace, tbleName, true);
+//      } catch (Exception e) {
+//        logger.warn("Failed to drop table", e);
+//      }
+//    }
+//  }
 
   static Stream<Arguments> blobSizes() {
     return Stream.of(
-        Arguments.of(128, "128b"), // 1 byte
-        Arguments.of(512, "512b"), // 512 byte
-        Arguments.of(1000, "1 KB"), // 1KB
-        Arguments.of(10_000, "10 KB"), // 10KB
-        Arguments.of(20000, "20 KB"), // 20KB
-        Arguments.of(30_000, "30 KB"), // 30KB
-        Arguments.of(40_000, "40 KB"), // 40KB
-        Arguments.of(50_000, "50 KB"), // 50KB
-        Arguments.of(50_000, "60 KB"), // 60KB
-        Arguments.of(70_000, "70 KB"), // 70KB
-        Arguments.of(50_000, "80 KB"), // 50KB
-        Arguments.of(90_000, "90 KB"), // 90KB
-        Arguments.of(100_000, "100 KB"), // 100KB
-        Arguments.of(1_000_000, "1 MB"), // 1MB
-        Arguments.of(5_000_000, "5 MB"), // 5MB
-        Arguments.of(10_000_000, "10 MB"), // 10MB
-        Arguments.of(50_000_000, "50 MB"), // 50 MB
-        Arguments.of(100_000_000, "100 MB"), // 100 MB
-        Arguments.of(200_000_000, "200 MB"), // 200 MB
-        Arguments.of(500_000_000, "500 MB") // 500 MB
+//        Arguments.of(128, "128b"), // 1 byte
+//        Arguments.of(512, "512b"), // 512 byte
+//        Arguments.of(1000, "1 KB"), // 1KB
+//        Arguments.of(10_000, "10 KB"), // 10KB
+//        Arguments.of(20000, "20 KB"), // 20KB
+//        Arguments.of(30_000, "30 KB"), // 30KB
+//        Arguments.of(40_000, "40 KB"), // 40KB
+//        Arguments.of(50_000, "50 KB"), // 50KB
+//        Arguments.of(50_000, "60 KB"), // 60KB
+//        Arguments.of(70_000, "70 KB"), // 70KB
+//        Arguments.of(50_000, "80 KB"), // 50KB
+//        Arguments.of(90_000, "90 KB"), // 90KB
+//        Arguments.of(100_000, "100 KB"), // 100KB
+//        Arguments.of(1_000_000, "1 MB"), // 1MB
+//        Arguments.of(5_000_000, "5 MB"), // 5MB
+//        Arguments.of(10_000_000, "10 MB"), // 10MB
+//        Arguments.of(50_000_000, "50 MB"), // 50 MB
+        Arguments.of(100_000_000, "100 MB") // 100 MB
+//        Arguments.of(200_000_000, "200 MB"), // 200 MB
+//        Arguments.of(500_000_000, "500 MB") // 500 MB
         );
   }