From 80c2480b86ad9ccd183a82ba5697b596089539ae Mon Sep 17 00:00:00 2001 From: Lukas Eder Date: Mon, 2 Jan 2012 17:36:55 +0000 Subject: [PATCH] Added some integration tests --- .../src/org/jooq/test/jOOQAbstractTest.java | 29 +++++++++++++++++++ 1 file changed, 29 insertions(+) diff --git a/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java b/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java index a50b94ff7d..4a48713276 100644 --- a/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java +++ b/jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java @@ -114,6 +114,7 @@ import org.jooq.DataType; import org.jooq.DatePart; import org.jooq.EnumType; import org.jooq.Field; +import org.jooq.FutureResult; import org.jooq.Insert; import org.jooq.InsertQuery; import org.jooq.InsertSetMoreStep; @@ -1768,12 +1769,40 @@ public abstract class jOOQAbstractTest< assertEquals(1, fetch8.size()); assertEquals(10, fetch8.get(0).p); + final Integer[] count = new Integer[] { 0 }; q.fetchInto(new RecordHandler() { @Override public void next(Record record) { assertEquals(1, record.getFields().size()); + assertEquals(10, record.getValue(0)); + count[0] += 1; } }); + + assertEquals(1, (int) count[0]); + + FutureResult fetch9 = q.fetchLater(); + Thread.sleep(50); + assertTrue(fetch9.isDone()); + assertEquals(1, fetch9.get().size()); + assertEquals(10, fetch9.get().getValue(0, 0)); + + Cursor fetch10 = q.fetchLazy(); + assertFalse(fetch10.isClosed()); + assertTrue(fetch10.hasNext()); + assertEquals(1, fetch10.getFields().size()); + assertEquals("p", fetch10.getField(0).getName()); + assertEquals(10, fetch10.fetchOne().getValue(0)); + assertFalse(fetch10.isClosed()); + assertFalse(fetch10.hasNext()); + assertTrue(fetch10.isClosed()); + + List> fetch11 = q.fetchMany(); + assertEquals(1, fetch11.size()); + assertEquals(1, fetch11.get(0).size()); + assertEquals(fetch1, fetch11.get(0)); + + assertEquals(fetch1.get(0), q.fetchOne()); } public static class TestPlainSQLResultQuery {