Camel: Как однажды вставить данные в таблицу DB, если действительны только все xmls?

Question

Collegues, у меня есть маршрут, который проверяет xml по xsd. Я в этом случае маршрут вызова .to("jdbc:DataSource") каждый раз, когда какой-либо XML является действительным:

from("ftp://....." + 
      "&throwExceptionOnConnectFailed=true" + 
      "&filterDirectory=${date:now:yyyymmdd}") 
       .choice() 
        .when(header("CamelFileName").contains("XML_A.....")).log("Validate ${file:name}") 
        .to("validator:file:C:\\integration\\xsds\\xml_a.xsd").log("${file:name} is valid") 
        .when(header("CamelFileName").contains("XML_B.....")).log("Validate ${file:name}") 
        .to("validator:file:C:\\integration\\xsds\\xml_b.xsd").log("${file:name} is valid") 
       .when(header("CamelFileName").contains("XML_C.....")).log("Validate ${file:name}") 
        .to("validator:file:C:\\integration\\xsds\\xml_c.xsd").log("${file:name} is valid") 
       .end() 
       .log("Upload table ExtractS") 
       .to("bean:stgExtractToSQL") 
       .to("jdbc:dataSource") /*Here i would like to execute only one insert into one single table*/ 
      ; 

Как назвать .to("jdbc:dataSource") только один раз (только), когда все XML действительны? P.S. После .to("jdbc:dataSource") Мне нужно обработать каждый XML-файл. Спасибо.

Answer 1

Если есть ошибка проверки, компонент валидатора Camel выдаст исключения, поэтому вы не должны попасть в .to("jdbc:dataSource") и должны быть в безопасности. Тем не менее, лучший способ справиться с этим - использовать и doCatch() на вашем маршруте, чтобы указать, что он знает об исключении, и в случае, если вам нужно добавить дополнительные действия, когда проверка не выполняется. Таким образом, ваш маршрут будет выглядеть примерно так:

from("ftp://....." + 
     "&throwExceptionOnConnectFailed=true" + 
     "&filterDirectory=${date:now:yyyymmdd}") 
      .log("Validate ${file:name}") 
      .doTry() 
       .choice() 
       .when(header("CamelFileName").contains("XML_A.....")) 
        .to("validator:file:C:\\integration\\xsds\\xml_a.xsd") 
       .when(header("CamelFileName").contains("XML_B.....")) 
        .to("validator:file:C:\\integration\\xsds\\xml_b.xsd") 
       .when(header("CamelFileName").contains("XML_C.....")) 
        .to("validator:file:C:\\integration\\xsds\\xml_c.xsd") 
      .endChoice() 

      .log("${file:name} is valid") 
      .log("Upload table ExtractS") 
      .to("bean:stgExtractToSQL") 
      .to("jdbc:dataSource") /*Here i would like to execute only one insert into one single table*/ 
      .endDoTry() 
      .doCatch(ValidationException.class) 
      .log("Validation of file [${file:name}] failed") 
      .end() 
     ;