Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,23 @@ import org.apache.spark.sql.catalyst.expressions.Literal
import org.apache.spark.sql.catalyst.util.quoteIdentifier
import org.apache.spark.sql.types.{DataType, DoubleType, FloatType}

/**
* The trait exposes util methods for preparing error messages such as quoting of error elements.
* All classes that extent `QueryErrorsBase` shall follow the rules:
* 1. Any values shall be outputted in the SQL standard style by using `toSQLValue()`.
* For example: 'a string value', 1, NULL.
* 2. SQL types shall be double quoted and outputted in the upper case using `toSQLType()`.
* For example: "INT", "DECIMAL(10,0)".
* 3. Elements of identifiers shall be wrapped by backticks by using `toSQLId()`.
* For example: `namespaceA`.`funcB`, `tableC`.
* 4. SQL statements shall be in the upper case prepared by using `toSQLStmt`.
* For example: DESC PARTITION, DROP TEMPORARY FUNCTION.
* 5. SQL configs and datasource options shall be wrapped by double quotes by using
* `toSQLConf()`/`toDSOption()`.
* For example: "spark.sql.ansi.enabled".
* 6. Any values of datasource options or SQL configs shall be double quoted.
* For example: "true", "CORRECTED".
*/
trait QueryErrorsBase {
// Converts an error class parameter to its SQL representation
def toSQLValue(v: Any, t: DataType): String = Literal.create(v, t) match {
Expand Down