Class MultiJdbcSchemaJoinTest


  • public class MultiJdbcSchemaJoinTest
    extends java.lang.Object
    Test case for joining tables from two different JDBC databases.
    • Constructor Detail

      • MultiJdbcSchemaJoinTest

        public MultiJdbcSchemaJoinTest()
    • Method Detail

      • test

        public void test()
                  throws java.sql.SQLException,
                         java.lang.ClassNotFoundException
        Throws:
        java.sql.SQLException
        java.lang.ClassNotFoundException
      • test2

        public void test2()
                   throws java.sql.SQLException,
                          java.lang.ClassNotFoundException
        Makes sure that test() is re-entrant. Effectively a test for TempDb.
        Throws:
        java.sql.SQLException
        java.lang.ClassNotFoundException
      • test3

        public void test3()
                   throws java.sql.SQLException
        Tests JdbcCatalogSchema.
        Throws:
        java.sql.SQLException
      • setup

        private java.sql.Connection setup()
                                   throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • testJdbcWithEnumerableHashJoin

        public void testJdbcWithEnumerableHashJoin()
                                            throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • testEnumerableWithJdbcJoin

        public void testEnumerableWithJdbcJoin()
                                        throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • testEnumerableWithJdbcJoinWithWhereClause

        public void testEnumerableWithJdbcJoinWithWhereClause()
                                                       throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • runQuery

        private java.util.Set<java.lang.Integer> runQuery​(java.sql.Connection calciteConnection,
                                                          java.lang.String query)
                                                   throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • testSchemaConsistency

        public void testSchemaConsistency()
                                   throws java.lang.Exception
        Throws:
        java.lang.Exception