Add time-related types to the storage and transactional interfaces.

build.gradle

@@ -31,7 +31,7 @@ subprojects {
         commonsDbcp2Version = '2.13.0'
         mysqlDriverVersion = '8.4.0'
         postgresqlDriverVersion = '42.7.4'
-        oracleDriverVersion = '21.16.0.0'
+        oracleDriverVersion = '23.6.0.24.10'
         sqlserverDriverVersion = '11.2.3.jre8'
         sqliteDriverVersion = '3.47.1.0'
         yugabyteDriverVersion = '42.7.3-yb-2'

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraColumnValueIntegrationTest.java

@@ -16,4 +16,9 @@ protected Properties getProperties(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected boolean isTimestampTypeSupported() {
+    return false;
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraConditionalMutationIntegrationTest.java

@@ -32,4 +32,9 @@ protected boolean shouldMutate(
         return super.shouldMutate(initialColumn, columnToCompare, operator);
     }
   }
+
+  @Override
+  protected boolean isTimestampTypeSupported() {
+    return false;
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraCrossPartitionScanIntegrationTest.java

@@ -24,4 +24,9 @@ protected Map<String, String> getCreationOptions() {
   @Override
   @Disabled("Cross partition scan with ordering is not supported in Cassandra")
   public void scan_WithOrderingForNonPrimaryColumns_ShouldReturnProperResult() {}
+
+  @Override
+  protected boolean isTimestampTypeSupported() {
+    return false;
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraMultipleClusteringKeyScanIntegrationTest.java

@@ -1,9 +1,12 @@
 package com.scalar.db.storage.cassandra;
 
 import com.scalar.db.api.DistributedStorageMultipleClusteringKeyScanIntegrationTestBase;
+import com.scalar.db.io.DataType;
 import java.util.Collections;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
+import java.util.stream.Collectors;
 
 public class CassandraMultipleClusteringKeyScanIntegrationTest
     extends DistributedStorageMultipleClusteringKeyScanIntegrationTestBase {
@@ -17,4 +20,11 @@ protected Properties getProperties(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected List<DataType> getDataTypes() {
+    return super.getDataTypes().stream()
+        .filter(type -> type != DataType.TIMESTAMP)
+        .collect(Collectors.toList());
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraMultiplePartitionKeyIntegrationTest.java

@@ -1,9 +1,12 @@
 package com.scalar.db.storage.cassandra;
 
 import com.scalar.db.api.DistributedStorageMultiplePartitionKeyIntegrationTestBase;
+import com.scalar.db.io.DataType;
 import java.util.Collections;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
+import java.util.stream.Collectors;
 
 public class CassandraMultiplePartitionKeyIntegrationTest
     extends DistributedStorageMultiplePartitionKeyIntegrationTestBase {
@@ -16,4 +19,11 @@ protected Properties getProperties(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected List<DataType> getDataTypes() {
+    return super.getDataTypes().stream()
+        .filter(type -> type != DataType.TIMESTAMP)
+        .collect(Collectors.toList());
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraSecondaryIndexIntegrationTest.java

@@ -1,9 +1,12 @@
 package com.scalar.db.storage.cassandra;
 
 import com.scalar.db.api.DistributedStorageSecondaryIndexIntegrationTestBase;
+import com.scalar.db.io.DataType;
 import java.util.Collections;
 import java.util.Map;
 import java.util.Properties;
+import java.util.Set;
+import java.util.stream.Collectors;
 
 public class CassandraSecondaryIndexIntegrationTest
     extends DistributedStorageSecondaryIndexIntegrationTestBase {
@@ -16,4 +19,11 @@ protected Properties getProperties(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected Set<DataType> getSecondaryIndexTypes() {
+    return super.getSecondaryIndexTypes().stream()
+        .filter(type -> type != DataType.TIMESTAMP)
+        .collect(Collectors.toSet());
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraSingleClusteringKeyScanIntegrationTest.java

@@ -1,9 +1,12 @@
 package com.scalar.db.storage.cassandra;
 
 import com.scalar.db.api.DistributedStorageSingleClusteringKeyScanIntegrationTestBase;
+import com.scalar.db.io.DataType;
 import java.util.Collections;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
+import java.util.stream.Collectors;
 
 public class CassandraSingleClusteringKeyScanIntegrationTest
     extends DistributedStorageSingleClusteringKeyScanIntegrationTestBase {
@@ -16,4 +19,11 @@ protected Properties getProperties(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected List<DataType> getClusteringKeyTypes() {
+    return super.getClusteringKeyTypes().stream()
+        .filter(type -> type != DataType.TIMESTAMP)
+        .collect(Collectors.toList());
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/CassandraSinglePartitionKeyIntegrationTest.java

@@ -1,9 +1,12 @@
 package com.scalar.db.storage.cassandra;
 
 import com.scalar.db.api.DistributedStorageSinglePartitionKeyIntegrationTestBase;
+import com.scalar.db.io.DataType;
 import java.util.Collections;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
+import java.util.stream.Collectors;
 
 public class CassandraSinglePartitionKeyIntegrationTest
     extends DistributedStorageSinglePartitionKeyIntegrationTestBase {
@@ -16,4 +19,11 @@ protected Properties getProperties(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected List<DataType> getPartitionKeyTypes() {
+    return super.getPartitionKeyTypes().stream()
+        .filter(type -> type != DataType.TIMESTAMP)
+        .collect(Collectors.toList());
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/ConsensusCommitIntegrationTestWithCassandra.java

@@ -16,4 +16,9 @@ protected Properties getProps(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected boolean isTimestampTypeSupported() {
+    return false;
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cassandra/SingleCrudOperationTransactionIntegrationTestWithCassandra.java

@@ -17,4 +17,9 @@ protected Properties getProps(String testName) {
   protected Map<String, String> getCreationOptions() {
     return Collections.singletonMap(CassandraAdmin.REPLICATION_FACTOR, "1");
   }
+
+  @Override
+  protected boolean isTimestampTypeSupported() {
+    return false;
+  }
 }

core/src/integration-test/java/com/scalar/db/storage/cosmos/CosmosMultipleClusteringKeyScanIntegrationTest.java

@@ -1,11 +1,11 @@
 package com.scalar.db.storage.cosmos;
 
-import com.google.common.collect.ArrayListMultimap;
-import com.google.common.collect.ListMultimap;
 import com.scalar.db.api.DistributedStorageMultipleClusteringKeyScanIntegrationTestBase;
 import com.scalar.db.io.DataType;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
+import java.util.stream.Collectors;
 
 public class CosmosMultipleClusteringKeyScanIntegrationTest
     extends DistributedStorageMultipleClusteringKeyScanIntegrationTestBase {
@@ -16,21 +16,11 @@ protected Properties getProperties(String testName) {
   }
 
   @Override
-  protected ListMultimap<DataType, DataType> getClusteringKeyTypes() {
+  protected List<DataType> getDataTypes() {
     // Return types without BLOB because blob is not supported for clustering key for now
-    ListMultimap<DataType, DataType> clusteringKeyTypes = ArrayListMultimap.create();
-    for (DataType firstClusteringKeyType : DataType.valuesWithoutTimesRelatedTypes()) {
-      if (firstClusteringKeyType == DataType.BLOB) {
-        continue;
-      }
-      for (DataType secondClusteringKeyType : DataType.valuesWithoutTimesRelatedTypes()) {
-        if (secondClusteringKeyType == DataType.BLOB) {
-          continue;
-        }
-        clusteringKeyTypes.put(firstClusteringKeyType, secondClusteringKeyType);
-      }
-    }
-    return clusteringKeyTypes;
+    return super.getDataTypes().stream()
+        .filter(type -> type != DataType.BLOB)
+        .collect(Collectors.toList());
   }
 
   @Override

core/src/integration-test/java/com/scalar/db/storage/cosmos/CosmosSingleClusteringKeyScanIntegrationTest.java

@@ -2,10 +2,10 @@
 
 import com.scalar.db.api.DistributedStorageSingleClusteringKeyScanIntegrationTestBase;
 import com.scalar.db.io.DataType;
-import java.util.HashSet;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
-import java.util.Set;
 
 public class CosmosSingleClusteringKeyScanIntegrationTest
     extends DistributedStorageSingleClusteringKeyScanIntegrationTestBase {
@@ -15,10 +15,10 @@ protected Properties getProperties(String testName) {
   }
 
   @Override
-  protected Set<DataType> getClusteringKeyTypes() {
+  protected List<DataType> getClusteringKeyTypes() {
     // Return types without BLOB because blob is not supported for clustering key for now
-    Set<DataType> clusteringKeyTypes = new HashSet<>();
-    for (DataType dataType : DataType.valuesWithoutTimesRelatedTypes()) {
+    List<DataType> clusteringKeyTypes = new ArrayList<>();
+    for (DataType dataType : DataType.values()) {
       if (dataType == DataType.BLOB) {
         continue;
       }

core/src/integration-test/java/com/scalar/db/storage/dynamo/DynamoMultipleClusteringKeyScanIntegrationTest.java

@@ -1,13 +1,13 @@
 package com.scalar.db.storage.dynamo;
 
-import com.google.common.collect.ArrayListMultimap;
-import com.google.common.collect.ListMultimap;
 import com.scalar.db.api.DistributedStorageMultipleClusteringKeyScanIntegrationTestBase;
 import com.scalar.db.io.Column;
 import com.scalar.db.io.DataType;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 import java.util.Random;
+import java.util.stream.Collectors;
 
 public class DynamoMultipleClusteringKeyScanIntegrationTest
     extends DistributedStorageMultipleClusteringKeyScanIntegrationTestBase {
@@ -18,21 +18,11 @@ protected Properties getProperties(String testName) {
   }
 
   @Override
-  protected ListMultimap<DataType, DataType> getClusteringKeyTypes() {
+  protected List<DataType> getDataTypes() {
     // Return types without BLOB because blob is not supported for clustering key for now
-    ListMultimap<DataType, DataType> clusteringKeyTypes = ArrayListMultimap.create();
-    for (DataType firstClusteringKeyType : DataType.valuesWithoutTimesRelatedTypes()) {
-      if (firstClusteringKeyType == DataType.BLOB) {
-        continue;
-      }
-      for (DataType secondClusteringKeyType : DataType.valuesWithoutTimesRelatedTypes()) {
-        if (secondClusteringKeyType == DataType.BLOB) {
-          continue;
-        }
-        clusteringKeyTypes.put(firstClusteringKeyType, secondClusteringKeyType);
-      }
-    }
-    return clusteringKeyTypes;
+    return super.getDataTypes().stream()
+        .filter(type -> type != DataType.BLOB)
+        .collect(Collectors.toList());
   }
 
   @Override

core/src/integration-test/java/com/scalar/db/storage/dynamo/DynamoMultiplePartitionKeyIntegrationTest.java

@@ -24,12 +24,12 @@ protected Map<String, String> getCreationOptions() {
   @Override
   protected ListMultimap<DataType, DataType> getPartitionKeyTypes() {
     ListMultimap<DataType, DataType> clusteringKeyTypes = ArrayListMultimap.create();
-    for (DataType firstClusteringKeyType : DataType.valuesWithoutTimesRelatedTypes()) {
+    for (DataType firstClusteringKeyType : DataType.values()) {
       // BLOB type is supported only for the last value in partition key
       if (firstClusteringKeyType == DataType.BLOB) {
         continue;
       }
-      for (DataType secondClusteringKeyType : DataType.valuesWithoutTimesRelatedTypes()) {
+      for (DataType secondClusteringKeyType : DataType.values()) {
         clusteringKeyTypes.put(firstClusteringKeyType, secondClusteringKeyType);
       }
     }

core/src/integration-test/java/com/scalar/db/storage/dynamo/DynamoSecondaryIndexIntegrationTest.java

@@ -21,7 +21,7 @@ protected Properties getProperties(String testName) {
   protected Set<DataType> getSecondaryIndexTypes() {
     // Return types without BOOLEAN because boolean is not supported for secondary index for now
     Set<DataType> clusteringKeyTypes = new HashSet<>();
-    for (DataType dataType : DataType.valuesWithoutTimesRelatedTypes()) {
+    for (DataType dataType : DataType.values()) {
       if (dataType == DataType.BOOLEAN) {
         continue;
       }

core/src/integration-test/java/com/scalar/db/storage/dynamo/DynamoSingleClusteringKeyScanIntegrationTest.java

@@ -3,11 +3,11 @@
 import com.scalar.db.api.DistributedStorageSingleClusteringKeyScanIntegrationTestBase;
 import com.scalar.db.io.Column;
 import com.scalar.db.io.DataType;
-import java.util.HashSet;
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 import java.util.Random;
-import java.util.Set;
 
 public class DynamoSingleClusteringKeyScanIntegrationTest
     extends DistributedStorageSingleClusteringKeyScanIntegrationTestBase {
@@ -18,10 +18,10 @@ protected Properties getProperties(String testName) {
   }
 
   @Override
-  protected Set<DataType> getClusteringKeyTypes() {
+  protected List<DataType> getClusteringKeyTypes() {
     // Return types without BLOB because blob is not supported for clustering key for now
-    Set<DataType> clusteringKeyTypes = new HashSet<>();
-    for (DataType dataType : DataType.valuesWithoutTimesRelatedTypes()) {
+    List<DataType> clusteringKeyTypes = new ArrayList<>();
+    for (DataType dataType : DataType.values()) {
       if (dataType == DataType.BLOB) {
         continue;
       }

core/src/integration-test/java/com/scalar/db/storage/dynamo/DynamoTestUtils.java

@@ -20,8 +20,7 @@ public static DoubleColumn getRandomDynamoDoubleColumn(Random random, String col
 
   public static double nextDynamoDouble(Random random) {
     return random
-        .doubles(MIN_DYNAMO_DOUBLE_VALUE, MAX_DYNAMO_DOUBLE_VALUE)
-        .limit(1)
+        .doubles(1, MIN_DYNAMO_DOUBLE_VALUE, MAX_DYNAMO_DOUBLE_VALUE)
         .findFirst()
         .orElse(0.0d);
   }

core/src/integration-test/java/com/scalar/db/storage/jdbc/ConsensusCommitAdminRepairIntegrationTestWithJdbcDatabase.java

@@ -9,7 +9,7 @@
 
 public class ConsensusCommitAdminRepairIntegrationTestWithJdbcDatabase
     extends ConsensusCommitAdminRepairIntegrationTestBase {
-  @LazyInit private RdbEngineStrategy rdbEngine;
+  @LazyInit private RdbEngineStrategy<?, ?, ?, ?> rdbEngine;
 
   @Override
   protected Properties getProps(String testName) {

core/src/integration-test/java/com/scalar/db/storage/jdbc/JdbcAdminImportTestUtils.java

@@ -107,7 +107,7 @@ public class JdbcAdminImportTestUtils {
           "geometry",
           "geography");
 
-  private final RdbEngineStrategy rdbEngine;
+  private final RdbEngineStrategy<?, ?, ?, ?> rdbEngine;
   private final int majorVersion;
   private final BasicDataSource dataSource;
 

core/src/integration-test/java/com/scalar/db/storage/jdbc/JdbcAdminRepairIntegrationTest.java

@@ -9,7 +9,7 @@
 
 public class JdbcAdminRepairIntegrationTest
     extends DistributedStorageAdminRepairIntegrationTestBase {
-  @LazyInit private RdbEngineStrategy rdbEngine;
+  @LazyInit private RdbEngineStrategy<?, ?, ?, ?> rdbEngine;
 
   @Override
   protected Properties getProperties(String testName) {

core/src/integration-test/java/com/scalar/db/storage/jdbc/JdbcAdminTestUtils.java

@@ -16,7 +16,7 @@
 public class JdbcAdminTestUtils extends AdminTestUtils {
 
   private final String metadataSchema;
-  private final RdbEngineStrategy rdbEngine;
+  private final RdbEngineStrategy<?, ?, ?, ?> rdbEngine;
   private final BasicDataSource dataSource;
 
   public JdbcAdminTestUtils(Properties properties) {

core/src/integration-test/java/com/scalar/db/storage/jdbc/JdbcDatabaseColumnValueIntegrationTest.java

@@ -11,7 +11,7 @@
 public class JdbcDatabaseColumnValueIntegrationTest
     extends DistributedStorageColumnValueIntegrationTestBase {
 
-  private RdbEngineStrategy rdbEngine;
+  private RdbEngineStrategy<?, ?, ?, ?> rdbEngine;
 
   @Override
   protected Properties getProperties(String testName) {