Check for specific rows in system catalog product test

trinodb · Oct 20, 2021 · f9a3975 · f9a3975
1 parent ef2a66f
commit f9a3975
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/testing/trino-product-tests/src/main/java/io/trino/tests/product/TestSystemConnector.java b/testing/trino-product-tests/src/main/java/io/trino/tests/product/TestSystemConnector.java
@@ -13,9 +13,11 @@
  */
 package io.trino.tests.product;
 
+import com.google.common.collect.ImmutableList;
 import io.trino.tempto.ProductTest;
 import org.testng.annotations.Test;
 
+import static io.trino.tempto.assertions.QueryAssert.Row.row;
 import static io.trino.tempto.assertions.QueryAssert.assertThat;
 import static io.trino.tempto.query.QueryExecutor.query;
 import static io.trino.tests.product.TestGroups.JDBC;
@@ -114,6 +116,10 @@ public void selectMetadataCatalogs()
         String sql = "select catalog_name, connector_id, connector_name from system.metadata.catalogs";
         assertThat(query(sql))
                 .hasColumns(VARCHAR, VARCHAR, VARCHAR)
-                .hasAnyRows();
+                .contains(
+                        ImmutableList.of(
+                                row("jmx", "jmx", "jmx"),
+                                row("system", "system", "system"),
+                                row("tpch", "tpch", "tpch")));
     }
 }