关于slick DB，slick profile是如何工作的

Question

我很难理解如何使用slick profile。

我的问题是：

我正试图通过Alpaka JDBC插件将Slick与Akka流结合使用。网上给出的例子如下：

#Load using SlickSession.forConfig("slick-h2")
slick-h2 {
  profile = "slick.jdbc.H2Profile$"
  db {
    connectionPool = disabled
    dataSourceClass = "slick.jdbc.DriverDataSource"
    properties = {
      driver = "org.h2.Driver"
      url = "jdbc:h2:/tmp/alpakka-slick-h2-test"
    }
  }
}

import scala.concurrent.Future

import akka.Done
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer

import akka.stream.scaladsl._
import akka.stream.alpakka.slick.scaladsl._

import slick.jdbc.GetResult

object SlickSourceWithPlainSQLQueryExample extends App {
  implicit val system = ActorSystem()
  implicit val mat = ActorMaterializer()
  implicit val ec = system.dispatcher

  implicit val session = SlickSession.forConfig("slick-h2")

  // The example domain
  case class User(id: Int, name: String)

  // We need this to automatically transform result rows
  // into instances of the User class.
  // Please import slick.jdbc.GetResult
  // See also: "http://slick.lightbend.com/doc/3.2.1/sql.html#result-sets"
  implicit val getUserResult = GetResult(r => User(r.nextInt, r.nextString))

  // This import enables the use of the Slick sql"...",
  // sqlu"...", and sqlt"..." String interpolators.
  // See also: "http://slick.lightbend.com/doc/3.2.1/sql.html#string-interpolation"
  import session.profile.api._

  // Stream the results of a query
  val done: Future[Done] =
    Slick
      .source(sql"SELECT ID, NAME FROM ALPAKKA_SLICK_SCALADSL_TEST_USERS".as[User])
      .log("user")
      .runWith(Sink.ignore)

  done.onComplete {
    case _ =>
      session.close()
      system.terminate()
  }
}

问题是它与

隐式val会话=滑动会话。forConfig（“slick-h2”）

我尝试如下使用slick会话：

object Main extends App {

  implicit val system = ActorSystem()
  implicit val mat = ActorMaterializer()
  implicit val ec = system.dispatcher

  implicit val session = SlickSession.forConfig("pp")
}

我的pp配置如下所示：

pp = {

  url                 = "jdbc:oracle:thin:@52.4.90.244:1521:pp"
  driver              = oracle.jdbc.OracleDriver
  keepAliveConnection = true
  connectionPool      = disabled


  user                = "xxxxx"
  password            = "xxxxx"

}

此代码在运行时中断。

Exception in thread "main" slick.SlickException: Configured profile oracle.jdbc.OracleDriver does not conform to requested profile slick.jdbc.JdbcProfile
    at slick.basic.DatabaseConfig$.forConfig(DatabaseConfig.scala:99)
    at akka.stream.alpakka.slick.javadsl.SlickSession$.forConfig(package.scala:47)
    at akka.stream.alpakka.slick.javadsl.SlickSession$.forConfig(package.scala:44)

但是在另一个代码中，我不使用Akka流，因此也不使用slickSession

object Main extends App {
  val db = Database.forConfig("pp")
.....}

代码运行得很好。

我得出结论，这与数据库有关。forconfig（“pp”）和SlickSession。forConfig（“slick-h2”）需要两种不同的东西。

在Slick网站上有一个关于个人资料的解释，但这不太容易理解，提供的指导也很少。它没有列出可用的配置文件及其语法。

因此我的问题是，这两个forConfig之间有什么区别。配置文件是如何工作的，在哪里需要它们。为什么数据库的两个配置文件处理方式不同。

最后也是最重要的一点，甲骨文的简介是什么。在slick 3.2.3中，slick现在是免费的。我在profile=“slick.jdbc.H2Profile$”中找不到它的配置文件

有人能帮助澄清配置文件的差异、预期的内容、配置文件的作用以及Oracle的配置文件是什么吗？

Answer 1

作为@Jeffrey Chung答案的后续内容。以下是解决方案。

  implicit val session = SlickSession.forConfig("pp")
  import session.profile.api._

配置文件应如下所示：

pp {
  profile = "slick.jdbc.OracleProfile$"
  db {
    url                 = "..."
    driver              = oracle.jdbc.OracleDriver
    keepAliveConnection = true
    connectionPool      = disabled


    user                = "...."
    password            = "...."
  }
}

Answer 2

Slick文档中的升级指南解释了驱动程序和配置文件之间的区别：

Slick的driver概念已被重命名为profile，以结束人们对Slick驱动程序与JDBC驱动程序之间的混淆。。。。

至于Alpakka的SlickSession不接受您的配置的原因，请查看源代码：

object SlickSession {
  private final class SlickSessionImpl(val slick: DatabaseConfig[JdbcProfile]) extends SlickSession {
    val db: JdbcBackend#Database = slick.db
    val profile: JdbcProfile = slick.profile // <-- expects a profile
  }
  ...
}

SlickSession专门在配置中查找配置文件，这就是定义驱动程序不起作用的原因。

要为Oracle定义配置文件，请使用OracleProfile。