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

[jOOQ/jOOQ#13827] NullPointerException when calling DBMS_AQ.dequeue

Browse Source
This commit is contained in:
Lukas Eder 2022-07-28 12:48:50 +02:00
parent 5711379dd9
commit 5cc3230694
1 changed files with 31 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
jOOQ/src/main/java/org/jooq/impl/DefaultDSLContext.java
View File

@ -662,6 +662,14 @@ public class DefaultDSLContext extends AbstractScope implements DSLContext, Seri
@Override
public <T> T connectionResult(ConnectionCallable<T> callable) {
// [#13827] [#13830] The OracleDSL.DBMS_AQ API requires a fix for
// #13830. However, #13830 risks introducing new
// regressions, which is why the fix has been applied
// only to work around #13827, so far.
if (data("org.jooq.workaround.issue13827") != null)
return connectionResult0(callable);
final Connection connection = configuration().connectionProvider().acquire();
if (connection == null)
@ -681,6 +689,29 @@ public class DefaultDSLContext extends AbstractScope implements DSLContext, Seri
}
}
private final <T> T connectionResult0(ConnectionCallable<T> callable) {
DefaultExecuteContext ctx = new DefaultExecuteContext(configuration());
Connection connection = ctx.connection();
if (connection == null)
throw new DetachedException("No JDBC Connection provided by ConnectionProvider");
return DefaultExecuteContext.localExecuteContext(ctx, () -> {
try {
return callable.run(connection);
}
catch (Error | RuntimeException e) {
throw e;
}
catch (Throwable t) {
throw new DataAccessException("Error while running ConnectionCallable", t);
}
finally {
Tools.safeClose(new DefaultExecuteListener(), ctx);
}
});
}
@Override
public void connection(ConnectionRunnable runnable) {
connectionResult(connection -> {