我有一个cassandra DB,使用quill和dao方法,如下所示:
override def patchLimit(id: Id, month: String, newTotalSpent: Money): F[Unit] =
run(
quote(
querySchema[LimitsDbModel]("project.limits")
.filter(_.id == lift(id.id))
.filter(_.month == lift(month))
.update(_.totalSpent -> lift(fromDomain(newTotalSpent))) // fromDomain -> simple converter
)
).map(_ => ()).asEffect // asEffect -> turns the future into a cat effect
我想要impl-logget批处理模式,但我不知道如何用quill语法编写这个,你能帮忙吗?