如何正确处理与 jooq 的连接?
How to handle a connection properly with jooq?
我在数据库中收到很多不活动的会话,这不仅占用了所有资源,而且有时还会导致数据库崩溃,需要我重新启动它。
我正在使用 jooq 和 kotlin,这就是我建立连接的方式。
@Component
class EstDBConnection(private val cfg: DatabaseConfig, private val jooqExecuteListener: PromJooqExecuteListener) {
init {
cfg.migrateFlyway()
}
fun <T> acquire(f: (DSLContext) -> T): T {
return DSL.using(DriverManager.getConnection(cfg.url, cfg.username, cfg.password), SQLDialect.ORACLE10G).use {
jooqExecuteListener.attach(it)
f(it)
}
}
}
您永远不会关闭正在创建的连接。请使用连接池(例如 HikariCP)来管理您的连接。除非你写了一个简单的批处理脚本,或者一些概念证明,否则你不应该直接使用 DriverManager.getConnection
我在数据库中收到很多不活动的会话,这不仅占用了所有资源,而且有时还会导致数据库崩溃,需要我重新启动它。
我正在使用 jooq 和 kotlin,这就是我建立连接的方式。
@Component
class EstDBConnection(private val cfg: DatabaseConfig, private val jooqExecuteListener: PromJooqExecuteListener) {
init {
cfg.migrateFlyway()
}
fun <T> acquire(f: (DSLContext) -> T): T {
return DSL.using(DriverManager.getConnection(cfg.url, cfg.username, cfg.password), SQLDialect.ORACLE10G).use {
jooqExecuteListener.attach(it)
f(it)
}
}
}
您永远不会关闭正在创建的连接。请使用连接池(例如 HikariCP)来管理您的连接。除非你写了一个简单的批处理脚本,或者一些概念证明,否则你不应该直接使用 DriverManager.getConnection