325.15.3. 聚合器配置

根据目标环境，聚合器可能需要一些配置。既然已经知道，每个聚合器都应拥有自己的存储库（具有数据库中创建的表的对应对）和一个数据源。如果默认 lobHandler 不适合您的数据库系统，可以使用 lobHandler 属性来注入它。

以下是 Oracle 的声明：

<bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler">
  <property name="nativeJdbcExtractor" ref="nativeJdbcExtractor"/>
</bean>
<bean id="nativeJdbcExtractor"
  class="org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor"/>
<bean id="repo"
  class="org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository">
  <property name="transactionManager" ref="transactionManager"/>
  <property name="repositoryName" value="aggregation"/>
  <property name="dataSource" ref="dataSource"/>
  <!-- Only with Oracle, else use default -->
  <property name="lobHandler" ref="lobHandler"/>
</bean>

  ==== optimistic 锁定

从 Camel 2.12 开始，您可以打开 optimisticLocking，并在集群环境中使用此基于 JDBC 的聚合存储库，其中多个 Camel 应用程序为聚合存储库共享同一数据库。如果存在一个竞争条件，则 JDBC 驱动程序将抛出一个特定于供应商的异常，则 JdbcAggregationRepository 可以响应。要知道从 JDBC 驱动程序造成异常，作为光明锁定错误，我们需要一个映射程序来执行此操作。因此，有一个 org.apache.camel.processor.aggregate.jdbc.JdbcOptimisticLockingExceptionMapper （如果需要），您可以实施自定义逻辑。有一个默认的实现 org.apache.camel.aggregate.jdbc.DefaultJdbcOptimisticLockingExceptionMapper （如下所示）：

以下检查已完成：

您还可以添加 FQN 类名称，如果任何导致异常（或任何嵌套）等于 FQN 类名称的任何错误，则它是一个光纤锁定错误。

以下是一个示例，其中定义了来自 JDBC 供应商的 2 额外 FQN 类名称：

<bean id="repo"
class="org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository">
  <property name="transactionManager" ref="transactionManager"/>
  <property name="repositoryName" value="aggregation"/>
  <property name="dataSource" ref="dataSource"/>
  <property name="jdbcOptimisticLockingExceptionMapper" ref="myExceptionMapper"/>
</bean>
<!-- use the default mapper with extraFQN class names from our JDBC driver -->
<bean id="myExceptionMapper" class="org.apache.camel.processor.aggregate.jdbc.DefaultJdbcOptimisticLockingExceptionMapper">
  <property name="classNames">
    <util:set>
      <value>com.foo.sql.MyViolationExceptoion</value>
      <value>com.foo.sql.MyOtherViolationExceptoion</value>
    </util:set>
  </property>
</bean>