in linkis-computation-governance/linkis-jdbc-driver/src/main/scala/org/apache/linkis/ujes/jdbc/LinkisSQLConnection.scala [231:403]
override def prepareCall(sql: String): CallableStatement =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"prepareCall not supported"
)
override def rollback(): Unit =
throw new LinkisSQLException(LinkisSQLErrorCode.NOSUPPORT_CONNECTION, "rollback not supported")
override def nativeSQL(sql: String): String =
throw new LinkisSQLException(LinkisSQLErrorCode.NOSUPPORT_CONNECTION, "nativeSQL not supported")
override def prepareCall(
sql: String,
resultSetType: Int,
resultSetConcurrency: Int
): CallableStatement =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"prepareCall not supported"
)
override def getTypeMap: util.Map[String, Class[_]] =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"getTypeMap not supported"
)
override def setTypeMap(map: util.Map[String, Class[_]]): Unit =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"setTypeMap not supported"
)
override def setHoldability(holdability: Int): Unit = throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"setHoldability not supported"
)
override def getHoldability: Int = 0
override def setSavepoint(): Savepoint =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"setSavepoint not supported"
)
override def setSavepoint(name: String): Savepoint =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"setSavepoint not supported"
)
override def rollback(savepoint: Savepoint): Unit =
throw new LinkisSQLException(LinkisSQLErrorCode.NOSUPPORT_CONNECTION, "rollback not supported")
override def releaseSavepoint(savepoint: Savepoint): Unit = throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"releaseSavepoint not supported"
)
override def createStatement(
resultSetType: Int,
resultSetConcurrency: Int,
resultSetHoldability: Int
): Statement =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"createStatement not supported"
)
override def prepareStatement(
sql: String,
resultSetType: Int,
resultSetConcurrency: Int,
resultSetHoldability: Int
): PreparedStatement =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"prepareStatement not supported"
)
override def prepareCall(
sql: String,
resultSetType: Int,
resultSetConcurrency: Int,
resultSetHoldability: Int
): CallableStatement =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"prepareCall not supported"
)
override def prepareStatement(sql: String, columnIndexes: Array[Int]): PreparedStatement =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"prepareStatement not supported"
)
override def prepareStatement(sql: String, columnNames: Array[String]): PreparedStatement =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"prepareStatement not supported"
)
override def createClob(): Clob =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"createClob not supported"
)
override def createBlob(): Blob =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"createBlob not supported"
)
override def createNClob(): NClob =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"createNClob not supported"
)
override def createSQLXML(): SQLXML =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"createSQLXML not supported"
)
override def isValid(timeout: Int): Boolean = true
override def setClientInfo(name: String, value: String): Unit =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"setClientInfo not supported"
)
override def setClientInfo(properties: Properties): Unit =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"properties not supported"
)
override def getClientInfo(name: String): String =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"getClientInfo not supported"
)
override def getClientInfo: Properties =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"getClientInfo not supported"
)
override def createArrayOf(typeName: String, elements: Array[AnyRef]): sql.Array =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"createArrayOf not supported"
)
override def createStruct(typeName: String, attributes: Array[AnyRef]): Struct =
throw new LinkisSQLException(
LinkisSQLErrorCode.NOSUPPORT_CONNECTION,
"createStruct not supported"
)
override def setSchema(schema: String): Unit = throwWhenClosed {
if (StringUtils.isBlank(schema)) {
throw new LinkisSQLException(LinkisSQLErrorCode.NOSUPPORT_STATEMENT, "schema is empty!")
}
createStatement().execute("use " + schema)
}