Csatlakozás az Azure Data Explorerhez JDBC-vel
A Java Database Connectivity (JDBC) egy adatbázisokhoz való kapcsolódásra és lekérdezések végrehajtására szolgáló Java API. A JDBC használatával csatlakozhat az Azure Data Explorerhez. Ezt a funkciót az Azure Data Explorer TDS-kompatibilis végpontja teszi lehetővé, amely a Microsoft SQL Server emulál. A végpont támogatja a TDS 7.x és 8.0 verzióját.
További információért tekintse meg az Azure Data Explorer SQL Server emulációjának áttekintését.
Csatlakozás a JDBC-vel
Az alábbi lépések azt mutatják be, hogyan használható a JDBC az Azure Data Explorer való csatlakozáshoz.
Hozzon létre egy alkalmazást a JAR,
adal4j
a JAR és az összes függőségük használatávalmssql-jdbc
. Az alábbiakban felsoroljuk azokat a függőségeket, amelyekre a verzió és1.6.3
a7.0.0
verziómssql-jdbc
adal4j
használatakor szükség van.mssql-jdbc-7.0.0.jre8.jar adal4j-1.6.3.jar accessors-smart-1.2.jar activation-1.1.jar asm-5.0.4.jar commons-codec-1.11.jar commons-lang3-3.5.jar gson-2.8.0.jar javax.mail-1.6.1.jar jcip-annotations-1.0-1.jar json-smart-2.3.jar lang-tag-1.4.4.jar nimbus-jose-jwt-6.5.jar oauth2-oidc-sdk-5.64.4.jar slf4j-api-1.7.21.jar
Hozzon létre egy alkalmazást a com.microsoft.sqlserver.jdbc.SQLServerDriver JDBC illesztőosztály használatához. A következő formátumú kapcsolati karakterlánc csatlakozhat. Cserélje le
<cluster_name.region>
a elemet a fürt nevére és a fürtrégióra, valamint<database_name>
az adatbázis nevére.jdbc:sqlserver://<cluster_name.region>.kusto.windows.net:1433;database=<database_name>;encrypt=true;trustServerCertificate=false;hostNameInCertificate=*.kusto.windows.net;loginTimeout=30;authentication=ActiveDirectoryIntegrated
JDBC felhasználói hitelesítés
Az alábbiakban egy példa látható arra, hogyan végezhet programozott hitelesítést Microsoft Entra azonosítóval JDBC-vel egy felhasználónév esetében.
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import com.microsoft.sqlserver.jdbc.SQLServerDataSource;
import com.microsoft.aad.msal4j.*;
public class Sample {
public static void main(String[] args) throws Exception {
IAuthenticationResult authenticationResult = futureAuthenticationResult.get();
SQLServerDataSource ds = new SQLServerDataSource();
ds.setServerName("<cluster_DNS>");
ds.setDatabaseName("<database_name>");
ds.setHostNameInCertificate("*.kusto.windows.net"); // Or appropriate regional domain.
ds.setAuthentication("ActiveDirectoryIntegrated");
try (Connection connection = ds.getConnection();
Statement stmt = connection.createStatement();) {
ResultSet rs = stmt.executeQuery("<T-SQL_query>");
/*
Read query result.
*/
} catch (Exception e) {
System.out.println();
e.printStackTrace();
}
}
}
JDBC-alkalmazáshitelesítés
Az alábbiakban egy példa látható arra, hogyan végezhet programozott hitelesítést Microsoft Entra azonosítóval az alkalmazásnév JDBC-vel való használatával.
import java.sql.*;
import com.microsoft.sqlserver.jdbc.*;
import com.microsoft.aad.msal4j.*;
import java.net.MalformedURLException;
import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class Sample {
public static void main(String[] args) throws Throwable {
// Can also use tenant name.
String authorityUrl = "https://login.microsoftonline.com/<tenant_ID>";
Set<String> scopes = new HashSet<>();
scopes.add("https://<cluster_DNS>/.default");
IConfidentialClientApplication clientApplication = ConfidentialClientApplication.builder("<application_client_ID>", ClientCredentialFactory.createFromSecret("<application_key>")).authority(authorityUrl).build();
CompletableFuture<IAuthenticationResult> futureAuthenticationResult = clientApplication.acquireToken(ClientCredentialParameters.builder(scopes).build());
IAuthenticationResult authenticationResult = futureAuthenticationResult.get();
SQLServerDataSource ds = new SQLServerDataSource();
ds.setServerName("<cluster_DNS>");
ds.setDatabaseName("<database_name>");
ds.setAccessToken(authenticationResult.accessToken());
connection = ds.getConnection();
statement = connection.createStatement();
ResultSet rs = statement.executeQuery("<T-SQL_query>");
/*
Read query result.
*/
}
}