出站网关
出站网关类似于出站和入站适配器的组合:它的作用是处理消息并使用它来执行 SQL 查询,然后通过发送到回复通道来响应结果。默认情况下,消息有效负载和标头可作为查询的输入参数,如下例所示
<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" />
上述示例的结果是在 mythings
表中插入一条记录,并将指示受影响行数的消息(有效负载是映射:{UPDATED=1}
)返回到输出通道。
如果更新查询是带有自动生成键的插入,则可以通过在上述示例中添加 keys-generated="true"
来使用生成的键填充回复消息(这不是默认设置,因为某些数据库平台不支持此功能)。以下示例显示了更改后的配置
<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"/>
除了更新计数或生成的键之外,您还可以提供一个选择查询来执行并从结果中生成回复消息(例如入站适配器),如下例所示
<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 查询不再是强制性的。您现在可以使用 `query` 属性或 `query` 元素仅提供一个选择查询。如果您需要使用通用网关或有效载荷丰富器等主动检索数据,这将非常有用。然后从结果中生成回复消息(类似于入站适配器的工作方式)并传递到回复通道。以下示例展示了如何使用 `query` 属性
<int-jdbc:outbound-gateway
query="select * from foos where id=:headers[id]"
request-channel="input"
reply-channel="output"
data-source="dataSource"/>
默认情况下,`SELECT` 查询的组件仅返回游标中的第一行。您可以使用 `max-rows` 选项调整此行为。如果您需要返回 `SELECT` 中的所有行,请考虑指定 `max-rows="0"`。 |
与通道适配器一样,您还可以为请求和回复提供 `SqlParameterSourceFactory` 实例。默认值与出站适配器相同,因此请求消息作为表达式的根可用。如果 `keys-generated="true"`,表达式的根是生成的键(如果只有一个,则为映射;如果有多个值,则为映射列表)。
出站网关需要引用 `DataSource` 或 `JdbcTemplate`。它还可以注入 `SqlParameterSourceFactory` 来控制将传入消息绑定到查询。
从 4.2 版本开始,`request-prepared-statement-setter` 属性在 `<int-jdbc:outbound-gateway>` 上可用,作为 `request-sql-parameter-source-factory` 的替代方案。它允许您指定 `MessagePreparedStatementSetter` bean 引用,该引用在执行之前实现更复杂的 `PreparedStatement` 准备。
从 6.0 版本开始,`JdbcOutboundGateway` 返回一个空列表结果,而不是像以前那样将其转换为 `null`,其含义为“无回复”。这导致应用程序中需要额外配置,在这些应用程序中,处理空列表是下游逻辑的一部分。有关可能的空列表处理选项,请参见 拆分器丢弃通道。
有关 `MessagePreparedStatementSetter` 的更多信息,请参见 出站通道适配器。