tomix26
commented
4 years ago Hey, thanks for the question. This library is strongly based on JDBC, so note it needs to be present on the classpath, at least in the test scope. Otherwise, there should be no other problem and it should be enough to create an adapter between JDBC and R2DBC projects. Check the example below.
The only thing to keep in mind is that the injected data source is actually an AOP proxy and the target database may change over time. This happens when the database is refreshed via @FlywayTest annotation. So it is necessary to detect it and create a new connection factory if that happens.
public class EmbeddedPostgresConnectionFactory implements ConnectionFactory {
private final DataSource dataSource; // an AOP proxy with a changing target database
private volatile BaseDataSource config; // the last instance of the target database
private volatile PostgresqlConnectionFactory factory;
public EmbeddedPostgresConnectionFactory(DataSource dataSource) {
this.dataSource = dataSource;
}
private PostgresqlConnectionFactory connectionFactory() {
BaseDataSource freshConfig;
try {
freshConfig = dataSource.unwrap(BaseDataSource.class);
} catch (SQLException e) {
throw new RuntimeException(e);
}
if (factory == null || config != freshConfig) { // checks if the target database has changed or not
config = freshConfig;
factory = new PostgresqlConnectionFactory(PostgresqlConnectionConfiguration.builder()
.host(freshConfig.getServerName())
.port(freshConfig.getPortNumber())
.username(freshConfig.getUser())
.password(freshConfig.getPassword())
.database(freshConfig.getDatabaseName())
.build());
}
return factory;
}
@Override
public Publisher<io.r2dbc.postgresql.api.PostgresqlConnection> create() {
return connectionFactory().create();
}
@Override
public ConnectionFactoryMetadata getMetadata() {
return connectionFactory().getMetadata();
}
}@RunWith(SpringRunner.class)
@AutoConfigureEmbeddedDatabase(beanName = "dataSource")
public class EmptyDatabaseIntegrationTest {
@Configuration
static class Config {
@Bean
public ConnectionFactory connectionFactory(DataSource dataSource) {
return new EmbeddedPostgresConnectionFactory(dataSource);
}
}
@Autowired
private ConnectionFactory connectionFactory;
@Test
public void testMethod() {
// some testing code...
Mono.from(connectionFactory.create())
.flatMapMany(connection -> Flux.from(connection
.createBatch()
.add("select * from player")
.add("select * from player")
.execute()))
.as(StepVerifier::create)
.expectNextCount(2)
.verifyComplete();
}
}
bfrggit
SalyczeQ
neeru-bhaskar
d-wire
Hello is there way to use zonky with R2DBC? I tried many things, but nothing help at all. Maybe it is possible to set port? Because as I see hostname, password and username name are always same and problem is with port which changing all time, not allowing to set url in properties