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

[#1082] Add some more DEBUG logging in AbstractResultQuery

Browse Source
This commit is contained in:
Lukas Eder 2012-01-28 13:13:14 +00:00
parent 21837feaff
commit a6423bbf16
1 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
jOOQ/src/main/java/org/jooq/impl/AbstractResultQuery.java
View File

@ -67,6 +67,7 @@ import org.jooq.exception.DataAccessException;
import org.jooq.exception.DataTypeException;
import org.jooq.exception.InvalidResultException;
import org.jooq.tools.Convert;
import org.jooq.tools.JooqLogger;
/**
* A query that returns a {@link Result}
@ -78,14 +79,15 @@ abstract class AbstractResultQuery<R extends Record> extends AbstractQuery imple
/**
* Generated UID
*/
private static final long serialVersionUID = -5588344253566055707L;
private static final long serialVersionUID = -5588344253566055707L;
private static final JooqLogger log = JooqLogger.getLogger(AbstractResultQuery.class);
private transient boolean lazy;
private transient int size;
private transient boolean many;
private transient Cursor<R> cursor;
private Result<R> result;
private List<Result<Record>> results;
private transient boolean lazy;
private transient int size;
private transient boolean many;
private transient Cursor<R> cursor;
private Result<R> result;
private List<Result<Record>> results;
AbstractResultQuery(Configuration configuration) {
super(configuration);
@ -113,6 +115,9 @@ abstract class AbstractResultQuery<R extends Record> extends AbstractQuery imple
PreparedStatement statement = super.prepare(configuration, sql);
if (size > 0) {
if (log.isDebugEnabled())
log.debug("Setting fetch size", size);
statement.setFetchSize(size);
}
@ -130,6 +135,9 @@ abstract class AbstractResultQuery<R extends Record> extends AbstractQuery imple
autoCommit = connection.getAutoCommit();
if (autoCommit) {
if (log.isDebugEnabled())
log.debug("Unsetting auto-commit", false);
connection.setAutoCommit(false);
}
}
@ -171,6 +179,9 @@ abstract class AbstractResultQuery<R extends Record> extends AbstractQuery imple
}
finally {
if (autoCommit) {
if (log.isDebugEnabled())
log.debug("Resetting auto-commit", autoCommit);
connection.setAutoCommit(autoCommit);
}
}