Package org.apache.calcite.test

Class CalciteAssert.AssertThat

java.lang.Object

org.apache.calcite.test.CalciteAssert.AssertThat

Enclosing class:

CalciteAssert

public static class CalciteAssert.AssertThat
extends java.lang.Object

Result of calling CalciteAssert.that().

Field Summary

Fields

Modifier and Type	Field	Description
private CalciteAssert.ConnectionFactory	connectionFactory
private static CalciteAssert.AssertThat	EMPTY

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AssertThat(CalciteAssert.ConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
java.sql.Connection	connect()	Use sparingly.
CalciteAssert.AssertThat	connectThrows(java.lang.String message)	Asserts that there is an exception with the given message while creating a connection.
CalciteAssert.AssertThat	connectThrows(java.util.function.Consumer<java.lang.Throwable> exceptionChecker)	Asserts that there is an exception that matches the given predicate while creating a connection.
CalciteAssert.AssertThat	doWithConnection(java.util.function.Consumer<org.apache.calcite.jdbc.CalciteConnection> fn)	Creates a CalciteConnection and executes a callback that returns no result.
<T> CalciteAssert.AssertThat	doWithConnection(java.util.function.Function<org.apache.calcite.jdbc.CalciteConnection,T> fn)	Creates a CalciteConnection and executes a callback.
<T> CalciteAssert.AssertThat	doWithDataContext(java.util.function.Function<org.apache.calcite.DataContext,T> fn)	Creates a DataContext and executes a callback.
CalciteAssert.AssertThat	enable(boolean enabled)
CalciteAssert.AssertMetaData	metaData(java.util.function.Function<java.sql.Connection,java.sql.ResultSet> function)
CalciteAssert.AssertThat	pooled()	Returns a version that uses a single connection, as opposed to creating a new one each time a test method is invoked.
CalciteAssert.AssertQuery	query(java.lang.String sql)
CalciteAssert.AssertThat	with(java.lang.String property, java.lang.Object value)
CalciteAssert.AssertThat	with(java.util.Map<java.lang.String,java.lang.String> map)
CalciteAssert.AssertThat	with(org.apache.calcite.avatica.ConnectionProperty property, java.lang.Object value)
CalciteAssert.AssertThat	with(org.apache.calcite.config.Lex lex)	Sets Lex property
CalciteAssert.AssertThat	with(CalciteAssert.Config config)
CalciteAssert.AssertThat	with(CalciteAssert.ConnectionFactory connectionFactory)	Creates a copy of this AssertThat, overriding the connection factory.
CalciteAssert.AssertThat	with(CalciteAssert.ConnectionPostProcessor postProcessor)
CalciteAssert.AssertThat	with(CalciteAssert.SchemaSpec... specs)	Creates a copy of this AssertThat, adding more schemas
CalciteAssert.AssertThat	withDefaultSchema(java.lang.String schema)	Sets the default schema of the connection.
CalciteAssert.AssertThat	withMaterializations(java.lang.String model, boolean existing, java.lang.String... materializations)	Adds materializations to the schema.
CalciteAssert.AssertThat	withMaterializations(java.lang.String model, java.lang.String... materializations)
CalciteAssert.AssertThat	withMaterializations(java.lang.String model, java.util.function.Function<org.apache.calcite.util.JsonBuilder,java.util.List<java.lang.Object>> materializations)	Adds materializations to the schema.
CalciteAssert.AssertThat	withModel(java.lang.String model)
CalciteAssert.AssertThat	withModel(java.net.URL model)
CalciteAssert.AssertThat	withSchema(java.lang.String name, org.apache.calcite.schema.Schema schema)	Sets the default schema to a given schema.

Methods inherited from class java.lang.Object

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

Field Detail

connectionFactory

private final CalciteAssert.ConnectionFactory connectionFactory

EMPTY

private static final CalciteAssert.AssertThat EMPTY

Constructor Detail

AssertThat

private AssertThat(CalciteAssert.ConnectionFactory connectionFactory)

Method Detail

with

public CalciteAssert.AssertThat with(CalciteAssert.Config config)

with

public CalciteAssert.AssertThat with(CalciteAssert.SchemaSpec... specs)

Creates a copy of this AssertThat, adding more schemas

with

public CalciteAssert.AssertThat with(CalciteAssert.ConnectionFactory connectionFactory)

Creates a copy of this AssertThat, overriding the connection factory.

with

public final CalciteAssert.AssertThat with(java.util.Map<java.lang.String,java.lang.String> map)

with

public CalciteAssert.AssertThat with(java.lang.String property,
                                     java.lang.Object value)

with

public CalciteAssert.AssertThat with(org.apache.calcite.avatica.ConnectionProperty property,
                                     java.lang.Object value)

with

public CalciteAssert.AssertThat with(org.apache.calcite.config.Lex lex)

Sets Lex property

withSchema

public CalciteAssert.AssertThat withSchema(java.lang.String name,
                                           org.apache.calcite.schema.Schema schema)

Sets the default schema to a given schema.

withDefaultSchema

public CalciteAssert.AssertThat withDefaultSchema(java.lang.String schema)

Sets the default schema of the connection. Schema name may be null.

with

public CalciteAssert.AssertThat with(CalciteAssert.ConnectionPostProcessor postProcessor)

withModel

public final CalciteAssert.AssertThat withModel(java.lang.String model)

withModel

public final CalciteAssert.AssertThat withModel(java.net.URL model)

withMaterializations

public final CalciteAssert.AssertThat withMaterializations(java.lang.String model,
                                                           java.lang.String... materializations)

withMaterializations

public final CalciteAssert.AssertThat withMaterializations(java.lang.String model,
                                                           boolean existing,
                                                           java.lang.String... materializations)

Adds materializations to the schema.

withMaterializations

public final CalciteAssert.AssertThat withMaterializations(java.lang.String model,
                                                           java.util.function.Function<org.apache.calcite.util.JsonBuilder,java.util.List<java.lang.Object>> materializations)

Adds materializations to the schema.

query

public CalciteAssert.AssertQuery query(java.lang.String sql)

connectThrows

public CalciteAssert.AssertThat connectThrows(java.lang.String message)

Asserts that there is an exception with the given message while creating a connection.

connectThrows

public CalciteAssert.AssertThat connectThrows(java.util.function.Consumer<java.lang.Throwable> exceptionChecker)

Asserts that there is an exception that matches the given predicate while creating a connection.

doWithConnection

public <T> CalciteAssert.AssertThat doWithConnection(java.util.function.Function<org.apache.calcite.jdbc.CalciteConnection,T> fn)
                                              throws java.lang.Exception

Creates a CalciteConnection and executes a callback.

Throws:

java.lang.Exception

doWithConnection

public final CalciteAssert.AssertThat doWithConnection(java.util.function.Consumer<org.apache.calcite.jdbc.CalciteConnection> fn)
                                                throws java.lang.Exception

Creates a CalciteConnection and executes a callback that returns no result.

Throws:

java.lang.Exception

doWithDataContext

public <T> CalciteAssert.AssertThat doWithDataContext(java.util.function.Function<org.apache.calcite.DataContext,T> fn)
                                               throws java.lang.Exception

Creates a DataContext and executes a callback.

Throws:

java.lang.Exception

connect

public java.sql.Connection connect()
                            throws java.sql.SQLException

Use sparingly. Does not close the connection.

Throws:

java.sql.SQLException

enable

public CalciteAssert.AssertThat enable(boolean enabled)

pooled

public CalciteAssert.AssertThat pooled()

Returns a version that uses a single connection, as opposed to creating a new one each time a test method is invoked.

metaData

public CalciteAssert.AssertMetaData metaData(java.util.function.Function<java.sql.Connection,java.sql.ResultSet> function)