出站网关

出站网关就像出站和入站适配器的组合:它的作用是处理消息并使用它来执行 SQL 查询,然后通过将其发送到回复通道来响应结果。 默认情况下,消息有效负载和标头可用作查询的输入参数,如下例所示:spring-doc.cn

<int-jdbc:outbound-gateway
    update="insert into mythings (id, status, name) values (:headers[id], 0, :payload[thing])"
    request-channel="input" reply-channel="output" data-source="dataSource" />

前面示例的结果是将记录插入表中,并返回一条消息,该消息指示受影响的行数(有效负载是 map: )到输出通道。mythings{UPDATED=1}spring-doc.cn

如果更新查询是具有自动生成的键的插入,则可以通过添加到前面的示例(这不是默认值,因为某些数据库平台不支持它),从而使用生成的键填充回复消息。 以下示例显示了更改后的配置:keys-generated="true"spring-doc.cn

<int-jdbc:outbound-gateway
    update="insert into mythings (status, name) values (0, :payload[thing])"
    request-channel="input" reply-channel="output" data-source="dataSource"
    keys-generated="true"/>

除了更新计数或生成的密钥,您还可以提供 select 查询来执行并从结果(例如入站适配器)生成回复消息,如下例所示:spring-doc.cn

<int-jdbc:outbound-gateway
    update="insert into foos (id, status, name) values (:headers[id], 0, :payload[foo])"
    query="select * from foos where id=:headers[$id]"
    request-channel="input" reply-channel="output" data-source="dataSource"/>

从 Spring Integration 2.2 开始,更新 SQL 查询不再是必需的。 现在,您可以使用 attribute 或 element 仅提供 select 查询。 如果您需要使用通用网关或有效负载扩充器等方式主动检索数据,这将非常有用。 然后从结果生成回复消息(类似于入站适配器的工作方式)并传递给回复通道。 以下示例显示了如何使用该属性:queryqueryqueryspring-doc.cn

<int-jdbc:outbound-gateway
    query="select * from foos where id=:headers[id]"
    request-channel="input"
    reply-channel="output"
    data-source="dataSource"/>

默认情况下,查询的组件仅从游标返回一行(第一行)。 您可以使用该选项调整此行为。 如果需要返回 SELECT 中的所有行,请考虑指定 .SELECTmax-rowsmax-rows="0"spring-doc.cn

与通道适配器一样,您也可以为 request 和 reply 提供实例。 默认值与出站适配器相同,因此请求消息可用作表达式的根。 If ,表达式的根是生成的键(如果只有一个映射,则为映射,如果多值,则为映射列表)。SqlParameterSourceFactorykeys-generated="true"spring-doc.cn

出站网关需要对 a 或 a 的引用。 它还可以具有 injected 来控制传入消息与查询的绑定。DataSourceJdbcTemplateSqlParameterSourceFactoryspring-doc.cn

从版本 4.2 开始,该属性在 上作为 的替代项提供。 它允许您指定 bean 引用,该引用在执行之前实现更复杂的准备。request-prepared-statement-setter<int-jdbc:outbound-gateway>request-sql-parameter-source-factoryMessagePreparedStatementSetterPreparedStatementspring-doc.cn

从版本 6.0 开始,将按原样返回一个空列表结果,而不是将其转换为以前的样子,其含义为 “no reply”。 这会导致在处理空列表是 downstream logic一部分的应用程序中进行额外的配置。 请参阅 Splitter Discard Channel 了解可能的空列表处理选项。JdbcOutboundGatewaynullspring-doc.cn

请参阅 出站通道适配器 以了解有关 的更多信息。MessagePreparedStatementSetterspring-doc.cn