Skip to content

Commit 2b85c83

Browse files
committed
to fix sql query specifications
1 parent 9533843 commit 2b85c83

File tree

3 files changed

+21
-21
lines changed

3 files changed

+21
-21
lines changed

bridge/src/test/scala/app/softnetwork/elastic/sql/SQLQuerySpec.scala

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1205,11 +1205,6 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
12051205
| }
12061206
| },
12071207
| "aggs": {
1208-
| "ct": {
1209-
| "value_count": {
1210-
| "field": "identifier2"
1211-
| }
1212-
| },
12131208
| "lastSeen": {
12141209
| "max": {
12151210
| "field": "createdAt",
@@ -1218,6 +1213,11 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
12181213
| "source": "def param1 = (doc['createdAt'].size() == 0 ? null : doc['createdAt'].value); (param1 == null) ? null : LocalDate.parse(param1, DateTimeFormatter.ofPattern(\"yyyy-MM-dd\"))"
12191214
| }
12201215
| }
1216+
| },
1217+
| "ct": {
1218+
| "value_count": {
1219+
| "field": "identifier2"
1220+
| }
12211221
| }
12221222
| }
12231223
| }
@@ -1373,11 +1373,6 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
13731373
| }
13741374
| },
13751375
| "aggs": {
1376-
| "ct": {
1377-
| "value_count": {
1378-
| "field": "identifier2"
1379-
| }
1380-
| },
13811376
| "lastSeen": {
13821377
| "max": {
13831378
| "field": "createdAt",
@@ -1386,6 +1381,11 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
13861381
| "source": "def param1 = (doc['createdAt'].size() == 0 ? null : doc['createdAt'].value); (param1 == null) ? null : ZonedDateTime.parse(param1, DateTimeFormatter.ofPattern(\"yyyy-MM-dd HH:mm:ss.SSS XXX\")).truncatedTo(ChronoUnit.MINUTES).get(ChronoField.YEAR)"
13871382
| }
13881383
| }
1384+
| },
1385+
| "ct": {
1386+
| "value_count": {
1387+
| "field": "identifier2"
1388+
| }
13891389
| }
13901390
| }
13911391
| }

es6/bridge/src/test/scala/app/softnetwork/elastic/sql/SQLQuerySpec.scala

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1205,11 +1205,6 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
12051205
| }
12061206
| },
12071207
| "aggs": {
1208-
| "ct": {
1209-
| "value_count": {
1210-
| "field": "identifier2"
1211-
| }
1212-
| },
12131208
| "lastSeen": {
12141209
| "max": {
12151210
| "field": "createdAt",
@@ -1218,6 +1213,11 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
12181213
| "source": "def param1 = (doc['createdAt'].size() == 0 ? null : doc['createdAt'].value); (param1 == null) ? null : LocalDate.parse(param1, DateTimeFormatter.ofPattern(\"yyyy-MM-dd\"))"
12191214
| }
12201215
| }
1216+
| },
1217+
| "ct": {
1218+
| "value_count": {
1219+
| "field": "identifier2"
1220+
| }
12211221
| }
12221222
| }
12231223
| }
@@ -1373,11 +1373,6 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
13731373
| }
13741374
| },
13751375
| "aggs": {
1376-
| "ct": {
1377-
| "value_count": {
1378-
| "field": "identifier2"
1379-
| }
1380-
| },
13811376
| "lastSeen": {
13821377
| "max": {
13831378
| "field": "createdAt",
@@ -1386,6 +1381,11 @@ class SQLQuerySpec extends AnyFlatSpec with Matchers {
13861381
| "source": "def param1 = (doc['createdAt'].size() == 0 ? null : doc['createdAt'].value); (param1 == null) ? null : ZonedDateTime.parse(param1, DateTimeFormatter.ofPattern(\"yyyy-MM-dd HH:mm:ss.SSS XXX\")).truncatedTo(ChronoUnit.MINUTES).get(ChronoField.YEAR)"
13871382
| }
13881383
| }
1384+
| },
1385+
| "ct": {
1386+
| "value_count": {
1387+
| "field": "identifier2"
1388+
| }
13891389
| }
13901390
| }
13911391
| }

sql/src/main/scala/app/softnetwork/elastic/sql/function/aggregate/package.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -216,7 +216,7 @@ package object aggregate {
216216
override def window: Window = ARRAY_AGG
217217
override def withPartitionBy(partitionBy: Seq[Identifier]): WindowFunction =
218218
this.copy(partitionBy = partitionBy)
219-
override def withFields(fields: Seq[Field]): WindowFunction = this.copy(fields = fields)
219+
override def withFields(fields: Seq[Field]): WindowFunction = this
220220
override def update(request: SQLSearchRequest): WindowFunction = super
221221
.update(request)
222222
.asInstanceOf[ArrayAgg]

0 commit comments

Comments
 (0)