Java API reference for the Databricks JDBC Driver

This article provides API reference documentation for the Databricks JDBC Driver, version 3 and above.

IDatabricksConnection interface

Describes methods to retrieve connection and statement execution handles.

Package: com.databricks.jdbc.api

getStatement
IDatabricksStatement getStatement(String statementId) throws SQLException Returns a handle for a given statement ID. Returns: An IDatabricksStatement to handle an existing execution.

getConnectionId
String getConnectionId() throws SQLException Returns a handle for the session connection. Returns: A String that represents the connection for the underlying session of the execution.

IDatabricksDriver interface

Describes methods to manage the driver connection.

Package: com.databricks.client.jdbc

com.databricks.client.jdbc.Driver extends com.databricks.client.jdbc.IDatabricksDriver and java.sql.Driver.

closeConnection
void closeConnection(String url, Properties info, String connectionId) throws SQLException Closes the connection for the specified connection ID and JDBC connection URL. Returns: None

IDatabricksResultSet interface

Describes methods to retrieve results of an asynchronous query.

Package: com.databricks.jdbc.api

getExecutionStatus
IExecutionStatus getExecutionStatus() throws SQLException Returns the status of the execution. Returns: An IExecutionStatus that represents the status of the execution

getStatementId
String getStatementId() throws SQLException Returns the associated statement-id of the async execution. Returns: A String that is the statement ID of the execution

IDatabricksStatement interface

Describes methods to execute and handle an asynchronous query.

Package: com.databricks.jdbc.api

executeAsync
ResultSet executeAsync(String sql) throws SQLException Executes a SQL command in asynchronous mode. Parameters: sql - the command to execute. Returns: A ResultSet that represents the results of the executed SQL

getExecutionResult
ResultSet getExecutionResult() throws SQLException Fetches a status and response for an already executed SQL command, and throws error if no command has been executed. This method can be called multiple times to poll execution status. Returns: A ResultSet that represents the results of the executed SQL

IDatabricksVolumeClient interface

Describes methods to manage files in Unity Catalog volumes.

Package: com.databricks.jdbc.api

prefixExists

boolean prefixExists(String catalog, String schema, String volume, String prefix, boolean caseSensitive) throws SQLException Determines if a specific prefix (folder-like structure) exists in the Unity Catalog volume. The prefix must be a part of the file name. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the Unity Catalog volume name of the cloud storage. prefix - the prefix to check for existence along with the relative path from the volume as the root directory. caseSensitive - whether the check should be case-sensitive or not. Returns: A boolean indicating whether the prefix exists or not.

objectExists

boolean objectExists(String catalog, String schema, String volume, String objectPath, boolean caseSensitive) throws SQLException Determines if a specific object (file) exists in the Unity Catalog volume. The object must match the file name exactly. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the Unity Catalog volume name of the cloud storage. objectPath - the path of the object (file) from the volume as the root directory to check for existence within the volume (inside any sub-folder). caseSensitive - a boolean indicating whether the check should be case-sensitive or not. Returns: A boolean indicating whether the object exists or not.

volumeExists

boolean volumeExists(String catalog, String schema, String volumeName, boolean caseSensitive) throws SQLException Determines if a specific volume exists in the given catalog and schema. The volume must match the volume name exactly. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volumeName - the name of the volume to check for existence. caseSensitive a boolean indicating whether the check should be case sensitive or not. Returns: A boolean indicating whether the volume exists or not.

listObjects

List<String> listObjects(String catalog, String schema, String volume, String prefix, boolean caseSensitive) throws SQLException Returns the list of all filenames in the Unity Catalog volume that start with a specified prefix. The prefix must be a part of the file path from the volume as the root. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the UC volume name of the cloud storage. prefix - the prefix of the filenames to list. This includes the relative path from the volume as the root directory. caseSensitive - a boolean indicating whether the check should be case-sensitive or not. Returns: A list of strings indicating the filenames that start with the specified prefix.

getObject (file)

boolean getObject(String catalog, String schema, String volume, String objectPath, String localPath) throws SQLException Retrieves an object (file) from the Unity Catalog volume and stores it in the specified local path. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the UC volume name of the cloud storage. objectPath - the path of the object (file) from the volume as the root directory. localPath - the local path where the retrieved data is to be stored. Returns: A boolean value indicating status of the GET operation.

getObject (stream)

InputStreamEntity getObject(String catalog, String schema, String volume, String objectPath) throws SQLException Retrieves an object as an input stream from the Unity Catalog volume. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the UC volume name of the cloud storage. objectPath - the path of the object (file) from the volume as the root directory. Returns: An instance of the input stream entity.

putObject (file)

boolean putObject(String catalog, String schema, String volume, String objectPath, String localPath, boolean toOverwrite) throws SQLException Uploads data from a local path to a specified path within a Unity Catalog volume. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the UC volume name of the cloud storage. objectPath the destination path where the object (file) is to be uploaded from the`volume as the root directory. localPath the local path from where the data is to be uploaded. toOverwrite a boolean indicating whether to overwrite the object if it already exists. Returns: A boolean value indicating the status of the PUT operation.

putObject (stream)

boolean putObject(String catalog, String schema, String volume, String objectPath, InputStream inputStream, long contentLength, boolean toOverwrite) throws SQLException Uploads data from an input stream to a specified path within a Unity Catalog volume. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the UC volume name of the cloud storage. objectPath - the destination path where the object (file) is to be uploaded from the volume as the root directory. inputStream - the input stream from where the data is to be uploaded. contentLength - the length of the input stream. toOverwrite a boolean indicating whether to overwrite the object if it already exists. Returns: A boolean value indicating status of the PUT operation.

deleteObject

boolean deleteObject(String catalog, String schema, String volume, String objectPath) throws SQLException Removes an object from a specified path within a Unity Catalog volume. Parameters: catalog - the catalog name of the cloud storage. schema - the schema name of the cloud storage. volume - the UC volume name of the cloud storage. objectPath - the path of the object (file) from the volume as the root directory to delete. Returns: A boolean value indicating the status of the DELETE operation.

IDatabricksGeospatial interface

Describes methods to work with geospatial data types (GEOMETRY and GEOGRAPHY). This interface is extended by IGeometry and IGeography marker interfaces for type-specific geospatial objects.

Package: com.databricks.jdbc.api

getWKT
String getWKT() Returns the Well-Known Text (WKT) representation of the geospatial object. Returns: A String containing the WKT representation without SRID prefix.

getWKB
byte[] getWKB() Returns the OGC-compliant Well-Known Binary (WKB) representation of the geospatial object. Returns: A byte array containing the WKB data.

getSRID
int getSRID() Returns the Spatial Reference System Identifier (SRID) of the geospatial object. Returns: An integer representing the SRID value (0 if not specified).

getType
String getType() Returns the geospatial type name. Returns: A String that is either GEOMETRY or GEOGRAPHY.

ExecutionState enum

Contains the states of an executing asynchronous query.

Package: com.databricks.jdbc.api

RUNNING	The statement is running on the server
PENDING	The statement is yet to run on the server
SUCCEEDED	The statement ran successfully
FAILED	The statement execution failed
ABORTED	The statement was aborted
CLOSED	The statement has been closed

IExecutionStatus interface

Describes methods to retrieve the status of an asynchronous query.

Package: com.databricks.jdbc.api

getExecutionState
ExecutionState getExecutionState() throws SQLException Returns the state of the execution status. Returns: An ExecutionState that represents the state of the execution status

getSqlState
String getSqlState() throws SQLException If it is set, returns the SQLState code for a failed status. Returns: A String that is the SQLState code

getErrorMessage
String getErrorMessage() throws SQLException Returns the error message of a failed execution. Returns: A String that is the error message.