Slick 3 插入不插入但没有错误

Question

我想通过做一个小测试来掌握 Slick 的窍门。我正在尝试插入。测试运行，没有错误，但是当我检查数据库时，没有插入记录。

我做错了什么？

这是我的测试代码：

注意：我禁用了第一个'flatMap'，因为当我想测试第二个插入方法时，当启用第一个平面图功能时该代码没有执行。

两种插入方式都没有插入新记录。对所有项目的第一个查询确实有效。 'Test id:xx' 行打印到控制台。

object TestSlick extends App {

  import slick.driver.PostgresDriver.api._
  import concurrent.ExecutionContext.Implicits.global
  import concurrent.duration._

  val config = ConfigFactory.load()
  val username = config.getString("app.database.jdbc.username")
  val password = config.getString("app.database.jdbc.password")
  val url: String = config.getString("app.database.jdbc.url")

  val db = Database.forURL(url, username, password)

  try {
    import Tables._

    val res = db.run(headlines.result).map(_.foreach {
      case HeadLineRow(id, _, _, _, _, companyId, text, from, days, end, user) =>
        println(s"Test id:$id")
    }).flatMap { _ =>
//      println("Inserting....")
//      val ts = Timestamp.valueOf(LocalDateTime.now())
//      val insertAction: DBIO[Option[Int]] = (headlines returning headlines.map(_.id)) +=
//        HeadLineRow(None, 100, 100, "tekst", ts, 5, ts, None, None, None, None)
//
//      db.run(insertAction.transactionally.map(
//        newId => println(s"New id: $newId"))
//      )
//    }.flatMap { _ =>
      println("Inserting....(2)")
      val ts = Timestamp.valueOf(LocalDateTime.now())
      val insertAction = headlines.map(p => p) += HeadLineRow(None, 1921, 65, "tekst2", ts, 5, ts, None, None, None, None)

      db.run(insertAction.transactionally.map(
        r => println(s"Insert result: ${r}"))
      )
    }

    Await.ready(res, 30 seconds);

  } finally db.close()
}

还有我的 table（使用 Slick 的生成器生成，然后稍微调整了一下（auto-inc id，交换了一些属性））

套餐com.wanneerwerkik.db.slick

// AUTO-GENERATED Slick data model
/** Stand-alone Slick data model for immediate use */
object Tables extends {
  val profile = slick.driver.PostgresDriver
} with Tables

/** Slick data model trait for extension, choice of backend or usage in the cake pattern. (Make sure to initialize this late.) */
trait Tables {
  val profile: slick.driver.JdbcProfile
  import profile.api._
  import slick.model.ForeignKeyAction
  import slick.collection.heterogeneous._
  import slick.collection.heterogeneous.syntax._
  // NOTE: GetResult mappers for plain SQL are only generated for tables where Slick knows how to map the types of all columns.
  import slick.jdbc.{GetResult => GR}

  /** DDL for all tables. Call .create to execute. */
  lazy val schema = Array(headlines.schema).reduceLeft(_ ++ _)
  @deprecated("Use .schema instead of .ddl", "3.0")
  def ddl = schema

  /**
   * Entity class storing rows of table 'head_line_bar'
   *  @param id Database column id SqlType(int4), PrimaryKey
   *  @param createdBy Database column created_by SqlType(int4), Default(None)
   *  @param createdOn Database column created_on SqlType(timestamp), Default(None)
   *  @param updatedBy Database column updated_by SqlType(int4), Default(None)
   *  @param updatedOn Database column updated_on SqlType(timestamp), Default(None)
   *  @param companyId Database column company_id SqlType(int4), Default(None)
   *  @param contentType Database column content_type SqlType(varchar), Length(255,true), Default(None)
   *  @param fromDate Database column from_date SqlType(timestamp), Default(None)
   *  @param numberofdays Database column numberofdays SqlType(int4), Default(None)
   *  @param uptoEndDate Database column upto_end_date SqlType(timestamp), Default(None)
   *  @param userId Database column user_id SqlType(int4), Default(None)
   */
  case class HeadLineRow(
      id: Option[Int],
      userId: Int,
      companyId: Int,
      contentType: String,
      fromDate: java.sql.Timestamp,
      numberofdays: Int,
      uptoEndDate: java.sql.Timestamp,
      createdBy: Option[Int] = None,
      createdOn: Option[java.sql.Timestamp] = None,
      updatedBy: Option[Int] = None,
      updatedOn: Option[java.sql.Timestamp] = None
  )

  /** GetResult implicit for fetching HeadLineBarRow objects using plain SQL queries */
  implicit def GetResultHeadLineRow(implicit e0: GR[Int], e1: GR[Option[Int]], e2: GR[Option[java.sql.Timestamp]], e3: GR[Option[String]]): GR[HeadLineRow] = GR{
    prs => import prs._
    HeadLineRow.tupled((<<?[Int], <<[Int], <<[Int], <<[String], <<[java.sql.Timestamp], <<[Int], <<[java.sql.Timestamp], <<?[Int], <<?[java.sql.Timestamp], <<?[Int], <<?[java.sql.Timestamp]))
  }
  /**
   * Table description of table head_line_bar.
   * Objects of this class serve as prototypes for rows in queries.
   */
  class Headlines(_tableTag: Tag) extends Table[HeadLineRow](_tableTag, "head_line_bar") {
    def * = (id, userId, companyId, contentType, fromDate, numberofdays, uptoEndDate, createdBy, createdOn, updatedBy, updatedOn) <> (HeadLineRow.tupled, HeadLineRow.unapply)
    /** Maps whole row to an option. Useful for outer joins. */
    def ? = (Rep.Some(id), userId, companyId, contentType, fromDate, numberofdays, uptoEndDate, createdBy, createdOn, updatedBy, updatedOn).shaped.<>({r=>import r._; _1.map(_=> HeadLineRow.tupled((_1.get, _2, _3, _4, _5, _6, _7, _8, _9, _10, _11)))}, (_:Any) =>  throw new Exception("Inserting into ? projection not supported."))

    /** Database column id SqlType(int4), PrimaryKey */
    val id: Rep[Option[Int]] = column[Option[Int]]("id", O.PrimaryKey, O.AutoInc)
    /** Database column user_id SqlType(int4), Default(None) */
    val userId: Rep[Int] = column[Int]("user_id")
    /** Database column company_id SqlType(int4), Default(None) */
    val companyId: Rep[Int] = column[Int]("company_id")
    /** Database column content_type SqlType(varchar), Length(255,true), Default(None) */
    val contentType: Rep[String] = column[String]("content_type", O.Length(255,varying=true))
    /** Database column from_date SqlType(timestamp), Default(None) */
    val fromDate: Rep[java.sql.Timestamp] = column[java.sql.Timestamp]("from_date")
    /** Database column numberofdays SqlType(int4), Default(None) */
    val numberofdays: Rep[Int] = column[Int]("numberofdays")
    /** Database column upto_end_date SqlType(timestamp), Default(None) */
    val uptoEndDate: Rep[java.sql.Timestamp] = column[java.sql.Timestamp]("upto_end_date")
    /** Database column created_by SqlType(int4), Default(None) */
    val createdBy: Rep[Option[Int]] = column[Option[Int]]("created_by", O.Default(None))
    /** Database column created_on SqlType(timestamp), Default(None) */
    val createdOn: Rep[Option[java.sql.Timestamp]] = column[Option[java.sql.Timestamp]]("created_on", O.Default(None))
    /** Database column updated_by SqlType(int4), Default(None) */
    val updatedBy: Rep[Option[Int]] = column[Option[Int]]("updated_by", O.Default(None))
    /** Database column updated_on SqlType(timestamp), Default(None) */
    val updatedOn: Rep[Option[java.sql.Timestamp]] = column[Option[java.sql.Timestamp]]("updated_on", O.Default(None))
  }
  /** Collection-like TableQuery object for table HeadLineBar */
  lazy val headlines = new TableQuery(tag => new Headlines(tag))

}

日志输出太大无法粘贴在这里所以我把它放在 this gist.

按照建议，我添加了一个 readLine 来等待结果，但它已经输出了同样的东西。我还在 Future 上添加了一个完成处理程序来打印它的成功或失败。显然它因 RejectedExecutionException 而失败。为什么？

Failure: java.util.concurrent.RejectedExecutionException: Task slick.backend.DatabaseComponent$DatabaseDef$$anon@2e4db0df rejected from java.util.concurrent.ThreadPoolExecutor@43760a50[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 1]

Answer 1

这只是一个猜测，但也许您的测试框架因 flatMap 内部产生一个新任务而再次需要执行上下文这一事实以某种方式混淆（参见例如 this thread - 它是关于Scala 2.10 但我认为这没有改变）。因此在执行插入之前释放资源。

您是否尝试过将 println 放在 finally 块中，看看它是在伴随插入的消息之前还是之后调用？

您是否尝试过运行使用 await 同步两种期货？在这种情况下，您可能不会遇到此问题。

您可以考虑使用完整的异步支持进行测试，例如参见this link.

Slick 3 插入不插入但没有错误

Slick 3 insert not inserting but no error

scala

slick

slick-3.0