Package org.apache.calcite.test

Class CalciteAssert

java.lang.Object

org.apache.calcite.test.CalciteAssert

public class CalciteAssert
extends Object

Fluid DSL for testing Calcite connections and queries.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CalciteAssert.AssertMetaData	Fluent interface for building a metadata query to be tested.
static class	CalciteAssert.AssertQuery	Fluent interface for building a query to be tested.
static class	CalciteAssert.AssertThat	Result of calling that().
static enum	CalciteAssert.Config	Connection configuration.
static interface	CalciteAssert.ConnectionPostProcessor	Connection post-processor.
static enum	CalciteAssert.DatabaseInstance	Information necessary to create a JDBC connection.
static interface	CalciteAssert.PreparedStatementConsumer	We want a consumer that can throw SqlException.
static enum	CalciteAssert.SchemaSpec	Specification for common test schemas.

Field Summary

Fields

Modifier and Type	Field	Description
static final CalciteAssert.DatabaseInstance	DB	Which database to use for tests that require a JDBC data source.

Method Summary

Modifier and Type	Method	Description
static SchemaPlus	addSchema(SchemaPlus rootSchema, CalciteAssert.SchemaSpec... schemas)	Adds a schema specification (or specifications) to the root schema, returning the last one created.
static void	assertArrayEqual(String message, Object[] expected, Object[] actual)	Asserts that two objects are equal.
static Consumer<ResultSet>	checkMaskedResultContains(String expected)
static Consumer<ResultSet>	checkResultContains(String... expected)
static Consumer<ResultSet>	checkResultContains(String expected, int count)
static Consumer<ResultSet>	checkResultCount(org.hamcrest.Matcher<Integer> expected)
static Consumer<ResultSet>	checkResultType(String expected)
static Consumer<Integer>	checkUpdateCount(int expected)
static CalciteAssert.AssertThat	hr()	Short-hand for CalciteAssert.that().with(Config.REGULAR).
static CalciteAssert.AssertThat	model(String model)	Short-hand for CalciteAssert.that().with(Config.EMPTY).withModel(model).
static CalciteAssert.AssertThat	that()	Creates an instance of CalciteAssert with the empty configuration.
static CalciteAssert.AssertThat	that(CalciteAssert.Config config)	Creates an instance of CalciteAssert with a given configuration.
static String	toString(ResultSet resultSet)	Converts a ResultSet to a string.

Methods inherited from class java.lang.Object

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

Field Details

DB

public static final CalciteAssert.DatabaseInstance DB

Which database to use for tests that require a JDBC data source.

See Also:

• CalciteSystemProperty.TEST_DB

Method Details

that

public static CalciteAssert.AssertThat that()

Creates an instance of CalciteAssert with the empty configuration.

that

public static CalciteAssert.AssertThat that(CalciteAssert.Config config)

Creates an instance of CalciteAssert with a given configuration.

model

public static CalciteAssert.AssertThat model(String model)

Short-hand for CalciteAssert.that().with(Config.EMPTY).withModel(model).

hr

public static CalciteAssert.AssertThat hr()

Short-hand for CalciteAssert.that().with(Config.REGULAR).

checkResultCount

public static Consumer<ResultSet> checkResultCount(org.hamcrest.Matcher<Integer> expected)

checkUpdateCount

public static Consumer<Integer> checkUpdateCount(int expected)

checkResultContains

public static Consumer<ResultSet> checkResultContains(String... expected)

checkResultContains

public static Consumer<ResultSet> checkResultContains(String expected,
 int count)

checkMaskedResultContains

public static Consumer<ResultSet> checkMaskedResultContains(String expected)

checkResultType

public static Consumer<ResultSet> checkResultType(String expected)

toString

public static String toString(ResultSet resultSet)
                       throws SQLException

Converts a ResultSet to a string.

Throws:

SQLException

addSchema

public static SchemaPlus addSchema(SchemaPlus rootSchema,
 CalciteAssert.SchemaSpec... schemas)

Adds a schema specification (or specifications) to the root schema, returning the last one created.

assertArrayEqual

public static void assertArrayEqual(String message,
 Object[] expected,
 Object[] actual)

Asserts that two objects are equal. If they are not, an AssertionError is thrown with the given message. If expected and actual are null, they are considered equal.

This method produces more user-friendly error messages than Assertions.assertArrayEquals(Object[], Object[], String)

Parameters:

message - the identifying message for the AssertionError (null okay)

expected - expected value

actual - actual value