потоковая передача scala slick3 с postgresql не работает - PullRequest
Новая
       15

потоковая передача scala slick3 с postgresql не работает

0 голосов
/ 20 сентября 2019

Postgresql verision: 9.3.25

В таблице, которую я пытаюсь транслировать, есть данные.Это напечатает данные для меня.Await.result(db.run(streamingLogTable.result),Duration.Inf).foreach(println)

Однако, если я попытался выполнить потоковую передачу, она не работает.Ничего не печатается. 

    db.stream(streamingLogTable.result.withStatementParameters(fetchSize = 100, 
      rsType = ResultSetType.ForwardOnly, 
      rsConcurrency = ResultSetConcurrency.ReadOnly).transactionally).foreach {
      a => {
        println(a)
        Thread.sleep(1000)
      }
    }

Мои классные таблицы выглядят следующим образом 

  class StreamingLog(tag: Tag) extends Table[(Int, String)](tag, "streaming_log") {
    def id = column[Int]("id", O.PrimaryKey)

    // This is the primary key column
    def log = column[String]("log")

    // Every table needs a * projection with the same type as the table's type parameter
    def * = (id, log)
  }

  val streamingLogTable = TableQuery[StreamingLog]

любые мысли, чтобы это сработало.

...