0

我有一个遗留的 Java 应用程序，并且希望在使用 scala 扩展应用程序时重用其数据库连接处理。

现有应用程序这样做是为了使用数据库（省略了 try/catch）：

Connection dbConn = NewConnectionPool.getRemotePool().getConnection();
PreparedStatement ps = dbConn.prepareStatement(someQuery);

在我尝试的scala代码中：

  class Rules {
  val connHandle = NewConnectionPool.getRemotePool.getConnection
  val session = connHandle.unwrap(classOf[java.sql.Connection])
  def loadTagRulesFromDb(name: String = "rules"): tagRuleSet = {
        //val tagRules = NamedDB('remotedb) readOnly { implicit session =>
        val tagRules = DB readOnly { implicit session =>
          sql"select * from databasename.messaging_routing_matchers".map(
            rs => tagRule(
              rs.long("id"),
              rs.string("description"),
              rs.long("ruleid"),
              rs.string("operator"),
              rs.string("target")
            )
          ).list.apply
        }
        for (tr <- tagRules) {
          println(tr)
        }
        tagRuleSet(name,DateTime.now(),tagRules)
      }
    }

并称之为：

Rules rr = new Rules();
rr.loadTagRulesFromDb("testing");

我收到此错误（DB 和 NamedDB 版本）“ Connection pool is not yet initialized.(name:'”，名称为 default 或 remotedb）：

java.lang.IllegalStateException: Connection pool is not yet initialized.(name:'default)
    at scalikejdbc.ConnectionPool$$anonfun$get$1.apply(ConnectionPool.scala:76) ~[scalikejdbc-core_2.11-2.4.2.jar:2.4.2]
    at scalikejdbc.ConnectionPool$$anonfun$get$1.apply(ConnectionPool.scala:74) ~[scalikejdbc-core_2.11-2.4.2.jar:2.4.2]
    at scala.Option.getOrElse(Option.scala:121) ~[scala-library-2.11.8.jar:na]
    at scalikejdbc.ConnectionPool$.get(ConnectionPool.scala:74) ~[scalikejdbc-core_2.11-2.4.2.jar:2.4.2]
    at scalikejdbc.ConnectionPool$.apply(ConnectionPool.scala:65) ~[scalikejdbc-core_2.11-2.4.2.jar:2.4.2]
    at scalikejdbc.DB$.connectionPool(DB.scala:151) ~[scalikejdbc-core_2.11-2.4.2.jar:2.4.2]
    at scalikejdbc.DB$.readOnly(DB.scala:172) ~[scalikejdbc-core_2.11-2.4.2.jar:2.4.2]
    at dk.coolsms.smsc.Rules.loadTagRulesFromDb(Rules.scala:28) ~[smsc.jar:na]
    at dk.coolsms.smsc.SendMessage.sendMessage(SendMessage.java:206) ~[smsc.jar:na]

我假设我可以从 BoneCP connectionHandle 以某种方式获得与 scalikejdbc 兼容的连接？

编辑：解决方案如下，注意DB readOnly etc.不应该使用，因为它依赖于DBs.setupAll()和 application.conf，这不适用于这种特定情况

4

1 回答 1

1

通过javax.sql.DataSource实例访问将是将 ScalikeJDBC 与现有数据库连接集成的最佳方式。

http://scalikejdbc.org/documentation/connection-pool.html

但是你已经有一个 raw java.sql.Connection，也可以简单地创建一个DBSession如下：

implicit val session = DBSession(conn)
sql"select * from databasename.messaging_routing_matchers".toMap.list.apply()
于 2016-06-15T16:01:56.443 回答