ऐसे कई तरीके हैं जिनसे आप इस कोड को तेज़ बना सकते हैं (प्रत्येक को चाहिए पिछले वाले की तुलना में तेज़ हो, लेकिन यह उत्तरोत्तर कम मुहावरेदार-चालाक हो जाता है):
-
insertOrUpdateAll
Run चलाएंinsertOrUpdate
. के बजाय अगर स्लीक-पीजी पर 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() }