Package org.apache.flink.sql.parser

Class SqlConstraintValidator

java.lang.Object

org.apache.flink.sql.parser.SqlConstraintValidator

public class SqlConstraintValidator
extends Object

Util to validate SqlTableConstraint.

Constructor Summary

Constructors

Constructor	Description
SqlConstraintValidator()

Method Summary

Modifier and Type	Method	Description
static List<SqlTableConstraint>	getFullConstraints(List<SqlTableConstraint> tableConstraints, org.apache.calcite.sql.SqlNodeList columnList)	Returns the column constraints plus the table constraints.
static void	validateAndChangeColumnNullability(List<SqlTableConstraint> tableConstraints, org.apache.calcite.sql.SqlNodeList columnList)	Check constraints and change the nullability of primary key columns.

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlConstraintValidator

public SqlConstraintValidator()

Method Detail

getFullConstraints

public static List<SqlTableConstraint> getFullConstraints(List<SqlTableConstraint> tableConstraints,
                                                          org.apache.calcite.sql.SqlNodeList columnList)

Returns the column constraints plus the table constraints.

validateAndChangeColumnNullability

public static void validateAndChangeColumnNullability(List<SqlTableConstraint> tableConstraints,
                                                      org.apache.calcite.sql.SqlNodeList columnList)
                                               throws SqlValidateException

Check constraints and change the nullability of primary key columns.

Throws:

SqlValidateException - if encountered duplicate primary key constraints, or the constraint is enforced or unique.