springboot2 webflux（2.1.2）+rxjava2-jdbc nodata

[feesx]

@Configuration public class RxJava2JdbcConfig { /**

• https://www.programcreek.com/java-api-examples/index.php?api=com.github.davidmoten.rx.jdbc.Database
• @return
• @throws Exception / @Bean public Database db() throws Exception { ConnectionProvider connection = ConnectionProvider.from("jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true", "root", "123456"); NonBlockingConnectionPool pool = Pools.nonBlocking() .maxPoolSize(Runtime.getRuntime().availableProcessors() 5) .connectionProvider(connection) .build(); return Database.from(pool); } }

public Flux getAllAdverts3() { String sql = "SELECT name,code FROM company"; return Flux.from(db.select(sql).autoMap(Company.class)); }

@Query("select name, code from company") public interface Company { @Column("name") String name();

@Column("code") 
String code();

}

result ：

[ {} ] but mysql have data

[davidmoten]

Did you check for an error emission from the Flux?

[davidmoten]

Instead of using spring have you tried to connect to the database directly using rxjava2-jdbc?