48.16. 将正文和标头存储为文本

由于它们可以包含任何类型的载荷，因此交换不可按设计序列化。它将转换为字节数组，以存储在数据库 BLOB 字段中。所有这些转换都由 JdbcCodec 类处理。代码的一个详细信息需要注意： ClassLoadingAwareObjectInputStream。

ClassLoadingAwareObjectInputStream 已从 Apache ActiveMQ 项目中重复使用。它打包 ObjectInputStream，并将它与 ContextClassLoader 而不是 当前的Threader 一起使用。这样做的好处是能够加载由其他捆绑包公开的类。这允许交换正文和标头具有自定义类型对象引用。

需要 Spring PlatformTransactionManager 来编配事务。

根据目标环境，聚合器可能需要进行一些配置。正如您已经了解，每个聚合器应具有自己的存储库（在数据库中创建对应的表对）和数据源。如果默认的 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>

您可以在集群环境中打开 optimisticLocking 并使用此 JDBC 的聚合存储库，其中多个 Camel 应用程序为聚合存储库共享同一数据库。如果出现 JDBC 驱动程序的竞争条件，则 JdbcAggregationRepository 可以响应特定的供应商异常。要了解 JDBC 驱动程序中的例外情况被视为 optimistick locking 错误，我们需要一个映射程序来执行此操作。因此，有 org.apache.camel.processor.aggregate.jdbc.JdbcOptimisticLockingExceptionMapper 允许您在需要时实施自定义逻辑。有默认的实现 org.apache.camel.processor.aggregate.jdbc.DefaultJdbcOptimisticLockingExceptionMapper，其工作如下：

完成以下检查：

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

下面是一个例子，其中从 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>

JdbcAggregationRepository 使用来自 Spring-TX 的两个不同的 事务模板。一个是只读的，一个用于读写操作。

但是，当在自己使用 < transacted /> 和使用通用平台 事务管理器的 路由中使用 JdbcAggregationRepository 时，可能需要配置 JdbcAggregationRepository 内事务模板所使用的 传播行为。

以下是进行该操作的方法：

<bean id="repo"
class="org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository">
  <property name="propagationBehaviorName" value="PROPAGATION_NESTED" />
</bean>

传播是由 org.springframework.transaction.TransactionDefinition 接口的常量指定，因此 传播BehaviorName 是方便的设置，允许使用常量名称。

有特殊的数据库可能会导致 JdbcAggregationRepository 使用优化的锁定问题。如果数据完整性冲突异常(SQLState 23505)除外），PostgreSQL 会将连接标记为无效。这使得连接在嵌套事务中有效不可用。详情请参考 文档。

org.apache.camel.processor.aggregate.jdbc.PostgresAggregationRepository 扩展 JdbcAggregationRepository，并使用特殊的 INSERT。ON CONFLICT .. 语句提供优化锁定行为。

此声明为 （带有默认的聚合表定义）：

INSERT INTO aggregation (id, exchange) values (?, ?) ON CONFLICT DO NOTHING

详情请参考 PostgreSQL 文档。

当使用此 子句时，java.sql.PreparedStatement.executeUpdate （） 调用返回 0， 而不是抛出 SQLState=23505 的 SQLException。进一步处理与通用 JdbcAggregationRepository 相同，但没有将 PostgreSQL 连接标记为无效。