Собственный материал в транзакции Slick

Question

Я использую Slick 3.1.1, и я хотел бы реализовать свои собственные вещи на транзакции Slick.

def findSomeProducts = table.getSomeProducts() //db operation 
def productTableUpdate = doSomeStuff1() //db operation 
def priceTableUpdate = doSomeStuff2() //db operation 

def updateElasticCache = updateIndexOfProduct() //this is not a database operation 

У меня есть эти функции выборки. Во-первых, я получаю некоторые продукты из db и после обновления таблиц. В конце мне нужно запустить метод updateElasticCache. Если метод updateElasticCache терпит неудачу, я хотел бы откатить целые db-файлы.

Я не могу использовать (for { ... } yield()).transactionally этот код, потому что он не применим для моих случаев. Это «транзакционно» ждет действия db. Но я хочу добавить еще одну функциональность, которая не является db-процессом.

Возможно ли это? Как я могу это достичь?

Answer 1

DBIO.from

Да !!! его можно добавить нон логику дб между дб логики в пятне, используя DBIO действия состава и DBIO.from

Обратите внимание, что «свой материал» должен вернуться в будущем, будущее может быть преобразован в DBIO и могут быть составлены вместе с обычные действия db.

DBIO.from может помочь вам в этом. Вот как это работает. DBIO.from берет будущее и преобразует его в DBIOAction. теперь вы можете скомпоновать эти действия с обычными действиями db для выполнения операций не-db вместе с операциями db в транзакции.

def updateElasticCache: Future[Unit] = Future(doSomething()) 

теперь позволяет сказать, у нас есть некоторые БД действия

def createUser(user: User): DBIO[Int] = ??? 

хочу CreateUser откатить, если обновление кэша не удается. поэтому я сделать следующий

val action = createUser.flatMap { _ => DBIO.from(updateElasticCache()) }.transactionally 
db.run(action) 

теперь, если updateElasticCache терпит неудачу всего tx потерпит неудачу, и все будет откатить в нормальное состояние.

Пример

Вы можете использовать для понимания, чтобы сделать его хорошо выглядеть

def updateStats: DBIO[Int] = ??? 
val rollbackActions = 
    (for { 
    cStatus <- createUser() 
    uStatus <- updateStats() 
    result <- DBIO.from(updateElasticCache()) 
    } yield result).transactionally 
db.run(rollbackActions) 

все рулонных спины, если updateElasticCache будущее терпит неудачу