test(oracle): Enable test class for Oracle connector

Author: namya28

.github/workflows/tests.yml

@@ -63,6 +63,7 @@ jobs:
           - :presto-mongodb -P ci-full-tests
           - :presto-redis -P ci-full-tests
           - :presto-elasticsearch
+          - :presto-oracle -P ci
           - :presto-orc
           - :presto-thrift-connector
           - :presto-spark-base -P presto-spark-tests-smoke

presto-oracle/src/main/java/com/facebook/presto/plugin/oracle/OracleClient.java

@@ -15,7 +15,10 @@
 
 import com.facebook.airlift.log.Logger;
 import com.facebook.presto.common.predicate.TupleDomain;
+import com.facebook.presto.common.type.CharType;
+import com.facebook.presto.common.type.DecimalType;
 import com.facebook.presto.common.type.Decimals;
+import com.facebook.presto.common.type.Type;
 import com.facebook.presto.common.type.VarcharType;
 import com.facebook.presto.plugin.jdbc.BaseJdbcClient;
 import com.facebook.presto.plugin.jdbc.BaseJdbcConfig;
@@ -36,6 +39,7 @@
 import com.facebook.presto.spi.statistics.TableStatistics;
 import com.google.common.collect.Maps;
 import jakarta.inject.Inject;
+import oracle.jdbc.OracleTypes;
 
 import java.sql.Connection;
 import java.sql.DatabaseMetaData;
@@ -49,15 +53,24 @@
 import java.util.Map;
 import java.util.Optional;
 
+import static com.facebook.presto.common.type.BigintType.BIGINT;
+import static com.facebook.presto.common.type.BooleanType.BOOLEAN;
+import static com.facebook.presto.common.type.DateType.DATE;
 import static com.facebook.presto.common.type.DecimalType.createDecimalType;
+import static com.facebook.presto.common.type.DoubleType.DOUBLE;
+import static com.facebook.presto.common.type.IntegerType.INTEGER;
+import static com.facebook.presto.common.type.RealType.REAL;
+import static com.facebook.presto.common.type.TimestampType.TIMESTAMP;
 import static com.facebook.presto.common.type.VarcharType.createUnboundedVarcharType;
 import static com.facebook.presto.common.type.VarcharType.createVarcharType;
+import static com.facebook.presto.common.type.Varchars.isVarcharType;
 import static com.facebook.presto.plugin.jdbc.JdbcErrorCode.JDBC_ERROR;
 import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.bigintReadMapping;
 import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.decimalReadMapping;
 import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.doubleReadMapping;
 import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.realReadMapping;
 import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.smallintReadMapping;
+import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.timestampReadMapping;
 import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.varbinaryReadMapping;
 import static com.facebook.presto.plugin.jdbc.mapping.StandardColumnMappings.varcharReadMapping;
 import static com.facebook.presto.spi.StandardErrorCode.NOT_SUPPORTED;
@@ -261,6 +274,7 @@ public Optional<ReadMapping> toPrestoType(ConnectorSession session, JdbcTypeHand
                 return Optional.of(smallintReadMapping());
             case Types.FLOAT:
             case Types.DOUBLE:
+            case OracleTypes.BINARY_DOUBLE:
                 return Optional.of(doubleReadMapping());
             case Types.REAL:
                 return Optional.of(realReadMapping());
@@ -283,10 +297,56 @@ public Optional<ReadMapping> toPrestoType(ConnectorSession session, JdbcTypeHand
                 return Optional.of(varcharReadMapping(createVarcharType(columnSize)));
             case Types.VARCHAR:
                 return Optional.of(varcharReadMapping(createVarcharType(columnSize)));
+            case Types.DATE:
+            case Types.TIMESTAMP:
+                return Optional.of(timestampReadMapping());
         }
         return super.toPrestoType(session, typeHandle);
     }
 
+    @Override
+    protected String toSqlType(Type type)
+    {
+        if (isVarcharType(type)) {
+            VarcharType varcharType = (VarcharType) type;
+            if (varcharType.isUnbounded()) {
+                return "VARCHAR2(4000)"; // Oracle max before CLOB
+            }
+            return format("VARCHAR2(%s)", varcharType.getLengthSafe());
+        }
+        if (type instanceof CharType) {
+            return format("CHAR(%s)", ((CharType) type).getLength());
+        }
+        if (type instanceof DecimalType) {
+            return format("NUMBER(%s, %s)",
+                    ((DecimalType) type).getPrecision(),
+                    ((DecimalType) type).getScale());
+        }
+
+        if (BIGINT.equals(type)) {
+            return "NUMBER(19)";
+        }
+        if (INTEGER.equals(type)) {
+            return "NUMBER(10)";
+        }
+        if (DOUBLE.equals(type)) {
+            return "BINARY_DOUBLE";
+        }
+        if (REAL.equals(type)) {
+            return "BINARY_FLOAT";
+        }
+        if (BOOLEAN.equals(type)) {
+            return "NUMBER(1)";
+        }
+        if (DATE.equals(type)) {
+            return "DATE";
+        }
+        if (TIMESTAMP.equals(type)) {
+            return "TIMESTAMP";
+        }
+        return super.toSqlType(type);
+    }
+
     @Override
     public String normalizeIdentifier(ConnectorSession session, String identifier)
     {