用于 JDBC 数据库连接的 Akka Projection 配置答案

【问题标题】：Akka Projection configuration for a JDBC database connection用于 JDBC 数据库连接的 Akka Projection 配置
【发布时间】：2021-08-17 15:08:03
【问题描述】：

在offsetting in a relational database with JDBC 下的 Akka Projection 文档中，没有关于应如何以及在何处建立与所用关系数据库的连接的配置的信息。我的意思是诸如用户名、密码或 url 之类的配置。

在offset in a relational database with Slick下的文档中，提供了如下的数据库连接配置，不清楚是否也可以用于JDBC：

# add here your Slick db settings
  db {
    # url = "jdbc:h2:mem:test1"
    # driver = org.h2.Driver
    # connectionPool = disabled
    # keepAliveConnection = true
  }

我应该如何以及在哪里指定 JDBC 连接参数？

【问题讨论】：

标签： scala jdbc akka akka-projection

【解决方案1】：

https://doc.akka.io/docs/akka-projection/current/jdbc.html#defining-a-jdbcsession

Scala 代码 sn-p 中的以下行是您可以指定连接参数的地方：

val c = DriverManager.getConnection("jdbc:h2:mem:test;DB_CLOSE_DELAY=-1")

【讨论】：

似乎该连接用于建立用于将记录投影到的 JDBC 会话。它不是用于访问投影本身使用的schema。还是应该将投影模式放在记录投影到的同一个 JDBC 数据库中？
我认为根据“使用JdbcProjection.exactlyOnce时，传递给处理程序的JdbcSession将用于在后台保存偏移量。”我需要将架构放在同一个数据库上。
是的，你必须在数据库中创建schema，然后在JdbcSession中建立到这个数据库的连接。