Fixed integration test

Signed-off-by: S V <vats02581@gmail.com>

Author: svats0001

r2dbc-mysql/src/test/java/io/asyncer/r2dbc/mysql/RsaEncryptionIntegrationTest.java

@@ -27,6 +27,7 @@
 import io.asyncer.r2dbc.mysql.internal.util.TestContainerExtension;
 import io.asyncer.r2dbc.mysql.internal.util.TestServerUtil;
 import io.r2dbc.spi.R2dbcPermissionDeniedException;
+import io.r2dbc.spi.ValidationDepth;
 
 @ExtendWith(TestContainerExtension.class)
 public class RsaEncryptionIntegrationTest {
@@ -43,8 +44,8 @@ void sslDisabledTest() {
             .database(TestServerUtil.getDatabase())
             .sslMode(SslMode.DISABLED)
             .build();
-
-        assertThrows(R2dbcPermissionDeniedException.class, () -> MySqlConnectionFactory.from(configuration).create().block());
+            
+        assertThat(MySqlConnectionFactory.from(configuration).create().block().validate(ValidationDepth.REMOTE).block()).isFalse();
     }
 
     @Test
@@ -61,7 +62,7 @@ void sslDisabledInvalidRsaConfig() {
             .serverRSAPublicKeyFile("/path/to/mysql/serverRSAPublicKey.pem")
             .build();
 
-        assertThrows(IllegalArgumentException.class, () -> MySqlConnectionFactory.from(configuration2).create().block());
+        assertThat(MySqlConnectionFactory.from(configuration2).create().block().validate(ValidationDepth.REMOTE).block()).isFalse();
     }
 
     @Test
@@ -78,6 +79,6 @@ void sslDisabledValidRsaConfig() {
             .serverRSAPublicKeyFile("/usr/local/mysql/data/public_key.pem")
             .build();
 
-        assertThat(MySqlConnectionFactory.from(configuration3).create().block()).isExactlyInstanceOf(MySqlSimpleConnection.class);
+        assertThat(MySqlConnectionFactory.from(configuration3).create().block().validate(ValidationDepth.REMOTE).block()).isTrue();
     }
 }