JdbcExtendedUtils

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. val DUMMY_TABLE_NAME: String

   

5. val DUMMY_TABLE_QUALIFIED_NAME: String

   

6. val EMPTY_SCHEMA: StructType

   

7. val PREFIXES: Array[String]

   

8. val SYSIBM_SCHEMA: String

   

9. def addSplitProperty(value: String, propertyName: String, options: Map[String, String], threshold: Int): Map[String, String]

   

10. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

11. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

12. def createSchema(schemaName: String, conn: Connection, dialect: JdbcDialect): Unit

    

13. def defaultPoolURL(session: SparkSession): String

    

14. def dropTable(conn: Connection, tableName: String, dialect: JdbcDialect, context: SQLContext, ifExists: Boolean): Unit

    

15. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

16. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

17. def executeUpdate(sql: String, conn: Connection): Unit

    

18. def fillColumnsClause(sql: StringBuilder, fields: Seq[String], escapeQuotes: Boolean = false, separator: String = " AND "): Unit

    

    Returns the SQL for creating the WHERE clause for a set of columns.

19. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

20. def getCatalystType(dialect: JdbcDialect, jdbcType: Int, typeName: String, size: Int, scale: Int, md: MetadataBuilder, session: Option[SparkSession]): DataType

    

21. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

22. def getInsertOrPutString(table: String, rddSchema: StructType, putInto: Boolean, escapeQuotes: Boolean = false): String

    

    Returns the SQL for prepare to insert or put rows into a table.

23. def getJdbcType(dt: DataType, md: Metadata, dialect: JdbcDialect): JdbcType

    

    Get JdbcType for given DataType and Metadata.

24. def getSQLDataType(dataType: DataType): DataType

    

    Annotations

    @tailrec()

25. def getTableSchema(schemaName: String, tableName: String, conn: Connection, session: Option[SparkSession]): StructType

    

26. def getTableWithSchema(table: String, conn: Connection, session: Option[SparkSession], forSpark: Boolean = true): (String, String)

    

27. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

28. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

29. def isRowLevelSecurityEnabled(table: String, conn: Connection): Boolean

    

30. def isSigned(typeId: Int): Boolean

    

    Is the given JDBC type (java.sql.Types) data type signed.

31. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

32. def normalizeSchema(schema: StructType, forSpark: Boolean = true): StructType

    

33. final def notify(): Unit

    

    Definition Classes

    AnyRef

34. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

35. def quotedName(table: String, escapeQuotes: Boolean = false): String

    

    get the table name in SQL quoted form e.g.

    get the table name in SQL quoted form e.g. "APP"."TABLE1"

36. def readSplitProperty(propertyName: String, options: Map[String, String]): Option[String]

    

37. def schemaString(schema: StructType, dialect: JdbcDialect): String

    

    Compute the schema string for this RDD.

    Compute the schema string for this RDD. This is different from JdbcUtils.schemaString in having its own getJdbcType that can honour metadata for VARCHAR/CHAR types.

38. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

39. def tableExists(table: String, conn: Connection, dialect: JdbcDialect, context: SQLContext): Boolean

    

    Returns true if the table already exists in the JDBC database.

40. def tableExistsInMetaData(schemaName: String, tableName: String, conn: Connection, skipType: String = ""): Boolean

    

41. def toLowerCase(k: String): String

    

42. def toString(): String

    

    Definition Classes

    AnyRef → Any

43. def toUpperCase(k: String): String

    

44. def truncateTable(conn: Connection, tableName: String, dialect: JdbcDialect): Unit

    

45. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

46. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

47. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )