使用 Slick 3.0 连接到 Mysql - 没有用户名、密码和假驱动程序不等于错误

Connecting to Mysql using Slick 3.0 - No username, no password and bogus driver does not equal error

我正在编写一个非常简单的 scala 脚本来使用 slick 3 连接到 Mysql。

我的build.sbt看起来像这样:

name := "slick_sandbox"

version := "1.0"

scalaVersion := "2.11.7"

libraryDependencies ++= Seq(
  "com.typesafe.slick" %% "slick" % "3.0.3",
  "org.slf4j" % "slf4j-nop" % "1.6.4",
  "mysql" % "mysql-connector-java" % "5.1.6"

)

application.conf:

Drivder是故意的错误;另外,我没有提供数据库用户名 密码!

mysqldb = {
  url = "jdbc:mysql://localhost/slickdb"
  driver = com.mysql.jdbc.Drivder
  connectionPool = disabled
  keepAliveConnection = true
}

Main.scala

进口slick.driver.MySQLDriver.api._ 导入 scala.concurrent.ExecutionContext.Implicits.global

object Main {

  def main(args: Array[String]) {

    // test to see this function is being run; it IS
    println("foobar")

    // I expected an error here due to the intentional
    // mistake I've inserted into application.conf
    // I made sure the conf file is getting read; if I change mysqldb
    // to some other string, I get correctly warned it is not a
    // valid key
    val db = Database.forConfig("mysqldb")

    val q = sql"select u.name from users ".as[String]

    db.run(q).map{ res=>
      println(res)
    }
  }
}

编译成功。现在 this 是我在终端上 运行 sbt run 时看到的结果:

felipe@felipe-XPS-8300:~/slick_sandbox$ sbt run
[info] Loading project definition from /home/felipe/slick_sandbox/project
[info] Set current project to slick_sandbox (in build file:/home/felipe/slick_sandbox/)
[info] Compiling 1 Scala source to /home/felipe/slick_sandbox/target/scala-2.11/classes...
[info] Running Main 
foobar
[success] Total time: 5 s, completed Sep 17, 2015 3:29:39 AM

一切看似正常;即使我明确地 运行 对不存在的数据库进行查询,slick 仍然继续进行,就好像什么都没发生一样。

我在这里错过了什么?

Slick 异步运行查询。所以它只是没有足够的时间来执行它。在您的情况下,您必须等待结果。

object Main {

  def main(args: Array[String]) {

    println("foobar")

    val db = Database.forConfig("mysqldb")

    val q = sql"select u.name from users ".as[String]

    Await.result(
      db.run(q).map{ res=>
      println(res)
    }, Duration.Inf)
  }
}