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

[jOOQ/jOOQ#11769] NPE when ParsingConnection is not attached to an actual connection

Browse Source
This commit is contained in:
Lukas Eder 2021-04-08 18:08:37 +02:00
parent 6bdfdf22f9
commit a2f1c99716
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
jOOQ/src/main/java/org/jooq/impl/ParsingConnection.java
View File

@ -54,7 +54,9 @@ import java.util.Map;
import org.jooq.Configuration;
import org.jooq.DSLContext;
import org.jooq.Param;
import org.jooq.SQLDialect;
import org.jooq.exception.DataAccessException;
import org.jooq.exception.DetachedException;
import org.jooq.impl.DefaultRenderContext.Rendered;
import org.jooq.impl.Tools.Cache;
import org.jooq.tools.JooqLogger;
@ -72,6 +74,9 @@ final class ParsingConnection extends DefaultConnection {
ParsingConnection(Configuration configuration) {
super(configuration.connectionProvider().acquire());
if (getDelegate() == null)
throw new DetachedException("ConnectionProvider did not provide a JDBC Connection");
this.configuration = configuration;
}

4
jOOQ/src/main/java/org/jooq/impl/ParsingConnectionFactory.java
View File

@ -48,6 +48,7 @@ import java.util.List;
import org.jooq.Configuration;
import org.jooq.Param;
import org.jooq.exception.DetachedException;
import org.jooq.impl.DefaultRenderContext.Rendered;
import org.reactivestreams.Publisher;
@ -72,6 +73,9 @@ final class ParsingConnectionFactory implements ConnectionFactory {
final Configuration configuration;
ParsingConnectionFactory(Configuration configuration) {
if (configuration.connectionFactory() instanceof NoConnectionFactory)
throw new DetachedException("ConnectionProvider did not provide an R2DBC ConnectionFactory");
this.configuration = configuration.derive();
this.configuration.set(setParamType(configuration.dialect(), configuration.settings()));
}