保持数据库会话打开

Question

我正在尝试利用 TypeSafe 的 slick 库与 MySQL 服务器进行交互。所有入门/教程示例都使用withSession{}，其中框架将自动创建会话，在{} 中执行查询，然后在块的末尾终止会话。

我的程序很健谈，我想在脚本的整个执行过程中保持持久连接。到目前为止，我已将这段代码拼凑在一起，以显式创建和关闭会话。

val db = Database.forURL("jdbc:mysql://localhost/sandbox", user = "root", password="***", driver = "com.mysql.jdbc.Driver")
val s = db.createSession()
...
s.close()

我可以在其中执行查询。但是，当我尝试执行命令时，例如

(Q.u + "插入TEST (name) values('"+name+"')").execute

它崩溃是因为它找不到隐式会话。我不完全理解syntax of the execute definition in the documentation，但似乎可能有一个可选参数来传递显式会话。我尝试过使用 .execute(s)，但会发出警告，表明 (s) 在纯表达式中没有做任何事情。

我如何明确指定一个预先存在的会话来运行查询？

附加：JAB解决方案的试用代码

class ActorMinion(name: String) extends Actor
{
    Database.forURL("jdbc:mysql://localhost/sandbox", user = "root", password="****", driver = "com.mysql.jdbc.Driver") withSession
    {
        def receive =
        {
            case Execute =>
            {
                (Q.u + "insert into TEST (name) values('"+name+"')").execute

                sender ! DoneExecuting(name,output,err.toString)
            }
        }
    }
}

返回编译错误

[错误] /home/ubuntu/helloworld/src/main/scala/hw.scala:41: 缺少扩展函数的参数类型

[错误] 匿名函数的参数类型必须是完全已知的。 (SLS 8.5)

[错误] 预期类型为：?

[错误] {

[错误] ^

[error] 发现一个错误

Answer 1

我能够从 this answer 得到我需要的东西

//imports at top of file
//import Database.threadLocalSession <--this should be commented/removed
import scala.slick.session.Session // <-- this should be added
......
//These two lines in actor constructor
val db = Database.forURL("jdbc:mysql://localhost/sandbox", user = "root", password="****", driver = "com.mysql.jdbc.Driver")
implicit var session: Session = db.createSession()
......
session.close() //This line in actor destructor

Answer 2

只需将脚本的相关部分附在withSession{} 中即可。请注意，如果您将会话保持打开一段时间/正在执行大量数据库操作查询，您还应该考虑利用事务。

如果数据有潜在的外部来源，你真的应该使用准备好的语句进行插入。