JOOQ多租户：使用ExecuteListener设置会话变量失败问题排查

问题场景 #

尝试通过JOOQ的ExecuteListener在原有SQL前拼接SET会话变量语句：

"SET \"svc.current_organization\" = '7998db24-e4da-4042-9fbf-c878ce0efcf6';" + ctx.sql()

执行时触发类型转换错误：

Error while reading field: location_id, at JDBC index: 1
Cannot convert from 0 (class java.lang.Integer) to class java.util.UUID

但单独执行SET语句则完全正常：

dsl.execute("SET \"svc.current_organization\" = '7998db24-e4da-4042-9fbf-c878ce0efcf6';")

相关代码 #

配置类（Kotlin） #

class JOOQConfiguration(val tenant: TenantAwareContext) {

    fun create(): JooqCustomContext {
        LOGGER.debug("MyCustomConfigurationFactory: create")
        return object : JooqCustomContext {
            override fun apply(configuration: Configuration?) {
                configuration!!.set(InitialisingVariableListener())
                Log.debug("Config TenantAwareContext(tenant='${tenant.tenantId}')")
            }
        }
    }
}

监听器代码（Kotlin） #

class InitialisingVariableListener() : ExecuteListener {
    override fun renderEnd(ctx: ExecuteContext) {
        ctx.sql("SET \"svc_event.current_organization\" = '7998db24-e4da-4042-9fbf-c878ce0efcf6';" + ctx.sql())
        Log.debug("RENDER END: " + ctx.sql())
    }
}

问题根源 #

拼接SQL后，JDBC执行的是多语句请求，SET语句会返回一个更新计数（如0），而JOOQ会错误地将这个更新计数当作后续业务查询的结果集去解析——原本要读取UUID类型的location_id，却拿到了Integer类型的更新计数，直接触发类型转换异常。

解决方案 #

不要将SET语句与业务查询拼接成单条SQL，改用独立执行的方式：

推荐修改监听器代码 #

在executeStart阶段单独执行SET语句，确保和后续业务查询是两个独立的JDBC操作：

class InitialisingVariableListener() : ExecuteListener {
    override fun executeStart(ctx: ExecuteContext) {
        ctx.dsl().execute("SET \"svc_event.current_organization\" = '7998db24-e4da-4042-9fbf-c878ce0efcf6';")
    }
}

其他可选方案 #

1. 自定义ConnectionProvider，在获取数据库连接时直接初始化会话变量
2. 使用JOOQ的ExecuteListener的prepareStart阶段执行SET语句，避免干扰结果解析

内容的提问来源于stack exchange，提问作者nucle