Skip to content

Commit

Permalink
CAY-2814 Select query iterator() and batchIterator() methods return i…
Browse files Browse the repository at this point in the history
…ncorrect results

 - fix tests
  • Loading branch information
stariy95 committed Nov 6, 2023
1 parent c0674e2 commit 84c6af4
Showing 1 changed file with 7 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,6 @@

import java.sql.SQLException;
import java.sql.Types;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;

import static org.junit.Assert.assertEquals;
Expand Down Expand Up @@ -120,7 +118,7 @@ public void scalarQueryWithIterator() {
@Test
public void dataRowQueryWithBatchIterator() {
try (ResultBatchIterator<?> iterator = SQLSelect
.dataRowQuery("SELECT * FROM PAINTING")
.dataRowQuery("SELECT * FROM PAINTING ORDER BY PAINTING_ID")
.batchIterator(context, 5)) {
int count = 0;
int paintingCounter = 0;
Expand All @@ -140,7 +138,7 @@ public void dataRowQueryWithBatchIterator() {
@Test
public void dataRowQueryWithIterator() {
try (ResultIterator<?> iterator = SQLSelect
.dataRowQuery("SELECT * FROM PAINTING")
.dataRowQuery("SELECT * FROM PAINTING ORDER BY PAINTING_ID")
.iterator(context)) {
int count = 0;
int paintingCounter = 0;
Expand All @@ -158,7 +156,7 @@ public void dataRowQueryWithIterator() {
@Test
public void QueryWithBatchIterator() {
try (ResultBatchIterator<Painting> iterator = SQLSelect
.query(Painting.class,"SELECT * FROM PAINTING")
.query(Painting.class,"SELECT * FROM PAINTING ORDER BY PAINTING_ID")
.batchIterator(context, 5)) {
int count = 0;
int paintingCounter = 0;
Expand All @@ -177,7 +175,7 @@ public void QueryWithBatchIterator() {
@Test
public void QueryWithIterator() {
try (ResultIterator<Painting> iterator = SQLSelect
.query(Painting.class, "SELECT * FROM PAINTING")
.query(Painting.class, "SELECT * FROM PAINTING ORDER BY PAINTING_ID")
.iterator(context)) {
int count = 0;
int paintingCounter = 0;
Expand All @@ -196,7 +194,7 @@ public void QueryWithIterator() {
@Test
public void MappingWithBatchIterator() {
try (ResultBatchIterator<DTO> iterator = SQLSelect
.columnQuery( "SELECT PAINTING_TITLE, ESTIMATED_PRICE FROM PAINTING")
.columnQuery( "SELECT PAINTING_TITLE, ESTIMATED_PRICE FROM PAINTING ORDER BY PAINTING_ID")
.map(this::toDto)
.batchIterator(context, 5)) {
int count = 0;
Expand All @@ -219,7 +217,7 @@ public void MappingWithBatchIterator() {
@Test
public void MappingWithIterator() {
try (ResultIterator<DTO> iterator = SQLSelect
.columnQuery("SELECT PAINTING_TITLE, ESTIMATED_PRICE FROM PAINTING")
.columnQuery("SELECT PAINTING_TITLE, ESTIMATED_PRICE FROM PAINTING ORDER BY PAINTING_ID")
.map(this::toDto)
.iterator(context)) {
int count = 0;
Expand All @@ -245,7 +243,7 @@ static class DTO {
private final Long estimatedPrice;

public DTO(Object[] data) {
this.title = "dto_" + (String) data[0];
this.title = "dto_" + data[0];
this.estimatedPrice = ((Number) data[1]).longValue();
}

Expand Down

0 comments on commit 84c6af4

Please sign in to comment.