scala – 在Futures中包装Slick查询

发布时间：2020-12-16 19:07:25 所属栏目：安全来源：网络整理

导读：我试图使用Slick异步查询 MySQL数据库.以下代码模板,我用于查询大约90k行的理解似乎在最初工作,但程序消耗了几GB的RAM,并在大约200个查询之后失败,没有警告. import scala.slick.jdbc.{StaticQuery = Q}def doQuery(): Future[List[String]] = future { val

我试图使用Slick异步查询 MySQL数据库.以下代码模板,我用于查询大约90k行的理解似乎在最初工作,但程序消耗了几GB的RAM,并在大约200个查询之后失败,没有警告.

import scala.slick.jdbc.{StaticQuery => Q}
def doQuery(): Future[List[String]] = future {
  val q = "select name from person"
  db withSession {
    Q.query[String](q).list
  }
}

我已经尝试使用fromURL方法和使用c3p0连接池设置连接.我的问题是：这是对数据库进行异步调用的方式吗？

解决方法

异步还是一个 open issue for Slick.

您可以尝试使用Iterables和流数据,而不是使用类似于以下的解决方案将其存储在内存中：Treating an SQL ResultSet like a Scala Stream

虽然最后请省略.toStream电话.它会将数据缓存在内存中,而Iterable不会.

如果你想要一个异步版本的iterable,你可以看看Observables.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!