问题描述
在MysqL db调用期间出现以下错误:
错误:[8]-此处仍在运行查询-race-> false
下面是方法:
public Maybe<Dbrow> fetchDbrow(Long x,Long y) {
return this.sqlClient
.rxGetConnection()
.flatMapMaybe(c -> this.fetchDbrow(c,x,y).doFinally(c::close))
.doOnError(err -> LOGGER.error("DB fetch Failed for c: {},y: {} with error : {}",y,err.getMessage()))
.retrywhen((Flowable<Throwable> f) -> f.take(4).delay(2,TimeUnit.SECONDS));
}
private Maybe<Dbrow> fetchDbrow(sqlConnection conn,Long x,Long y) {
return conn
.rxQueryWithParams(DBQUERY,new JsonArray().add(x).add(y))
.toMaybe()
.flatMap(res -> {
Dbrow dbrow = new Dbrow();
JsonArray result = res.getResults().get(0);
dbrow.setId(result.getLong(0))
.setX(result.getString(1))
.setY(result.getString(2));
return Maybe.just(dbrow);
});
}
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)