Packages

c

org.apache.spark.sql.jdbc

JdbcSQLQueryBuilder

class JdbcSQLQueryBuilder extends AnyRef

The builder to build a single SELECT query.

Note: All the withXXX methods will be invoked at most once. The invocation order does not matter, as all these clauses follow the natural SQL order: sample the table first, then filter, then group by, then sort, then offset, then limit.

Source
JdbcSQLQueryBuilder.scala
Since

3.5.0

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. JdbcSQLQueryBuilder
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new JdbcSQLQueryBuilder(dialect: JdbcDialect, options: JDBCOptions)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def build(): String

    Build the final SQL query that following dialect's SQL syntax.

  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @IntrinsicCandidate()
  7. var columnList: String

    columns, but as a String suitable for injection into a SQL query.

    columns, but as a String suitable for injection into a SQL query.

    Attributes
    protected
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. var groupByClause: String

    A GROUP BY clause representing pushed-down grouping columns.

    A GROUP BY clause representing pushed-down grouping columns.

    Attributes
    protected
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. var limit: Int

    A LIMIT value representing pushed-down limit.

    A LIMIT value representing pushed-down limit.

    Attributes
    protected
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  18. var offset: Int

    A OFFSET value representing pushed-down offset.

    A OFFSET value representing pushed-down offset.

    Attributes
    protected
  19. var orderByClause: String

    A ORDER BY clause representing pushed-down sort of top n.

    A ORDER BY clause representing pushed-down sort of top n.

    Attributes
    protected
  20. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  21. var tableSampleClause: String

    A table sample clause representing pushed-down table sample.

    A table sample clause representing pushed-down table sample.

    Attributes
    protected
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. var whereClause: String

    A WHERE clause representing both filters, if any, and the current partition.

    A WHERE clause representing both filters, if any, and the current partition.

    Attributes
    protected
  27. def withColumns(columns: Array[String]): JdbcSQLQueryBuilder

    The columns names that following dialect's SQL syntax.

    The columns names that following dialect's SQL syntax. e.g. The column name is the raw name or quoted name.

  28. def withGroupByColumns(groupByColumns: Array[String]): JdbcSQLQueryBuilder

    Constructs the GROUP BY clause that following dialect's SQL syntax.

  29. def withLimit(limit: Int): JdbcSQLQueryBuilder

    Saves the limit value used to construct LIMIT clause.

  30. def withOffset(offset: Int): JdbcSQLQueryBuilder

    Saves the offset value used to construct OFFSET clause.

  31. def withPredicates(predicates: Array[Predicate], part: JDBCPartition): JdbcSQLQueryBuilder

    Constructs the WHERE clause that following dialect's SQL syntax.

  32. def withSortOrders(sortOrders: Array[String]): JdbcSQLQueryBuilder

    Constructs the ORDER BY clause that following dialect's SQL syntax.

  33. def withTableSample(sample: TableSampleInfo): JdbcSQLQueryBuilder

    Constructs the table sample clause that following dialect's SQL syntax.

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped