jooq在极少数情况下生成不正确的sql

Question

我有一个spring云网关应用程序，将身份验证数据保存到db。应用程序在kubernetes中运行。我有太多不同的情况，有时我有json数据要保存，有时json数据为空。保存此数据的代码如下所示：

with(AUTHENTICATED_SESSION) {
context.insertInto(this, ACCESS_TOKEN_MD5_HASH, REFRESH_TOKEN, CONTEXT_DATA)
.values(
accessTokenMd5,
refreshToken,
if (contextData != null) {
JSONB.jsonb(objectMapper.writeValueAsString(contextData))
} else {
null
}
)
.execute()
}

生成的列定义

public final TableField<AuthenticatedSessionRecord, JSONB> CONTEXT_DATA = createField(DSL.name("context_data"), SQLDataType.JSONB, this, "");

保存空值通常像它应该的那样工作：

insert into "public"."authenticated_session" ("access_token_md5_hash", "refresh_token", "context_data") values (?, ?, cast(? as jsonb))
: -> with bind values      : insert into "public"."authenticated_session" ("access_token_md5_hash", "refresh_token", "context_data") values ('hash', 'token', cast(null as jsonb))

有时查询看起来像这样，它会导致以下的异常

insert into "public"."authenticated_session" ("access_token_md5_hash", "refresh_token", "context_data") values (?, ?, ?)
: -> with bind values      : insert into "public"."authenticated_session" ("access_token_md5_hash", "refresh_token", "context_data") values ('hash', 'token', null)

org.jooq.exception.DataAccessException: SQL [insert into "public"."authenticated_session" ("access_token_md5_hash", "refresh_token", "context_data") values (?, ?, ?)]; ERROR: column "context_data" is of type jsonb but expression is of type character varying
Hint: You will need to rewrite or cast the expression.
Position: 121
at org.jooq_3.14.6.DEFAULT.debug(Unknown Source) ~[na:na]
at org.jooq.impl.Tools.translate(Tools.java:2880) ~[jooq-3.14.6.jar:na]
at org.jooq.impl.DefaultExecuteContext.sqlException(DefaultExecuteContext.java:757) ~[jooq-3.14.6.jar:na]
at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:389) ~[jooq-3.14.6.jar:na]
at org.jooq.impl.AbstractDelegatingQuery.execute(AbstractDelegatingQuery.java:119) ~[jooq-3.14.6.jar:na]

因此，在极少数情况下，jooq似乎会生成不正确的sql(没有转换为jsonb(。

这个问题真的很烦人，因为当这种情况发生时，应用程序根本不可用。重新启动吊舱会有所帮助。这个问题很可能只有在应用程序启动后才会出现。

使用版本：

• jooq3.14.6
• 弹簧套2.3.5.释放
• 弹簧云网关2.2.5.RELEASE
• docker容器中的Postgresql 10.12
• postgresql驱动程序42.2.5
• kotlin 1.4.10

Answer 1

你的问题中有一个提示，每次我看到它，我都很高兴实现了这个功能：

at org.jooq_3.14.6.DEFAULT.debug(Unknown Source) ~[na:na]

DEFAULT指的是SQLDialect.DEFAULT，但在您的情况下应该是SQLDialect.POSTGRES。得到无效SQL的原因是，在这些情况下，您没有正确配置Configuration。

这应该有助于您跟踪问题，记住jOOQQuery对象不是线程安全的。