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

在本节中，我们将使用基于 JDBC 的幂等存储库。

注意

抽象类
有一个抽象类 org.apache.camel.processor.idempotent.jdbc.AbstractJdbcMessageIdRepository，您可以扩展为构建自定义 JDBC 幂等存储库。

首先，我们必须创建数据库表，该表将由幂等库使用。我们使用以下模式：

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

我们添加了 createdAt 列：

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

注意

SQL Server TIMESTAMP 类型是一个固定长度二进制字符串类型。它没有映射到任何 JDBC 时间类型： DATE、TIME 或 TIMESTAMP。

当与并发消费者合作时，在处理器名称和消息Id 上创建一个唯一的约束至关重要。由于此约束的语法与数据库与数据库不同，因此我们在此不会显示它。

您有几个选项可根据您的需要调整 org.apache.camel.processor.idempotent.jdbc.JdbcMessageIdRepository ：

参数	默认值	描述
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（`字符串`），第三个则是当此条目添加到存储库时的时间戳(`java.sql.Timestamp`)。
deleteString	DELETE FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ?AND messageId = ?	此语句用于从数据库中删除条目。它取两个参数。第一个是处理器名称（`字符串`），第二个是消息 ID（`字符串`）。

option tableName 可用于使用默认的 SQL 查询，但具有不同表名称。但是，如果要自定义 SQL 查询，则可以单独配置每个查询。