Package org.apache.calcite.test

Class MultiJdbcSchemaJoinTest

java.lang.Object

org.apache.calcite.test.MultiJdbcSchemaJoinTest

public class MultiJdbcSchemaJoinTest
extends java.lang.Object

Test case for joining tables from two different JDBC databases.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	MultiJdbcSchemaJoinTest.TempDb	Pool of temporary databases.

Constructor Summary

Constructors

Constructor	Description
MultiJdbcSchemaJoinTest()

Method Summary

Modifier and Type	Method	Description
private java.util.Set<java.lang.Integer>	runQuery(java.sql.Connection calciteConnection, java.lang.String query)
private java.sql.Connection	setup()
void	test()
void	test2()	Makes sure that test() is re-entrant.
void	testEnumerableWithJdbcJoin()
void	testEnumerableWithJdbcJoinWithWhereClause()
void	testJdbcWithEnumerableJoin()
void	testSchemaConsistency()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

setup

private java.sql.Connection setup()
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

testJdbcWithEnumerableJoin

public void testJdbcWithEnumerableJoin()
                                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