我需要从我的 Scala 代码连接到 mySQL 数据库。我有下面的代码来建立连接。我正在导入 java 包以从 scala 连接到数据库,并且我正在使用 Drivermanager 进行连接。我已经在其中编写了一个类和一个方法来进行连接,并且我正在从我的对象中扩展和使用它。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
class DBConnectionClass {
val user = "root"
val pass = "admin"
val url = "jdbc:mysql://172.16.40.5/scalatest"
def readDataBase() = {
try {
Class.forName("com.mysql.jdbc.Driver")
val connection: Connection = DriverManager.getConnection(url, user, pass);
}
catch {
case _: Throwable => println("Could not connect to database")
}
}
}
在我正在运行的 scala 对象中,
object TestAppMain {
def main(args: Array[String]){
val DBconnObject = new DBConnectionClass
DBconnObject.readDataBase
println("Check DB Is connected or not")
}
}
但它抛出了一个无法连接到数据库的异常..任何人都可以帮助我......提前谢谢