51.14. JDBC 기반 idempotent 리포지토리 사용

createTableIfNotExists

true

Camel이 존재하지 않는 경우 테이블을 생성해야 하는지 여부를 정의합니다.

tableName

CAMEL_MESSAGEPROCESSED

기본 이름 대신 사용자 지정 테이블 이름을 사용하려면 CAMEL_MESSAGEPROCESSED.

tableExistsString

SELECT 1 FROM CAMEL_MESSAGEPROCESSED WHERE 1 = 0

이 쿼리는 테이블이 이미 있는지 여부를 확인하는 데 사용됩니다. 테이블이 존재하지 않음을 나타내기 위해 예외를 throw해야 합니다.

createString

CREATEForwarded CAMEL_MESSAGEPROCESSED (processorName VARCHAR(255), messageId VARCHAR(100), createdAt TIMESTAMP)

테이블을 만드는 데 사용되는 명령문입니다.

queryString

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

메시지가 리포지토리에 이미 존재하는지 여부를 파악하는 데 사용되는 쿼리입니다(결과가 '0'과 같지 않음). 두 개의 매개 변수가 필요합니다. 첫 번째는 프로세서 이름(문자열)이고, 두 번째는 메시지 ID(문자열)입니다.

insertString

CloudEvent INTO CAMEL_MESSAGEPROCEED (processorName, messageId, createdAt) VALUES (?, ?, ?)

테이블에 항목을 추가하는 데 사용되는 명령문입니다. 세 개의 매개 변수가 필요합니다. 첫 번째는 프로세서 이름(문자열)이고, 두 번째는 메시지 id(문자열)이고, 세 번째는 이 항목이 리포지토리에 추가될 때 타임스탬프(Java.sql.Timestamp)입니다.

deleteString

DELETE FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ? 및 messageId = ?

데이터베이스에서 항목을 삭제하는 데 사용되는 명령문입니다. 두 개의 매개 변수를 사용합니다. 첫 번째는 프로세서 이름(문자열)이고, 두 번째는 메시지 ID(문자열)입니다.

lockMaxAgeMillis

이는 잠금이 고립된 것으로 간주되는 기간을 나타냅니다. 즉, currentTimestamp - createdAt >= lockMaxAgeMillis가 분리되는 경우 잠금이 분리됩니다.

lockKeepAliveIntervalMillis

지속적으로 업데이트되는 빈도는At Timestamp 열에 생성됩니다.