第 51 章 SQL
支持生成者和消费者
SQL 组件允许您使用 JDBC 查询来处理数据库。此组件和 JDBC 组件之间的区别是 SQL，查询是端点的属性，并使用消息有效负载作为传递给查询的参数。
这个组件使用 spring-jdbc 后面的 springenes 进行实际 SQL 处理。
Maven 用户需要将以下依赖项添加到其 pom.xml 中。
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-sql</artifactId>
<version>{CamelSBVersion}</version>
<!-- use the same version as your Camel core version -->
</dependency>SQL 组件还支持：
- 适用于 Idempotent Consumer EIP 模式的 JDBC 存储库。请参见以下信息。
- 适用于聚合器 EIP 模式的 JDBC 存储库。请参见以下信息。
51.1. URI 格式
注意
此组件可用作 事务客户端。
SQL 组件使用以下端点 URI 表示法：
sql:select * from table where id=# order by name[?options]
您可以使用 :'114name_of_the_parameter' 样式使用命名参数，如下所示：
sql:select * from table where id=:#myId order by name[?options]
使用命名参数时，Camel 将以给定优先级查找名称：
-
来自消息正文（如果它是一个
java.util.Map - 来自消息标头
如果无法解析命名参数，则会抛出异常。
您可以使用简单表达式作为参数，如下所示：
sql:select * from table where id=:#${exchangeProperty.myId} order by name[?options]请注意，表示 SQL 查询的参数的标准 ? 符号被替换为 kiosk 符号，因为 ? 符号用于为端点指定选项。? 符号替换可以基于端点配置。
您可以将 SQL 查询外部化到 classpath 或文件系统中的文件，如下所示：
sql:classpath:sql/myquery.sql[?options]
myquery.sql 文件位于 classpath 中，只是纯文本
-- this is a comment
select *
from table
where
id = :#${exchangeProperty.myId}
order by
name在文件中，您可以使用多行并根据需要格式化 SQL。还使用注释，如 - dash 行。
