我们如何在 Kotlin Exposed 中编写查询？

Question

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

例如，我想分解以下查询，以便第一部分充当范围。

这个查询returns我想要的

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 "scope"

优化查询

所以像这样：

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

最终我想将其下推到 Measurements 对象或 Measurement class 这样我就可以做这样的事情

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

Answer 1

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

第一个提供了"scope"

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")
    })}
}

第二个函数使用传入的范围和任何优化以及 returns "collection" 个对象进行查询。

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") }

这里是接近table的对象和实体类：

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
}

我们如何在 Kotlin Exposed 中编写查询？

How do we compose queries in Kotlin Exposed?

kotlin

kotlin-exposed