-
Notifications
You must be signed in to change notification settings - Fork 44
Description
oracle-r2dbc version: 0.2.0
spring-boot: 2.5.2
Database: Oracle 19c
r2dbc:oracle:thin:@LDAP://server:port/database,cn=OracleContext,dc=WORLD
Error:
reactor.core.Exceptions$ErrorCallbackNotImplemented: io.r2dbc.spi.R2dbcTransientResourceException: [17002] [08006] Error de E/S: Invalid connection string format, a valid format is: "host:port:sid" (CONNECTION_ID=qyq8AuNhQreSmex/HBjgiA==)
Caused by: io.r2dbc.spi.R2dbcTransientResourceException: Error de E/S: Invalid connection string format, a valid format is: "host:port:sid" (CONNECTION_ID=qyq8AuNhQreSmex/HBjgiA==)
at oracle.r2dbc.impl.OracleR2dbcExceptions.toR2dbcException(OracleR2dbcExceptions.java:211)
at oracle.r2dbc.impl.OracleReactiveJdbcAdapter$$Lambda$1262/00000000A3888C30.apply(Unknown Source)
at reactor.core.publisher.Flux.lambda$onErrorMap$29(Flux.java:6720)
at reactor.core.publisher.Flux$$Lambda$1264/000000008D4CE270.apply(Unknown Source)
code for test:
ConnectionFactory connectionFactory = ConnectionFactories.get(
"r2dbc:oracle:thin:@ldap://server:port/database,cn=OracleContext,dc=WORLD");
Mono.from(connectionFactory.create())
.flatMapMany(connection ->
Flux.from(connection.createStatement(
"SELECT 'Hello, Oracle' FROM sys.dual")
.execute())
.flatMap(result ->
result.map((row, metadata) -> row.get(0, String.class)))
.doOnNext(System.out::println)
.thenMany(connection.close()))
.subscribe();
thanks