我们注意到在我们的软件中随机删除了数据库连接(postgres)。在Jooq文档中搜索时,我发现初始化后每次调用set()方法都可能会删除整个框架的线程安全性。
因此,我的方法是重构BaseDAO中的每个方法,以摆脱setConfiguration()函数并更改为DSLContext。
例如
public TransactionalCallable<Optional<T>> get(I id) {
return cfg -> {
try {
base.setConfiguration(cfg);
return doGet(id).map(p -> Optional.of(from(p))).orElse(Optional.empty());
} finally {
base.setConfiguration(null);
}
};
}
protected Optional<E> doGet(I id) {
return Optional.ofNullable(base.findById(id));
}
[base
是DaoImpl的一个实例。
那么我将如何使用DSLContext实现base.findById(id)
?我是否了解有关线程安全的错误信息?
编辑:我从这样的东西开始
public TransactionalCallable<Optional<T>> get(I id) {
return cfg -> doGet(id).run(cfg).map(p -> Optional.of(from(p))).orElse(Optional.empty());
}
protected TransactionalCallable<Optional<E>> doGet(I id) {
return cfg -> {
try (DSLContext context = using(cfg)) {
return Optional.ofNullable(base.findById(id));
}
};
}
但仍然不确定如何正确使用该上下文。
我怀疑这个问题正在导致您观察到的副作用,我可以在您的代码中找到此处:
public TransactionalCallable<Optional<T>> get(I id) {
return cfg -> {
try {
base.setConfiguration(cfg);
return doGet(id).map(p -> Optional.of(from(p))).orElse(Optional.empty());
} finally {
base.setConfiguration(null);
}
};
}
...是每个事务执行一次操作,每个承租人只能执行一次:在某些情况下设置配置。
这是生命周期问题。您似乎正在跨事务共享资源(base
)。如果这是共享资源,则不得在每个事务中对其进行修改。 base
的生命周期应该与租户生命周期甚至应用程序生命周期相对应,因此不必担心再次设置此资源。