github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[#811] Loader integration tests fail for SQLite

Browse Source 
[#812] CSV Loader test leaves Postgres JDBC connection in an inconsistent transactional state on error
This commit is contained in:
Lukas Eder 2011-10-16 16:22:52 +00:00
parent 8bb5c0d075
commit 1d7ad47734
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
jOOQ-test/src/org/jooq/test/jOOQAbstractTest.java
View File

@ -7480,6 +7480,9 @@ public abstract class jOOQAbstractTest<
.ignoreRows(0)
.execute();
// [#812] Reset stale connection. Seems to be necessary in Postgres
resetLoaderConnection();
assertEquals(1, loader.processed());
assertEquals(1, loader.errors().size());
assertNotNull(loader.errors().get(0));
@ -7500,6 +7503,9 @@ public abstract class jOOQAbstractTest<
.ignoreRows(0)
.execute();
// [#812] Reset stale connection. Seems to be necessary in Postgres
resetLoaderConnection();
assertEquals(2, loader.processed());
assertEquals(2, loader.errors().size());
assertNotNull(loader.errors().get(0));
@ -7524,6 +7530,9 @@ public abstract class jOOQAbstractTest<
.ignoreRows(0)
.execute();
// [#812] Reset stale connection. Seems to be necessary in Postgres
resetLoaderConnection();
assertEquals(1, loader.processed());
assertEquals(1, loader.errors().size());
assertNotNull(loader.errors().get(0));
@ -7657,6 +7666,9 @@ public abstract class jOOQAbstractTest<
}
}
// [#812] Reset stale connection. Seems to be necessary in Postgres
resetLoaderConnection();
// Rollback on duplicate keys
// --------------------------
loader =
@ -7720,7 +7732,14 @@ public abstract class jOOQAbstractTest<
assertNull(result.getValue(2, TAuthor_FIRST_NAME()));
assertEquals("Hesse", result.getValue(2, TAuthor_LAST_NAME()));
assertEquals("Coelho", result.getValue(1, TAuthor_LAST_NAME()));
assertEquals("Orwell", result.getValue(0, TAuthor_LAST_NAME()));
}
private void resetLoaderConnection() throws SQLException {
connection.rollback();
connection.close();
connection = null;
connection = getConnection();
connection.setAutoCommit(false);
}
/**