该代码已到达“填充要执行的迁移”日志。但是,没有AAA,EEE和CCC日志都可以访问,因此doOnSuccess内部没有任何代码正在运行。对于我如何解决此问题的任何帮助,将不胜感激。
databaseclient.execute().sql("CREATE TABLE IF NOT EXISTS " + TRACKING_TABLE +" ("+PROPERTY_SERVICE+ " varchar(255) NOT NULL," + PROPERTY_VERSION+" float(4) NOT NULL," +PROPERTY_SCRIPT+" varchar(255) NOT NULL);")
.then()
.concatWith(databaseclient.execute().sql("CREATE TABLE IF NOT EXISTS " + TRACKING_SEAL_TABLE+" ("+PROPERTY_SERVICE+ " varchar(255) NOT NULL,"+ PROPERTY_VERSION+" float(4) NOT NULL);")
.then())
.doOnComplete(() -> {
log.info("Populating migrations to be executed");// reaches here
databaseclient.select().from(TRACKING_SEAL_TABLE).as(MigrationSealDetails.class).fetch().all() .collectList()
.map()//mapping function
.doOnError(e -> log.log(Level.SEVERE,"EEE",e))
.doOnSuccess(highestSealPerService -> {
log.info("AAA");
databaseclient.select().from(TRACKING_TABLE).as(MigrationDetails.class).fetch().all()
.collectList()
.doOnSuccess(migrationsExecuted -> {
// other code
}).block();
}).block();
}).blockLast();
log.info("CCC");