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

createTableIfNotExists

true

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

tableExistsString

SELECT 1 FROM CAMEL_MESSAGEPROCESSED WHERE 1 = 0

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

createString

CREATEECDHE CAMEL_MESSAGEPROCESSED(processorName VARCHAR(255), messageId VARCHAR(100), TIMESTAMP에서 생성된 메시지)

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

queryString

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

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

insertString

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

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

deleteString

DELETE FROM CAMEL_MESSAGEPROCESSED WHERE processorName = ? AND messageId = ?

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