Databricks JDBC Sürücüsü için Java API başvurusu

Bu makalede Databricks JDBC Sürücüsü, sürüm 3 ve üzeri için API başvuru belgeleri sağlanmaktadır.

IDatabricksConnection arayüzü

Bağlantı ve ifade yürütme tanıtıcılarını alma yöntemlerini açıklar.

Paket: com.databricks.jdbc.api

getStatement
IDatabricksStatement getStatement(String statementId) throws SQLException Belirli bir deyim kimliği için bir tanımlayıcı döndürür. İadeler Mevcut bir yürütmeyi yönetmek için IDatabricksStatement.

getConnectionId
String getConnectionId() throws SQLException Oturum bağlantısı için bir tanıtıcı döndürür. İadeler Yürütmenin temel oturumu için bağlantıyı temsil eden bir dizge.

IDatabricksDriver arabirimi

Sürücü bağlantısını yönetme yöntemlerini açıklar.

Paket: com.databricks.client.jdbc

com.databricks.client.jdbc.Driver, com.databricks.client.jdbc.IDatabricksDriver ve java.sql.Driver'yi genişletir.

bağlantıyı kapat
void closeConnection(String url, Properties info, String connectionId) throws SQLException Belirtilen bağlantı kimliği ve JDBC bağlantı URL'si için bağlantıyı kapatır. İadeler Hiç kimse

IDatabricksResultSet arabirimi

Zaman uyumsuz sorgunun sonuçlarını alma yöntemlerini açıklar.

Paket: com.databricks.jdbc.api

Çalıştırma Durumunu Al
IExecutionStatus getExecutionStatus() throws SQLException Yürütmenin durumunu döndürür. İadeler Yürütmenin durumunu temsil eden bir IExecutionStatus

getStatementId
String getStatementId() throws SQLException Zaman uyumsuz yürütmenin ilişkili ifade kimliğini döndürür. İadeler Çalıştırmanın beyan kimliği olan bir dize

IDatabricksStatement arayüzü

Zaman uyumsuz sorgu yürütme ve işleme yöntemlerini açıklar.

Paket: com.databricks.jdbc.api

executeAsync (asenkron çalıştır)
ResultSet executeAsync(String sql) throws SQLException Sql komutunu zaman uyumsuz modda yürütür. Parametreler: sql - yürütülecek komut. İadeler Yürütülen SQL'in sonuçlarını temsil eden ResultSet

YürütmeSonucunuAl
ResultSet getExecutionResult() throws SQLException Zaten yürütülen bir SQL komutu için durum ve yanıt getirir ve hiçbir komut yürütülmezse hata oluşturur. Bu yöntem, yürütme durumunu yoklamak için birden çok kez çağrılabilir. İadeler Yürütülen SQL'in sonuçlarını temsil eden ResultSet

IDatabricksVolumeClient arayüzü

Unity Kataloğu birimlerindeki dosyaları yönetme yöntemlerini açıklar.

Paket: com.databricks.jdbc.api

prefixExists

boolean prefixExists(String catalog, String schema, String volume, String prefix, boolean caseSensitive) throws SQLException Unity Kataloğu biriminde belirli bir önek (klasör benzeri yapı) olup olmadığını belirler. Ön ek, dosya adının bir parçası olmalıdır. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolama biriminin Unity Kataloğu birim adı. prefix - kök dizin olarak birimden göreli yol ile birlikte var olup olmadığını denetlemek için ön ek. caseSensitive - Denetimin büyük/küçük harfe duyarlı olup olmaması gerektiği. İadeler Ön ekin var olup olmadığını gösteren boole değeri.

objectExists

boolean objectExists(String catalog, String schema, String volume, String objectPath, boolean caseSensitive) throws SQLException Unity Kataloğu biriminde belirli bir nesnenin (dosya) var olup olmadığını belirler. Nesne, dosya adıyla tam olarak eşleşmelidir. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolama biriminin Unity Kataloğu birim adı. objectPath - birimde (herhangi bir alt klasörün içinde) var olup olmadığını denetlemek için kök dizin olarak birimden nesnenin (dosya) yolu. caseSensitive - denetimin büyük/küçük harfe duyarlı olup olmaması gerektiğini gösteren boole değeri. İadeler Nesnenin var olup olmadığını gösteren boole değeri.

volumeExists

boolean volumeExists(String catalog, String schema, String volumeName, boolean caseSensitive) throws SQLException Belirli bir birimin verilen katalogda ve şemada mevcut olup olmadığını belirler. Hacim, hacim adıyla tam olarak eşleşmelidir. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volumeName - var olup olmadığını kontrol etmek için birimin adı. caseSensitive denetimin büyük/küçük harfe duyarlı olup olmaması gerektiğini gösteren boole değeri. İadeler Birimin var olup olmadığını gösteren boole değeri.

NesneleriListele

List<String> listObjects(String catalog, String schema, String volume, String prefix, boolean caseSensitive) throws SQLException Unity Kataloğu birimindeki belirtilen ön ekle başlayan tüm dosya adlarının listesini döndürür. Ön ek, birimin kök dizini olarak dosya yolunun bir parçası olmalıdır. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolamanın UC birim adı. prefix - listeleye dosya adlarının ön eki. Bu, kök dizin olarak birimden göreli yolu içerir. caseSensitive - denetimin büyük/küçük harfe duyarlı olup olmaması gerektiğini gösteren boole değeri. İadeler Belirtilen ön ek ile başlayan dosya adlarını gösteren dizelerin listesi.

getObject (dosya)

boolean getObject(String catalog, String schema, String volume, String objectPath, String localPath) throws SQLException Unity Kataloğu biriminden bir nesne (dosya) alır ve belirtilen yerel yolda depolar. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolamanın UC birim adı. objectPath - kök dizin olarak birimden nesnenin (dosya) yolu. localPath - alınan verilerin depolandığı yerel yol. İadeler GET işleminin durumunu gösteren bir boole değeri.

getObject (akış)

InputStreamEntity getObject(String catalog, String schema, String volume, String objectPath) throws SQLException Unity Kataloğu biriminden bir nesneyi giriş akışı olarak alır. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolamanın UC birim adı. objectPath - kök dizin olarak birimden nesnenin (dosya) yolu. İadeler Giriş akışı varlığının bir örneği.

putObject (dosya)

boolean putObject(String catalog, String schema, String volume, String objectPath, String localPath, boolean toOverwrite) throws SQLException Yerel bir yoldan Unity Kataloğu birimi içindeki belirtilen yola veri yükler. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolamanın UC birim adı. objectPath nesnenin (dosyanın) 'biriminden kök dizin olarak karşıya yüklendiği hedef yol. localPath verilerin yüklenmesi gereken yerel yol. toOverwrite nesnenin zaten var olup olmadığına göre üzerine yazılıp yazılmayacağını belirten bir boolean değeri. İadeler PUT işleminin durumunu gösteren boolean değeri.

putObject (akış)

boolean putObject(String catalog, String schema, String volume, String objectPath, InputStream inputStream, long contentLength, boolean toOverwrite) throws SQLException Bir giriş akışındaki verileri Unity Kataloğu birimindeki belirtilen yola yükler. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolamanın UC birim adı. objectPath - nesnenin (dosyanın) birimden hedef yol olarak kök dizine yüklenmesinin yapıldığı yer. inputStream - verilerin karşıya yüklendiği giriş akışı. contentLength - giriş akışının uzunluğu. toOverwrite nesnenin zaten var olup olmadığına göre üzerine yazılıp yazılmayacağını belirten bir boolean değeri. İadeler PUT işleminin durumunu belirten boole değeri.

deleteObject

boolean deleteObject(String catalog, String schema, String volume, String objectPath) throws SQLException Unity Kataloğu birimi içinde belirtilen bir yoldan bir nesneyi kaldırır. Parametreler: catalog - bulut depolamanın katalog adı. schema - bulut depolamanın şema adı. volume - bulut depolamanın UC birim adı. objectPath - birimde kök dizin olarak silinecek nesnenin (dosya) yolu. İadeler DELETE işleminin sonucunu gösteren Boolean değeri.

IDatabricksGeospatial arayüzü

Jeo-uzamsal veri türleri (GEOMETRY ve GEOGRAPHY) ile çalışma yöntemlerini açıklar. Bu arabirim, IGeometry ve IGeography işaretleyici arabirimleri tarafından türe özgü jeo-uzamsal nesneler için genişletilir.

Paket: com.databricks.jdbc.api

getWKT
String getWKT() Jeo-uzamsal nesnenin Well-Known Metin (WKT) şeklindeki gösterimini döndürür. İadeler SRID ön eki olmadan WKT gösterimini içeren bir Dize.

getWKB
byte[] getWKB() Coğrafi nesnenin OGC uyumlu Well-Known İkili (WKB) gösterimini döndürür. İadeler WKB verilerini içeren bayt dizisi.

getSRID
int getSRID() Jeo-uzamsal nesnenin Uzamsal Başvuru Sistemi Tanımlayıcısını (SRID) döndürür. İadeler SRID değerini temsil eden bir tamsayı (belirtilmezse 0).

getType
String getType() Jeo-uzamsal tür adını döndürür. İadeler GEOMETRY veya GEOGRAPHY olan bir Dize.

ExecutionState numaralandırma

Bir zaman uyumsuz yürütülen sorgunun durumlarını içerir.

Paket: com.databricks.jdbc.api

RUNNING	ifade sunucuda çalışıyor
PENDING	Açıklama henüz sunucuda çalıştırılmadı.
SUCCEEDED	Sorgu başarıyla çalıştı
FAILED	İfade yürütme başarısız oldu
ABORTED	Deyimi durduruldu
CLOSED	Açıklama kapatıldı

IExecutionStatus arabirimi

Zaman uyumsuz sorgunun durumunu alma yöntemlerini açıklar.

Paket: com.databricks.jdbc.api

getExecutionState
ExecutionState getExecutionState() throws SQLException Yürütme durumunu döndürür. İadeler Yürütme durumunun halini temsil eden ExecutionState

getSqlState
String getSqlState() throws SQLException Ayarlanırsa, başarısız durum için SQLState kodunu döndürür. İadeler SQLState kodu olan bir Dize

getErrorMessage
String getErrorMessage() throws SQLException Başarısız bir yürütmenin hata iletisini döndürür. İadeler Hata iletisi olan dize.