325.13. JDBC 기반 멱등 리포지토리 사용
Camel 2.7부터 사용 가능: 이 섹션에서는 JDBC 기반 멱등 리포지토리를 사용합니다.
TIP:*Abstract 클래스* From Camel 2.9에서 사용 중인 추상 클래스 org.apache.camel.processor.idempotent.jdbc.AbstractJdbcMessageIdRepository 을 사용하면 사용자 정의 JDBC 멱등 리포지토리를 빌드할 수 있습니다.
먼저 멱등 리포지토리에서 사용할 데이터베이스 테이블을 만들어야 합니다. Camel 2.7 의 경우 다음 스키마를 사용합니다.
CREATE TABLE CAMEL_MESSAGEPROCESSED ( processorName VARCHAR(255), messageId VARCHAR(100) )
Camel 2.8 에서 createdAt 열을 추가했습니다.
CREATE TABLE CAMEL_MESSAGEPROCESSED ( processorName VARCHAR(255), messageId VARCHAR(100), createdAt TIMESTAMP )
경고: SQL Server TIMESTAMP 유형은 고정 길이의 바이너리 문자열입니다. DATE,TIME 또는 TIMESTAMP 의 JDBC 시간 유형에 매핑되지 않습니다.
JdbcMessageIdRepository 사용자 정의
Camel 2.9.1 부터 필요에 따라 org.apache.camel.processor.idempotent.jdbc.JdbcMessageIdRepository 을 튜닝할 수 있는 몇 가지 옵션이 있습니다.
| 매개변수 | 기본값 | 설명 |
|---|---|---|
| createTableIfNotExists | true | Camel이 테이블이 없는 경우 테이블을 만들려고 할지 여부를 정의합니다. |
| tableExistsString | SELECT 1 FROM CAMEL_MESSAGEPROCESSED WHERE 1 = 0 | 이 쿼리는 테이블이 이미 있는지 여부를 파악하는 데 사용됩니다. 테이블이 존재하지 않음을 나타내기 위해 예외를 throw해야 합니다.It must throw an exception to indicate the table doesn't exist. |
| createString | CREATE TABLE CAMEL_MESSAGEPROCESSED(프로세서 이름 VARCHAR(255), messageId VARCHAR(100),At TIMESTAMP) | 테이블을 만드는 데 사용되는 문입니다. |
| queryString | SELECT COUNT(*) FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ? AND messageId = ? |
메시지가 이미 있는지 확인하는 데 사용되는 쿼리입니다(결과는 '0'과 동일함). 두 개의 매개 변수를 사용합니다. 첫 번째는 프로세서 이름( |
| insertString | INSERT INTO CAMEL_MESSAGEPROCESSED (프로세서 이름, messageId, createdAt) VALUES(?, ?) |
항목을 테이블에 추가하는 데 사용되는 문입니다. 세 개의 매개 변수를 사용합니다. 첫 번째는 프로세서 이름( |
| deleteString | DELETE FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ? AND messageId = ? |
데이터베이스에서 항목을 삭제하는 데 사용되는 문입니다. 두 개의 매개 변수를 사용합니다. 첫 번째는 프로세서 이름( |
