jczuchnowski

val db = Database.forConfig("h2mem1")

val queryAction: DBIO[Option[Int]] = ...

val result: Future[Option[Int]] = db.run(queryAction)

jczuchnowski

import zio.IO

trait AssetRepository {
  def add(name: String, price: BigDecimal): IO[RepositoryFailure, AssetId]
    
  def getById(id: AssetId): IO[RepositoryFailure, Option[Asset]]

  def update(id: AssetId, name: String, price: BigDecimal): IO[RepositoryFailure, Unit]
}

jczuchnowski

trait DatabaseProvider {
  def databaseProvider: DatabaseProvider.Service
}

object DatabaseProvider {
  trait Service {
    def db: UIO[BasicBackend#DatabaseDef]
  }
}

jczuchnowski

trait LiveDatabaseProvider extends DatabaseProvider {
  override val databaseProvider = new DatabaseProvider.Service {
    override val db = ZIO.effectTotal(Database.forURL(url = "jdbc:h2:prod"))
  }
}

jczuchnowski

trait PortfolioAssetRepository {
  def portfolioAssetRepository: PortfolioAssetRepository.Service
}

object PortfolioAssetRepository {
  trait Service {
  
    def add(name: String, price: BigDecimal): IO[RepositoryException, AssetId]
    
    def getById(id: AssetId): IO[RepositoryException, Option[Asset]]

jczuchnowski

db <- ZIO.accessM[DatabaseProvider](_.databaseProvider.db)

jczuchnowski

db.run(action)

jczuchnowski

result <- ZIO.fromFuture(ec => db.run(dbio))

jczuchnowski

def fromDBIO[R](dbio: DBIO[R]): ZIO[DatabaseProvider, Throwable, R] =
  for {
    db <- ZIO.accessM[DatabaseProvider](_.databaseProvider.db)
    r  <- ZIO.fromFuture(ec => db.run(dbio))
  } yield r

jczuchnowski

def fromStreamingDBIO[T](dbio: StreamingDBIO[_, T]): ZIO[DatabaseProvider, Throwable, ZStream[Any, Throwable, T]] =
  for {
    db <- ZIO.accessM[DatabaseProvider](_.databaseProvider.db)
    r  <- ZIO.effect(db.stream(dbio).toStream())
  } yield r