diff --git a/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuery.kt b/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuery.kt index aa6c921886166..3d5dbba06bc7c 100644 --- a/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuery.kt +++ b/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuery.kt @@ -2,7 +2,7 @@ package io.airbyte.cdk.read import com.fasterxml.jackson.databind.JsonNode -import io.airbyte.cdk.discover.Field +import io.airbyte.cdk.discover.FieldOrMetaField import io.airbyte.cdk.jdbc.LosslessJdbcFieldType /** @@ -11,7 +11,7 @@ import io.airbyte.cdk.jdbc.LosslessJdbcFieldType */ data class SelectQuery( val sql: String, - val columns: List, + val columns: List, val bindings: List, ) { data class Binding( diff --git a/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuerySpec.kt b/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuerySpec.kt index 86498d4388e1d..dd61da0601260 100644 --- a/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuerySpec.kt +++ b/airbyte-cdk/bulk/toolkits/extract-jdbc/src/main/kotlin/io/airbyte/cdk/read/SelectQuerySpec.kt @@ -2,7 +2,7 @@ package io.airbyte.cdk.read import com.fasterxml.jackson.databind.JsonNode -import io.airbyte.cdk.discover.Field +import io.airbyte.cdk.discover.FieldOrMetaField import java.math.BigDecimal /** @@ -21,19 +21,19 @@ data class SelectQuerySpec( ) sealed interface SelectNode { - val columns: List + val columns: List } data class SelectColumns( - override val columns: List, + override val columns: List, ) : SelectNode { - constructor(vararg columns: Field) : this(columns.toList()) + constructor(vararg columns: FieldOrMetaField) : this(columns.toList()) } data class SelectColumnMaxValue( - val column: Field, + val column: FieldOrMetaField, ) : SelectNode { - override val columns: List + override val columns: List get() = listOf(column) } @@ -85,41 +85,41 @@ data class Or( } sealed interface WhereClauseLeafNode : WhereClauseNode { - val column: Field + val column: FieldOrMetaField val bindingValue: JsonNode } data class GreaterOrEqual( - override val column: Field, + override val column: FieldOrMetaField, override val bindingValue: JsonNode, ) : WhereClauseLeafNode data class Greater( - override val column: Field, + override val column: FieldOrMetaField, override val bindingValue: JsonNode, ) : WhereClauseLeafNode data class LesserOrEqual( - override val column: Field, + override val column: FieldOrMetaField, override val bindingValue: JsonNode, ) : WhereClauseLeafNode data class Lesser( - override val column: Field, + override val column: FieldOrMetaField, override val bindingValue: JsonNode, ) : WhereClauseLeafNode data class Equal( - override val column: Field, + override val column: FieldOrMetaField, override val bindingValue: JsonNode, ) : WhereClauseLeafNode sealed interface OrderByNode data class OrderBy( - val columns: List, + val columns: List, ) : OrderByNode { - constructor(vararg columns: Field) : this(columns.toList()) + constructor(vararg columns: FieldOrMetaField) : this(columns.toList()) } data object NoOrderBy : OrderByNode