sql >> Database >  >> RDS >> Mysql

Slick 3.0 bulk invoegen of updaten (upsert)

Er zijn verschillende manieren waarop u deze code sneller kunt maken (elk moet sneller zijn dan de voorgaande, maar het wordt steeds minder idiomatisch-slick):

  • Voer insertOrUpdateAll uit in plaats van insertOrUpdate indien op slick-pg 0.16.1+

    await(run(TableQuery[FooTable].insertOrUpdateAll rows)).sum
    
  • Voer uw DBIO-gebeurtenissen allemaal tegelijk uit, in plaats van te wachten tot ze allemaal zijn vastgelegd voordat u de volgende uitvoert:

    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
    
  • Ga naar het JDBC-niveau en voer je upsert in één keer uit (idee via dit antwoord ):

    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. SQL Server GUID-sorteeralgoritme. Waarom?

  2. MySQL ORDER BY Datumveld dat geen datumnotatie heeft

  3. Hoe meerdere rapporten met barcode \ of meerdere barcodes in één rapport af te drukken

  4. Wat is cursor in orakel