如何基于Camel Header动态加载SQL脚本至消息体供JDBC组件使用？

我来帮你搞定这个根据Header动态加载SQL文件的问题！你的核心思路是对的——用Simple语言的resource:classpath语法拼接动态路径，不过咱们可以把细节捋清楚，再给你几个备选方案以防万一。

方案1：直接用Simple语言（最简洁） #

你当前的配置写法其实是正确的，但要确保几个前提：

1. 确认CamelCustomer这个Header确实存在，并且值是正确的（比如customerA、customerB这类对应目录名的字符串）
2. 确保resources/sql/${header.CamelCustomer}/Insert.sql这个路径下的文件真实存在
3. 你的Camel版本支持动态资源路径（Camel 2.16+应该都没问题，老版本可能有兼容性问题）

完整的XML配置应该是这样的：

<!-- INSERT data -->
<setBody>
    <simple>resource:classpath:sql/${header.CamelCustomer}/Insert.sql</simple>
</setBody>

如果这个写法不生效，先检查Header的大小写（Camel的Header名称是大小写敏感的），或者打印一下Header的值确认是否正确：

<log message="Current customer: ${header.CamelCustomer}" loggingLevel="INFO"/>

方案2：用Groovy脚本（灵活度更高） #

如果Simple语言的动态加载在你的环境里有问题，可以试试Groovy脚本，它能更灵活地处理路径和异常：

<setBody>
    <groovy>
        def customer = request.headers.get('CamelCustomer')
        if (!customer) {
            throw new IllegalArgumentException("CamelCustomer header is missing!")
        }
        def resourcePath = "sql/${customer}/Insert.sql"
        def resource = context.classLoader.getResourceAsStream(resourcePath)
        if (!resource) {
            throw new FileNotFoundException("SQL file not found at path: ${resourcePath}")
        }
        resource.text
    </groovy>
</setBody>

方案3：自定义Bean（适合复杂逻辑） #

如果需要更复杂的逻辑（比如缓存SQL内容、多环境适配），可以写一个JavaBean来处理加载逻辑：

第一步：创建SQL加载Bean #

import org.apache.camel.Exchange;
import org.springframework.core.io.ClassPathResource;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import org.springframework.util.FileCopyUtils;

public class CustomerSqlLoader {
    public String loadInsertSql(Exchange exchange) throws IOException {
        // 获取Header中的客户标识
        String customer = exchange.getIn().getHeader("CamelCustomer", String.class);
        
        // 参数校验
        if (customer == null || customer.trim().isEmpty()) {
            throw new IllegalArgumentException("CamelCustomer header cannot be empty");
        }
        
        // 加载资源文件
        String resourcePath = String.format("sql/%s/Insert.sql", customer.trim());
        ClassPathResource sqlResource = new ClassPathResource(resourcePath);
        
        if (!sqlResource.exists()) {
            throw new IOException(String.format("SQL file not found: %s", resourcePath));
        }
        
        // 读取文件内容并返回
        byte[] sqlBytes = FileCopyUtils.copyToByteArray(sqlResource.getInputStream());
        return new String(sqlBytes, StandardCharsets.UTF_8);
    }
}

第二步：在路由中引用Bean #

<!-- 注册Bean -->
<bean id="customerSqlLoader" class="com.yourpackage.CustomerSqlLoader"/>

<!-- 在路由中调用Bean加载SQL -->
<setBody>
    <method ref="customerSqlLoader" method="loadInsertSql"/>
</setBody>

额外建议：异常处理 #

不管用哪种方案，都建议加上异常处理逻辑，避免因为文件不存在或Header缺失导致路由崩溃：

<onException>
    <exception>java.io.IOException</exception>
    <exception>java.lang.IllegalArgumentException</exception>
    <log message="Failed to load SQL for customer ${header.CamelCustomer}: ${exception.message}" loggingLevel="ERROR"/>
    <!-- 可以设置错误响应或进行重试 -->
    <setHeader headerName="CamelHttpResponseCode"><constant>500</constant></setHeader>
    <setBody><constant>Failed to process customer-specific SQL request</constant></setBody>
</onException>

内容的提问来源于stack exchange，提问作者Themis Pyrgiotis