0

我想使用 Kotlin Exposed 创建类似于 Ruby 的 ActiveRecord Scopes 的东西。

例如，我想分解以下查询，以便第一部分起到作用域的作用。

这个查询返回我想要的。

val m1 = Measurement.wrapRows(Measurements.innerJoin(Runs).select {
        ((exists(Tags.select { Tags.run.eq(Runs.sequelId) and Tags.name.eq("region") and Tags.value.eq("default") })) or notExists(Tags.select {
            Tags.run.eq(Runs.sequelId) and Tags.name.eq("region")
        })) and Measurements.name.eq("someName")

我想将此部分用作范围：

val q1 = Measurements.innerJoin(Runs).select {
    ((exists(Tags.select { Tags.run.eq(Runs.sequelId) and Tags.name.eq("region") and Tags.value.eq("default") })) or notExists(Tags.select {
        Tags.run.eq(Runs.sequelId) and Tags.name.eq("region")
    }))
}

然后能够使用 q1“范围”细化查询

所以是这样的：

val q2 = q1.having { Measurements.name.eq("someName")  } // which does not work

最终我想把它推到测量对象或测量类中，这样我就可以做这样的事情

Measurement.withDefaultRegion.where( Measurements.name.eq("someName")
4

1 回答 1

1

通过向模型的伴生对象添加几个函数，我能够得到我想要的东西。

第一个提供“范围”

fun defaultRegion() :Op<Boolean> {
    return Op.build {(exists(Tags.select { Tags.run.eq(Runs.sequelId) and Tags.name.eq("region") and Tags.value.eq("default") })) or notExists(Tags.select {
        Tags.run.eq(Runs.sequelId) and Tags.name.eq("region")
    })}
}

第二个函数使用传入的范围和任何细化进行查询，并返回对象的“集合”。

fun withDefaultRegionAnd( refinedBy: (SqlExpressionBuilder.()->Op<Boolean>)) : SizedIterable<Measurement> {
    return Measurement.wrapRows(Measurements.innerJoin(Runs).select(Measurement.defaultRegion() and SqlExpressionBuilder.refinedBy() ))
}

在客户端级别，我可以简单地这样做：

val measurements = Measurement.withDefaultRegionAnd { Measurements.name.eq("someName") }

以下是近似表对象和实体类：

object Measurements : IntIdTable("measurements") {

    val sequelId = integer("id").primaryKey()
    val run = reference("run_id", Runs)
    // more properties
}

class Measurement(id: EntityID<Int>) : IntEntity(id) {
    companion object : IntEntityClass<Measurement>(Measurements) {
        fun defaultRegion() :Op<Boolean> {
            return Op.build {(exists(Tags.select { Tags.run.eq(Runs.sequelId) and Tags.name.eq("region") and Tags.value.eq("default") })) or notExists(Tags.select {
                Tags.run.eq(Runs.sequelId) and Tags.name.eq("region")
            })}
        }
        fun withDefaultRegionAnd( refinedBy: (SqlExpressionBuilder.()->Op<Boolean>)) : SizedIterable<Measurement> {
            return Measurement.wrapRows(Measurements.innerJoin(Runs).select(Measurement.defaultRegion() and SqlExpressionBuilder.refinedBy() ))
        }
    }

    var run by Run referencedOn Measurements.run
    var name by Measurements.name
    // more properties
}
于 2018-08-10T13:49:50.550 回答