mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2025-03-13 19:37:30 +01:00
Code Issues Projects Releases Packages Wiki Activity

Use transactionally when inserting data into our database with createAll (#708)

Browse source
This commit is contained in:
Chris Stewart 2019-08-21 06:28:28 -05:00 • committed by GitHub
parent 6a69228bae
commit 1619d5d123
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
db-commons/src/main/scala/org/bitcoins/db/CRUDAutoInc.scala
View file

@ -18,9 +18,9 @@ abstract class CRUDAutoInc[T <: DbRowAutoInc[T]](
val query = table
.returning(table.map(_.id))
.into((t, id) => t.copyWithId(id = id))
val actions: Vector[DBIOAction[query.SingleInsertResult, NoStream, Write]] =
ts.map(r => query.+=(r))
database.runVec(DBIO.sequence(actions))
val actions: DBIOAction[query.MultiInsertResult, NoStream, Write] =
query.++=(ts)
database.runVec(actions)
}
override def findByPrimaryKeys(ids: Vector[Long]): Query[Table[_], T, Seq] = {

4
db-commons/src/main/scala/org/bitcoins/db/SlickUtil.scala
View file

@ -12,8 +12,8 @@ sealed abstract class SlickUtil {
database: SafeDatabase,
table: TableQuery[U])(
implicit ec: ExecutionContext): Future[Vector[T]] = {
val actions = ts.map(t => (table += t).andThen(DBIO.successful(t)))
val result = database.run(DBIO.sequence(actions))
val actions = (table ++= ts).andThen(DBIO.successful(ts)).transactionally
val result = database.run(actions)
result
}
}