Upgrade to R2DBC 0.9.

Remove MySQL support as the MySQL driver is not yet published. Update groupId for Postgres driver to org.postgresql.

See #710

Author: mp911de

pom.xml

@@ -30,7 +30,7 @@
 		<degraph-check.version>0.1.4</degraph-check.version>
 		<postgresql.version>42.2.5</postgresql.version>
 		<mysql.version>8.0.21</mysql.version>
-		<r2dbc-spi-test.version>0.8.5.RELEASE</r2dbc-spi-test.version>
+		<r2dbc-spi-test.version>0.9.1.RELEASE</r2dbc-spi-test.version>
 		<mssql-jdbc.version>7.1.2.jre8-preview</mssql-jdbc.version>
 		<mariadb-jdbc.version>2.5.4</mariadb-jdbc.version>
 		<r2dbc-releasetrain.version>Borca-RELEASE</r2dbc-releasetrain.version>
@@ -224,7 +224,7 @@
 		<!-- R2DBC Drivers -->
 
 		<dependency>
-			<groupId>io.r2dbc</groupId>
+			<groupId>org.postgresql</groupId>
 			<artifactId>r2dbc-postgresql</artifactId>
 			<optional>true</optional>
 		</dependency>
@@ -241,12 +241,6 @@
 			<scope>test</scope>
 		</dependency>
 
-		<dependency>
-			<groupId>dev.miku</groupId>
-			<artifactId>r2dbc-mysql</artifactId>
-			<scope>test</scope>
-		</dependency>
-
 		<dependency>
 			<groupId>org.mariadb</groupId>
 			<artifactId>r2dbc-mariadb</artifactId>

src/test/java/org/springframework/data/r2dbc/core/ReactiveDataAccessStrategyTestSupport.java

@@ -18,6 +18,8 @@
 import static org.assertj.core.api.Assertions.*;
 import static org.mockito.Mockito.*;
 
+import io.r2dbc.spi.Parameters;
+import io.r2dbc.spi.R2dbcType;
 import io.r2dbc.spi.Row;
 import io.r2dbc.spi.RowMetadata;
 import io.r2dbc.spi.test.MockColumnMetadata;
@@ -198,7 +200,7 @@ private <T> void testType(BiConsumer<PrimitiveTypes, T> setter, Function<Primiti
 		ReactiveDataAccessStrategy strategy = getStrategy();
 		Row rowMock = mock(Row.class);
 		RowMetadata metadataMock = MockRowMetadata.builder()
-				.columnMetadata(MockColumnMetadata.builder().name(fieldname).build()).build();
+				.columnMetadata(MockColumnMetadata.builder().name(fieldname).type(Parameters.in(testValue.getClass()).getType()).build()).build();
 
 		PrimitiveTypes toSave = new PrimitiveTypes();
 		setter.accept(toSave, testValue);

src/test/java/org/springframework/data/r2dbc/dialect/DialectResolverUnitTests.java

@@ -2,8 +2,6 @@
 
 import static org.assertj.core.api.Assertions.*;
 
-import dev.miku.r2dbc.mysql.MySqlConnectionConfiguration;
-import dev.miku.r2dbc.mysql.MySqlConnectionFactory;
 import io.r2dbc.h2.H2ConnectionConfiguration;
 import io.r2dbc.h2.H2ConnectionFactory;
 import io.r2dbc.mssql.MssqlConnectionConfiguration;
@@ -41,13 +39,10 @@ void shouldResolveDatabaseType() {
 		MssqlConnectionFactory mssql = new MssqlConnectionFactory(MssqlConnectionConfiguration.builder().host("localhost")
 				.database("foo").username("bar").password("password").build());
 		H2ConnectionFactory h2 = new H2ConnectionFactory(H2ConnectionConfiguration.builder().inMemory("mem").build());
-		MySqlConnectionFactory mysql = MySqlConnectionFactory
-				.from(MySqlConnectionConfiguration.builder().host("localhost").username("mysql").build());
 
 		assertThat(DialectResolver.getDialect(postgres)).isEqualTo(PostgresDialect.INSTANCE);
 		assertThat(DialectResolver.getDialect(mssql)).isEqualTo(SqlServerDialect.INSTANCE);
 		assertThat(DialectResolver.getDialect(h2)).isEqualTo(H2Dialect.INSTANCE);
-		assertThat(DialectResolver.getDialect(mysql)).isEqualTo(MySqlDialect.INSTANCE);
 	}
 
 	@Test // gh-20, gh-104

src/test/java/org/springframework/data/r2dbc/repository/AbstractR2dbcRepositoryIntegrationTests.java

@@ -24,6 +24,7 @@
 import lombok.Setter;
 import lombok.Value;
 import reactor.core.publisher.Flux;
+import reactor.core.publisher.Hooks;
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
@@ -60,6 +61,10 @@
  */
 public abstract class AbstractR2dbcRepositoryIntegrationTests extends R2dbcIntegrationTestSupport {
 
+	static {
+		Hooks.onOperatorDebug();
+	}
+
 	@Autowired private LegoSetRepository repository;
 	@Autowired private ConnectionFactory connectionFactory;
 	protected JdbcTemplate jdbc;