51.14. 使用基于 JDBC 的幂等存储库

createTableIfNotExists

true

定义 Camel 是否应该尝试创建表（如果不存在）。

tableName

CAMEL_MESSAGEPROCESSED

使用自定义表名称而不是默认名称：CAMEL_MESSAGEPROCESSED。

tableExistsString

SELECT 1 FROM CAMEL_MESSAGEPROCESSED WHERE 1 = 0

此查询用于找出表是否已存在。必须抛出异常，以指示表不存在。

createString

CREATE TABLE CAMEL_MESSAGEPROCESSED (processorName VARCHAR (255), messageId VARCHAR (100), createdAt TIMESTAMP)

用于创建表的 语句。

queryString

SELECT COUNT(*) FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ?AND messageId = ?

用于识别存储库中是否已存在消息的查询（结果不等于 '0'）。它取两个参数：第一个是处理器名称(字符串)，第二个是消息 ID (字符串)。

insertString

INSERT INTO CAMEL_MESSAGEPROCESSED (processorName, messageId, createdAt) VALUES (?, ?, ?)

用于将条目添加到表中的语句。它采用三个参数。第一个是处理器名称(字符串)，第二个名称为消息 ID (String)，当此条目添加到存储库中时，第三个是时间戳(java.sql.Timestamp)。

deleteString

DELETE FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ?AND messageId = ?

用于从数据库中删除条目的声明。它取两个参数。第一个是处理器名称(字符串)，第二个是消息 ID (字符串)。

lockMaxAgeMillis

这指的是锁定被视为孤立的 i.e. 的持续时间。如果 currentTimestamp - createdAt >= lockMaxAgeMillis then lock is孤立。

lockKeepAliveIntervalMillis

保持 alive 更新的频率为 createdAt Timestamp 列。