ScalikeJdbc 多重插入

Question

我们如何在同一个事务中执行多次插入？

  def insertData(dataList: List[Data])(implicit session: DBSession = autoSession) = {

    // todo: this is probably opening and closing a connection every time?
    dataList.foreach(data => insertData(data))
  }

  def insertData(data: Data) = withSQL {
    val t = DataTable.column
    insert.into(DataTable).namedValues(
      d.name -> data.name,
      d.title -> data.title
    )
  }.update().apply()

如果每次插入的事务数以千计或更多，则为每个插入创建不同的事务将不会有效。

http://scalikejdbc.org/documentation/operations.html

Answer 1

像这样修改你的 insertData 方法：

def insertData(data: Data)(implicit session: DBSession = AutoSession) = withSQL {
  val t = DataTable.column
  insert.into(DataTable).namedValues(
    d.name -> data.name,
    d.title -> data.title
  )
}.update().apply()

然后，使用 DB.localTx：

DB.localTx { implicit s =>
  dataList.foreach(data => insertData(data))
}