org.apache.calcite.sql.test

类 AbstractSqlTester

java.lang.Object

org.apache.calcite.sql.test.AbstractSqlTester

所有已实现的接口:

AutoCloseable, SqlTester

直接已知子类:

SqlOperatorTest.TesterImpl, SqlValidatorTester

public abstract class AbstractSqlTester
extends Object
implements SqlTester, AutoCloseable

Abstract implementation of SqlTester that talks to a mock catalog.

This is to implement the default behavior: testing is only against the SqlValidator.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.calcite.sql.test.SqlTester

SqlTester.ParameterChecker, SqlTester.ResultChecker, SqlTester.TypeChecker, SqlTester.ValidatedNodeConsumer, SqlTester.ValidatedNodeFunction<R>, SqlTester.VmName

构造器概要

构造器

构造器和说明
AbstractSqlTester()

方法概要

限定符和类型	方法和说明
void	assertConvertsTo(SqlTestFactory factory, DiffRepository diffRepos, String sql, String plan, boolean trim, boolean expression, boolean decorrelate) Checks that a SQL statement converts to a given plan, optionally trimming columns that are not needed.
void	assertExceptionIsThrown(SqlTestFactory factory, org.apache.calcite.sql.parser.StringAndPos sap, @Nullable String expectedMsgPattern) Checks that a query is valid, or, if invalid, throws the right message at the right location.
static String	buildQuery(String expression)
protected String	buildQuery2(SqlTestFactory factory, String expression) Builds a query that extracts all literals as columns in an underlying select.
static String	buildQueryAgg(String expression)
void	check(SqlTestFactory factory, String query, SqlTester.TypeChecker typeChecker, SqlTester.ParameterChecker parameterChecker, SqlTester.ResultChecker resultChecker) Tests that a SQL query returns a result of expected type and value.
void	checkAgg(SqlTestFactory factory, String expr, String[] inputValues, SqlTester.ResultChecker resultChecker) Checks that an aggregate expression returns the expected result.
void	checkAggFails(SqlTestFactory factory, String expr, String[] inputValues, String expectedError, boolean runtime) Tests that an aggregate expression fails at run time.
void	checkColumnType(SqlTestFactory factory, String sql, String expected) Checks that a query returns one column of an expected type.
void	checkFails(SqlTestFactory factory, org.apache.calcite.sql.parser.StringAndPos sap, String expectedError, boolean runtime) Tests that a scalar SQL expression fails at run time.
protected void	checkParseEx(Throwable e, @Nullable String expectedMsgPattern, org.apache.calcite.sql.parser.StringAndPos sap)
void	checkQueryFails(SqlTestFactory factory, org.apache.calcite.sql.parser.StringAndPos sap, String expectedError) Tests that a SQL query fails at prepare time.
void	checkWinAgg(SqlTestFactory factory, String expr, String[] inputValues, String windowSpec, String type, SqlTester.ResultChecker resultChecker) Checks that a windowed aggregate expression returns the expected result.
void	close() This default implementation does nothing.
org.apache.calcite.util.Pair<org.apache.calcite.sql.validate.SqlValidator,org.apache.calcite.rel.RelRoot>	convertSqlToRel2(SqlTestFactory factory, String sql, boolean decorrelate, boolean trim) Converts a SQL string to a (SqlValidator, RelNode) pair.
org.apache.calcite.sql2rel.RelFieldTrimmer	createFieldTrimmer(org.apache.calcite.sql.validate.SqlValidator validator, org.apache.calcite.tools.RelBuilder relBuilder) Creates a RelFieldTrimmer.
void	forEachQuery(SqlTestFactory factory, String expression, Consumer<String> consumer) Given a scalar expression, generates a sequence of SQL queries that evaluate it, and calls a given action with each.
org.apache.calcite.rel.type.RelDataType	getColumnType(SqlTestFactory factory, String sql) Returns the data type of the sole column of a SQL query.
org.apache.calcite.rel.type.RelDataType	getResultType(SqlTestFactory factory, String sql) Returns the data type of the row returned by a SQL query.
org.apache.calcite.sql.SqlNode	parseExpression(SqlTestFactory factory, String expr) Parses an expression.
org.apache.calcite.sql.SqlNode	parseQuery(SqlTestFactory factory, String sql) Parses a query.
void	setFor(org.apache.calcite.sql.SqlOperator operator, SqlTester.VmName... unimplementedVmNames) Declares that this test is for a given operator.
org.apache.calcite.rel.RelNode	trimRelNode(SqlTestFactory factory, org.apache.calcite.rel.RelNode relNode) Trims a RelNode.
<R> R	validateAndApply(SqlTestFactory factory, org.apache.calcite.sql.parser.StringAndPos sap, SqlTester.ValidatedNodeFunction<R> function) Parses and validates a query, then calls a function on the result.
void	validateAndThen(SqlTestFactory factory, org.apache.calcite.sql.parser.StringAndPos sap, SqlTester.ValidatedNodeConsumer consumer) Parses and validates a query, then calls an action on the result.

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.calcite.sql.test.SqlTester

check, checkFails, convertSqlToRel

构造器详细资料

AbstractSqlTester

public AbstractSqlTester()

方法详细资料

close

public void close()

This default implementation does nothing.

指定者:

close 在接口中 AutoCloseable

assertExceptionIsThrown

public void assertExceptionIsThrown(SqlTestFactory factory,
                                    org.apache.calcite.sql.parser.StringAndPos sap,
                                    @Nullable String expectedMsgPattern)

从接口复制的说明: SqlTester

Checks that a query is valid, or, if invalid, throws the right message at the right location.

If expectedMsgPattern is null, the query must succeed.

If expectedMsgPattern is not null, the query must fail, and give an error location of (expectedLine, expectedColumn) through (expectedEndLine, expectedEndColumn).

指定者:

assertExceptionIsThrown 在接口中 SqlTester

参数:

factory - Factory

sap - SQL statement

expectedMsgPattern - If this parameter is null the query must be

checkParseEx

protected void checkParseEx(Throwable e,
                            @Nullable String expectedMsgPattern,
                            org.apache.calcite.sql.parser.StringAndPos sap)

getColumnType

public org.apache.calcite.rel.type.RelDataType getColumnType(SqlTestFactory factory,
                                                             String sql)

从接口复制的说明: SqlTester

Returns the data type of the sole column of a SQL query.

For example, getResultType("VALUES (1") returns INTEGER.

Fails if query returns more than one column.

指定者:

getColumnType 在接口中 SqlTester

另请参阅:

SqlTester.getResultType(SqlTestFactory, String)

getResultType

public org.apache.calcite.rel.type.RelDataType getResultType(SqlTestFactory factory,
                                                             String sql)

从接口复制的说明: SqlTester

Returns the data type of the row returned by a SQL query.

For example, getResultType("VALUES (1, 'foo')") returns RecordType(INTEGER EXPR$0, CHAR(3) EXPR#1).

指定者:

getResultType 在接口中 SqlTester

parseQuery

public org.apache.calcite.sql.SqlNode parseQuery(SqlTestFactory factory,
                                                 String sql)
                                          throws org.apache.calcite.sql.parser.SqlParseException

从接口复制的说明: SqlTester

Parses a query.

指定者:

parseQuery 在接口中 SqlTester

抛出:

org.apache.calcite.sql.parser.SqlParseException

parseExpression

public org.apache.calcite.sql.SqlNode parseExpression(SqlTestFactory factory,
                                                      String expr)
                                               throws org.apache.calcite.sql.parser.SqlParseException

从接口复制的说明: SqlTester

Parses an expression.

指定者:

parseExpression 在接口中 SqlTester

抛出:

org.apache.calcite.sql.parser.SqlParseException

checkColumnType

public void checkColumnType(SqlTestFactory factory,
                            String sql,
                            String expected)

从接口复制的说明: SqlTester

Checks that a query returns one column of an expected type. For example, checkType("VALUES (1 + 2)", "INTEGER NOT NULL").

指定者:

checkColumnType 在接口中 SqlTester

参数:

factory - Factory

sql - Query expression

expected - Type string

setFor

public void setFor(org.apache.calcite.sql.SqlOperator operator,
                   SqlTester.VmName... unimplementedVmNames)

从接口复制的说明: SqlTester

Declares that this test is for a given operator. So we can check that all operators are tested.

指定者:

setFor 在接口中 SqlTester

参数:

operator - Operator

unimplementedVmNames - Names of virtual machines for which this

checkAgg

public void checkAgg(SqlTestFactory factory,
                     String expr,
                     String[] inputValues,
                     SqlTester.ResultChecker resultChecker)

从接口复制的说明: SqlTester

Checks that an aggregate expression returns the expected result.

For example, checkAgg("AVG(DISTINCT x)", new String[] {"2", "3", null, "3" }, new Double(2.5), 0);

指定者:

checkAgg 在接口中 SqlTester

参数:

factory - Factory

expr - Aggregate expression, e.g. SUM(DISTINCT x)

inputValues - Array of input values, e.g. ["1", null, "2"]

resultChecker - Checks whether the result has the expected value

checkWinAgg

public void checkWinAgg(SqlTestFactory factory,
                        String expr,
                        String[] inputValues,
                        String windowSpec,
                        String type,
                        SqlTester.ResultChecker resultChecker)

从接口复制的说明: SqlTester

Checks that a windowed aggregate expression returns the expected result.

For example, checkWinAgg("FIRST_VALUE(x)", new String[] {"2", "3", null, "3" }, "INTEGER NOT NULL", 2, 0d);

指定者:

checkWinAgg 在接口中 SqlTester

参数:

factory - Factory

expr - Aggregate expression, e.g. SUM(DISTINCT x)

inputValues - Array of input values, e.g. ["1", null, "2"]

type - Expected result type

resultChecker - Checks whether the result has the expected value

check

public void check(SqlTestFactory factory,
                  String query,
                  SqlTester.TypeChecker typeChecker,
                  SqlTester.ParameterChecker parameterChecker,
                  SqlTester.ResultChecker resultChecker)

从接口复制的说明: SqlTester

Tests that a SQL query returns a result of expected type and value. Checking of type and value are abstracted using SqlTester.TypeChecker and SqlTester.ResultChecker functors.

指定者:

check 在接口中 SqlTester

参数:

factory - Factory

query - SQL query

typeChecker - Checks whether the result is the expected type

parameterChecker - Checks whether the parameters are of expected types

resultChecker - Checks whether the result has the expected value

validateAndThen

public void validateAndThen(SqlTestFactory factory,
                            org.apache.calcite.sql.parser.StringAndPos sap,
                            SqlTester.ValidatedNodeConsumer consumer)

从接口复制的说明: SqlTester

Parses and validates a query, then calls an action on the result.

指定者:

validateAndThen 在接口中 SqlTester

validateAndApply

public <R> R validateAndApply(SqlTestFactory factory,
                              org.apache.calcite.sql.parser.StringAndPos sap,
                              SqlTester.ValidatedNodeFunction<R> function)

从接口复制的说明: SqlTester

Parses and validates a query, then calls a function on the result.

指定者:

validateAndApply 在接口中 SqlTester

checkFails

public void checkFails(SqlTestFactory factory,
                       org.apache.calcite.sql.parser.StringAndPos sap,
                       String expectedError,
                       boolean runtime)

从接口复制的说明: SqlTester

Tests that a scalar SQL expression fails at run time.

指定者:

checkFails 在接口中 SqlTester

参数:

factory - Factory

sap - SQL scalar expression

expectedError - Pattern for expected error. If !runtime, must include an error location.

runtime - If true, must fail at runtime; if false, must fail at validate time

checkQueryFails

public void checkQueryFails(SqlTestFactory factory,
                            org.apache.calcite.sql.parser.StringAndPos sap,
                            String expectedError)

从接口复制的说明: SqlTester

Tests that a SQL query fails at prepare time.

指定者:

checkQueryFails 在接口中 SqlTester

参数:

factory - Factory

sap - SQL query and error position

expectedError - Pattern for expected error. Must include an error location.

checkAggFails

public void checkAggFails(SqlTestFactory factory,
                          String expr,
                          String[] inputValues,
                          String expectedError,
                          boolean runtime)

从接口复制的说明: SqlTester

Tests that an aggregate expression fails at run time.

指定者:

checkAggFails 在接口中 SqlTester

参数:

factory - Factory

expr - An aggregate expression

inputValues - Array of input values

expectedError - Pattern for expected error

runtime - If true, must fail at runtime; if false, must fail at validate time

buildQuery

public static String buildQuery(String expression)

buildQueryAgg

public static String buildQueryAgg(String expression)

buildQuery2

protected String buildQuery2(SqlTestFactory factory,
                             String expression)

Builds a query that extracts all literals as columns in an underlying select.

For example,

1 < 5

becomes

SELECT p0 < p1 FROM (VALUES (1, 5)) AS t(p0, p1)

Null literals don't have enough type information to be extracted. We push down CAST(NULL AS type) but raw nulls such as CASE 1 WHEN 2 THEN 'a' ELSE NULL END are left as is.

参数:

factory - Test factory

expression - Scalar expression

返回:

Query that evaluates a scalar expression

forEachQuery

public void forEachQuery(SqlTestFactory factory,
                         String expression,
                         Consumer<String> consumer)

从接口复制的说明: SqlTester

Given a scalar expression, generates a sequence of SQL queries that evaluate it, and calls a given action with each.

指定者:

forEachQuery 在接口中 SqlTester

参数:

factory - Factory

expression - Scalar expression

consumer - Action to be called for each query

assertConvertsTo

public void assertConvertsTo(SqlTestFactory factory,
                             DiffRepository diffRepos,
                             String sql,
                             String plan,
                             boolean trim,
                             boolean expression,
                             boolean decorrelate)

从接口复制的说明: SqlTester

Checks that a SQL statement converts to a given plan, optionally trimming columns that are not needed.

指定者:

assertConvertsTo 在接口中 SqlTester

参数:

factory - Factory

diffRepos - Diff repository

sql - SQL query or expression

plan - Expected plan

trim - Whether to trim columns that are not needed

expression - True if sql is an expression, false if it is a query

convertSqlToRel2

public org.apache.calcite.util.Pair<org.apache.calcite.sql.validate.SqlValidator,org.apache.calcite.rel.RelRoot> convertSqlToRel2(SqlTestFactory factory,
                                                                                                                                  String sql,
                                                                                                                                  boolean decorrelate,
                                                                                                                                  boolean trim)

从接口复制的说明: SqlTester

Converts a SQL string to a (SqlValidator, RelNode) pair.

指定者:

convertSqlToRel2 在接口中 SqlTester

trimRelNode

public org.apache.calcite.rel.RelNode trimRelNode(SqlTestFactory factory,
                                                  org.apache.calcite.rel.RelNode relNode)

从接口复制的说明: SqlTester

Trims a RelNode.

指定者:

trimRelNode 在接口中 SqlTester

createFieldTrimmer

public org.apache.calcite.sql2rel.RelFieldTrimmer createFieldTrimmer(org.apache.calcite.sql.validate.SqlValidator validator,
                                                                     org.apache.calcite.tools.RelBuilder relBuilder)

Creates a RelFieldTrimmer.

参数:

validator - Validator

relBuilder - Builder

返回:

Field trimmer