Enable and fix all Cassandra connector tests in CI

Author: bibith4

.github/workflows/tests.yml

@@ -48,7 +48,7 @@ jobs:
           - ":presto-tests -P ci-only-plan-determinism"
           - ":presto-tests -P ci-only-resource-manager" 
           - ":presto-accumulo"
-          - ":presto-cassandra -P test-cassandra-integration-smoke-test"
+          - ":presto-cassandra -P ci-full-tests"
           - ":presto-hive"
           - ":presto-hive -P test-hive-materialized-queries"
           - ":presto-hive -P test-hive-materialized-aggregations"

presto-cassandra/pom.xml

@@ -272,18 +272,14 @@
                 </plugins>
             </build>
         </profile>
+        <!-- Full test suite for CI/CD pipelines -->
         <profile>
-            <id>test-cassandra-integration-smoke-test</id>
+            <id>ci-full-tests</id>
             <build>
                 <plugins>
                     <plugin>
                         <groupId>org.apache.maven.plugins</groupId>
                         <artifactId>maven-surefire-plugin</artifactId>
-                        <configuration>
-                            <includes>
-                                <include>**/TestCassandraIntegrationSmokeTest.java</include>
-                            </includes>
-                        </configuration>
                     </plugin>
                 </plugins>
             </build>

presto-cassandra/src/test/java/com/facebook/presto/cassandra/TestCassandraDistributed.java

@@ -19,6 +19,7 @@
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.Optional;
 
+import static com.facebook.presto.common.type.BigintType.BIGINT;
 import static com.facebook.presto.common.type.VarcharType.VARCHAR;
 import static com.facebook.presto.testing.MaterializedResult.resultBuilder;
 import static com.facebook.presto.testing.assertions.Assert.assertEquals;
@@ -119,16 +120,16 @@ public void testShowColumns(@Optional("PARQUET") String storageFormat)
     {
         MaterializedResult actual = computeActual("SHOW COLUMNS FROM orders");
 
-        MaterializedResult expectedParametrizedVarchar = resultBuilder(getSession(), VARCHAR, VARCHAR, VARCHAR, VARCHAR)
-                .row("orderkey", "bigint", "", "")
-                .row("custkey", "bigint", "", "")
-                .row("orderstatus", "varchar", "", "")
-                .row("totalprice", "double", "", "")
-                .row("orderdate", "varchar", "", "")
-                .row("orderpriority", "varchar", "", "")
-                .row("clerk", "varchar", "", "")
-                .row("shippriority", "integer", "", "")
-                .row("comment", "varchar", "", "")
+        MaterializedResult expectedParametrizedVarchar = resultBuilder(getSession(), VARCHAR, VARCHAR, VARCHAR, VARCHAR, BIGINT, BIGINT, BIGINT)
+                .row("orderkey", "bigint", "", "", Long.valueOf(19), null, null)
+                .row("custkey", "bigint", "", "", Long.valueOf(19), null, null)
+                .row("orderstatus", "varchar", "", "", null, null, Long.valueOf(2147483647))
+                .row("totalprice", "double", "", "", Long.valueOf(53), null, null)
+                .row("orderdate", "varchar", "", "", null, null, Long.valueOf(2147483647))
+                .row("orderpriority", "varchar", "", "", null, null, Long.valueOf(2147483647))
+                .row("clerk", "varchar", "", "", null, null, Long.valueOf(2147483647))
+                .row("shippriority", "integer", "", "", Long.valueOf(10), null, null)
+                .row("comment", "varchar", "", "", null, null, Long.valueOf(2147483647))
                 .build();
 
         assertEquals(actual, expectedParametrizedVarchar);
@@ -151,4 +152,57 @@ public void testWrittenStats()
     {
         // TODO Cassandra connector supports CTAS and inserts, but the test would fail
     }
+
+    @Override
+    public void testPayloadJoinApplicability()
+    {
+        // no op -- test not supported due to lack of support for array types.
+    }
+
+    @Override
+    public void testPayloadJoinCorrectness()
+    {
+        // no op -- test not supported due to lack of support for array types.
+    }
+    @Override
+    public void testNonAutoCommitTransactionWithCommit()
+    {
+        // Connector only supports writes using ctas
+    }
+
+    @Override
+    public void testNonAutoCommitTransactionWithRollback()
+    {
+        // Connector only supports writes using ctas
+    }
+
+    @Override
+    public void testRemoveRedundantCastToVarcharInJoinClause()
+    {
+        // no op -- test not supported due to lack of support for array types.
+    }
+
+    @Override
+    public void testStringFilters()
+    {
+        // no op -- test not supported due to lack of support for char type.
+    }
+
+    @Override
+    public void testSubfieldAccessControl()
+    {
+        // no op -- test not supported due to lack of support for array types.
+    }
+
+    @Override
+    protected String getOrderDateExpression(String storageFormat)
+    {
+        return "CAST(o.orderdate AS DATE)";
+    }
+
+    @Override
+    protected String getShipDateExpression(String storageFormat)
+    {
+        return "cast(l.shipdate as DATE)";
+    }
 }