Slick 3.0 групово вмъкване или актуализиране (upsert)

Има няколко начина, по които можете да направите този код по-бърз (всеки трябва бъде по-бърз от предишните, но става все по-малко идиоматичен):

• Изпълнете insertOrUpdateAll вместо insertOrUpdate ако е на slick-pg 0.16.1+

  await(run(TableQuery[FooTable].insertOrUpdateAll rows)).sum
  

• Стартирайте вашите DBIO събития наведнъж, вместо да чакате всяко едно да се ангажира, преди да стартирате следващото:

  val toBeInserted = rows.map { row => TableQuery[FooTable].insertOrUpdate(row) }
  val inOneGo = DBIO.sequence(toBeInserted)
  val dbioFuture = run(inOneGo)
  // Optionally, you can add a `.transactionally`
  // and / or `.withPinnedSession` here to pin all of these upserts
  // to the same transaction / connection
  // which *may* get you a little more speed:
  // val dbioFuture = run(inOneGo.transactionally)
  val rowsInserted = await(dbioFuture).sum
  

• Спуснете се до нивото на JDBC и стартирайте upsert наведнъж (идея чрез този отговор ):

  val SQL = """INSERT INTO table (a,b,c) VALUES (?, ?, ?)
  ON DUPLICATE KEY UPDATE c=VALUES(a)+VALUES(b);"""
  
  SimpleDBIO[List[Int]] { session =>
    val statement = session.connection.prepareStatement(SQL)
    rows.map { row =>
      statement.setInt(1, row.a)
      statement.setInt(2, row.b)
      statement.setInt(3, row.c)
      statement.addBatch()
    }
    statement.executeBatch()
  }