代码之家  ›  专栏  ›  技术社区  ›  RomanGoltsov

Scala、Cassandra、Quill、Need impl logget批处理模式

  •  0
  • RomanGoltsov  · 技术社区  · 2 年前

    我有一个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语法编写这个,你能帮忙吗?

    0 回复  |  直到 2 年前