diff --git a/jOOQ-test/src/org/jooq/test/_/testcases/AbstractLoaderTests.java b/jOOQ-test/src/org/jooq/test/_/testcases/AbstractLoaderTests.java index 4252d66b6d..5981fb9916 100644 --- a/jOOQ-test/src/org/jooq/test/_/testcases/AbstractLoaderTests.java +++ b/jOOQ-test/src/org/jooq/test/_/testcases/AbstractLoaderTests.java @@ -43,6 +43,7 @@ package org.jooq.test._.testcases; import static junit.framework.Assert.assertEquals; import static junit.framework.Assert.assertNotNull; import static junit.framework.Assert.assertNull; +// ... import static org.jooq.impl.DSL.count; import java.sql.Date; @@ -102,7 +103,7 @@ extends BaseTest loader = createLoader1(); + Loader loader = createForEmptyFile(); assertEquals(0, loader.processed()); assertEquals(0, loader.errors().size()); @@ -113,8 +114,7 @@ extends BaseTest createLoader9() throws java.io.IOException; + protected abstract Loader createLoaderWithRollbackOnDuplicateKeys() throws java.io.IOException; - protected abstract Loader createLoader8() throws java.io.IOException; + protected abstract Loader createLoaderUpdatingDuplicateRecords() throws java.io.IOException; - protected abstract Loader createLoader7() throws java.io.IOException; + protected abstract Loader createLoaderButDontLoadAllColumns() throws java.io.IOException; - protected abstract Loader createLoader6() throws java.io.IOException; + protected abstract Loader createLoaderWithDifferentNulls() throws java.io.IOException; - protected abstract Loader createLoader5() throws java.io.IOException; + protected abstract Loader createLoaderIgnoringDuplicateRecords() throws java.io.IOException; - protected abstract Loader createLoader4() throws java.io.IOException; + protected abstract Loader createLoaderAbortingOnDuplicateRecords() throws java.io.IOException; - protected abstract Loader createLoader3() throws java.io.IOException; + protected abstract Loader createLoaderIgnoringConstraintViolationOnLAST_NAME() throws java.io.IOException; - protected abstract Loader createLoader10() throws java.io.IOException; + protected abstract Loader createLoaderCommittingAndIgnoringDuplicates() throws java.io.IOException; - protected abstract Loader createLoader2() throws java.io.IOException; + protected abstract Loader createLoaderAbortingOnConstraintViolationOnLAST_NAME() throws java.io.IOException; - protected abstract Loader createLoader1() throws java.io.IOException; + protected abstract Loader createForEmptyFile() throws java.io.IOException; private void resetLoaderConnection() throws SQLException { jOOQAbstractTest.connection.rollback(); diff --git a/jOOQ-test/src/org/jooq/test/_/testcases/CsvLoaderTests.java b/jOOQ-test/src/org/jooq/test/_/testcases/CsvLoaderTests.java index b61b81a817..21a62a2e65 100644 --- a/jOOQ-test/src/org/jooq/test/_/testcases/CsvLoaderTests.java +++ b/jOOQ-test/src/org/jooq/test/_/testcases/CsvLoaderTests.java @@ -82,7 +82,7 @@ extends AbstractLoaderTests createLoader9() throws java.io.IOException { + protected Loader createLoaderWithRollbackOnDuplicateKeys() throws java.io.IOException { Loader loader; String csv = "\"ID\",\"First Qualifier\",\"Last Qualifier\"\r" + "8,Hermann,Hesse\n" + @@ -101,7 +101,7 @@ extends AbstractLoaderTests createLoader8() throws java.io.IOException { + protected Loader createLoaderUpdatingDuplicateRecords() throws java.io.IOException { Loader loader; String csv = "\"ID\",\"First Qualifier\",\"Last Qualifier\"\r" + "1,Hermann,Hesse\n" + @@ -117,7 +117,7 @@ extends AbstractLoaderTests createLoader7() throws java.io.IOException { + protected Loader createLoaderButDontLoadAllColumns() throws java.io.IOException { Loader loader; String csv = "\"ID\",ignore,\"First Qualifier\",\"Last Qualifier\"\r" + "5,asdf,{null},Hesse\n" + @@ -133,7 +133,7 @@ extends AbstractLoaderTests createLoader6() throws java.io.IOException { + protected Loader createLoaderWithDifferentNulls() throws java.io.IOException { String csv = "####Some Data####\n" + "\"ID\",\"Last Qualifier\"\r" + @@ -151,7 +151,7 @@ extends AbstractLoaderTests createLoader5() throws java.io.IOException { + protected Loader createLoaderIgnoringDuplicateRecords() throws java.io.IOException { Loader loader; String csv = "1,\"Kafka\"\n" + "2,Frisch"; @@ -169,7 +169,7 @@ extends AbstractLoaderTests createLoader4() throws java.io.IOException { + protected Loader createLoaderAbortingOnDuplicateRecords() throws java.io.IOException { String csv = "1;'Kafka'\n" + "2;Frisch"; @@ -188,7 +188,7 @@ extends AbstractLoaderTests createLoader3() throws java.io.IOException { + protected Loader createLoaderIgnoringConstraintViolationOnLAST_NAME() throws java.io.IOException { Loader loader; String csv = "3\n" + "4"; @@ -204,7 +204,7 @@ extends AbstractLoaderTests createLoader10() throws java.io.IOException { + protected Loader createLoaderCommittingAndIgnoringDuplicates() throws java.io.IOException { Loader loader; String csv = "\"ID\",\"First Qualifier\",\"Last Qualifier\"\r" + @@ -224,7 +224,7 @@ extends AbstractLoaderTests createLoader2() throws java.io.IOException { + protected Loader createLoaderAbortingOnConstraintViolationOnLAST_NAME() throws java.io.IOException { String csv = "3\n" + "4"; Loader execute = create().loadInto(TAuthor()) @@ -239,7 +239,7 @@ extends AbstractLoaderTests createLoader1() throws java.io.IOException { + protected Loader createForEmptyFile() throws java.io.IOException { return create().loadInto(TAuthor()) .loadCSV("") .fields(TAuthor_ID()) diff --git a/jOOQ-test/src/org/jooq/test/_/testcases/JsonLoaderTests.java b/jOOQ-test/src/org/jooq/test/_/testcases/JsonLoaderTests.java index b79370813c..e1909358bb 100644 --- a/jOOQ-test/src/org/jooq/test/_/testcases/JsonLoaderTests.java +++ b/jOOQ-test/src/org/jooq/test/_/testcases/JsonLoaderTests.java @@ -80,7 +80,7 @@ extends AbstractLoaderTests createLoader9() throws java.io.IOException { + protected Loader createLoaderWithRollbackOnDuplicateKeys() throws java.io.IOException { String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"},{\"name\":\"FIRST_NAME\",\"type\":\"VARCHAR\"},{\"name\":\"LAST_NAME\",\"type\":\"VARCHAR\"}]," + "\"records\":[[8,\"Hermann\",\"Hesse\"],[1,\"Max\",\"Frisch\"],[2,\"Friedrich\",\"Dürrenmatt\"]]}"; Loader loader; @@ -101,7 +101,7 @@ extends AbstractLoaderTests createLoader8() throws java.io.IOException { + protected Loader createLoaderUpdatingDuplicateRecords() throws java.io.IOException { String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"},{\"name\":\"FIRST_NAME\",\"type\":\"VARCHAR\"},{\"name\":\"LAST_NAME\",\"type\":\"VARCHAR\"}]," + "\"records\":[[1,Hermann,\"Hesse\"],[7,\"Max\",\"Frisch\"]]}"; Loader loader; @@ -119,7 +119,7 @@ extends AbstractLoaderTests createLoader7() throws java.io.IOException { + protected Loader createLoaderButDontLoadAllColumns() throws java.io.IOException { String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"},{\"name\":\"ignore\",\"type\":\"String\"},{\"name\":\"FIRST_NAME\",\"type\":\"VARCHAR\"},{\"name\":\"LAST_NAME\",\"type\":\"VARCHAR\"}]," + "\"records\":[[5,\"asdf\",null,\"Hesse\"],[6,\"asdf\",\"\",\"Frisch\"]]}"; Loader loader; @@ -136,7 +136,7 @@ extends AbstractLoaderTests createLoader6() throws java.io.IOException { + protected Loader createLoaderWithDifferentNulls() throws java.io.IOException { String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"},{\"name\":\"FIRST_NAME\",\"type\":\"VARCHAR\"},{\"name\":\"LAST_NAME\",\"type\":\"VARCHAR\"}]," + "\"records\":[[3,\"\",\"Hesse\"],[4,\"\",\"Frisch\"]]}"; @@ -156,7 +156,7 @@ extends AbstractLoaderTests createLoader5() throws java.io.IOException { + protected Loader createLoaderIgnoringDuplicateRecords() throws java.io.IOException { Loader loader; String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"},{\"name\":\"LAST_NAME\",\"type\":\"VARCHAR\"}]," + "\"records\":[[1,\"Kafka\"],[2,\"Frisch\"]]}"; @@ -176,7 +176,7 @@ extends AbstractLoaderTests createLoader4() throws java.io.IOException { + protected Loader createLoaderAbortingOnDuplicateRecords() throws java.io.IOException { String csv = "1;'Kafka'\n" + "2;Frisch"; String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"},{\"name\":\"LAST_NAME\",\"type\":\"VARCHAR\"}]," + @@ -197,7 +197,7 @@ extends AbstractLoaderTests createLoader3() throws java.io.IOException { + protected Loader createLoaderIgnoringConstraintViolationOnLAST_NAME() throws java.io.IOException { Loader loader; String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"}],\"records\":[[3],[4]]}"; String csv = "3\n" + @@ -214,7 +214,7 @@ extends AbstractLoaderTests createLoader10() throws java.io.IOException { + protected Loader createLoaderCommittingAndIgnoringDuplicates() throws java.io.IOException { Loader loader; String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"},{\"name\":\"FIRST_NAME\",\"type\":\"VARCHAR\"},{\"name\":\"LAST_NAME\",\"type\":\"VARCHAR\"}]," + "\"records\":[[8,\"Hermann\",\"Hesse\"],[1,\"Max\",\"Frisch\"],[2,\"Friedrich\",\"Dürrenmatt\"]]}"; @@ -236,7 +236,7 @@ extends AbstractLoaderTests createLoader2() throws java.io.IOException { + protected Loader createLoaderAbortingOnConstraintViolationOnLAST_NAME() throws java.io.IOException { String json = "{\"fields\":[{\"name\":\"ID\",\"type\":\"INTEGER\"}],\"records\":[[3],[4]]}"; String csv = "3\n" + "4"; @@ -252,7 +252,7 @@ extends AbstractLoaderTests createLoader1() throws java.io.IOException { + protected Loader createForEmptyFile() throws java.io.IOException { return create().loadInto(TAuthor()) .loadCSV("") .fields(TAuthor_ID())