课程表

Slick课程

工具箱
速查手册

Slick 连接和事务处理

当前位置:免费教程 » 数据库/运维 » Slick

数据库连接和事务处理

你可以在程序的任何地方使用数据库查询,当执行查询时你需要有一个数据库连接。

你可以通过创建一个 Database 对象来连接一个 JDBC 数据库,有多种方法可以创建一个数据库对象。

使用 JDBC URL

你可以使用 JDBC URL 来创建一个 Database 对象(URL 的格式取决于连接的数据库的类型),比如:

  1. val db = Database.forURL("jdbc:h2:mem:test1;DB_CLOSE_DELAY=-1", driver="org.h2.Driver")

创建一个基于内存的 H2 数据库连接,再比如我们之前使用的 MySQL 数据库,可以使用

  1. val db = Database.forURL("jdbc:mysql://127.0.0.1/Chinook",
  2. driver = "com.mysql.jdbc.Driver",
  3. user="user",
  4. password="password")

使用 DataSource

你可以使用已有的 datasource 对象,来构建一个 Database 对象,比如你从连接池中取得一个 Datasource 对象,然后连接到 Slick 库中

  1. val db = Database.forDataSource(dataSource: javax.sql.DataSource)

之后你创建一个 Session 对象,将从连接池中取得一个数据库连接,当关闭 Session 时,连接退回给连接池以作他用。

使用 JNDI 名称

如果你使用 JNDI,你可以提供 JNDI 名称来构建一个 Database 对象:

  1. val db = Database.forName(jndiName: String)

Session 管理

现在你有了一个数据库对象可以打开一个数据库(Slick 函数库封装了一个 Session 对象)

Database 的 withSession 方法,创建一个 Session 对象,它可以传递给一个函数,函数返回时自动关闭这个 Session 对象,如果你使用连接池,关闭 Session 对象,自动将连接退回连接池。

  1. val query = for (c <- coffees) yield c.name
  2. val result = db.withSession {
  3. session =>
  4. query.list()( session )
  5. }

你可以看到,我们可以在 withSession 之外定义查询,只有在实际执行查询时才需要一个 Session 对象,要注意的是 Session 的缺省模式为自动提交(auto-commit )模式。每个数据库指令(比如 insert )都自动提交给数据库。 如果需要将几个指令作为一个整体,那么就需要使用事务处理(Transaction)上面的例子,我们在执行查询时,明确指明了 session 对象,你可以使用隐含对象来避免这种情况,比如:

  1. val query = for (c <- coffees) yield c.name
  2. val result = db.withSession {
  3. implicit session =>
  4. query.list // <- takes session implicitly
  5. }
  6. // query.list // <- would not compile, no implicit value of type Session

手工管理 Session

这不是推荐使用的情况,但如果你需要自己管理 Session 对象,你可以自己管理 Session 的生命周期:

  1. val query = for (c <- coffees) yield c.name
  2. val session : Session = db.createSession
  3. val result = query.list()( session )
  4. session.close

事务处理

你可以使用 Session 对象的 withTransaction 方法来创建一个事务,传给该方法的语句将作为一个整体事务执行,如果出现异常,Slick 自动回滚事务,你也可以使用 rollback 强制事务回滚,要注意的是 Slick 只会回滚数据库相关操作,而不会取消其它 Scala 语句。

  1. session.withTransaction {
  2. // your queries go here
  3. if (/* some failure */ false){
  4. session.rollback // signals Slick to rollback later
  5. }
  6. } //

如果你没有 Session 对象,也可以直接使用数据库对象的 withTransaction 方法,如:

  1. db.withTransaction{
  2. implicit session =>
  3. // your queries go here
  4. }
转载本站内容时,请务必注明来自W3xue,违者必究。
 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号