diff --git a/extensions/jdbc/jdbc-mysql/deployment/src/main/java/io/quarkus/jdbc/mysql/deployment/MySQLJDBCProxies.java b/extensions/jdbc/jdbc-mysql/deployment/src/main/java/io/quarkus/jdbc/mysql/deployment/MySQLJDBCProxies.java new file mode 100644 index 00000000000000..1e64c907070b37 --- /dev/null +++ b/extensions/jdbc/jdbc-mysql/deployment/src/main/java/io/quarkus/jdbc/mysql/deployment/MySQLJDBCProxies.java @@ -0,0 +1,52 @@ +package io.quarkus.jdbc.mysql.deployment; + +import java.io.Serializable; +import java.sql.Connection; +import java.sql.Statement; +import java.util.ArrayList; +import java.util.List; + +import com.mysql.cj.MysqlConnection; +import com.mysql.cj.WarningListener; +import com.mysql.cj.conf.PropertySet; +import com.mysql.cj.jdbc.JdbcConnection; +import com.mysql.cj.jdbc.JdbcPreparedStatement; +import com.mysql.cj.jdbc.JdbcPropertySet; +import com.mysql.cj.jdbc.JdbcStatement; +import com.mysql.cj.jdbc.ha.LoadBalancedConnection; +import com.mysql.cj.jdbc.ha.ReplicationConnection; +import com.mysql.cj.jdbc.result.ResultSetInternalMethods; +import com.mysql.cj.protocol.Resultset; + +import io.quarkus.deployment.annotations.BuildStep; +import io.quarkus.deployment.builditem.nativeimage.NativeImageProxyDefinitionBuildItem; + +public final class MySQLJDBCProxies { + + @BuildStep + List registerProxies() { + List proxies = new ArrayList<>(); + proxies.add(new NativeImageProxyDefinitionBuildItem(JdbcConnection.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(MysqlConnection.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(Statement.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(AutoCloseable.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(JdbcStatement.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(Connection.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(java.sql.ResultSet.class.getName())); + + proxies.add( + new NativeImageProxyDefinitionBuildItem(JdbcPreparedStatement.class.getName(), JdbcStatement.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(JdbcPropertySet.class.getName(), PropertySet.class.getName(), + Serializable.class.getName())); + proxies.add( + new NativeImageProxyDefinitionBuildItem(Resultset.class.getName(), ResultSetInternalMethods.class.getName())); + proxies.add(new NativeImageProxyDefinitionBuildItem(LoadBalancedConnection.class.getName(), + JdbcConnection.class.getName())); + proxies.add( + new NativeImageProxyDefinitionBuildItem(ReplicationConnection.class.getName(), JdbcConnection.class.getName())); + proxies.add( + new NativeImageProxyDefinitionBuildItem(ResultSetInternalMethods.class.getName(), + WarningListener.class.getName(), Resultset.class.getName())); + return proxies; + } +} diff --git a/extensions/jdbc/jdbc-mysql/deployment/src/main/java/io/quarkus/jdbc/mysql/deployment/MySQLJDBCReflections.java b/extensions/jdbc/jdbc-mysql/deployment/src/main/java/io/quarkus/jdbc/mysql/deployment/MySQLJDBCReflections.java index a85da95ca63071..4dab5c595276c5 100644 --- a/extensions/jdbc/jdbc-mysql/deployment/src/main/java/io/quarkus/jdbc/mysql/deployment/MySQLJDBCReflections.java +++ b/extensions/jdbc/jdbc-mysql/deployment/src/main/java/io/quarkus/jdbc/mysql/deployment/MySQLJDBCReflections.java @@ -1,5 +1,16 @@ package io.quarkus.jdbc.mysql.deployment; +import java.sql.Wrapper; + +import com.mysql.cj.conf.url.FailoverConnectionUrl; +import com.mysql.cj.conf.url.FailoverDnsSrvConnectionUrl; +import com.mysql.cj.conf.url.LoadBalanceConnectionUrl; +import com.mysql.cj.conf.url.LoadBalanceDnsSrvConnectionUrl; +import com.mysql.cj.conf.url.ReplicationConnectionUrl; +import com.mysql.cj.conf.url.ReplicationDnsSrvConnectionUrl; +import com.mysql.cj.conf.url.SingleConnectionUrl; +import com.mysql.cj.conf.url.XDevApiConnectionUrl; +import com.mysql.cj.conf.url.XDevApiDnsSrvConnectionUrl; import com.mysql.cj.exceptions.AssertionFailedException; import com.mysql.cj.exceptions.CJCommunicationsException; import com.mysql.cj.exceptions.CJConnectionFeatureNotAvailableException; @@ -26,6 +37,10 @@ import com.mysql.cj.exceptions.UnableToConnectException; import com.mysql.cj.exceptions.UnsupportedConnectionStringException; import com.mysql.cj.exceptions.WrongArgumentException; +import com.mysql.cj.jdbc.Driver; +import com.mysql.cj.jdbc.ha.NdbLoadBalanceExceptionChecker; +import com.mysql.cj.jdbc.ha.StandardLoadBalanceExceptionChecker; +import com.mysql.cj.log.StandardLogger; import com.mysql.cj.protocol.AsyncSocketFactory; import com.mysql.cj.protocol.NamedPipeSocketFactory; import com.mysql.cj.protocol.SocksProxySocketFactory; @@ -39,28 +54,30 @@ public final class MySQLJDBCReflections { @BuildStep void registerDriverForReflection(BuildProducer reflectiveClass) { - reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, com.mysql.cj.jdbc.Driver.class.getName())); + + reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, Driver.class.getName())); reflectiveClass.produce( - new ReflectiveClassBuildItem(false, false, com.mysql.cj.conf.url.FailoverDnsSrvConnectionUrl.class.getName())); + new ReflectiveClassBuildItem(false, false, FailoverDnsSrvConnectionUrl.class.getName())); reflectiveClass.produce( - new ReflectiveClassBuildItem(false, false, com.mysql.cj.conf.url.FailoverConnectionUrl.class.getName())); + new ReflectiveClassBuildItem(false, false, FailoverConnectionUrl.class.getName())); reflectiveClass - .produce(new ReflectiveClassBuildItem(false, false, com.mysql.cj.conf.url.SingleConnectionUrl.class.getName())); + .produce(new ReflectiveClassBuildItem(false, false, SingleConnectionUrl.class.getName())); reflectiveClass.produce( - new ReflectiveClassBuildItem(false, false, com.mysql.cj.conf.url.LoadBalanceConnectionUrl.class.getName())); + new ReflectiveClassBuildItem(false, false, LoadBalanceConnectionUrl.class.getName())); reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, - com.mysql.cj.conf.url.LoadBalanceDnsSrvConnectionUrl.class.getName())); + LoadBalanceDnsSrvConnectionUrl.class.getName())); reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, - com.mysql.cj.conf.url.ReplicationDnsSrvConnectionUrl.class.getName())); + ReplicationDnsSrvConnectionUrl.class.getName())); reflectiveClass.produce( - new ReflectiveClassBuildItem(false, false, com.mysql.cj.conf.url.ReplicationConnectionUrl.class.getName())); + new ReflectiveClassBuildItem(false, false, ReplicationConnectionUrl.class.getName())); reflectiveClass.produce( - new ReflectiveClassBuildItem(false, false, com.mysql.cj.conf.url.XDevApiConnectionUrl.class.getName())); + new ReflectiveClassBuildItem(false, false, XDevApiConnectionUrl.class.getName())); reflectiveClass.produce( - new ReflectiveClassBuildItem(false, false, com.mysql.cj.conf.url.XDevApiDnsSrvConnectionUrl.class.getName())); + new ReflectiveClassBuildItem(false, false, XDevApiDnsSrvConnectionUrl.class.getName())); reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, com.mysql.cj.jdbc.ha.LoadBalancedAutoCommitInterceptor.class.getName())); - reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, com.mysql.cj.log.StandardLogger.class.getName())); + reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, StandardLogger.class.getName())); + reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, Wrapper.class.getName())); } @BuildStep @@ -103,5 +120,9 @@ void registerExceptionsForReflection(BuildProducer ref reflectiveClass .produce(new ReflectiveClassBuildItem(false, false, UnsupportedConnectionStringException.class.getName())); reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, WrongArgumentException.class.getName())); + reflectiveClass.produce(new ReflectiveClassBuildItem(true, true, "com.mysql.cj.jdbc.MysqlXAException")); + reflectiveClass + .produce(new ReflectiveClassBuildItem(false, false, StandardLoadBalanceExceptionChecker.class.getName())); + reflectiveClass.produce(new ReflectiveClassBuildItem(false, false, NdbLoadBalanceExceptionChecker.class.getName())); } }