如何通过驼峰路由从bean访问SQL连接？

Question

我将数据插入到多个表中，我使用mybatis组件来实现这一点。在插入数据之前，我还需要创建一个临时表。高层概述如下：

1. 获取要插入的数据

步骤2到5应该是他们自己的单一事务，以防出现故障。我现在有这个：

from(initialEndpoint)
        .routeId("database-appender")
        .aggregate().expression(constant(true)).completionSize(100).aggregationStrategy(new LinkListAggregator())
        .transacted()
            .bean(CreateTmpLinksTable.class)
            .to("mybatis:prepareLinks?executorType=reuse&statementType=InsertList")
            .to("mybatis:insertLinks?executorType=reuse&statementType=InsertList")
            .to("mybatis:insertLinkSources?executorType=reuse&statementType=InsertList")
        .end()
        .log("Wrote at most ${body.size} links to the database")

CreateTmpLinksTable需要有权访问当前连接，这样临时表的创建就不会在不同的事务中发生（如果有关系，以PostgreSQL为目标）。

我目前有：

public class CreateTmpLinksTable {
    public void createImportTable(Exchange exchange) throws SQLException {
        final Connection conn = exchange.getIn().getHeader("TransactionConnection", Connection.class);
        try (final Statement stat = conn.createStatement()) {
            stat.execute("CREATE TEMPORARY TABLE tmp_links(" +
                    "url text, hostname text, service media, service_id bigint, user_id bigint, screen_name text, harvested_at timestamp with time zone, body text" +
                    ") ON COMMIT DROP");
        }
    }
}

我也没有设置我的交易管理器。我怀疑我必须找到交易管理器，以便正确参与交易。

问题：

>

如何从常规bean中获取事务管理器？是否只需要获取上下文，然后从上下文中通过注册表获取管理器？

有没有更好的方法来做我需要的事情？我至少可以看到一个：将所有的责任都转移到一个豆子里，在那里做工作。还有其他方法吗？

注意：我正在学习Camel，我喜欢只使用代码。一旦我知道了一切是如何联系在一起的，我就可以把这些知识转移到Spring上。

Answer 1

Q1，如果您可以将bean实例传递到camel路由，那么您可以自己设置事务管理器，否则您必须使用注册表来查找事务管理器实例。

问题2：如果需要管理其他资源，可以将数据库更新工作包装在一个bean中，并在camel中使用事务DSL。