Fix tests to use safe character

Author: KodaiD

core/src/integration-test/java/com/scalar/db/storage/objectstorage/ObjectStorageMultipleClusteringKeyScanIntegrationTest.java

@@ -1,7 +1,12 @@
 package com.scalar.db.storage.objectstorage;
 
 import com.scalar.db.api.DistributedStorageMultipleClusteringKeyScanIntegrationTestBase;
+import com.scalar.db.io.Column;
+import com.scalar.db.io.DataType;
+import com.scalar.db.io.TextColumn;
+import com.scalar.db.util.TestUtils;
 import java.util.Properties;
+import java.util.stream.IntStream;
 
 public class ObjectStorageMultipleClusteringKeyScanIntegrationTest
     extends DistributedStorageMultipleClusteringKeyScanIntegrationTestBase {
@@ -20,4 +25,15 @@ protected int getThreadNum() {
   protected boolean isParallelDdlSupported() {
     return false;
   }
+
+  @Override
+  protected Column<?> getColumnWithMaxValue(String columnName, DataType dataType) {
+    if (dataType == DataType.TEXT && ObjectStorageEnv.isCloudStorage()) {
+      // Since Cloud Storage can't handle 0xFF character correctly, we use "ZZZ..." as the max value
+      StringBuilder builder = new StringBuilder();
+      IntStream.range(0, TestUtils.MAX_TEXT_COUNT).forEach(i -> builder.append('Z'));
+      return TextColumn.of(columnName, builder.toString());
+    }
+    return super.getColumnWithMaxValue(columnName, dataType);
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/objectstorage/ObjectStorageMultiplePartitionKeyIntegrationTest.java

@@ -1,7 +1,12 @@
 package com.scalar.db.storage.objectstorage;
 
 import com.scalar.db.api.DistributedStorageMultiplePartitionKeyIntegrationTestBase;
+import com.scalar.db.io.Column;
+import com.scalar.db.io.DataType;
+import com.scalar.db.io.TextColumn;
+import com.scalar.db.util.TestUtils;
 import java.util.Properties;
+import java.util.stream.IntStream;
 
 public class ObjectStorageMultiplePartitionKeyIntegrationTest
     extends DistributedStorageMultiplePartitionKeyIntegrationTestBase {
@@ -20,4 +25,15 @@ protected int getThreadNum() {
   protected boolean isParallelDdlSupported() {
     return false;
   }
+
+  @Override
+  protected Column<?> getColumnWithMaxValue(String columnName, DataType dataType) {
+    if (dataType == DataType.TEXT && ObjectStorageEnv.isCloudStorage()) {
+      // Since Cloud Storage can't handle 0xFF character correctly, we use "ZZZ..." as the max value
+      StringBuilder builder = new StringBuilder();
+      IntStream.range(0, TestUtils.MAX_TEXT_COUNT).forEach(i -> builder.append('Z'));
+      return TextColumn.of(columnName, builder.toString());
+    }
+    return super.getColumnWithMaxValue(columnName, dataType);
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/objectstorage/ObjectStorageSingleClusteringKeyScanIntegrationTest.java

@@ -1,12 +1,29 @@
 package com.scalar.db.storage.objectstorage;
 
 import com.scalar.db.api.DistributedStorageSingleClusteringKeyScanIntegrationTestBase;
+import com.scalar.db.io.Column;
+import com.scalar.db.io.DataType;
+import com.scalar.db.io.TextColumn;
+import com.scalar.db.util.TestUtils;
 import java.util.Properties;
+import java.util.stream.IntStream;
 
 public class ObjectStorageSingleClusteringKeyScanIntegrationTest
     extends DistributedStorageSingleClusteringKeyScanIntegrationTestBase {
+
   @Override
   protected Properties getProperties(String testName) {
     return ObjectStorageEnv.getProperties(testName);
   }
+
+  @Override
+  protected Column<?> getColumnWithMaxValue(String columnName, DataType dataType) {
+    if (dataType == DataType.TEXT && ObjectStorageEnv.isCloudStorage()) {
+      // Since Cloud Storage can't handle 0xFF character correctly, we use "ZZZ..." as the max value
+      StringBuilder builder = new StringBuilder();
+      IntStream.range(0, TestUtils.MAX_TEXT_COUNT).forEach(i -> builder.append('Z'));
+      return TextColumn.of(columnName, builder.toString());
+    }
+    return super.getColumnWithMaxValue(columnName, dataType);
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/objectstorage/ObjectStorageSinglePartitionKeyIntegrationTest.java

@@ -1,12 +1,29 @@
 package com.scalar.db.storage.objectstorage;
 
 import com.scalar.db.api.DistributedStorageSinglePartitionKeyIntegrationTestBase;
+import com.scalar.db.io.Column;
+import com.scalar.db.io.DataType;
+import com.scalar.db.io.TextColumn;
+import com.scalar.db.util.TestUtils;
 import java.util.Properties;
+import java.util.stream.IntStream;
 
 public class ObjectStorageSinglePartitionKeyIntegrationTest
     extends DistributedStorageSinglePartitionKeyIntegrationTestBase {
+
   @Override
   protected Properties getProperties(String testName) {
     return ObjectStorageEnv.getProperties(testName);
   }
+
+  @Override
+  protected Column<?> getColumnWithMaxValue(String columnName, DataType dataType) {
+    if (dataType == DataType.TEXT && ObjectStorageEnv.isCloudStorage()) {
+      // Since Cloud Storage can't handle 0xFF character correctly, we use "ZZZ..." as the max value
+      StringBuilder builder = new StringBuilder();
+      IntStream.range(0, TestUtils.MAX_TEXT_COUNT).forEach(i -> builder.append('Z'));
+      return TextColumn.of(columnName, builder.toString());
+    }
+    return super.getColumnWithMaxValue(columnName, dataType);
+  }
 }