sql >> データベース >  >> RDS >> Mysql

Slick 3.0の一括挿入または更新(アップサート)

    このコードを高速化する方法はいくつかあります(それぞれ 前のものよりも高速ですが、慣用的な滑らかさが次第に少なくなります):

    • 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レベルにドロップダウンして、アップサートを一度に実行します(この回答によるアイデア ):

      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()
      }
      


    1. 同じ列で満たすMYSQLANDクエリ

    2. OracleSql開発者でExplainPlanを表示するにはどうすればよいですか?

    3. Oracle10gExpressのホームページが表示されない

    4. Oracle-文字列のカンマ区切りを分割します(文字列にはスペースと連続したカンマが含まれます)