2

我是一个 Slick 初学者，正在尝试使用 Slick 3.0 RC1。在我的第一个项目中，我想将数据从文本文件导入到各种表中。整个导入应按顺序进行，因为数据在一个事务中的文件中。

我尝试创建操作的迭代器并将它们包装在 DBO.sequence 中。

问题是当行数很大时，导入失败并出现 StackOverflowError。显然我误解了如何使用 Slick 来做我想做的事情。有没有更好的方法如何将大量数据链接到一个交易中？

这是我的代码的简化版本，我不是从文件中读取数据，而是简单地从 Range 中“导入”数字。XS 表的偶数，YS 表的奇数。

val db = Database.forConfig("h2mem1")

try {

  class Xs(tag: Tag) extends Table[(Long, String)](tag, "XS") {
    def id = column[Long]("ID", O.PrimaryKey)
    def name = column[String]("NAME")
    override def * : ProvenShape[(Long, String)] = (id, name)
  }

  class Ys(tag: Tag) extends Table[(Long, String)](tag, "YS") {
    def id = column[Long]("ID", O.PrimaryKey)
    def name = column[String]("NAME")
    override def * : ProvenShape[(Long, String)] = (id, name)
  }

  val xs = TableQuery[Xs]
  val ys = TableQuery[Ys]


  val setupAction = DBIO.seq((xs.schema ++ ys.schema).create)

  val importAction = DBIO.sequence((1L to 100000L).iterator.map { x =>
    if (x % 2 == 0) {
      xs +=(x, x.toString)
    } else {
      ys +=(x, x.toString)
    }
  })

  val f = db.run((setupAction andThen importAction))

  Await.result(f, Duration.Inf)

} finally {
  db.close
}
4

1 回答 1

0

该问题是由于在 RC1 版本的 Slick 中实现效率不高造成的。如这里的问题线程所示，实施已得到改进。

在 Slick 3 RC 3 中，问题解决了 :)

于 2015-04-02T09:50:56.327 回答