Spark - Lecture de SQL Server à l'aide de com.microsoft.Azure

La classe ne semble pas être définie dans votre configuration ni spécifié nulle part ailleurs. classe.forname code> Validate simplement la présence du pilote JDBC. Le pilote est également pour Microsoft.SQLServer code>, qui est une bibliothèque différente.

Considérez en utilisant ceci: P>

import com.microsoft.sqlserver.jdbc.SQLServerDriver
import java.util.Properties
val jdbcHostname = "localhost"
val jdbcPort = 1433
val jdbcDatabase = "Student"
val jdbcTable = "dbo.MemberDetail"

val MyDBUrl = s"jdbc:sqlserver://${jdbcHostname}:${jdbcPort};database=${jdbcDatabase}"

val MyDBProperties = new Properties()
MyDBProperties.put("user", "test")
MyDBProperties.put("password", "****")
MyDBProperties.setProperty("Driver", "com.microsoft.sqlserver.jdbc.SQLServerDriver")
val df = spark.read.jdbc(MyDBUrl, jdbcTable, MyDBProperties)

Puisque vous utilisez Azure-sqldb-Spark pour se connecter à SQL Server.

Toutes les propriétés de connexion dans Le pilote Microsoft JDBC pour SQL Server est pris en charge dans ce connecteur. Ajouter des propriétés de connexion en tant que champs du com.microsoft.azure.sqldb.spark.config.config.config.config.

Vous n'avez pas besoin de créer le pilote JDBC classe.forname ("com.microsoft .sqlserver.jdbc.sqlserverdriver ") à nouveau.

Votre froide devrait être comme ceci: xxx

ref:

1. Connectez une étincelle à SQL DB à l'aide du connecteur
2. Azure-sqldb-Spark

   espère que cela aide.