Package com.databricks.jdbc.api.internal
Interface IDatabricksConnectionContext
-
- All Known Implementing Classes:
DatabricksConnectionContext
public interface IDatabricksConnectionContext
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanacceptUndeterminedCertificateRevocation()booleancheckCertificateRevocation()intgetAsyncExecPollInterval()StringgetAuthEndpoint()Returns the OAuth2 authorization endpoint URL for the authorization code flow.AuthFlowgetAuthFlow()AuthMechgetAuthMech()StringgetAuthScope()Returns the OAuth2 authentication scope used in the request.StringgetAzureTenantId()Returns the Azure tenant ID for the Azure Databricks workspace.StringgetAzureWorkspaceResourceId()StringgetCatalog()StringgetClientId()Map<String,String>getClientInfoProperties()StringgetClientSecret()DatabricksClientTypegetClientType()StringgetClientUserAgent()Returns the userAgent string specific to client used to fetch results.com.databricks.sdk.core.utils.CloudgetCloud()com.databricks.sdk.core.ProxyConfig.ProxyAuthTypegetCloudFetchProxyAuthType()StringgetCloudFetchProxyHost()StringgetCloudFetchProxyPassword()intgetCloudFetchProxyPort()StringgetCloudFetchProxyUser()intgetCloudFetchThreadPoolSize()Returns the number of threads to be used for fetching data from cloud storageCompressionCodecgetCompressionCodec()IDatabricksComputeResourcegetComputeResource()Returns warehouse-Id as parsed from JDBC connection UrlStringgetConnectionURL()StringgetConnectionUuid()Returns a unique identifier for this connection context.StringgetCustomerUserAgent()Returns the userAgent string specified as part of the JDBC connection stringMap<String,String>getCustomHeaders()Returns the custom headers set in the JDBC connection string.intgetDefaultStringColumnLength()Returns maximum number of characters that can be contained in STRING columns.BooleangetDirectResultMode()StringgetEndpointURL()StringgetGcpAuthType()StringgetGoogleCredentials()StringgetGoogleServiceAccount()StringgetHostForOAuth()StringgetHostUrl()Returns host-Url for Databricks server as parsed from JDBC connection in formathttps://server:portintgetHttpConnectionPoolSize()Returns the size for HTTP connection poolStringgetHttpPath()intgetIdleHttpConnectionExpiry()StringgetJWTAlgorithm()Returns the algorithm used for signing the JWT (e.g., RS256, ES256).StringgetJWTKeyFile()Returns the file path to the JWT private key used for signing the JWT.StringgetJWTPassphrase()Returns the passphrase to decrypt the private key if the key is encrypted.StringgetKID()Returns the Key ID (KID) used in the JWT header, identifying the key.intgetLogFileCount()intgetLogFileSize()LogLevelgetLogLevel()StringgetLogPathString()intgetMaxBatchSize()Returns the maximum number of commands that can be executed in a single batch.StringgetNonProxyHosts()Returns the non-proxy hosts that should be excluded from proxying.StringgetNullableClientId()List<Integer>getOAuth2RedirectUrlPorts()Returns the list of OAuth2 redirect URL ports used for OAuth authentication.StringgetOAuthDiscoveryURL()Returns the discovery URL used to obtain the OAuth2 token and authorization endpoints.StringgetOAuthRefreshToken()Returns the OAuth2 refresh token used to obtain a new access token when the current one expires.List<String>getOAuthScopesForU2M()StringgetPassThroughAccessToken()Returns the pass through access tokencom.databricks.sdk.core.ProxyConfig.ProxyAuthTypegetProxyAuthType()StringgetProxyHost()StringgetProxyPassword()intgetProxyPort()StringgetProxyUser()intgetRateLimitRetryTimeout()intgetRowsFetchedPerBlock()Returns maximum number of rows that a query returns at a time.StringgetSchema()Map<String,String>getSessionConfigs()intgetSocketTimeout()Returns the socket timeout in seconds for HTTP connections.StringgetSSLTrustStore()Returns the SSL trust store file path used for SSL connections.StringgetSSLTrustStorePassword()Returns the SSL trust store password of the trust store file.StringgetSSLTrustStoreType()Returns the SSL trust store type of the trust store file.intgetTelemetryBatchSize()Returns the batch size for Telemetry logs processingintgetTemporarilyUnavailableRetryTimeout()StringgetToken()Returns the auth token (personal access token)StringgetTokenEndpoint()Returns the OAuth2 token endpoint URL for retrieving tokens.List<Integer>getUCIngestionRetriableHttpCodes()Returns the list of HTTP codes to retry for UC Volume IngestionintgetUCIngestionRetryTimeoutSeconds()Returns retry timeout in seconds for UC Volume IngestionBooleangetUseCloudFetchProxy()BooleangetUseEmptyMetadata()BooleangetUseProxy()BooleangetUseSystemProxy()StringgetVolumeOperationAllowedPaths()Returns allowlisted local file paths for UC Volume operationsbooleanisAllPurposeCluster()booleanisComplexDatatypeSupportEnabled()Returns true if driver return complex data type java objects natively as opposed to stringbooleanisOAuthDiscoveryModeEnabled()Returns whether OAuth2 discovery mode is enabled, which fetches endpoints dynamically.booleanisPropertyPresent(DatabricksJdbcUrlParams urlParam)booleanisRequestTracingEnabled()Returns true if request tracing should be enabled.booleanisSqlExecHybridResultsEnabled()Returns true if driver should use hybrid results in SQL_EXEC API.booleanisTelemetryEnabled()Checks if Telemetry is enabledvoidsetClientType(DatabricksClientType clientType)BooleanshouldEnableArrow()BooleanshouldRetryRateLimitError()BooleanshouldRetryTemporarilyUnavailableError()booleansupportManyParameters()booleanuseJWTAssertion()Returns whether JWT assertion should be used for OAuth2 authentication.
-
-
-
Method Detail
-
getHostUrl
String getHostUrl() throws DatabricksParsingException
Returns host-Url for Databricks server as parsed from JDBC connection in formathttps://server:port- Returns:
- Databricks host-Url
- Throws:
DatabricksParsingException
-
getComputeResource
IDatabricksComputeResource getComputeResource()
Returns warehouse-Id as parsed from JDBC connection Url- Returns:
- warehouse-Id
-
getToken
String getToken()
Returns the auth token (personal access token)- Returns:
- auth token
-
getPassThroughAccessToken
String getPassThroughAccessToken()
Returns the pass through access token- Returns:
- access token
-
getHostForOAuth
String getHostForOAuth()
-
getClientId
String getClientId() throws DatabricksParsingException
- Throws:
DatabricksParsingException
-
getNullableClientId
String getNullableClientId()
-
getClientSecret
String getClientSecret()
-
getOAuthScopesForU2M
List<String> getOAuthScopesForU2M() throws DatabricksParsingException
- Throws:
DatabricksParsingException
-
getAuthMech
AuthMech getAuthMech()
-
getAuthFlow
AuthFlow getAuthFlow()
-
isPropertyPresent
boolean isPropertyPresent(DatabricksJdbcUrlParams urlParam)
-
getLogLevel
LogLevel getLogLevel()
-
getLogPathString
String getLogPathString()
-
getLogFileSize
int getLogFileSize()
-
getLogFileCount
int getLogFileCount()
-
getClientUserAgent
String getClientUserAgent()
Returns the userAgent string specific to client used to fetch results.
-
getCompressionCodec
CompressionCodec getCompressionCodec()
-
getCustomerUserAgent
String getCustomerUserAgent()
Returns the userAgent string specified as part of the JDBC connection string
-
getCatalog
String getCatalog()
-
getSchema
String getSchema()
-
getCustomHeaders
Map<String,String> getCustomHeaders()
Returns the custom headers set in the JDBC connection string.- Returns:
- Map of custom headers
-
isAllPurposeCluster
boolean isAllPurposeCluster()
-
getHttpPath
String getHttpPath()
-
getProxyHost
String getProxyHost()
-
getProxyPort
int getProxyPort()
-
getProxyUser
String getProxyUser()
-
getProxyPassword
String getProxyPassword()
-
getUseProxy
Boolean getUseProxy()
-
getProxyAuthType
com.databricks.sdk.core.ProxyConfig.ProxyAuthType getProxyAuthType()
-
getUseSystemProxy
Boolean getUseSystemProxy()
-
getUseCloudFetchProxy
Boolean getUseCloudFetchProxy()
-
getCloud
com.databricks.sdk.core.utils.Cloud getCloud() throws DatabricksParsingException- Throws:
DatabricksParsingException
-
getCloudFetchProxyHost
String getCloudFetchProxyHost()
-
getCloudFetchProxyPort
int getCloudFetchProxyPort()
-
getCloudFetchProxyUser
String getCloudFetchProxyUser()
-
getCloudFetchProxyPassword
String getCloudFetchProxyPassword()
-
getCloudFetchProxyAuthType
com.databricks.sdk.core.ProxyConfig.ProxyAuthType getCloudFetchProxyAuthType()
-
getEndpointURL
String getEndpointURL() throws DatabricksParsingException
- Throws:
DatabricksParsingException
-
getAsyncExecPollInterval
int getAsyncExecPollInterval()
-
shouldEnableArrow
Boolean shouldEnableArrow()
-
getClientType
DatabricksClientType getClientType()
-
setClientType
void setClientType(DatabricksClientType clientType)
-
getUseEmptyMetadata
Boolean getUseEmptyMetadata()
-
getCloudFetchThreadPoolSize
int getCloudFetchThreadPoolSize()
Returns the number of threads to be used for fetching data from cloud storage
-
getDirectResultMode
Boolean getDirectResultMode()
-
shouldRetryTemporarilyUnavailableError
Boolean shouldRetryTemporarilyUnavailableError()
-
shouldRetryRateLimitError
Boolean shouldRetryRateLimitError()
-
getTemporarilyUnavailableRetryTimeout
int getTemporarilyUnavailableRetryTimeout()
-
getRateLimitRetryTimeout
int getRateLimitRetryTimeout()
-
getIdleHttpConnectionExpiry
int getIdleHttpConnectionExpiry()
-
supportManyParameters
boolean supportManyParameters()
-
getConnectionURL
String getConnectionURL()
-
checkCertificateRevocation
boolean checkCertificateRevocation()
-
acceptUndeterminedCertificateRevocation
boolean acceptUndeterminedCertificateRevocation()
-
getJWTKeyFile
String getJWTKeyFile()
Returns the file path to the JWT private key used for signing the JWT.
-
getKID
String getKID()
Returns the Key ID (KID) used in the JWT header, identifying the key.
-
getJWTPassphrase
String getJWTPassphrase()
Returns the passphrase to decrypt the private key if the key is encrypted.
-
getJWTAlgorithm
String getJWTAlgorithm()
Returns the algorithm used for signing the JWT (e.g., RS256, ES256).
-
useJWTAssertion
boolean useJWTAssertion()
Returns whether JWT assertion should be used for OAuth2 authentication.
-
getTokenEndpoint
String getTokenEndpoint()
Returns the OAuth2 token endpoint URL for retrieving tokens.
-
getAuthEndpoint
String getAuthEndpoint()
Returns the OAuth2 authorization endpoint URL for the authorization code flow.
-
isOAuthDiscoveryModeEnabled
boolean isOAuthDiscoveryModeEnabled()
Returns whether OAuth2 discovery mode is enabled, which fetches endpoints dynamically.
-
getOAuthDiscoveryURL
String getOAuthDiscoveryURL()
Returns the discovery URL used to obtain the OAuth2 token and authorization endpoints.
-
getAuthScope
String getAuthScope()
Returns the OAuth2 authentication scope used in the request.
-
getOAuthRefreshToken
String getOAuthRefreshToken()
Returns the OAuth2 refresh token used to obtain a new access token when the current one expires.
-
getOAuth2RedirectUrlPorts
List<Integer> getOAuth2RedirectUrlPorts()
Returns the list of OAuth2 redirect URL ports used for OAuth authentication.
-
getGcpAuthType
String getGcpAuthType() throws DatabricksParsingException
- Throws:
DatabricksParsingException
-
getGoogleServiceAccount
String getGoogleServiceAccount()
-
getGoogleCredentials
String getGoogleCredentials()
-
getNonProxyHosts
String getNonProxyHosts()
Returns the non-proxy hosts that should be excluded from proxying.
-
getSSLTrustStore
String getSSLTrustStore()
Returns the SSL trust store file path used for SSL connections.
-
getSSLTrustStorePassword
String getSSLTrustStorePassword()
Returns the SSL trust store password of the trust store file.
-
getSSLTrustStoreType
String getSSLTrustStoreType()
Returns the SSL trust store type of the trust store file.
-
getMaxBatchSize
int getMaxBatchSize()
Returns the maximum number of commands that can be executed in a single batch.
-
isTelemetryEnabled
boolean isTelemetryEnabled()
Checks if Telemetry is enabled
-
getTelemetryBatchSize
int getTelemetryBatchSize()
Returns the batch size for Telemetry logs processing
-
getConnectionUuid
String getConnectionUuid()
Returns a unique identifier for this connection context.This UUID is generated when the connection context is instantiated and serves as a unique internal identifier for each JDBC connection.
-
getVolumeOperationAllowedPaths
String getVolumeOperationAllowedPaths()
Returns allowlisted local file paths for UC Volume operations
-
isSqlExecHybridResultsEnabled
boolean isSqlExecHybridResultsEnabled()
Returns true if driver should use hybrid results in SQL_EXEC API.
-
getAzureTenantId
String getAzureTenantId()
Returns the Azure tenant ID for the Azure Databricks workspace.
-
isRequestTracingEnabled
boolean isRequestTracingEnabled()
Returns true if request tracing should be enabled.
-
getDefaultStringColumnLength
int getDefaultStringColumnLength()
Returns maximum number of characters that can be contained in STRING columns.
-
isComplexDatatypeSupportEnabled
boolean isComplexDatatypeSupportEnabled()
Returns true if driver return complex data type java objects natively as opposed to string
-
getHttpConnectionPoolSize
int getHttpConnectionPoolSize()
Returns the size for HTTP connection pool
-
getUCIngestionRetriableHttpCodes
List<Integer> getUCIngestionRetriableHttpCodes()
Returns the list of HTTP codes to retry for UC Volume Ingestion
-
getUCIngestionRetryTimeoutSeconds
int getUCIngestionRetryTimeoutSeconds()
Returns retry timeout in seconds for UC Volume Ingestion
-
getAzureWorkspaceResourceId
String getAzureWorkspaceResourceId()
-
getRowsFetchedPerBlock
int getRowsFetchedPerBlock()
Returns maximum number of rows that a query returns at a time.
-
getSocketTimeout
int getSocketTimeout()
Returns the socket timeout in seconds for HTTP connections.
-
-